消息confirm机制

前言：我们在消息生产端的可靠性投递方案中的方案一，producer就是通过消息confirm机制来确保消息能能投递到MQ(或者说是exchange)如果失败话做重投。

confirm机制：message 从 producer 成功投递到 rabbitmq broker cluster 则会返回一个 confirmCallback

tips:confirm机制只保证消息达到exchange,不保证消息到达queue

三种confirm方式：

普通confirm模式：每发送一条消息后，调用waitForConfirms()方法，等待服务器端confirm。实际上是一种串行confirm了。
批量confirm模式：每发送一批消息后，调用waitForConfirms()方法，等待服务器端confirm。
异步confirm模式：提供一个回调方法，服务端confirm了一条或者多条消息后Client端会回调这个方法。

实现异步监听的消息的confirm:

在channel上开启确认模式：channel.confirmSelect()
在channel上添加监听：addConfirmListener,监听成功和失败的返回结果（实际业务中就可以根据结果对详细进行重发、记录日志等）

测试代码：

不需要消费者，直接在生产端声明队列，交换机做测试就好

package com.vivo.demo1.confirm;import com.rabbitmq.client.*;import java.io.IOException;
import java.util.concurrent.TimeoutException;/*** @author:luzaichun* @Date:2020/12/20* @Time:22:39**/
public class Producer {public static void main(String[] args) throws IOException, TimeoutException {ConnectionFactory factory = new ConnectionFactory();factory.setHost("192.168.3.7");factory.setPort(5672);factory.setVirtualHost("/");Connection connection = factory.newConnection();Channel channel = connection.createChannel();//开启确认模式channel.confirmSelect();channel.exchangeDeclare("confirm_exchange","topic",false,false,null);channel.queueDeclare("confirm_queue",false,false,false,null);channel.queueBind("confirm_queue","confirm_exchange","topic.#");channel.basicPublish("confirm_exchange","topic.confirm",null,"测试消息确认机制".getBytes());channel.addConfirmListener(new ConfirmListener() {//只要是[交换机]确认收到了消息就会回调ConfirmListener的handleAck方法。(即使交换机没有正确路由到队列中)@Overridepublic void handleAck(long deliveryTag, boolean multiple) throws IOException {System.out.println("ack...消息投递成功");}//只要是[交换机]没有确认收到了消息就会回调ConfirmListener的handleNack方法。@Overridepublic void handleNack(long deliveryTag, boolean multiple) throws IOException {System.out.println("nack。。。消息投递失败，例如队列满了");}});}}

启动生产者可以看到控制台，回调成功。然后我们观察控制台发现消息已经到达confirm_queue队列，消息投递成功。

消息confirm机制相关推荐

RabbitMQ之消息确认机制（事务+Confirm）
概述在使用RabbitMQ的时候,我们可以通过消息持久化操作来解决因为服务器的异常奔溃导致的消息丢失,除此之外我们还会遇到一个问题,当消息的发布者在将消息发送出去之后,消息到底有没有正确到达brok ...
springboot + rabbitmq 用了消息确认机制，感觉掉坑里了
最近部门号召大伙多组织一些技术分享会,说是要活跃公司的技术氛围,但早就看穿一切的我知道,这 T M 就是为了刷KPI.不过,话说回来这的确是件好事,与其开那些没味的扯皮会,多做技术交流还是很有助于个人 ...
java确认rabbitmq_RabbitMQ 消息确认机制
生产端 Confirm 消息确认机制消息的确认,是指生产者投递消息后,如果 Broker 收到消息,则会给我们生产者一个应答.生产者进行接收应答,用来确定这条消息是否正常的发送到 Broker ,这 ...
RabbitMQ消息确认机制
文章目录 1. 事务机制 2. Confirm模式 2.1 生产者 2.1.1 普通Confirm模式 2.1.2 批量Confirm模式 2.1.3 异步Confirm模式 2.2 消费者 3. 其 ...
RabbitMQ消息确认机制和消息重发机制
一.机制首先我们要知道一条消息的传递过程. 生产者 -> 交换机 -> 队列我们的生产者生产消息,生产完成的消息发送到交换机,由交换机去把这个消息转发到对应的队列上.这其中我们可能在 ...
RabbitMQ消息确认机制-可靠抵达
消息发送到被消费的流程: JAVA的生产端的发送数据----->Broker(消息服务器)-------->达到Exchange交换机------------->通过路由键到达Que ...
RabbitMQ学习笔记（四）-消息确认机制
引入在使用 RabbitMQ 的时候,作为消息发送方希望杜绝任何消息丢失或者投递失败场景.RabbitMQ 为我们提供了两种方式用来控制消息的投递可靠性模式. confirm 确认模式 return ...
RabbitMQ实战 - Confirm机制
1 什么是Confirm机制消息的确认 Pro投递消息后,若Broker收到消息,则会给Pro一个应答 Pro接收应答用来确定该消息是否正常地发送到Broker,这种方式也是消息可靠性投递的核心保 ...
RabbitMQ之订阅模式与主题模式，消息确认机制
1.订阅模式作用类似与微信公众号,你订阅了就可以接收到消息解读: 1.一个生产者,多个消费者. 2.每一个消费者都有自己的队列 3.生产者没有直搂把洧息发送到队列而是发到了交换机转发器exch ...

消息confirm机制

三种confirm方式：

实现异步监听的消息的confirm:

测试代码：

消息confirm机制相关推荐

最新文章

热门文章