開始方法: ActiveMQ ブローカーの作成と接続

1. Amazon MQ コンソールにサインインします。

2. [Select broker engine] (ブローカーエンジンの選択) ページで [Apache ActiveMQ] を選択します。

3. [Select deployment and storage] (デプロイとストレージタイプの選択) ページの [Deployment mode and storage type] (デプロイモードとストレージタイプ) セクションで、以下を実行します。

   1. [Deployment mode] (デプロイモード) を選択します ([Active/standby broker] (アクティブ/スタンバイブローカー)など)。詳細については、「Amazon MQ for ActiveMQ ブローカーのデプロイオプション」を参照してください。

      • 単一インスタンスブローカーは 1 つのアベイラビリティーゾーンにある 1 つのブローカーで構成されます。ブローカーは、アプリケーションおよび Amazon EBSまたは Amazon EFSストレージボリュームと通信します。詳細については、「オプション 1: Amazon MQ シングルインスタンスブローカー」を参照してください。

      • 高可用性対応のアクティブ/スタンバイブローカーは、2 つの異なるアベイラビリティーゾーンにある 2 つのブローカーで構成され、冗長ペアで設定されます。これらのブローカーは、アプリケーションおよび Amazon と同期的に通信しますEFS。詳細については、「オプション 2: 高可用性を実現する Amazon MQ アクティブ/スタンバイブローカー」を参照してください。

      • ブローカーのネットワークのサンプル設計図の詳細については、「サンプル設計図」を参照してください。

   2. ストレージタイプ ( などEBS) を選択します。詳細については、「Storage」を参照してください。

      注記

      Amazon は単一のアベイラビリティーゾーン内でデータをEBSレプリケートし、ActiveMQ アクティブ/スタンバイデプロイモードをサポートしていません。

   3. [Next (次へ)] を選択します。

4. [Configure settings] (設定の定義) ページの [Details] (詳細) セクションで、以下を実行します。

   1. [Broker name] (ブローカー名) を入力します。

      重要

      ブローカー名に個人を特定できる情報 (PII) やその他の機密情報や機密情報を追加しないでください。ブローカー名には、 CloudWatch ログを含む他の AWS のサービスからアクセスできます。ブローカー名は、プライベートデータや機密データとして使用することを意図していません。

   2. [Broker instance type] (ブローカーインスタンスタイプ) を選択します (mq.m5.large など)。詳細については、「Broker instance types」を参照してください。

5. [ActiveMQ Web Console access] (ActiveMQ ウェブコンソールアクセス) セクションで、[Username] (ユーザーネーム) と [Password] (パスワード) を入力します。ブローカーのユーザー名とパスワードには、以下の制限が適用されます:

   • ユーザーネームに使用できるのは、英数字、ダッシュ、ピリオド、アンダースコア、およびチルダ (- . _ ~) のみです。

   • パスワードは 12 文字以上の長さで、一意の文字を少なくとも 4 つ含める必要があり、カンマ、コロン、または等号 (,:=) は使用できません。

   重要

   ブローカーのユーザー名に個人を特定できる情報 (PII) やその他の機密情報や機密情報を追加しないでください。ブローカーユーザー名は、 CloudWatch ログを含む他の AWS のサービスからアクセスできます。ブローカーのユーザー名は、プライベートデータや機密データとして使用することを意図していません。

6. [Deploy] (デプロイ) をクリックします。

   Amazon MQ がブローカーを作成している間は、[Creation in progress] (作成中) ステータスが表示されます。

   ブローカーの作成には約 15 分かかります。

   ブローカーが正常に作成されると、Amazon MQ が [Running] (実行中) ステータスを表示します。

7. 選択 MyBroker.

   リポジトリの [] MyBroker ページの Connect セクションで、ブローカーの ActiveMQ ウェブコンソール を書き留めます。URL例：

   https://b-1234a5b6-78cd-901e-2fgh-3i45j6k178l9-1.mq.us-east-2.amazonaws.com:8162

   また、ブローカーのワイヤレベルプロトコルの [Endpoints] (エンドポイント) もメモしておきます。 OpenWire エンドポイントの例を次に示します。

   ssl://b-1234a5b6-78cd-901e-2fgh-3i45j6k178l9-1.mq.us-east-2.amazonaws.com:61617

1. Amazon MQ コンソールにサインインします。

