最近一直在玩rebbitMQ，终于抽时间可以写一下关于RebbitMQ与Spring框架整合的东西了。
安装消息队列环境
因为是自己玩，环境安装都是在Windows上进行的，总体来说过程比较简单，Linux上应该也差不多。
Windows上RabbitMQ的开发可以参考：https://www.jianshu.com/p/4c65827edbd1
消息队列安装完后，就可以开始整合测试了。
安装完毕之后可以按照以下说明进行配置，新建virtual-host，交换器和队列，当然这些都可以考代码新建及操作。
https://blog.csdn.net/u013177381/article/details/74011645
引入依赖
<dependency>
<groupId>org.springframework.amqp</groupId>
<artifactId>spring-rabbit</artifactId>
<version>1.6.5.RELEASE</version>
<exclusions>
<exclusion>
<artifactId>spring-context</artifactId>
<groupId>org.springframework</groupId>
</exclusion>
</exclusions>
</dependency>
<!-- RabbitMQ -->
<dependency>
<groupId>com.rabbitmq</groupId>
<artifactId>amqp-client</artifactId>
<version>3.5.1</version>
</dependency>
消息通信使用的是amqp协议通信，这里的<exclusion>是为防止spring包引入冲突
这样前期的准备工作就做好了，接下来就开始整合spring
spring配置
- 首先是写一个RabbitMQ属性文件 rabbitMQ.properties :
rmq.ip=127.0.0.1
rmq.producer.num=20
rmq.port=5672
rmq.manager.user=guest
rmq.manager.password=guest
当然这是最基本的属性，可以在配置了MQ之后进行修改，如新建用户及密码等，guest仅限于本机访问。
- spring引入properties文件：
<bean id="propertyConfigurer" class="com.trace.app.framework.toolsmodel.ConvertPwdPropertyConfigurer">
<property name="locations">
<list>
<value>classpath:rabbitMQ.properties</value>
</list>
</property>
<property name="fileEncoding" value="utf-8"></property>
</bean>
- 配置连接工厂
以下给出两种方式，都可行：(提前使用控制台建立了virtual-host)
<rabbit:connection-factory id="connectionFactory" virtual-host="test" host="${rmq.ip}"
username="${rmq.manager.user}" password="${rmq.manager.password}" port="${rmq.port}"/>
<bean id="connectionFactory" class="org.springframework.amqp.rabbit.connection.CachingConnectionFactory">
<!--<constructor-arg value="localhost" />-->
<property name="username" value="${rmq.manager.user}" />
<property name="password" value="${rmq.manager.password}" />
<property name="host" value="${rmq.ip}" />
<property name="port" value="${rmq.port}" />
<property name="virtualHost" value="test"/>
</bean>
第一种形式是使用Spring提供的<rabbit:xxx>标签，主要有如下4中转发器类型标签
rabbit:fanout-exchange
rabbit:direct-exchange
rabbit:topic-exchange
rabbit:headers-exchange
接下来要声明消息队列管理员管理该连接工厂（同样是两种方法）
<!--<bean id="rabbitAdmin" class="org.springframework.amqp.rabbit.core.RabbitAdmin">-->
<!--<constructor-arg ref="connectionFactory" />-->
<!--</bean>-->
<rabbit:admin connection-factory="connectionFactory"/>
还需要声明消息队列中的交换器和队列，这里我是直接在控制台建立了messageExchange交换器和messageQueue队列
<!-- 声明消息队列，消息系统监听队列 -->
<!-- messageQueue 是在（1）中创建的队列 -->
<rabbit:queue id="messageQueue" durable="true" auto-delete="false" exclusive="false" name="messageQueue"/>
<!-- exchange queue binging key 绑定 -->
<!--声明交换 在（1）配置的交换-->
<rabbit:topic-exchange name="messageExchange" durable="true" auto-delete="false" id="messageExchange" >
<rabbit:bindings>
<rabbit:binding pattern="message.*" queue="messageQueue"/>
</rabbit:bindings>
</rabbit:topic-exchange>
<rabbit:template exchange="messageExchange" id="rabbitTemplate" connection-factory="connectionFactory"/>
- 声明生产者和消费者
声明生产者和消费者，下面给出xml配置的声明方式，可以多个生产者和多个消费者。
<!--声明生产者 -->
<bean id="messageSender"
class="com.trace.app.framework.services.MessageSender" name="MessageSender">
<property name="amqpTemplate" ref="rabbitTemplate"/>
<!-- <property name="routingKey" value="message.test" ></property> -->
</bean>
<!--声明消费者 -->
<bean id="messageConsumer" class="com.trace.app.framework.services.MessageConsumer" name="messageConsumer" />
还需要让消费者监听队列，做以下配置：
<rabbit:listener-container
connection-factory="connectionFactory" acknowledge="auto">
<!-- 让消费者监听这个队列 -->
<rabbit:listener ref="messageConsumer" queues="messageQueue" />
</rabbit:listener-container>
当然也可以使用注释的方法声明生产者和消费者对象，这里就不赘述了。
- 测试
自此spring的整合配置就完成了，再来贴出我的生产者和消费者的测试代码
生产者
/**
* rabbitMQ生产者
* */
@Service
public class MessageSender {
private AmqpTemplate amqpTemplate;
private String routingKey;
public AmqpTemplate getAmqpTemplate() {
return amqpTemplate;
}
public void setAmqpTemplate(AmqpTemplate amqpTemplate) {
this.amqpTemplate = amqpTemplate;
}
public String getRoutingKey() {
return routingKey;
}
public void setRoutingKey(String routingKey) {
this.routingKey = routingKey;
}
public void sendDataToQueue(Object obj) {
System.out.println("routingKey = " + this.routingKey);
System.out.println("Obj = " + obj);
amqpTemplate.convertAndSend(this.routingKey, obj);
}
}
消费者
/**
* rabbitMQ消费者
* */
public class MessageConsumer implements MessageListener {
private Logger logger = LoggerFactory.getLogger(MessageConsumer.class);
@Override
public void onMessage(Message message) {
logger.info("receive message:{}",message);
}
}
自此spring整合RabbitMQ的过程就结束了，在接下会介绍关于RabbitMQ生产者和消费者的具体事例，作为备忘参考。
