問題タブ [amazon-mq]

イベント駆動型メッセージング システムには、Amazon MQ、ActiveMQ、および OpenWire を使用しています。

受信できる最大フレームサイズは 104,857,600 (100 MB) です。(postman を使用して) 103 MB に相当するメッセージを送信した後、AWS 内のブローカー ログを調べると、100 MB が制限であることが明確に示されています。

AWS サポートに問い合わせたところ、AmazonMQ サービス チームはセキュリティ上の理由からこれらの制限を実装しており、この制限を引き上げる方法があるかどうか、またその方法を教えてくれるとのことでした。

彼らがそれを増やすための解決策を持っていれば、それはそれほど大きくないと思います. この質問につながるのは、この壁を回避する方法を知っている人はいますか? この最大フレーム サイズの増加をサポートするために、Amazon MQ 設定 xml ファイルを編集できますか?

お時間をいただきありがとうございました。

Amazon MQ ブローカーを作成しました。

• ブローカーエンジンを選択: RabbitMQ 3.8.6
• 単一インスタンス ブローカー
• ネットワークとセキュリティ: パブリック アクセス
• VPC とサブネット: デフォルトの VPC とサブネットを使用します

私は 2 つのライブラリを試しました: RabbitMQ マニュアルと Enqueue\AmqpExt から

どちらも Amazon に接続できません (docker コンテナーを使用するとすべて正常に動作します。しかし、AMAZON MQ を試してみたいと思います。

以下のコードを使用しました。

結果：

'ssl_on' => true を使用すると、同じエラーが発生します。

Amazonにssl証明書を提供していないため、それが起こるかどうかはわかりません。

もしそうなら、それを修正する方法は？

以下の私のコードは、AmazonMQ (RabbitMQ) に接続するために .netcore 3.1 (RabbitMQ.Client 6.1 を使用) にあります。

自己コンテナーを使用してコードを公開し、マシン (Windows 10) では問題なく動作しますが、Windows 7 で実行すると、このエラーが発生しました。

しばらくしてエラーを掘り下げて検索して試した後 (たとえば、ファイアウォールをオフにする、アプリケーションのインバウンド アウトバウンドのルールを追加するなど)、これを修正する方法がわかりませんでした。誰でもこれを修正するのを手伝ってくれます。どうもありがとうございました。

rabbitmq を amazon mq (rabbitmq) に移行するためのこの記事に出会いました。 https://aws.amazon.com/blogs/compute/migrating-message-driven-applications-to-amazon-mq-for-rabbitmq/

次の文が表示されます。

「Amazon MQ for RabbitMQ では、TLS を使用した AMQP の安全なバージョンのみをサポートしています。以下のコード スニペットは、Pika ライブラリを使用した AMQPS 接続を示しています。サーバー側でのピア検証はサポートしていないことに注意してください。」

それは、Amazon mq (rabbitmq) に対して常に安全な接続を確保することが必須であることを意味するのでしょうか、それとも、安全な接続を選択する場合は TLS を使用する必要があると単純に言っているのでしょうか。

内部で ActiveMQ を使用する Amazon MQ を使用しています。ActiveMQ がメッセージを受信するたびに、AWS ラムダ関数をトリガーできます。SQS イベントからメッセージを読み取るラムダ関数を作成しました。キャプチャできる型がSQSeventありますが、Amazon MQ の場合、使用する関数シグネチャの型がわかりません。

SQS の場合、これを使用します。

Amazon MQ に何を使用すればよいかわかりません。

助けてください。ローカルから AWS にアクセスできないため、コードをデプロイする前に確認してください。

概要

切断された接続を検出できるように、コンシューマーでハートビートを設定しようとしています。たとえば、ブローカーが再起動された場合、フェイルオーバーに再接続する可能性があります。

Consumer/Dispatcher をローカルで実行し、キューを AWS で実行してコードをテストしたところ、すべて正常に動作しました。ただし、コードを AWS に移動すると、コンシューマーはサーバー/ブローカーでハートビートを設定しますが、ハートビートはサーバー/ブローカーによって送信されたり、クライアント/コンシューマーによって受信されたりすることはありません。その結果、HeartbeatException要求されたサーバーのハートビート間隔が経過するとすぐに がスローされます。

私のコードは、stomp-php-examples github の例に基づいています。

• レポ: https://github.com/stomp-php/stomp-php-examples
• ハートビートの例: https://github.com/stomp-php/stomp-php-examples/blob/support/version-4/src/heartbeats_server.php

なぜこれが機能しないのかについての次の最良の推測は、AWS によって提供されるデフォルトの構成を使用しているため、キュー構成に関連するものです (と思います)。ハートビートの構成設定についてグーグルで検索しましたが、これは新しいトピックであるため、あまり進んでいません。どんな助けでも大歓迎です！

設定

• アマゾン MQ (ActiveMQ 5.15.14)
• stomp-php 5.0 (本日現在の最新バージョン)

セットアップの詳細を提供できることをうれしく思います。

コード

コンシューマー (簡易版)

バージョン 5.15.14 の単一インスタンス ブローカーで再現しました。

ブローカーの STOMP デバッグをオンに切り替えようとしましたが、uri下の属性<transportConnector>は許可されていないようです。構成は保存されますが、属性が引き出されuriます。

<transportConnector>Amazon MQ 設定で許可される要素とその属性

Spring XML 構成ファイル (xsd ファイル) の操作