2. ブローカーリストから、ブローカーの名前を選択します (例: MyBroker）。

3. リポジトリの [] MyBroker ページの Connections セクションで、ブローカーのウェブコンソールとワイヤレベルのプロトコルのアドレスURLとポートを書き留めます。

4. [Details] (詳細) セクションの [Security and network] (セキュリティとネットワーク) で、セキュリティグループの名前または をクリックします。

   EC2 ダッシュボードのセキュリティグループページが表示されます。

5. セキュリティグループのリストから、セキュリティグループを選択します。

6. ページ下部で、[インバウンド] を選択し、次に [編集] を選択します。

7. 「インバウンドルールの編集」ダイアログボックスで、パブリックにアクセスできるようにするすべての URLまたはエンドポイントにルールを追加します (次の例は、ブローカーウェブコンソールでこれを行う方法を示しています）。

   1. [ルールの追加] を選択します。

   2. タイプ で、カスタム TCPを選択します。

   3. [Port Range] (ポート範囲) にはウェブコンソールポート (8162) を入力します。

   4. [Source] (ソース) では、[Custom] (カスタム) が選択された状態のままにしておき、ウェブコンソールにアクセスできるようにするシステムの IP アドレスを入力します (192.0.2.1 など)。

   5. [Save] (保存) をクリックします。

      これで、ブローカーはインバウンド接続を受け入れることができます。

1. ブローカーのエンドポイントを使用してメッセージプロデューサーのJMSプール接続ファクトリを作成し、ファクトリに対して createConnectionメソッドを呼び出します。

   注記

   アクティブ/スタンバイブローカーの場合、Amazon MQ は 2 つの ActiveMQ ウェブコンソール を提供しますがURLs、一度にアクティブになるのURLは 1 つだけです。同様に、Amazon MQ はワイヤレベルプロトコルごとに 2 つのエンドポイントを提供しますが、ペアごとに一度に 1 つのエンドポイントしかアクティブになりません。-1 および -2 サフィックスは冗長ペアを表します。詳細については、「Amazon MQ for ActiveMQ ブローカーのデプロイオプション」を参照してください。

   ワイヤレベルプロトコルのエンドポイントについては、フェイルオーバートランスポートを使用することによって、アプリケーションがエンドポイントのどちらか一方に接続することを許可できます。

   // Create a connection factory.
   final ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(wireLevelEndpoint);
   
   // Pass the sign-in credentials.
   connectionFactory.setUserName(activeMqUsername);
   connectionFactory.setPassword(activeMqPassword);
   
   // Create a pooled connection factory.
   final PooledConnectionFactory pooledConnectionFactory = new PooledConnectionFactory();
   pooledConnectionFactory.setConnectionFactory(connectionFactory);
   pooledConnectionFactory.setMaxConnections(10);
   
   // Establish a connection for the producer.
   final Connection producerConnection = pooledConnectionFactory.createConnection();
   producerConnection.start(); 
   
   // Close all connections in the pool.
   pooledConnectionFactory.clear();

   注記

   メッセージプロデューサーは、常に PooledConnectionFactory クラスを使用する必要があります。詳細については、「常に接続プールを使用する」を参照してください。

2. セッション、MyQueue という名前のキュー、およびメッセージプロデューサーを作成します。

   // Create a session.
   final Session producerSession = producerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
   
   // Create a queue named "MyQueue".
   final Destination producerDestination = producerSession.createQueue("MyQueue");
   
   // Create a producer from the session to the queue.
   final MessageProducer producer = producerSession.createProducer(producerDestination);
   producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

3. メッセージ文字列 "Hello from Amazon MQ!" を作成してから、メッセージを送信します。

   // Create a message.
   final String text = "Hello from Amazon MQ!";
   TextMessage producerMessage = producerSession.createTextMessage(text);
   
   // Send the message.
   producer.send(producerMessage);
   System.out.println("Message sent.");

4. プロデューサーをクリーンアップします。

   producer.close();
   producerSession.close();
   producerConnection.close();

1. ブローカーのエンドポイントを使用してメッセージプロデューサーの接続JMSファクトリを作成し、ファクトリに対して createConnectionメソッドを呼び出します。

   // Create a connection factory.
   final ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(wireLevelEndpoint);
   
   // Pass the sign-in credentials.
   connectionFactory.setUserName(activeMqUsername);
   connectionFactory.setPassword(activeMqPassword);
   
   // Establish a connection for the consumer.
   final Connection consumerConnection = connectionFactory.createConnection();
   consumerConnection.start();

   注記

   メッセージコンシューマーには、PooledConnectionFactory クラスを一切使用しないでください。詳細については、「常に接続プールを使用する」を参照してください。

2. セッション、MyQueue という名前のキュー、およびメッセージコンシューマーを作成します。

   // Create a session.
   final Session consumerSession = consumerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
   
   // Create a queue named "MyQueue".
   final Destination consumerDestination = consumerSession.createQueue("MyQueue");
   
   // Create a message consumer from the session to the queue.
   final MessageConsumer consumer = consumerSession.createConsumer(consumerDestination);

3. メッセージの待機を開始し、メッセージの到着時にメッセージを受信します。

   // Begin to wait for messages.
   final Message consumerMessage = consumer.receive(1000);
   
   // Receive the message when it arrives.
   final TextMessage consumerTextMessage = (TextMessage) consumerMessage;
   System.out.println("Message received: " + consumerTextMessage.getText());

   注記

   AWS メッセージングサービス (Amazon などSQS) とは異なり、コンシューマーは常にブローカーに接続されています。

4. コンシューマー、セッション、および接続を閉じます。

   consumer.close();
   consumerSession.close();
   consumerConnection.close();
   

ブローカーを Lambda 関数に接続する

1. Lambda 関数実行IAMロール に次のロールアクセス許可を追加します。 https://docs.aws.amazon.com/lambda/latest/dg/lambda-intro-execution-role.html

   • mq:DescribeBroker

   • ec2:CreateNetworkInterface

   • ec2:DeleteNetworkInterface

   • ec2:DescribeNetworkInterfaces

   • ec2:DescribeSecurityGroups

   • ec2:DescribeSubnets

   • ec2:DescribeVpcs

   • ログ：CreateLogGroup

   • ログ：CreateLogStream

   • ログ：PutLogEvents

   • secretsmanager:GetSecretValue

   注記

   必要なIAMアクセス許可がないと、関数は Amazon MQ リソースからレコードを正常に読み取ることができません。

2. (オプション) パブリックアクセシビリティがないブローカーを作成した場合は、次のいずれかを実行して、Lambda のブローカーへの接続を許可する必要があります。

   • パブリックサブネットごとに 1 つのNATゲートウェイを設定します。詳細については、「 AWS Lambda デベロッパーガイド」のVPC「 接続関数のインターネットアクセスとサービスアクセス」を参照してください。

   • VPC エンドポイントを使用して、Amazon Virtual Private Cloud (Amazon VPC) と Lambda 間の接続を作成します。Amazon は、 AWS Security Token Service （AWS STS) と Secrets Manager エンドポイントにも接続VPCする必要があります。詳細については、「 AWS Lambda デベロッパーガイド」の「Lambda のインターフェイスVPCエンドポイントの設定」を参照してください。

3. AWS Management Consoleを使用して、Lambda 関数のイベントソースとしてブローカーを設定します。create-event-source-mapping AWS Command Line Interface コマンドを使用することもできます。

4. ブローカーから取り込まれたメッセージを処理するための Lambda 関数のコードをいくつか記述します。イベントソースマッピングによって取得される Lambda ペイロードは、ブローカーのエンジンタイプに依存します。以下は、Amazon MQ for ActiveMQ キューの Lambda ペイロードの例です。

   注記

   この例では、testQueue がキューの名前です。

   {
     "eventSource": "aws:amq",
     "eventSourceArn": "arn:aws:mq:us-west-2:112556298976:broker:test:b-9bcfa592-423a-4942-879d-eb284b418fc8",
     "messages": {
       [
         {
           "messageID": "ID:b-9bcfa592-423a-4942-879d-eb284b418fc8-1---mq---us-west-2.amazonaws.com.rproxy.goskope.com-37557-1234520418293-4:1:1:1:1",
           "messageType": "jms/text-message",
           "data": "QUJDOkFBQUE=",
           "connectionId": "myJMSCoID",
           "redelivered": false,
           "destination": {
             "physicalname": "testQueue" 
           }, 
           "timestamp": 1598827811958,
           "brokerInTime": 1598827811958,
           "brokerOutTime": 1598827811959
         },
         {
           "messageID": "ID:b-9bcfa592-423a-4942-879d-eb284b418fc8-1---mq---us-west-2.amazonaws.com.rproxy.goskope.com-37557-1234520418293-4:1:1:1:1",
           "messageType":"jms/bytes-message",
           "data": "3DTOOW7crj51prgVLQaGQ82S48k=",
           "connectionId": "myJMSCoID1",
           "persistent": false,
           "destination": {
             "physicalname": "testQueue" 
           }, 
           "timestamp": 1598827811958,
           "brokerInTime": 1598827811958,
           "brokerOutTime": 1598827811959
         }
       ]
     }
   }