rabbitmq

SpringAMQP 之 RabbitTemplate

2018-08-16  本文已影响175人  HmilyMing

RabbitTemplate 即消息模板

它是在之前于 SpringAMQP 整合的时候进行发送消息的关键类。它提供了丰富的发送消息方法,包括可靠性投递消息方法、回调监听消息接口 ConfirmCallback、返回值确认接口 ReturnCallback 等等。同样我们需要进行注入到 Spring 容器中,然后直接使用。RabbitTemplate 在 Spring 整合时需要实例化,但是在 Springboot 整合时,在配置文件里添加配置即可。

代码示例:

代码地址:  https://github.com/hmilyos/rabbitmq-spring-demo

先实例化 RabbitTemplate

然后就在单元测试类里面写个方法发送消息

运行单元测试,上管控台查看消息是否发送到queue里面了。如下图所示,queue接收到消息了。

在queue里面获取一下消息,看到额外设置的东西

改进一下代码,发送三个不同routingkey的消息

再次启动测试方法,上管控台查看一下消息,本次发送了三条,加上之前未消费的一条,根据路由规则交换机 topic001 绑定  spring.*  所以 queue001 有三条消息,queue002有一条消息。

再严谨的获取一下消息内容进行确认

自此 RabbitTemplate 的 demo演示完毕。

上一篇下一篇

猜你喜欢

热点阅读