rabbitmq可靠性投递_阿里Java研发二面:了解RabbitMQ?说说RabbitMQ可靠性投递

上期写到高并发下RabbitMq消息中间件你应该介么玩今天给小伙伴说说!有自己看法的也可以在评论区留言探讨,也可以转发关注下我以后会长期分享!

目录:确保消息发送到RabbitMQ服务器

确保消息被正确的路由

确保消息在队列正确地存储

确保消息从队列正确地投递到消费者

消费者回调

补偿机制

消息幂等性

消息的顺序性

可靠性投递

首先需要明确,效率和可靠性是无法兼得的,如果要保证每一个环节都成功,势必会对消息的收发效率造成影响,如过是一些业务实时性要求不是特别高的场合,可以牺牲可靠性来换取效率。

①代表消息从生产者发送到Exchange

②代表消息从Exchange路由到Queue

③ 代表消息在Queue中存储;

④ 代表消费者订阅Queue并消费消息。

1.确保消息发送到RabbitMQ服务器

可能因为网络或者Broker的问题导致①失败,而生产者是无法得知消息是否正确发送到Broker的。

有两种解决方案:

第一种是Transaction事务模式

第二种是Confirm确认模式1.在通过channel.txSelect方法开启事务之后,我们便可以发布消息给RabbitMQ了,如果事务提交成功,则消息一定 到达了RabbitMQ中,如果在事务提交执行之前由于RabbitMQ异常崩溃或者其他原因抛出异常,这个时候我们便可以将其捕获,进而通过执行channel.txRollback方法来实现事务回滚。使用事务机制的话会“吸干”RabbitMQ的性 能,一般不建议使用。

2.生产者通过调用channel.confirmSelect方法(即Confirm.Select命令)将信道设置为confirm模式。一旦消息被投递到所有匹配的队列之后,RabbitMQ就会发送一个确认(Basic.Ack)给生产者(包含消息的唯一ID),这就使得生产者知晓消息已经正确到达了目的地了。

2.确保消息被正确的路由

可能因为路由关键字错误,或者队列不存在,或者队列名称错误导致②失败。使用mandatory参数和ReturnListener,可以实现消息无法路由的时候返回给生产者。

另一种方式就是使用备份交换机(alternate-exchange),无法路由的消息会发送到这个交换机上。

Map arguments = new HashMap();

// 指定交换机的备份交换机

arguments.put("alternate-exchange","ALTERNATE_EXCHANGE");

channel.exchangeDeclare("TEST_EXCHANGE","topic", false, false, false, arguments);

3.确保消息在队列正确地存储

可能因为系统宕机、重启、关闭等等情况导致存储在队列的消息丢失,即③出现问题。

解决方案:

1.队列持久化

// String queue, boolean durable, boolean exclusive, boolean autoDelete, Map arguments

channel.queueDeclare(QUEUE_NAME, true, false, false, null);

2.交换机持久化

// String exchange, boolean durable

channel.exchangeDeclare("MY_EXCHANGE","true");

3.消息持久化

AMQP.BasicProperties properties = new AMQP.BasicProperties

.Builder()

// 2代表持久化,其他代表瞬态

.deliveryMode(2)

.build();

channel.basicPublish("", QUEUE_NAME, properties, msg.getBytes());

4.确保消息从队列正确地投递到消费者

如果消费者收到消息后未来得及处理即发生异常,或者处理过程中发生异常,会导致④失败。

为了保证消息从队列可靠性到达消费者,RabbitMQ提供了消息确认机制(message acknowledgement),消费者在订阅队列时,可以指定autoAck参数,当autoAck等于false时,RabbitMQ会等待消费者显示地回复确认消息才从队列中删除该消息。

如果消息消费失败,也可以调用Basic.Reject或者BasicNack来拒绝当前消息而不是确认,如果requere参数为true,可以把这条消息重新存入队列,以便发送给下一个消费者。

5.消费者回调

消费者处理消息之后,可以再发送一条消息给生产者,或者调用生产者地API,告知消息处理完毕。

6.补偿机制

对于一定时间没有响应地消息,可以设置一个定时重发地机制,但是要控制次数,比如最多重复三次,否则会造成消息堆积。

7.消息幂等性

服务端是没有这种控制的,只能在消费端控制。

如何避免消息的重复消费?消息重复消费可能会有两个原因:生产者的问题。环节①重复发送消息,比如在开启Confirm模式但未收到确认

环节④出了问题,由于消费者未发送ACK或者其它原因,消息重复投递

