rabbitMQ与spring集成在项目中使用
2016-12-27 16:58
399 查看
rabbitMQ与spring集成
1、引入spring-rabbit依赖
2、对应spring的版本4.2.8.RELEASE
3、配置sping-mq.xml配置文件
此时可以使用test-template向exchange中推送消息,exchange接收到消息后向其绑定的队列进行消息投递。
exchange有两种类型:
a. fanout类型的exchange,该类型的exchange会对其绑定的队列进行广播(即当前exchange绑定的所有队列都会被投递)
b. direct类型的exchange,改类型的exchange会根据key投递到不同的队列(key可以使用通配符,具体参考文档)
使用rabbitMQ时候遇到的问题
1 监听b队列,向a队列推送消息,结果监听器也可以监听到消息
原因:要通过rabbitMQ提供的网页管理工具检查该exchange绑定到哪些queue上去了,要保证该exchange只向a队列投递,而不是既绑定了a队列又绑定了b队列。
1、引入spring-rabbit依赖
<dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit</artifactId> <version>1.5.1.RELEASE</version> </dependency>
2、对应spring的版本4.2.8.RELEASE
3、配置sping-mq.xml配置文件
<rabbit:connection-factory id="connectionFactory" host="${mq.host}" port="${mq.port}" username="${mq.username}" password="${mq.password}" /> <rabbit:admin connection-factory="connectionFactory" /> <!-- 模板类需要自己重新定义,exchange需要重新制定并在下方定义,routing-key需要重新指定,并与下方exchange中的key保持一致 --> <!-- 定义template start --> <rabbit:template id="test-template" connection-factory="connectionFactory" exchange="test.exchange" /> <!-- 定义template end --> <!-- 定义queue start --> <rabbit:queue name="test.a.queue" /> <rabbit:queue name="test.b.queue" /> <!-- 定义queue end --> <!-- exchange重新定义并与上边的模本中保持一致,binding中的queue和key也要用自己重新定义的 start --> <rabbit:fanout-exchange name="test.exchange"> <rabbit:bindings> <rabbit:binding queue="test.a.queue" /> </rabbit:bindings> </rabbit:fanout-exchange> <rabbit:listener-container connection-factory="connectionFactory" concurrency="10" prefetch="5"> <rabbit:listener queue-names="test.a.queue" method="listen" ref="testListener" /> </rabbit:listener-container> <!-- listener配置 --> <bean id="testListener" class="org.t.TestListener"/>
此时可以使用test-template向exchange中推送消息,exchange接收到消息后向其绑定的队列进行消息投递。
exchange有两种类型:
a. fanout类型的exchange,该类型的exchange会对其绑定的队列进行广播(即当前exchange绑定的所有队列都会被投递)
b. direct类型的exchange,改类型的exchange会根据key投递到不同的队列(key可以使用通配符,具体参考文档)
使用rabbitMQ时候遇到的问题
1 监听b队列,向a队列推送消息,结果监听器也可以监听到消息
原因:要通过rabbitMQ提供的网页管理工具检查该exchange绑定到哪些queue上去了,要保证该exchange只向a队列投递,而不是既绑定了a队列又绑定了b队列。
相关文章推荐
- springboot中rabbitmq集成——多项目
- 使用junit进行集成spring项目的单元测试
- 在Spring项目中集成使用MongoDB
- 使用maven创建一个spring-boot项目-集成springmvc
- 在springboot项目中使用mybatis 集成 Sharding-JDBC
- Spring集成RabbitMQ-使用RabbitMQ更方便
- RabbitMQ简介,安装,Spring集成 demo,以及使用(spring集成在最下面)
- 1 springboot项目集成使用disconf,基于docker环境
- 从零学spring boot--集成mybatis--项目--使用注解方式
- Spring集成RabbitMQ-使用RabbitMQ更方便
- 4 springboot项目集成使用disconf,配置文件更新及回调
- springboot中rabbitmq集成——单项目
- SpringBoot | 第十二章:RabbitMQ的集成和使用
- 2 springboot项目集成使用disconf,基于docker环境
- [置顶] 使用maven创建一个spring-boot项目-集成springmvc
- 在Spring项目中集成使用dubbo实现分布式服务
- springboot中rabbitmq集成——单项目
- 使用SpringBoot搭建小型项目,集成mybatis,redis,swagger2,并部署在外部容器中。
- Java Web学习系列——Maven Web项目中集成使用Spring、MyBatis实现对MySQL的数据访问
- ThreadLocal的实现原理,及使用实例,解决spring,hibernate非web项目下的懒加载 no session or session was closed(1)!