温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

rabbitMQ系列高级整合应用rabbitTemplate

发布时间:2020-08-06 00:52:31 来源:网络 阅读:705 作者:凯哥Java 栏目:编程语言

RabbitMQ整合spring之消息模板-RabbitTemplate

RabbitTemplate:消息模板。这是spring整合rabbit提供的消息模板。是进行发送消息的关键类。

本文有凯哥Java(kaigejava)发布

功能:

该类提供了丰富的发送方法,包括可靠性投递消息方法、回调监听消息接口ConfirmCallback、返回值确认接口ReturnCallBack等等。同样我们需要注入到spring容器中,然后就可以想其他bean那样正常使用了。

代码示例:

1:在RabbitMQConfig类中添加rabbitTemplate声明:

/**
声明rabbitTemplate
@param connectionFactory
@return
*/
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory){
   RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
   return  rabbitTemplate;
}



rabbitMQ系列高级整合应用rabbitTemplate

这样之后,template就被spring 容器管理了。在使用的时候,直接autoWried即可.

在测试类中:

rabbitMQ系列高级整合应用rabbitTemplate

启动测试类,在管控台中查看queue接收到的消息:

rabbitMQ系列高级整合应用rabbitTemplate

我们看到,queue001里面有一条消息。

在页面管控台,找到对应的queue。我们这里使用的是queue001.点进去查看:

rabbitMQ系列高级整合应用rabbitTemplate

可以看到get messages如上图。点击get Messages按钮,我们就会获取到。

rabbitMQ系列高级整合应用rabbitTemplate

我们可以看到,headers中的数据。Attr这个是我们额外添加的。也被接收到了。

说明,我们消息模板简单使用已经成功了。

本文是《rabbitMq精讲系列》教程中的:rabbitMQ精讲系列第二十篇 高级整合应用第三篇 rabbitTemplate对象。系列教程,建议从第一篇看起。

凯哥个人博客:www.kaigejava.com

原文出处:http://kaigejava.com/article/detail/534


下节预告:SimpleMessageListenerContainer



向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI