基本概念

异步模式：Channel对象提供的ConfirmListener()回调方法只包含deliverTag(当前Channel发出的消息序列号)，需要自己为每一个Channel维护一个cunconfirm的消息序列号集合，每个publish数据，集合中元素+1，回调一次handleAck方法，unconfirm集合删除相应的一条（multiple=false）或多条（multiple=true）记录。从程序效率上看，这个unconfirm集合最好采用有序集合SortedSet存储结构

代码与实例

程序运行截图如下：

源码如下：

package tx;import com.rabbitmq.client.Channel;
import com.rabbitmq.client.ConfirmListener;
import com.rabbitmq.client.Connection;
import util.ConnectionUtils;import java.io.IOException;
import java.util.Collections;
import java.util.SortedSet;
import java.util.TreeSet;
import java.util.concurrent.TimeoutException;public class TxSend {private static final String QUEUE_NAME = "test_queue_confirm3";public static void main(String[] args) throws IOException, TimeoutException, InterruptedException {Connection connection = ConnectionUtils.getConnect();Channel channel = connection.createChannel();channel.queueDeclare(QUEUE_NAME, false, false, false, null);//生产者调用confirmSelect 将 channel 设置为 confirm 模式channel.confirmSelect();//未确认的标识final SortedSet<Long> confirmSet = Collections.synchronizedSortedSet(new TreeSet<Long>());channel.addConfirmListener(new ConfirmListener() {//ACKpublic void handleAck(long l, boolean b) throws IOException {if(b){System.out.println("> handleAck multiple!");    //多条confirmSet.headSet(l + 1).clear();}else{System.out.println("> handleAck multiple false!");  //单条confirmSet.remove(l);}}//Nack 回执有问题的public void handleNack(long l, boolean b) throws IOException {if(b){System.out.println("> handleNack multiple!");   //多条confirmSet.headSet(l + 1).clear();}else{System.out.println("> handleNack multiple false!"); //单条confirmSet.remove(l);}}});String msgStr = "Hello World!";while (true){long seqNo = channel.getNextPublishSeqNo();channel.basicPublish("", QUEUE_NAME, null, msgStr.getBytes());confirmSet.add(seqNo);}}
}

Java笔记-RabbitMQ中生产者端confirm模式(异步模式)相关推荐

Java笔记-RabbitMQ中生产者端confirm模式
目录基本概念代码与实例基本概念生产者将信号设置成confirm模式,一旦信道进入confirm模式,将有在该信道上面发布的消息都会被指派一个唯一的ID(从1开始),一旦消息被投递到所有匹配的队 ...
Java笔记(学习中。。)
Java笔记 eclipse的使用常用的dos指令预备知识基本语法变量关于字符型关于String 进制转换运算符流程控制数组数组的内存解析: 数组的Arrays工具类面向对象对 ...
Java笔记-RabbitMQ的消息确认机制（事务）
目录基本概念代码与实例基本概念消息应答与消息持久化,如下代码: boolean autoAck = false; channel.basicConsume(QUEUE_NAME, autoAc ...
Spring Boot工作笔记-RabbitMQ中Unsupported major.minor version 52.0问题
目录错误演示解决方法错误演示字符串如下: java.lang.UnsupportedClassVersionError: com/rabbitmq/client/ConnectionFacto ...
Java笔记-Spring中RabbitMQ的调用
目录基本概念代码与演示基本概念 Spring中已经整合了RabbitMQ,通过配置bean文件,然后在源码中加载,可以简化代码操作. 身为C++程序员不得不说这种方式真的是太爽了. 在本人做过的 ...
Java笔记-spring-rabbitmq中queue设置argument（添加x-message-ttl）
最近在读Spring的官方文档,在此记录下自己做的小实验. 这里主要是在生产者中声明和添加: @BeanQueue queue(){Queue queue = new Queue(queueName, ...
java 舍_Java中BigDecimal的8种舍入模式
java.math.BigDecimal 不可变的.任意精度的有符号十进制数.BigDecimal 由任意精度的整数非标度值和32位的整数标度(scale)组成. 如果为零或正数,则标度是小数点后的位 ...
rabbitmq中的三种交换器(匹配模式)
direct(直接交换模式) 消息中的路由键(routing key)如果和Binding中的binding key一致,交换器就将消息发到对应的队列中.它是完全匹配,单播的模式. fanout(广播 ...
Java笔记-spring-rabbitmq中使用@RabbitListener消费（手动确认，获header数据）
手动确认时: application.properties需要添加 spring.rabbitmq.listener.simple.acknowledge-mode=manual 确认ack chan ...

Java笔记-RabbitMQ中生产者端confirm模式(异步模式)

基本概念

代码与实例

Java笔记-RabbitMQ中生产者端confirm模式(异步模式)相关推荐

最新文章

热门文章