javaでfluentdのサーバ、
つまりforwordを受ける側の処理なのだが、
これを書こうと思い、
fluentdのmsgpackのフォーマットを調査していたところ、
以下のライブラリに出会った。
https://github.com/okumin/influent
上記のライブラリはとても素晴らしく、
javaのマルチスレッド、NIOを十二部に活用されていた。
テストをしたところ、十分な負荷にも耐えられ、
高い安定性を誇ることが分かった。
※テストしたのは、バージョン0.3.0
ただ、msgpackを前提としているので、
jsonデータのmsgpack化ではパースエラーになる。
具体的には、公式に提供されているphpライブラリだと、
デフォルトの書き込みフォーマットはjsonであるため、
ここはmsgpackに変更する必要がある。
とはいえ、とても優れたプロダクトであり、
UDPのハートビートにも対応されている点は、
とても利用しやすいと感じた。感謝感謝。
以上