問題タブ [jeromq]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
java - サブサーバーのソケットがダウンしているときに ZMQ パブ クライアントのソケット バッファ メッセージを作成する方法
アプリケーション A がパブリッシャー クライアントを使用して、そのデータを受け入れるためのサブサーバー ソケットを持つアプリケーション B に競合的にデータをストリーミングする 2 つのアプリケーションがあるとします。再デプロイ、再起動) A はすべての保留中のメッセージをバッファリングし、B が使用可能になると、バッファリングされたメッセージは通過し、ソケットはリアルタイム ストリームに追いつきますか?
簡単に言えば、SUB SERVER が使用できないときに PUB CLIENT ソケット バッファ メッセージを制限付きで作成するにはどうすればよいでしょうか?
PUB クライアントのデフォルトの動作はミュート状態でドロップすることですが、これを制限サイズのバッファーに変更できれば素晴らしいと思いますが、zmq で可能ですか? または、アプリケーションレベルで行う必要がありますか...
私はソケットに HWM と LINGER を設定しようとしましたが、私が間違っていなければ、パブリッシャーがサブスクライバーに接続されているが、サブスクライバーが非常に遅いため、パブリッシャーがメッセージをバッファリングし始めるという遅い消費者のケースにのみ責任があります (hwm はこれらのメッセージの数を制限します)...
私はjeromqjvmプラットフォームをターゲットにしているので使用しています。
java - ZeroMQ がメッセージの発行に失敗する
ZMQ パブリッシャーとサブスクライバーの基本的な実装を機能させようとしていますが、黙って失敗しています。JeroMQ 0.5.2 (現在のバージョン) と Java 8 を使用しています。
次の公式テスト ファイルを検討してください: https://github.com/zeromq/jeromq/blob/master/src/test/java/org/zeromq/PubSubTest.java
最初のテスト (testRaceConditionIssue322) 全体を新しいメイン クラスにコピーして実行しました。パブリッシャーはポートにバインドし、すべてのメッセージを送信すると主張しますが、受信者は単一のメッセージを受信しません。ログを追加すると、パブリッシャーがメッセージを送信する前に、サブスクライバーが自分自身がサブスクライブされていると信じていることが示されます。
これを 2 台のコンピューターと異なるコードで試してみましたが、毎回同じ最終結果です。何を与える？