位置: IT常识 - 正文

RabbitMQ学习笔记(rabbitmq中文手册)

编辑:rootadmin
RabbitMQ 整合RabbitMQ /** * 使用RabbitMQ * 1、引入ampq场景,RabbitAutoConfiguration 就会自动生效 * 2、给容器中自动配置了 * RabbitTemplate、AmqpAdmin、CachingConnectionFactory、Rab ... RabbitMQ整合RabbitMQ/** * 使用RabbitMQ * 1、引入ampq场景,RabbitAutoConfiguration 就会自动生效 * 2、给容器中自动配置了 * RabbitTemplate、AmqpAdmin、CachingConnectionFactory、RabbitMessagingTemplate * 所有的属性都是在 * @EnableConfigurationProperties(RabbitProperties.class) * @ConfigurationProperties(prefix = "spring.rabbitmq") * public class RabbitProperties * 3、给配置文件中配置 spring.rabbitmq 信息 * 4、@EnableRabbit 开启功能 * 5、监听消息:使用 @RabbitListener,必须有 @EnableRabbit * @RabbitListener:类 + 方法上 * @RabbitHandler: 只能标在方法上 */<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId></dependency># rabbit 配置文件spring.rabbitmq.host=192.168.106.101spring.rabbitmq.port=5672spring.rabbitmq.virtual-host=/

推荐整理分享RabbitMQ学习笔记(rabbitmq中文手册),希望有所帮助,仅作参考,欢迎阅读内容。

RabbitMQ学习笔记(rabbitmq中文手册)

文章相关热门搜索词:rabbitmq入门案例,rabbitmq入门到精通,rabbit mq教程,rabbitmq入门,rabbitmq简书,rabbitmq入门,rabbit mq教程,rabbit mq教程,内容如对您有帮助,希望把文章链接给更多的朋友!

测试

