目錄

?

?

基本概念

代碼與實例

---

?

基本概念

異步模式：Channel對象提供的ConfirmListener()回調(diào)方法只包含deliverTag(當(dāng)前Channel發(fā)出的消息序列號)，需要自己為每一個Channel維護一個cunconfirm的消息序列號集合，每個publish數(shù)據(jù)，集合中元素+1，回調(diào)一次handleAck方法，unconfirm集合刪除相應(yīng)的一條（multiple=false）或多條（multiple=true）記錄。從程序效率上看，這個unconfirm集合最好采用有序集合SortedSet存儲結(jié)構(gòu)

?

代碼與實例

程序運行截圖如下：

源碼如下：

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);//生產(chǎn)者調(diào)用confirmSelect 將 channel 設(shè)置為 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 回執(zhí)有問題的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);}} }

?

?

總結(jié)

以上是生活随笔為你收集整理的Java笔记-RabbitMQ中生产者端confirm模式(异步模式)的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。