前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >rabbitMQ系列高级整合应用rabbitTemplate

rabbitMQ系列高级整合应用rabbitTemplate

原创
作者头像
凯哥Java
修改2019-08-08 10:27:51
1.1K0
修改2019-08-08 10:27:51
举报
文章被收录于专栏:凯哥Java凯哥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;}

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

在测试类中:

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

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

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

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

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

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

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

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

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

下节预告:SimpleMessageListenerContainer

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
容器服务
腾讯云容器服务(Tencent Kubernetes Engine, TKE)基于原生 kubernetes 提供以容器为核心的、高度可扩展的高性能容器管理服务,覆盖 Serverless、边缘计算、分布式云等多种业务部署场景,业内首创单个集群兼容多种计算节点的容器资源管理模式。同时产品作为云原生 Finops 领先布道者,主导开源项目Crane,全面助力客户实现资源优化、成本控制。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档