問題タブ [nats.io]
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.
nats.io - 大きなサイズのファイルを購読するにはどうすればよいですか? - NATS ストリーミング サブスクライブの問題
私は新しい NATS です。NATS-streaming-server の例を使用して、テキスト ファイルを送受信しようとしました。
テキストファイル(〜9B)を送信すると動作します
-クライアント「cs-publisher」としてクラスター「test-cluster」に接続するパブリッシュ。件名 foo で 1 件のメッセージを公開 URL: nats://localhost:4222 ペイロードは 9 バイトです。0.0076917 秒 (130 メッセージ/秒) で確認応答付きの 1 メッセージを公開しました。
-Sub クライアント「cs-subscriber」としてクラスター「test-cluster」に接続しています。件名 foo url: nats://localhost:4222 で 1 メッセージを受信 6E-07 秒 (1666666 メッセージ/秒) で 1 メッセージを受信しました。
しかし、テキストファイル (~80MB) を送信すると、サブスクライブが機能しませんでした。
-Pub クライアント「cs-publisher」としてクラスター「test-cluster」に接続します。件名 foo で 1 件のメッセージを公開 URL: nats://localhost:4222 ペイロードは 77552640 バイトです。1.2574163 秒 (0 メッセージ/秒) で確認応答付きの 1 メッセージを公開しました。
-Sub クライアント「cs-subscriber」としてクラスター「test-cluster」に接続しています。件名 foo の URL で 1 件のメッセージを受信: nats://loaclhost:4222
サブスクライブが反応しない理由がわかりません。同じコードを使用し、送信したファイルを変更しただけです。
byte[] ペイロード = File.ReadAllBytes("test.txt");
....
文字列 guid = c.Publish(件名、ペイロード、(obj、pubArgs) =>
私を助けてください