私は新しい 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) =>
私を助けてください