publisher-confirms ,實現一個監(jiān)聽器用于監(jiān)聽 broker 端給我們返回的確認請求: RabbitTemplate.Conf...
投稿
publisher-confirms ,實現一個監(jiān)聽器用于監(jiān)聽 broker 端給我們返回的確認請求: RabbitTemplate.Conf...
MessageConverter 即消息轉換器 我們在進行發(fā)送消息的時候,正常情況下消息體為二進制的數據方式進行傳輸,如果希望內部幫我們進行轉換...
MessageListenerAdapter 即消息監(jiān)聽適配器 這一節(jié),我們先寫一下代碼,再總結 MessageListenerAdapter ...
SimpleMessageListenerContainer 即簡單消息監(jiān)聽容器。 這個類非常的強大,我們可以對他進行很多的設置,用對于消費者的...
RabbitTemplate 即消息模板 它是在之前于 SpringAMQP 整合的時候進行發(fā)送消息的關鍵類。 它提供了豐富的發(fā)送消息方法,包括...
RabbitAdmin 類可以很好的操作 rabbitMQ,在 Spring 中直接進行注入即可。 RabbitAdmin 類 的底層實現就是從...
死信隊列: DLX,dead-letter-exchange 利用 dlx,當消息在一個隊列中變成死信 (dead message) 之后,它能...
消費端的手工 ACK 和 NACK 消費端進行消費的時候,如果由于業(yè)務異常導致失敗了,返回 NACK 達到最大重試次數,此時我們可以進行日志的記...
假設一個場景,由于我們的消費端突然全部不可用了,導致 rabbitMQ 服務器上有上萬條未處理的消息,這時候如果沒做任何現在,隨便開啟一個消費端...
之前的文章里面,我都是在消費端的代碼里面編寫 while 循環(huán),進行 consumer.nextDelivery 方法進行獲取下一條消息,然后進...