使用 Amazon SQS Java Messaging Library

创建连接工厂并对该工厂调用 createConnection 方法。

// Create a new connection factory with all defaults (credentials and region) set automatically
SQSConnectionFactory connectionFactory = new SQSConnectionFactory(
        new ProviderConfiguration(),
        AmazonSQSClientBuilder.defaultClient()
        );
 
// Create the connection.
SQSConnection connection = connectionFactory.createConnection();

SQSConnection 类对 javax.jms.Connection 进行了扩展。除了 JMS 标准连接方法，SQSConnection 还提供其他一些方法，例如 getAmazonSQSClient 和 getWrappedAmazonSQSClient。这两种方法均可让您执行未包含在 JMS 规范中的管理操作，例如创建新队列。不过，getWrappedAmazonSQSClient 方法还提供当前连接使用的 Amazon SQS 客户端的封装版本。该包装程序将客户端中的每个异常转变为 JMSException，从而让预期有 JMSException 发生的现有代码更方便地使用该异常。

您可以使用从 getAmazonSQSClient 和 getWrappedAmazonSQSClient 返回的客户端对象来执行未包含在 JMS 规范中的管理操作（例如，可以创建 Amazon SQS 队列）。

如果您现有的代码需要 JMS 异常，则应使用 getWrappedAmazonSQSClient：

当连接和基础 Amazon SQS 队列准备就绪时，将创建一个具有 AUTO_ACKNOWLEDGE 模式的非事务性 JMS 会话。

// Create the nontransacted session with AUTO_ACKNOWLEDGE mode
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

为了向队列发送文本消息，将创建一个 JMS 队列标识和消息创建者。

// Create a queue identity and specify the queue name to the session
Queue queue = session.createQueue("MyQueue");
 
// Create a producer for the 'MyQueue'
MessageProducer producer = session.createProducer(queue);

创建文本消息并将它发送到队列。

要接收消息，可为同一队列创建一个使用者，然后调用 start 方法。

您可以随时对连接调用 start 方法。不过，使用者不会开始接收消息，直至调用此方法。

// Create a consumer for the 'MyQueue'
MessageConsumer consumer = session.createConsumer(queue);
// Start receiving incoming messages
connection.start();

在超时设为 1 秒钟的情况下对该使用者调用 receive 方法，然后输出收到的消息内容。

关闭连接和会话。

// Close the connection (and the session).
connection.close();

实施 MessageListener 接口。

class MyListener implements MessageListener {
 
    @Override
    public void onMessage(Message message) {
        try {
            // Cast the received message as TextMessage and print the text to screen.
            System.out.println("Received: " + ((TextMessage) message).getText());
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

在收到消息时，调用 onMessage 接口的 MessageListener 方法。在此监听器实现中，输出保存在消息中的文本。

对 receive 实现实例设置使用者消息监听器，而不是对使用者显式调用 MyListener 方法。主线程会等待一秒钟。

// Create a consumer for the 'MyQueue'.
MessageConsumer consumer = session.createConsumer(queue);
 
// Instantiate and set the message listener for the consumer.
consumer.setMessageListener(new MyListener());
 
// Start receiving incoming messages.
connection.start();
 
// Wait for 1 second. The listener onMessage() method is invoked when a message is received.
Thread.sleep(1000);

要在消息处理完毕后显式确认消息，则必须创建具有 CLIENT_ACKNOWLEDGE 模式的会话。

// Create the non-transacted session with CLIENT_ACKNOWLEDGE mode.
Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);

收到消息时，显示消息，然后显式确认消息。

// Cast the received message as TextMessage and print the text to screen. Also acknowledge the message.
if (receivedMessage != null) {
    System.out.println("Received: " + ((TextMessage) receivedMessage).getText());
    receivedMessage.acknowledge();
    System.out.println("Acknowledged: " + message.getJMSMessageID());
}