RabbitMQ实战 - Confirm机制
1 什么是Confirm机制
- 消息的确认
Pro投递消息后,若Broker收到消息,则会给Pro一个应答 - Pro接收应答
用来确定该消息是否正常地发送到Broker,这种方式也是消息可靠性投递的核心保障
2 Confirm机制流程图
Pro发送消息到Broker,Broker接收到消息后,产生回送响应
Pro中有一个Confirm Listener异步监听响应应答
3 如何实现Confirm确认消息?
- 在channel上开启确认模式:
channel.confirmSelect()
- 在channel上添加监听:
addConfirmListener
,监听成功和失败的返回结果,根据具体的结果对消息进行重新发送、或记录日志等后续处理
4 代码实战
Con
Pro
检验 server 是否启动
lsof -i:5672
启动Con,检查管控台
启动Pro
RabbitMQ实战 - Confirm机制相关推荐
- RabbitMQ的confirm机制
目录 前言 一.confirm机制的选择 二.异步confirm设计. 第一个问题:我们要支持重试,所以我们必须想一个办法,在发送之前把消息save起来,当监听到ACK后,在把对应的消息remove掉 ...
- 《RabbitMQ 实战指南》第五章 RabbitMQ 进阶(下)
<RabbitMQ 实战指南>第五章 RabbitMQ 进阶(下) 文章目录 <RabbitMQ 实战指南>第五章 RabbitMQ 进阶(下) 一.持久化 二.生产者确认 1 ...
- 《RabbitMQ 实战指南》第三章 客户端开发向导
<RabbitMQ 实战指南> 文章目录 <RabbitMQ 实战指南> 一.简介 二.连接 RabbitMQ 三.使用交换器和队列 1.exchangeDeclare 方法详 ...
- RabbitMQ实战教程
RabbitMQ实战教程 1.什么是RabbitMQ 1.1 MQ(Message Queue)消息队列 1.1.1 异步处理 1.1.2 应用解耦 1.1.3 流量削峰 1.2 背景知识介绍 1.2 ...
- RabbitMQ实战笔记
RabbitMQ实战笔记 1 MQ引言 1.1 中间件技术及架构的概述 1.2 什么是MQ 1.3 为什么要用MQ 1.4 MQ的分类 1.5 MQ的选择 2 RabbitMQ 的引言 2.1 Rab ...
- rabbitmq实战指南_RabbitMQ之脑裂
点击上方蓝色字体,选择"设为星标" 9 10 本文总结<RabbitMQ实战指南>网络分区章节,并亲自实践才有这篇文章,手动处理章节详细记录了操作过程中的注意事项.如果 ...
- RabbitMQ消息确认机制
文章目录 1. 事务机制 2. Confirm模式 2.1 生产者 2.1.1 普通Confirm模式 2.1.2 批量Confirm模式 2.1.3 异步Confirm模式 2.2 消费者 3. 其 ...
- RabbitMQ实战经验分享
RabbitMQ实战经验分享 原文:RabbitMQ实战经验分享 前言 最近在忙一个高考项目,看着系统顺利完成了这次高考,终于可以松口气了.看到那些即将参加高考的学生,也想起当年高三的自己. 下面分享 ...
- 《RabbitMQ 实战指南》第二章 RabbitMQ 入门
<RabbitMQ 实战指南> 文章目录 <RabbitMQ 实战指南> 一.相关概念介绍 1.生产者和消费者 2.队列 3.交换器.路由键.绑定 4.交换器类型 5.Rabb ...
最新文章
- python_redis模块
- AopContext.currentProxy();为什么能获取到代理对象
- mysql查询当前库的实例名_oracle查询数据库名、实例名等
- 认识Linux系统服务(鸟哥18章)
- android Handler UI线程后台线程通信
- Eclipse中的SVN插件
- app具体介绍界面-01
- 余贞侠C语言程序设计课后参考答案
- 互亿无线5G视频短信
- 图像处理的边缘和纹理的区别
- 构造函数中慎用memset
- 用C语言实现求水仙花数
- 中职高二学生计算机学情分析,高二学生学习数学的学情分析.doc
- 第 l 个数到第 r 个数的和
- 人力资源管理系统如何促进业务增长
- ant man什么意思_ant是什么意思_ant翻译_读音_用法_翻译
- 微信h5隐藏导航栏和状态栏_导航栏未在SwiftUI中隐藏
- theano及cuda环境搭建
- IOT物联网商业源码完整版下载附搭建教程
- android native层进程通信
热门文章
- plt.scatter 中cmap参数详解
- python 梯度下降法实现一元线性回归
- 基于javaweb仓库理系统设计与实现进销存管理.rar(论文+毕业设计+源码+答辩PPT)
- Zoomla!逐浪CMS高端全栈训练营—开始报名啦
- 《周易》六十四卦歌诀
- 快手__nsTokensig和sig签名
- 如何在MacOS上卸载IPGuard的软件--LAgent/LSDhelper程序
- :before和::before是什么区别
- Java工具类库Hutool,GitHub星标15k+
- iOS基础——通过案例学知识之UITableView