私はパブリッシャー、Javaでサブスクライバーを書いています。サーバーレベルでクラスタリングしました。 500 TPS(1秒あたりのトランザクション)のレートで30 KBのメッセージを発行および購読することができます。NATS IOパフォーマンス調整
しかし私は2000 TPS以上のパフォーマンスを改善したいと考えています。 同じように達成する方法を提案してください。
Apache CamelでJavaを使用しました。
私はパブリッシャー、Javaでサブスクライバーを書いています。サーバーレベルでクラスタリングしました。 500 TPS(1秒あたりのトランザクション)のレートで30 KBのメッセージを発行および購読することができます。NATS IOパフォーマンス調整
しかし私は2000 TPS以上のパフォーマンスを改善したいと考えています。 同じように達成する方法を提案してください。
Apache CamelでJavaを使用しました。
nats-streaming-serverタグを使用しました。 NATSストリーミングやNATSを指しているかどうかを確認するだけです。
NATSストリーミングの場合、publish
コールはサーバとの要求応答であるため、処理が遅くなります。 AckHandler
を指定すると、パブリッシュコールが非ブロッキングになっているため、より高速にパブリッシュすることができます。サーバーは依然として承認通知を送信しますが、ハンドラは非同期に呼び出されます。使用例については、https://github.com/nats-io/java-nats-streaming#asynchronous-publishingを参照してください。