对于重复发送的消息,可以对每一条消息生成一个唯一的业务id,通过日志或者建表来做重复控制。

8.消息的顺序性

消息的顺序性是指消费者消费消息的顺序跟生产者投递消息的顺序是一致的。

在RabbitMQ中,一个队列有多个消费者时,由于不同的消费者消费消息的速度是不一样的,顺序无法保证

学习分享对于高并发下RabbitMq消息中间件的使用,这位大咖也有讲解的视频,在这免费分享给大家,有需要的朋友可以帮忙点个赞关注下吧,分享不易,然后关注我的专栏(Java快速进阶通道)看顶部提示,或直接(点我)领取哦!

视频教学的内容包括:削峰限流、解耦作用

有限资源完成高并发购票

RabbitMq原理透析

购票完整闭环流程

单元测试与多线程高并发测试

不管多忙,每天给自己预留至少半小时的学习时间,拒绝做代码垃圾的搬运工!

有不对的地方可以在评论区留言,觉得不错的朋友希望能得到您的转发支持,同时可以持续关注我,每周定期会分享3到4篇精选干货!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/537041.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

IBM发布Open Liberty 18.0.0.4,支持MicroProfile 2.1和反应性扩展框架

IBM在2018年第四季度发布的Open Liberty 18.0.0.4提供了对MicroProfile 2.1、反应性扩展框架和连接池指标的全面支持。根据发布说明:Open Liberty现在对JAX-RS 2.1进行了反应性扩展,这样你就可以使用来自Apache CXF和Jersey的提供程序。在ops方面&#x…

b700a怎么连蓝牙_233621蓝牙2.1无线音箱B700A小测

随着蓝牙技术的发展,使用蓝牙的相关产品也越来越多,各种蓝牙耳机、蓝牙键盘、蓝牙鼠标都让我们的外设摆脱了线材的束缚。小编之前也介绍过一款便携蓝牙音箱,也评测过一款蓝牙耳机,而今天拿到的是一款采用蓝牙2.1技术,造…

详解:设计模式之-适配器模式

分享一波:程序员赚外快-必看的巅峰干货 简介 在设计模式中,适配器模式有时候也称包装样式或者包装。将一个类的接口转接成用户所期待的。一个适配使得因接口不兼容而不能在一起工作的类工作在一起,做法是将类自己的接口包裹在一个已存在的类中。 分类 …

excel 中编程:vba 入门

2019独角兽企业重金招聘Python工程师标准>>> 1. 打开编程环境: altF11 打开开发环境 注意需要启动宏,不然不能执行自定义的程序,保存后文件的后缀应该是:.xlsm 选择一个 sheet 或一个模块,右键查看代码&…

android 快传 源码_最新安卓仿茄子快传APP源码包括服务端源码Android开发快传类项目源码全套...

适使用范围: 安卓APP茄子快传源码 Android项目源码相似茄子快传的快传项目包括服务端运行环境: Android app源码详细:本项目是一个基于安卓的相似茄子快传的项目源码,包括安卓用户端源码,java的PC用户端和PHP 的web网…

详解:设计模式之-策略设计模式

分享一波:程序员赚外快-必看的巅峰干货 什么是策略模式 定义一系列的算法,并将每一个算法单独进行封装,而且使它们可以相互替换,从而达到传递不同参数而执行不同算法的结果。 策略模式让算法独立于使用它的客户而独立变化 策略模式应用场…

mysql decode语句_MySQL复制问题的分析

s这是学习笔记的第 2031 篇文章最近有个业务的MySQL复制问题还是比较多,做了事务降维之后,把一些敏感操作和线上环境隔离起来,整体的效果好了许多,不过今天在外面的时候,又收到一条报警短信,让我心里咯噔一…

jvm形象简介之一看就懂

分享一波:程序员赚外快-必看的巅峰干货 据 JVM 规范,JVM 内存结构共分为虚拟机栈、堆、方法区、程序计数器、本地方法栈五个部分。这里的java内存结构与前面所述的Java内存模型是两个概念,不可以混淆。 堆 java堆是java虚拟机所管理的内存中最大的一块…

MZOJ 1345 hero

一道宽搜模版题,可写错了两个地方的我只得了56(掩面痛哭) http://10.37.2.111/problem.php?id1345 先看看正确的 #include <bits/stdc.h> #define read read() #define up(i,l,r) for(int i l; i<r; i) using namespace std;int read {int x 0; char ch getchar()…

