最近一直在玩rebbitMQ袄简，終于抽時間可以寫一下關(guān)于RebbitMQ與Spring框架整合的東西了。
安裝消息隊列環(huán)境
因為是自己玩，環(huán)境安裝都是在Windows上進行的精耐，總體來說過程比較簡單希太，Linux上應(yīng)該也差不多克饶。
Windows上RabbitMQ的開發(fā)可以參考：http://www.reibang.com/p/4c65827edbd1
消息隊列安裝完后，就可以開始整合測試了誊辉。
安裝完畢之后可以按照以下說明進行配置矾湃，新建virtual-host，交換器和隊列堕澄，當(dāng)然這些都可以考代碼新建及操作邀跃。
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協(xié)議通信霉咨，這里的<exclusion>是為防止spring包引入沖突
這樣前期的準(zhǔn)備工作就做好了，接下來就開始整合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
當(dāng)然這是最基本的屬性拍屑，可以在配置了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>標(biāo)簽，主要有如下4中轉(zhuǎn)發(fā)器類型標(biāo)簽
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隊列
<!-- 聲明消息隊列星爪，消息系統(tǒng)監(jiān)聽隊列 -->
<!-- messageQueue 是在（1）中創(chuàng)建的隊列 -->
<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"/>
- 聲明生產(chǎn)者和消費者
聲明生產(chǎn)者和消費者，下面給出xml配置的聲明方式粉私，可以多個生產(chǎn)者和多個消費者移必。
<!--聲明生產(chǎn)者 -->
<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" />
還需要讓消費者監(jiān)聽隊列，做以下配置：
<rabbit:listener-container
connection-factory="connectionFactory" acknowledge="auto">
<!-- 讓消費者監(jiān)聽這個隊列 -->
<rabbit:listener ref="messageConsumer" queues="messageQueue" />
</rabbit:listener-container>
當(dāng)然也可以使用注釋的方法聲明生產(chǎn)者和消費者對象毡鉴，這里就不贅述了崔泵。
- 測試
自此spring的整合配置就完成了，再來貼出我的生產(chǎn)者和消費者的測試代碼
生產(chǎn)者
/**
* rabbitMQ生產(chǎn)者
* */
@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的過程就結(jié)束了猪瞬，在接下會介紹關(guān)于RabbitMQ生產(chǎn)者和消費者的具體事例憎瘸，作為備忘參考。
