在 Spring 中使用 AWS SQS 创建消息驱动 Bean

在 我之前的帖子 中，我展示了一个简单的示例，说明如何使用 AWS SQS 和 Spring Framework 将消息放入队列并从队列中读取消息。在这篇文章中，我更进一步，使用 Spring 创建了一个“消息驱动 Bean”，这样放入队列中的每条消息都会“自动”获取和处理。 AWS 在 其文档页面 上将其称为异步方式。为此，我将在 Spring 中定义一个 MessageListener 并将其配置为侦听我的队列，如此处 所述 。要查看初始项目设置，请参阅 我之前的帖子 ，因为我不会在此处再次显示。

Spring 应用程序上下文将像这样定义消息监听器（和相应的对象）：

 <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”适配器的“委托”。这个“适配器”bean 还可以负责转换消息有效负载（此处忽略）并在委托的侦听器中调用正确的方法。
在“jmsContainer”bean 中，“适配器”与使用的 JMS 连接工厂和要侦听的目标链接。剩下的就是 MDB 本身的源代码：

 <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>

我认为这是相当简单的。为放入队列的每条消息调用方法“onMessage”，在这种情况下它只是打印消息的文本内容。要查看它是否正常工作，我使用以下“主”类：

 <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>

这导致以下输出：

 <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>