jsonをtcp経由でlogstashに送信し、接続を開いたままにしないでください。

Question

以下のコードはスレッドで実行され、メッセージをキューから取り出してlogstashに送信します。私はjson（メッセージの内容である）がソケットに入れて、もう一方の端に到達することを証明するユニットテストをしました。

しかし、実際のlogstashでポイントすると、何も起きません。私は同じコンテンツを 'nc'することができ、それが表示されます。もちろん、ncは1つのメッセージを送信し終わった時点で接続を終了します。私たちが今までの接続を失った場合、再接続するには少し複雑です。

logstashの設定は非常に簡単です：

input { 
tcp { 
    port => 9191 
    codec => json 
    } 
} 
output { 
    stdout { 
     codec => rubydebug 
    } 
} 


     while (true) { 
       byte[] message = messages.take(); 
       executor.getWithRetry(() -> { 
        try { 
         if (socket == null) { 
          socket = new Socket(sinkAddress, port); 
         } 
         socket.getOutputStream().write(message); 
         return null; 
        } catch (IOException e) { 
         socket.close(); 
         socket = null; 
         throw e; 
        } 
       }).join(); 
      } 

Answer 1

は、あなたがメッセージの最後に改行文字を送信していることを確認します。私は "\ n"を送ることがWindowsのログボックスからLinux上で実行されているlogstashまでうまく動作することを発見しました。