在我之前的文章中，我展示了一個(gè)簡單的示例，該示例如何將AWS SQS與Spring Framework結(jié)合使用以將消息放入隊(duì)列中并從隊(duì)列中讀取消息。 在本文中，我將更進(jìn)一步，并使用Spring創(chuàng)建一個(gè)“消息驅(qū)動(dòng)的Bean”，以便對放入隊(duì)列中的每個(gè)消息都進(jìn)行“自動(dòng)”處理。 AWS在其文檔頁面上將其稱為異步方式。 要做到這一點(diǎn)，我將在Spring中定義一個(gè)MessageListener并將其配置為描述來聽我的隊(duì)列在這里 。 要查看初始項(xiàng)目設(shè)置，請參閱我的前一篇文章，因?yàn)樵诖瞬辉儋樖觥?

Spring應(yīng)用程序上下文將定義消息偵聽器（和相應(yīng)的對象），如下所示：

<bean id="amazonMessageListener" class="net.pascalalma.aws.sqs.SpringMessageDrivenBean" /><bean id="messageListener" class="org.springframework.jms.listener.adapter.MessageListenerAdapter"><property name="delegate" ref="amazonMessageListener"/><property name="defaultListenerMethod" value="onMessage"/><property name="messageConverter"><null/></property></bean><bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"><property name="connectionFactory" ref="connectionFactory"/><property name="destinationName" ref="queueName" /><property name="messageListener" ref="messageListener" /></bean>

首先，我定義了我的MDB（MessageDrivenBean）bean，并將其稱為“ amazonMessageListener”。 接下來，我將此MDB用作“ messageListener”適配器的“代理”。 這個(gè)“適配器” bean還可以負(fù)責(zé)轉(zhuǎn)換消息有效負(fù)載（此處忽略）并在委托的偵聽器中調(diào)用正確的方法。

在'jmsContainer'bean中，'adapter'與使用的JMS連接Factory和目標(biāo)鏈接在一起。

剩下的就是MDB本身的源代碼：

package net.pascalalma.aws.sqs;import org.apache.log4j.Logger; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.TextMessage;public class SpringMessageDrivenBean {final static Logger logger = Logger.getLogger(SpringMessageDrivenBean.class);public void onMessage(Message message) {if (message instanceof TextMessage) {try {logger.info(String.format("MDB received: %s ", ((TextMessage) message).getText()));}catch (JMSException ex) {throw new RuntimeException(ex);}}else {throw new IllegalArgumentException("Message must be of type TextMessage");}} }

我認(rèn)為這非常簡單。 對于放在隊(duì)列中的每條消息，都會(huì)調(diào)用方法“ onMessage”，在這種情況下，它僅打印消息的文本內(nèi)容。 為了查看它的工作原理，我使用下面的“ main”類：

package net.pascalalma.aws.sqs;import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext;public class SpringMdbMain {public static void main(String[] args) {//Build application context by reading spring-config.xmlApplicationContext ctx = new ClassPathXmlApplicationContext(new String[]{"application-context.xml"});//Get an instance of ProviderService class;MyMessageProvider prdSvc = (MyMessageProvider) ctx.getBean("myMessageProviderService");//Call getProduct method of ProductServiceprdSvc.sendMessage("This is a test A");prdSvc.sendMessage("This is a test B");prdSvc.sendMessage("This is a test C");prdSvc.sendMessage("This is a test D");} }

結(jié)果為以下輸出：

2015-04-11 13:17:20 DEBUG net.pascalalma.aws.sqs.MyMessageProvider(23) - Sending message with txt: This is a test A 2015-04-11 13:17:26 DEBUG net.pascalalma.aws.sqs.MyMessageProvider(36) - Message sent 2015-04-11 13:17:26 DEBUG net.pascalalma.aws.sqs.MyMessageProvider(23) - Sending message with txt: This is a test B 2015-04-11 13:17:26 INFO net.pascalalma.aws.sqs.SpringMessageDrivenBean(16) - MDB received: This is a test A 2015-04-11 13:17:26 DEBUG net.pascalalma.aws.sqs.MyMessageProvider(36) - Message sent 2015-04-11 13:17:26 DEBUG net.pascalalma.aws.sqs.MyMessageProvider(23) - Sending message with txt: This is a test C 2015-04-11 13:17:26 INFO net.pascalalma.aws.sqs.SpringMessageDrivenBean(16) - MDB received: This is a test B 2015-04-11 13:17:27 DEBUG net.pascalalma.aws.sqs.MyMessageProvider(36) - Message sent 2015-04-11 13:17:27 DEBUG net.pascalalma.aws.sqs.MyMessageProvider(23) - Sending message with txt: This is a test D 2015-04-11 13:17:27 INFO net.pascalalma.aws.sqs.SpringMessageDrivenBean(16) - MDB received: This is a test C 2015-04-11 13:17:27 DEBUG net.pascalalma.aws.sqs.MyMessageProvider(36) - Message sent 2015-04-11 13:17:27 INFO net.pascalalma.aws.sqs.SpringMessageDrivenBean(16) - MDB received: This is a test D

翻譯自: https://www.javacodegeeks.com/2015/05/creating-a-message-driven-bean-with-aws-sqs-in-spring.html

總結(jié)

以上是生活随笔為你收集整理的在Spring使用AWS SQS创建消息驱动Bean的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。