opencv拖动进度条_OpenCV GUI基本操作,回调函数,进度条,裁剪图像等-阿里云开发者社区...

代码为转载&#xff0c;出处找不到了&#xff0c;不贴了工具条进度条&#xff1a;// ConvertColor.cpp : 定义控制台应用程序的入口点。//#include "stdafx.h"#include #include #include #pragma comment(lib,"opencv_core2410d.lib")#pragma comment(lib…

区间DP初探 P1880 [NOI1995]石子合并

https://www.luogu.org/problemnew/show/P1880 区间dp,顾名思义,是以区间为阶段的一种线性dp的拓展 状态常定义为$f[i][j]$,表示区间[i,j]的某种解; 通常先枚举区间长度,再枚举左端点,最后枚举断点(k) 石子合并便是一道经典的区间dp #include <bits/stdc.h> #define read…

jvm详解 - 新生代与老年代

*************************************优雅的分割线 ********************************** 分享一波:程序员赚外快-必看的巅峰干货 Java 中的堆是 JVM 所管理的最大的一块内存空间&#xff0c;主要用于存放各种类的实例对象。 在 Java 中&#xff0c;堆被划分成两个不同的区…

pymysql建表_Python数据库操作,针对pymysql 和 MYSQL数据库

此文将以MYSQL数据库做为例子,pymysql库作为驱动进行学习安装MYSQL数据库与pymysql第三方库安装pymysql库不多做叙述安装navicat for mysql,此程序用来管理MYSQL数据库注意: 连接过程中可能会出现1251错误解决办法,在cmd命令下登录mysql后输入:ALTER USER rootlocalhost IDENTI…

从0到1使用VUE-CLI3开发实战(五):模块化VUEX及使用vuetify

小肆前几天发了一篇2019年Vue精品开源项目库的汇总&#xff0c;今天小肆要使用的是在UI组件中排行第三的Vuetify。vuetify介绍 Vuetify是一个渐进式的框架&#xff0c;完全根据Material Design规范开发&#xff0c;一共拥有80多个组件&#xff0c;对移动端支持非常好。 支持SSR…

详解垃圾回收算法

分享一波:程序员赚外快-必看的巅峰干货 标记清除算法 概念 该算法有两个阶段。 标记阶段&#xff1a;找到所有可访问的对象&#xff0c;做个标记。 清除阶段&#xff1a;遍历堆&#xff0c;把未被标记的对象回收 缺点&#xff1a;会产生碎片&#xff0c;不够连贯 应用场景…

智能情绪分析技术_石化缘推荐:炼化企业智能机器人巡检技术应用前景分析!...

本期内容由湖南天一奥星泵业有限公司冠名炼化企业智能机器人巡检技术应用前景分析王国彤1,孙秉才2,储胜利2,宋亚敏1(1.中国石油天然气股份有限公司大连石化分公司&#xff0c;辽宁省大连市&#xff1b;2.中国石油集团安全环保技术研究院有限公司&#xff0c;北京市)摘要&#x…

CentOS 7编译程序后的环境变量设置

今晚在 CentOS 7 上配置 Gitea&#xff0c;配置完成后在本地 clone 仓库会提示 Failed to execute git command: exec: "git-upload-pack": executable file not found in $PATH&#xff0c;果断用软连接打法解决。随后在 push 时又出现 Failed to execute git comma…

详解:JVM内存调优参数

分享一波:程序员赚外快-必看的巅峰干货 -Xms JVM启动时申请的初始Heap值&#xff0c;默认为操作系统物理内存的1/64但小于1G。默认当空余堆内存大于70%时&#xff0c;JVM会减小heap的大小到-Xms指定的大小&#xff0c;可通过-XX:MaxHeapFreeRation来指定这个比列。Server端JV…

数组指针 sizeof 实现_C++数组指针!

学习C数组的时候&#xff0c;对数组的了解不是很深。也不知道&#xff0c;为什么声明一个数组&#xff0c;int a[10]&#xff0c;为什么a就是数组的地址。你可以这样理解&#xff0c;将a理解为指向数组头的一个指针&#xff0c;这样就好理解了。理解了之后确实好像豁然开朗的样…

利用人工智能提升团队包容性

在2018年11月举行的Gartner应用技术与解决方案峰会上&#xff0c;高级主管分析师John Kostoulas认为&#xff0c;积极培养包容性文化的团队和团队领导者将超越他们的目标。Kostoulas引用了CEB-Gartner在2016年进行的一项领导力验证调查&#xff0c;他指出&#xff0c;性别多元化…