publisher-confirms ，實現一個監(jiān)聽器用于監(jiān)聽 broker 端給我們返回的確認請求： RabbitTemplate.Conf...
投稿
收錄了2篇文章 · 3人關注
-
RabbitMQ 與 SpringBoot2.X 整合
-
SpringAMQP 消息轉換器 - MessageConverter
MessageConverter 即消息轉換器 我們在進行發(fā)送消息的時候，正常情況下消息體為二進制的數據方式進行傳輸，如果希望內部幫我們進行轉換...
-
SpringAMQP 消息適配器 - MessageListenerAdapter
MessageListenerAdapter 即消息監(jiān)聽適配器 這一節(jié)，我們先寫一下代碼，再總結 MessageListenerAdapter ...
-
SpringAMQP 消息容器 - SimpleMessageListenerContainer
SimpleMessageListenerContainer 即簡單消息監(jiān)聽容器。 這個類非常的強大，我們可以對他進行很多的設置，用對于消費者的...
-
SpringAMQP 之 RabbitTemplate
RabbitTemplate 即消息模板 它是在之前于 SpringAMQP 整合的時候進行發(fā)送消息的關鍵類。 它提供了豐富的發(fā)送消息方法，包括...
-
SpringAMQP 用戶管理組件 RabbitAdmin 以及聲明式配置
RabbitAdmin 類可以很好的操作 rabbitMQ，在 Spring 中直接進行注入即可。 RabbitAdmin 類 的底層實現就是從...
-
rabbitmq 死信隊列
死信隊列: DLX，dead-letter-exchange 利用 dlx，當消息在一個隊列中變成死信 (dead message) 之后，它能...
-
RabbitMQ 消費端 ACK 與重回隊列機制
消費端的手工 ACK 和 NACK 消費端進行消費的時候，如果由于業(yè)務異常導致失敗了，返回 NACK 達到最大重試次數，此時我們可以進行日志的記...
-
RabbitMQ 消費端的限流策略
假設一個場景，由于我們的消費端突然全部不可用了，導致 rabbitMQ 服務器上有上萬條未處理的消息，這時候如果沒做任何現在，隨便開啟一個消費端...
-
RabbitMQ 的自定義消費者使用
之前的文章里面，我都是在消費端的代碼里面編寫 while 循環(huán)，進行 consumer.nextDelivery 方法進行獲取下一條消息，然后進...
{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1881139527',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','https://upload.jianshu.io/collections/images/1649119/5.png', '推薦專題《rabbitmq》（ 分享自 @簡書 ）','http://m.itdecent.cn/c/e7c10a5e22eb?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認gb2312'));){kind=link}