こんにちは、rabbit mq の簡単な解決策を探しています。以下は、ウサギで行われた設定です。
- うさぎサーバーを起動する
- 永続オプションを使用してトピック タイプの交換 (myexchange) を作成します。
- 永続オプションと x-max-length-bytes を 4 に設定し、x-max-length を 2 に設定して、キュー (myqueue) を作成します。
- myrouting を使用して myexchange を myqueue にバインドします。
- aqmp チャネルを使用して basic_publish を使用してメッセージを発行します (channel.basicPublish(myexchange, myrouting, true, null, "test".getBytes("UTF-8"));
- channel.confirmSelect(); のようなパブリッシャー確認設定を使用します。および channel.waitForConfirmsOrDie();
以下のコードスニペット
channel = connectionFactory.getChannel();
channel.queueDeclarePassive("myqueue");
channel.confirmSelect();
channel.basicPublish("myexchange", "myrouting", true,
null, "test".getBytes("UTF-8"));
channel.waitForConfirmsOrDie();
現在、rabbit mq はメッセージ数の超過/サイズの超過に対してエラーで応答していません。1kb のサイズで 1000 件のメッセージを送信でき、消費者もこれらすべてのメッセージを消費します。では、どうすればエラーコードを取得できますか? これについて何か助けてください。