目錄

?

?

基本概念

代碼與實(shí)例

---

?

基本概念

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

?

代碼與實(shí)例

程序運(yùn)行截圖如下：

源碼如下：

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();//未確認(rèn)的標(biāo)識(shí)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)容還不錯(cuò)，歡迎將生活随笔推薦給好友。