亚马逊sqs的异步消费者

我不熟悉队列。 我能够成功发布消息并同步接收它们但是，我现在正试图异步。

sqs提供的参考链接建议使用jmsclient包装器。 如果您已经有一个集成到jms客户端的代码，那么该链接还会提到使用它。

http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/jmsclient.html#samples

但我重新开始，我引用这个例子同步发送和recv消息。

https://github.com/aws/aws-sdk-java/blob/master/src/samples/AmazonSimpleQueueService/SimpleQueueServiceSample.java

我可以使用相同的代码，但使用消息监听器实现它吗？ 任何代码示例将不胜感激。

Answer 1

Amazon SQS开发人员指南中有关使用JMS与Amazon SQS的部分中的代码示例，其中显示了如何使用JMS异步接收消息。

首先，实现MessageListener接口：

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

然后将其设置为MessageConsumer的MessageListener：

 // Create a consumer for the 'TestQueue'. 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 will be invoked when a message is received. Thread.sleep(1000); 

Answer 2

SQS代表“简单队列服务”。 字面意思是简单。 因此，它不支持JMS的一些细节，特别是异步侦听器。

我写了一篇关于这个主题的博客文章： http ： //thedulinreport.com/2015/05/09/guaranteeing-delivery-of-messages-with-aws-sqs/

基本上，你需要做的是在一个无限循环中编写一个轮询器，但是你想要聪明一点 – 你不想继续进行过多的轮询，因为每个请求都要收费。