一、好言
万物皆有裂缝处，那时光射进来的地方。
二、背景
这篇主要是amq的一些用法，比如队列queue，topic，还有注解的使用,并且看了公司的一些封装，有点感触，在这里面也会说下。
三、内容
3.1 、xml对列的配置方式，queueDestination的配置使用的是对象，在对象中再指定名字：
<!-- 定义消息队列（Queue） -->
<bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
<!-- 设置消息队列的名字 -->
<constructor-arg>
<value>mouse-one</value>
</constructor-arg>
</bean>
<!-- 配置JMS模板（Queue），Spring提供的JMS工具类，它发送、接收消息。 -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory" />
<property name="defaultDestination" ref="queueDestination" />
<property name="receiveTimeout" value="10000" />
</bean>
<!-- 定义消息队列（Queue），我们监听一个新的队列，queue2 -->
<bean id="queueDestination2" class="org.apache.activemq.command.ActiveMQQueue">
<!-- 设置消息队列的名字 -->
<constructor-arg>
<value>mouse-two</value>
</constructor-arg>
</bean>
<!-- 配置消息队列监听者（Queue），代码下面给出，只有一个onMessage方法 -->
<bean id="queueMessageListener" class="com.mouse.moon.message.listener.QueueMessageListener" />
<!-- 消息监听容器（Queue），配置连接工厂，监听的队列是queue2，监听器是上面定义的监听器 -->
<bean id="jmsContainer"
class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory" />
<property name="destination" ref="queueDestination2" />
<property name="messageListener" ref="queueMessageListener" />
</bean>
amq中，jmsTemplate的send可以接手对象ActiveMQQueue，也可以直接接收DestinationName,所以下面给出配置
3.2、使用名字进行消息推送
<!-- 配置JMS模板（Queue），Spring提供的JMS工具类，它发送、接收消息。 -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory" />
<property name="defaultDestinationName" value="mouse-name-one"></property>
<property name="receiveTimeout" value="10000" />
</bean>
<!-- 配置消息队列监听者（Queue），代码下面给出，只有一个onMessage方法 -->
<bean id="queueMessageListener" class="com.mouse.moon.message.listener.QueueMessageListener" />
<!-- 消息监听容器（Queue），配置连接工厂，监听的队列是queue2，监听器是上面定义的监听器 -->
<bean id="jmsContainer"
class="org.springframework.jms.listener.DefaultMessageListenerContainer" abstract="true">
<property name="connectionFactory" ref="connectionFactory" />
</bean>
<bean parent="jmsContainer">
<property name="destinationName" value="mouse-name-two" />
<property name="messageListener" ref="queueMessageListener" />
</bean>
junit代码：
@Test
public void testProduce(){
for(int i = 0;i < 5; i++){
producerService.sendMessage("mouse-name-one","测试消息发送了哈哈哈哈哈哈哈" + i+new Date()+new Random().nextInt(100));
}
}
这里直接调用封装好的对象，传入名字进行。
代码都有，可以直接看配置了。
3.3 以注解的形式配置监听器
启用注解
<jms:annotation-driven/>
<bean id="jmsListenerContainerFactory" class="org.springframework.jms.config.DefaultJmsListenerContainerFactory">
<property name="connectionFactory" ref="connectionFactory"/>
</bean>
package com.mouse.moon.message.listener;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.jms.listener.adapter.MessageListenerAdapter;
import org.springframework.stereotype.Component;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.TextMessage;
/**
* Created by Mahone Wu on 2017/4/11.
*/
@Component
public class QueueMessageListenerAnno extends MessageListenerAdapter {
private Logger logger = LoggerFactory.getLogger(QueueMessageListenerAnno.class);
@JmsListener(destination = "mouse-one",concurrency = "5-10")
public void onMessageMahone(Message message, Session session){
TextMessage tm = (TextMessage)message;
try{
logger.info("注解QueueMessageListenerAnno 收到消息{}",tm.getText());
}catch (JMSException e){
logger.error("监听的bug"+e);
e.printStackTrace();
}
}
}
图片.png
3.4、有关公用提取
<!-- 消息监听容器（Queue），配置连接工厂，监听的队列是queue2，监听器是上面定义的监听器 -->
<bean id="jmsContainer"
class="org.springframework.jms.listener.DefaultMessageListenerContainer" abstract="true">
<property name="connectionFactory" ref="connectionFactory" />
</bean>
<bean parent="jmsContainer">
<property name="destinationName" value="mouse-name-two" />
<property name="messageListener" ref="queueMessageListener" />
</bean>
可以看出下面这个bean我使用了属性parent,这里使用了父类，也就是类似说继承一些属性，并且jmsContainer中的abstract属性我设置为了true，否则会报错，因为其他几个属性都是必填项目，abstract属性为true后则抽象了。这样，我们在使用XML时候不用每一个这样的配置都要指定connectionFactory属性。
上述配置有借鉴使用Spring JMS收发消息该文章。
我自己的代码地址在GitHub上可见
https://github.com/MahoneWu/mq
