将 Java 应用程序连接到您的 Amazon MQ 代理

登录 Amazon MQ 控制台。

从代理列表中选择您的代理的名称（例如 MyBroker)。

在 MyBroker 页面的 Connections (连接) 部分，记下代理 Web 控制台 URL 和线级协议的地址和端口。

在 Details (详细信息) 部分的 Security and network (安全与网络) 下，选择您的安全组名称或 。

此时将显示 EC2 Dashboard 的 Security Groups (安全组) 页面。

从安全组列表中，选择您的安全组。

在页面底部，选择 Inbound (入站)，然后选择 Edit (编辑)。

在 Edit inbound rules (编辑入站规则) 对话框中，为希望公开访问的每个 URL 或终端节点添加规则（以下示例显示如何为代理 Web 控制台执行此操作。

1. 选择 Add Rule（添加规则）。

2. 对于 Type (类型)，选择 Custom TCP (自定义 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();