首页 > 其他分享 >RabbitMq

RabbitMq

时间:2023-03-08 09:46:31浏览次数:38  
标签:mandatory 队列 direct RabbitMq topic 消息 设置

消息安全发送策略?

  • 设置mandatory = true参数,添加监听事件
  • 设置备份交换机
  • 事务机制
  • 异步确认机制

设置mandatory = tue

exchange根据自身类型和消息routingKey无法 匹配到合适队列,broker就会调用basic.return 方法 ,将消息通知生产者,否则 设置false ,broker将消息直接丢弃

消息投递路径

生产者 -> Broker -> Exchange -> Queue -> 消费者

spring + rabbit实现方案

  • 开启confirm模式
    • 消息 -> Exchange触发confirmCallback回调
  • 设置回调函数
    • 消息 -> Queue触发returnCallback回调

exchange三种类型fanout direct topic区别?

针对消费者

  • fanout - 不需要配置routerkey 所有队列都可以接收到信息
  • direct - 直连 routerkey需要完全匹配的队列才能接受到数据
  • topic - 模糊匹配路由key 的队列 才会接收到数据

标签:mandatory,队列,direct,RabbitMq,topic,消息,设置
From: https://www.cnblogs.com/tianxiadier/p/17116212.html

相关文章

  • RabbitMQ
    RabbitMQ简介实现了AMQP(高级队列协议)Erlang是面向并发的编程语言,充分利用了CPU的性能,延迟特别低支持多种语言通讯:Java,Python...都有相应的API支持海量......
  • Docker启动RabbitMQ访问15672连接超时解决方法
    docker成功启动rabbitmq后访问15672端口报连接超时原因:rabbitmq默认web界面管理插件是关闭的,需要通过命令开启解决办法:1、查看rabbit的容器id:dockerps2、进入......
  • java——spring boot集成RabbitMQ——高级特效——死信代码示例
    首先,消息成为死信的条件:       首先看消息生产者,生产者和之前的一样,没什么变化(注意:后面统一把nomal改为normal了):          消费......
  • RabbitMQUtils
    自动创建消息队列和队列绑定关系importcom.lubansoft.center.process.task.api.constant.ProcessMQKeys;importcom.lubansoft.center.process.task.api.model.mq.Proc......
  • RabbitMQ入门指南
    1.简介RabbitMQ是采用erlang语言实现AMQP(AdvancedMessageQueuingProtocol,高级消息队列协议)的消息中间件,它最初起源于金融系统,用于在分布式系统中存储转发消息......
  • JMeter安装RabbitMQ测试插件
    整体流程如下:先下载AMQP插件源码,可以通过ant+ivy在本地编译成jar包,再将jar包导入JMeter目录下,重启JMeter生效。ApacheAnt是一个基于Java的构建工具。Ant可用于自动化......
  • .NET6使用RabbitMQ
    什么是RabbitMQ   RabbitMQ(RabbitMessageQueue)是一个开源的,基于AMQP(AdvancedMessageQueuingProtocol)协议的完整的可复用的企业级消息队,RabbitMQ可以实现......
  • rabbitmq管理界面的使用
    有人问,我是开发,页面对我有用么?当然有用额,通过页面可以验证后台配置和预期的效果是否一致。而且页面的可视化,以及操作性比代码更加方便。文章目录​​queue界面​​​......
  • rabbitmq的启动命令和springboot整合使用rabbitmq
    环境:windows安装erlang和rabbitmq的过程这里不多说,记得两个的版本要对应。1.启动rabbitmq:进入sbin目录:其中可能报错:则需要终止已经开始的进程(可能是之前启动过)tasklist|......
  • 121、商城业务---订单服务---rabbitmq消息积压、丢失、重复等解决方案
    ......