將 Java 應用程式連線到您的 Amazon MQ 代理程式

登入 Amazon MQ 主控台。

從代理程式清單中，選擇您的代理程式名稱 (例如，MyBroker)。

在 MyBroker 頁面的 Connections (連線) 區段中，記下代理程式 Web 主控台 URL 和線路通訊協定的位址和連接埠。

在 Details (詳細資訊) 區段的 Security and network (安全與網路) 下，選擇您的安全群組名稱或 。

隨即會顯示 EC2 儀表板的 Security Groups (安全群組) 頁面。

從安全群組清單選擇您的安全群組。

在頁面的最下方，選擇 Inbound (傳入)，然後選擇 Edit (編輯)。

在 Edit inbound rules (編輯傳入規則) 對話方塊中，為您要公開存取的每個 URL 或端點新增規則 (下列範例顯示如何針對代理程式 Web 主控台執行此動作)。

1. 選擇 Add Rule (新增規則)。

2. 針對類型，選取自訂 TCP。

3. 針對 Port Range (連接埠範圍)，輸入 Web 主控台連接埠 (8162)。

4. 針對 Source (來源)，讓 Custom (自訂) 保持已選取狀態，然後輸入您希望能夠存取 Web 主控台的系統 IP 地址 (例如，192.0.2.1)。

5. 選擇 Save (儲存)。

   您的代理程式現在已可接受傳入連線。

使用代理程式的端點為訊息生產者建立 JMS 集區連接工廠，然後對工廠呼叫 createConnection 方法。

// 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();

建立工作階段、名為 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);

建立訊息字串 "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.");

清除生產者。

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

使用代理程式的端點為訊息生產者建立 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();

建立工作階段、名為 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);

開始等待訊息，並在訊息送達時接收訊息。

// 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());

關閉消費者、工作階段和連線。

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