package com.atguigu.gulimall.order;import com.atguigu.gulimall.order.entity.OrderReturnApplyEntity;import lombok.extern.slf4j.Slf4j;import org.junit.Test;import org.junit.runner.RunWith;import org.springframework.amqp.core.AmqpAdmin;import org.springframework.amqp.core.Binding;import org.springframework.amqp.core.DirectExchange;import org.springframework.amqp.core.Queue;import org.springframework.amqp.rabbit.core.RabbitTemplate;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;import org.springframework.test.context.junit4.SpringRunner;import java.util.Date;@Slf4j@RunWith(SpringRunner.class)@SpringBootTestpublic class GulimallOrderApplicationTests { @Autowired AmqpAdmin amqpAdmin; @Autowired RabbitTemplate rabbitTemplate; /** * 1、创建Exchange[hello.java.exchange]、Queue、Binding * - 使用 AmqpAdmin 进行创建 * * 2、如何收发消息 -> RabbitTemplate * 如果发送的消息是个对象,使用序列化机制,将对象写出去,对象实现 Serializable 接口 * 自定义序列化添加配置 * @Configuration * public class MyRabbitConfig { * @Bean * public MessageConverter messageConverter() { * return new Jackson2JsonMessageConverter(); * } * } */ @Test public void sendMessageTest() { String msg = "Hello World"; OrderReturnApplyEntity orderReturnApplyEntity = new OrderReturnApplyEntity(); orderReturnApplyEntity.setId(1L); orderReturnApplyEntity.setSkuName("华为"); orderReturnApplyEntity.setCreateTime(new Date()); rabbitTemplate.convertAndSend("hello.java.exchange", "hello.java", orderReturnApplyEntity); log.info("消息发送完成:{}", orderReturnApplyEntity); } @Test public void createExchange() { //amqpAdmin /** * DirectExchange * public DirectExchange(String name, boolean durable, boolean autoDelete, Map<String, Object> arguments) */ DirectExchange exchange = new DirectExchange("hello.java.exchange", true,false); amqpAdmin.declareExchange(exchange); log.info("Exchange[{}]创建成功", "hello.java.exchange"); } @Test public void createQueue() { /** * public Queue(String name, boolean durable, boolean exclusive, boolean autoDelete) */ Queue queue = new Queue("hello-java-queue", true, false,true); amqpAdmin.declareQueue(queue); log.info("Queue[{}]创建成功", "hello-java-queue"); } @Test public void createBinding() { /** * public Binding(String destination【目的地】, * DestinationType destinationType【目的地类型】, * String exchange【交换机】, * String routingKey【路由键】, * Map<String, Object> arguments)【参数】 * 将 exchange 指定交换机和 destination目的地进行绑定,使用routingKey作为指定路由键 */ Binding binding = new Binding("hello-java-queue", Binding.DestinationType.QUEUE,"hello.java.exchange","hello.java",null); amqpAdmin.declareBinding(binding); log.info("Binding == 创建成功"); }}

测试监听消息

/** * queues:
本文链接地址:https://www.jiuchutong.com/zhishi/309258.html 转载请保留说明!

上一篇:如何禁用WordPress的XML-RPC功能(如何禁用笔记本键盘触摸板)

下一篇:如何打开phpcms网站的数据库配置文件(开启php)

  • 剪映怎么设置成满屏(剪映怎么设置成满屏模式)

    剪映怎么设置成满屏(剪映怎么设置成满屏模式)

  • 小米手机轻敲背部怎么设置(小米手机轻敲背面)

    小米手机轻敲背部怎么设置(小米手机轻敲背面)

  • 苹果11清理运行的软件如何操作(苹果11清理运行内存怎么清理)

    苹果11清理运行的软件如何操作(苹果11清理运行内存怎么清理)

  • 微信订阅号消息怎么关闭(微信订阅号消息看一看关闭不了)

    微信订阅号消息怎么关闭(微信订阅号消息看一看关闭不了)

  • wps老是卡死怎么回事(wps卡死其他都正常)

    wps老是卡死怎么回事(wps卡死其他都正常)

  • raid5后期可增加硬盘吗(raid5后期增加硬盘)

    raid5后期可增加硬盘吗(raid5后期增加硬盘)

  • 老人机有信号打不出去(老人机有信号打不进电话)

    老人机有信号打不出去(老人机有信号打不进电话)

  • 屏幕漏液是怎么造成的(屏幕漏液是怎么导致的)

    屏幕漏液是怎么造成的(屏幕漏液是怎么导致的)

  • 华为双微信在哪里开启(华为手机双微信在哪里设置)

    华为双微信在哪里开启(华为手机双微信在哪里设置)

  • 显示非好友却能发消息(显示非好友却能发信息)

    显示非好友却能发消息(显示非好友却能发信息)

  • 优酷会员开通后可以取消退费吗(优酷会员开通后怎么取消自动续费)

    优酷会员开通后可以取消退费吗(优酷会员开通后怎么取消自动续费)

  • ipad微信已登录是什么意思(iPad微信已登录,但是设备是离线状态)

    ipad微信已登录是什么意思(iPad微信已登录,但是设备是离线状态)

  • 小米商城退款多久能到(小米商城退款多久能回到银行卡)

    小米商城退款多久能到(小米商城退款多久能回到银行卡)

  • 大数据的核心能力是什么(大数据的核心技术是什么)

    大数据的核心能力是什么(大数据的核心技术是什么)

  • xsmax充电多久(xsmax充满电多久)

    xsmax充电多久(xsmax充满电多久)

  • 手机卡成空号了怎么办(手机卡成空号了交话费进去可以用吗?)

    手机卡成空号了怎么办(手机卡成空号了交话费进去可以用吗?)

  • 华为yalal10是什么手机(yalal10是华为什么型号手机)

    华为yalal10是什么手机(yalal10是华为什么型号手机)

  • 拼多多视频怎么上传(拼多多视频怎么下载)

    拼多多视频怎么上传(拼多多视频怎么下载)

  • 微星主板显卡插哪个槽(微星主板显卡插槽)

    微星主板显卡插哪个槽(微星主板显卡插槽)

  • vivox9puls有没有nfc功能(vivox9splus有nfc)

    vivox9puls有没有nfc功能(vivox9splus有nfc)

  • 扒一扒抖音是如何做线程优化的(抖音是如何成功的)

    扒一扒抖音是如何做线程优化的(抖音是如何成功的)

  • vue开发环境搭建及配置(windows)(vue环境搭建的几种方法)

    vue开发环境搭建及配置(windows)(vue环境搭建的几种方法)

  • phpcms跟帝国cms区别是什么(帝国cms和thinkphp哪个好)

    phpcms跟帝国cms区别是什么(帝国cms和thinkphp哪个好)

  • 简易征收怎样计提增值税
  • 建筑业如何分项目核算
  • 印花税计提缴纳的会计分录
  • 房产税的计税依据包含增值税吗
  • 如何计提当月的个人所得税?
  • 小额支出没有发票怎么做账
  • 住宿费收据属于什么凭证
  • 百旺税控盘自己用不了
  • 发票第一联需要保存多久
  • 固定资产盘亏计入什么科目
  • 账面现金可以转出吗
  • 增值税减免所得税填在哪一栏
  • 科目错一题扣几分
  • 发票服务名称都有什么
  • 怎么在网上申请电话卡
  • 普通折叠发票代码是几位数
  • 工会经费免征三年需要申报吗
  • 房地产企业借款费用
  • 盈余公积可以随便用吗
  • 香港公司在大陆设立子公司
  • 以前年度发生的费用
  • 食品发票需要清关吗
  • 出口退免税是什么意思
  • 职工教育经费怎么做账
  • 车改补贴是否计入工资总额
  • 土地的增值税进项能否抵扣
  • 单位转让专利技巧和方法
  • 销售商品货款已预收
  • 税务登记都需要什么
  • 发票的开具时效为
  • 入住酒店报销
  • 出售汽车属于什么费用
  • 携程只有电子发票吗
  • 库存商品在贷方怎么调回借方
  • 公司购买的原材料,原价格销售合理吗
  • 赡养老人个税扣除标准和条件是什么
  • 质押的应收票据怎么做账
  • 污水处理费该谁交
  • 单位购买金税盘的分录
  • 重庆四日游最佳攻略超详细
  • 累计折旧额怎么计算公式
  • 对于在某一时点履行义务,企业应当在
  • PHP:mcrypt_cfb()的用法_Mcrypt函数
  • 前端请求方式
  • 【第十一届“泰迪杯”数据挖掘挑战赛】B题产品订单的数据分析与需求预测“解题思路“”以及“代码分享”
  • 税率变更为13%的文件
  • thinkphp自定义标签page
  • Win11 Build 23435 预览版今日发布: 文件管理器引入图库功能
  • postman 下载
  • golang和php
  • thinkphp apidoc
  • ajax获取php数据
  • 物流公司主营业务怎么写
  • 赠品怎么做
  • 小规模纳税人工资薪金怎么申报
  • 负债类科目的余额方向为借方 不考虑双向等例外情况
  • 建筑公司计提企税怎么算
  • sql server 2008怎么使用sql语句
  • 存货的期末余额是账面余额吗
  • 销售自己使用过的固定资产
  • 离职补偿金的计算基数
  • 税控盘减免税款月末不用交税还要结转吗
  • 企业在期间新购进的设备、器具
  • 营业执照类型有限责任公司(自然人独资)是什么行业类别
  • 资产季末值
  • 发票以外的其他发票
  • sqlserver数据库怎么导出
  • gridview自定义排序
  • Windows7设置默认打印机
  • 重装网卡驱动win11
  • jquery的实现原理
  • jquery移动div到另一个div中
  • 在html中写入javascript
  • 江苏省高新区地图
  • 国家税务总局通知公告
  • 如何建立守信联系
  • 税务系统怎么修改办税人
  • 如何查询车辆购置税
  • 韩国税务怎么算收入
  • 独立的法人企业
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设