RabbitMQ - 实例操作

以前在单项目中用过RabbitMQ，没有问题,不过这次在分布式项目中使用RabbitMQ中有点搞糊涂了，但是实际上是没有问题的，思路清晰就行

简单看一下实际操作的示例吧： 

资源文件中需要配置基本的rabbitMQ的属性，如下：

1 #rabbitmq config
2 rabbitmq.host=192.168.1.188
3 rabbitmq.port=5672
4 rabbitmq.username=lee
5 rabbitmq.password=lee
6 rabbitmq.vhost=danger

然后要配置applicationContext-rabbitmq.xml，这个文件需要新建，当然你也可以在你的service.xml中编写，但是为了配置清晰嘛

内容如下：

1     <!-- 定义RabbitMQ的连接工厂 -->
 2     <rabbit:connection-factory id="connectionFactory"
 3         host="${rabbitmq.host}" 
 4         port="${rabbitmq.port}" 
 5         username="${rabbitmq.username}" 
 6         password="${rabbitmq.password}"
 7         virtual-host="${rabbitmq.vhost}" />
 8         
 9     <!-- 定义消息管理员 -->
10     <rabbit:admin connection-factory="connectionFactory"/>
11     
12     <!-- 生产者需要以下 -->
13     <!-- 定义交换机 -->
14     <rabbit:topic-exchange name="rest-content-exchange" durable="true" auto-declare="true">
15         <!-- 如果是2个不同的系统进行通知，那就手动在管理后台进行绑定 -->
16         <rabbit:bindings>
17             <rabbit:binding queue="rest-sms-queue" pattern="rest.sms.#"/>
18             <rabbit:binding queue="rest-jpush-queue" pattern="rest.jpush.#"/>
19             <rabbit:binding queue="rest-sysmsg-queue" pattern="rest.sysmsg.#"/>
20         </rabbit:bindings>
21     </rabbit:topic-exchange>
22     
23     <!-- 定义rabbitTemplate -->
24     <rabbit:template id="rabbitTemplate" connection-factory="connectionFactory" exchange="rest-content-exchange"/>
25     
26     
27     <!-- 消费者需要以下 -->
28     <!-- 定义队列 -->
29     <rabbit:queue name="rest-sms-queue" durable="true" auto-declare="true"/>
30     <rabbit:queue name="rest-jpush-queue" durable="true" auto-declare="true"/>
31     <rabbit:queue name="rest-sysmsg-queue" durable="true" auto-declare="true"/>
32     
33     <!-- 消费者 -->
34     <bean id="smsHandler" class="com.dingli.components.mq.handler.SmsHandler"></bean>
35     <bean id="jpushHandler" class="com.dingli.components.mq.handler.JpushHandler"></bean>
36     <bean id="saveSysMsgHandler" class="com.dingli.components.mq.handler.SaveSysMsgHandler"></bean>
37     
38     <!-- 队列监听 -->
39     <!-- TODO 注释了后台不会滚动显示 -->
40     <rabbit:listener-container connection-factory="connectionFactory" acknowledge="none" >
41         <rabbit:listener ref="smsHandler" method="excute" queue-names="rest-sms-queue" />
42         <rabbit:listener ref="jpushHandler" method="excute" queue-names="rest-jpush-queue" />
43         <rabbit:listener ref="saveSysMsgHandler" method="saveMsgExcute" queue-names="rest-sysmsg-queue" />
44     </rabbit:listener-container>

这里需要注意acknowledge，这个属性默认是auto，如果消费者报错了，会一直报错，因为他是轮询监听的，可以修改为none或者manul

再看看实现的消费者以及助手类，助手类可以理解为service

监听3个routing-key

1 @Component
 2 public class SendMsgRestProducerImpl implements SendMsgRestProducer {
 3 
 4     @Autowired    
 5     private RabbitTemplate rabbitTemplate;
 6     
 7     @Override
 8     public void sendSMS(String mqSMSMessageJson) {
 9         rabbitTemplate.convertAndSend("rest.sms.send", mqSMSMessageJson);
10     }
11 
12     @Override
13     public void jpushContent(String mqJPushMessageJson) {
14         rabbitTemplate.convertAndSend("rest.jpush.send", mqJPushMessageJson);
15     }
16 
17     @Override
18     public void saveContent(String mqSysMessageJson) {
19         rabbitTemplate.convertAndSend("rest.sysmsg.send", mqSysMessageJson);
20     }
21     
22 }

这样，直接调用componentImpl就行了！并且这3个都是异步的

为什么要使用RabbitMQ，那就是效率问题，有些主流程实现后，附流程你不在乎，成功不成功不影响，顶多重发一次，这样的业务可以使用消息队列

当然也有更多更复杂的也需要用的，这里的业务场景就比较简单了

RabbitMQ 的详细介绍：请点这里
RabbitMQ 的下载地址：请点这里