接上一篇:(企业内部需求实战_进阶_06)SSM集成RabbitMQ 订阅模式 关键代码讲解、开发、测试
此项目采用MQ发送消息模式为:订阅模式,如果对RabbitMQ不熟悉,请学习RabbitMQ专栏进行相关知识点的学习!遇到问题,可以给我留言!看到后定会回复!
文章目录
- 一、RabbitMQ配置文件
- 1. 生产者配置文件更新
- 二、启动项目验证
- 2.1. 启动tomcat7插件
- 2.2. 清空控制台
- 三、管控台总览
- 4.1. 在交换机中查看绑定的队列
- 4.2. 在队列中查看绑定的交换机
- 五、请求验证测试
- 5.1. 生产者①请求
- 5.2. 生产者②请求
- 六、启动RabbitMQ
- 6.1. 进入sbin目录,双击运行
- 6.2. 启动图示
一、RabbitMQ配置文件
1. 生产者配置文件更新
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:rabbit="http://www.springframework.org/schema/rabbit"
xsi:schemaLocation="http://www.springframework.org/schema/rabbit
http://www.springframework.org/schema/rabbit/spring-rabbit-1.4.xsd
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.1.xsd">
<!--生产者者配置如下:-->
<!-- 定义RabbitMQ的连接工厂 -->
<rabbit:connection-factory id="connectionFactory"
host="${rabbitmq.host}" port="${rabbitmq.port}" username="${rabbitmq.username}"
password="${rabbitmq.password}" virtual-host="${rabbitmq.vhost}"/>
<!-- 管理消息队列 -->
<rabbit:admin connection-factory="connectionFactory"/>
<!--此处为配置文件方式 管控台配置模式需要注释 默认模式管控台 Start-->
<!-- 定义一个队列或者多个队列 自动声明-->
<rabbit:queue name="ORDER-CATEGORY-GBLFY-QUEUE" auto-declare="true" durable="true"/>
<rabbit:queue name="ORDER-USER-MENU-QUEUE" auto-declare="true" durable="true"/>
<rabbit:fanout-exchange name="ORDER-TRACE-EXCHANGE">
<rabbit:bindings>
<!-- 可绑定多个队列,发送的时候指定key进行发送 -->
<rabbit:binding queue="ORDER-CATEGORY-GBLFY-QUEUE"/>
<rabbit:binding queue="ORDER-USER-MENU-QUEUE"/>
</rabbit:bindings>
</rabbit:fanout-exchange>
<!--此处为配置文件方式 管控台配置模式需要注释 默认模式管控台 End-->
<!-- 定义交换机 自动声明-->
<rabbit:fanout-exchange name="ORDER-TRACE-EXCHANGE"
auto-declare="true" durable="true"/>
<!-- 定义MQ消息模板 -->
<rabbit:template id="rabbitTemplate"
connection-factory="connectionFactory" exchange="ORDER-TRACE-EXCHANGE"/>
</beans>
二、启动项目验证
2.1. 启动tomcat7插件
2.2. 清空控制台
三、管控台总览
4.1. 在交换机中查看绑定的队列
4.2. 在队列中查看绑定的交换机
五、请求验证测试
5.1. 生产者①请求
http://localhost:8888/snedUserMQMsg
5.2. 生产者②请求
http://localhost:8888/sendMenuMQMsg
六、启动RabbitMQ
6.1. 进入sbin目录,双击运行
6.2. 启动图示