publisher-confirms ,實(shí)現(xiàn)一個(gè)監(jiān)聽器用于監(jiān)聽 broker 端給我們返回的確認(rèn)請(qǐng)求: RabbitTemplate.Conf...
MessageConverter 即消息轉(zhuǎn)換器 我們在進(jìn)行發(fā)送消息的時(shí)候,正常情況下消息體為二進(jìn)制的數(shù)據(jù)方式進(jìn)行傳輸,如果希望內(nèi)部幫我們進(jìn)行轉(zhuǎn)換...
MessageListenerAdapter 即消息監(jiān)聽適配器 這一節(jié),我們先寫一下代碼,再總結(jié) MessageListenerAdapter ...
SimpleMessageListenerContainer 即簡單消息監(jiān)聽容器。 這個(gè)類非常的強(qiáng)大,我們可以對(duì)他進(jìn)行很多的設(shè)置,用對(duì)于消費(fèi)者的...
RabbitTemplate 即消息模板 它是在之前于 SpringAMQP 整合的時(shí)候進(jìn)行發(fā)送消息的關(guān)鍵類。 它提供了豐富的發(fā)送消息方法,包括...
RabbitAdmin 類可以很好的操作 rabbitMQ,在 Spring 中直接進(jìn)行注入即可。 RabbitAdmin 類 的底層實(shí)現(xiàn)就是從...
死信隊(duì)列: DLX,dead-letter-exchange 利用 dlx,當(dāng)消息在一個(gè)隊(duì)列中變成死信 (dead message) 之后,它能...
提前說一下,這一小節(jié)不涉及代碼演示,都是在管控臺(tái)操作。 TTL消息TTL 是 time to live 的縮寫,也就是生存時(shí)間。rabbitMQ...
消費(fèi)端的手工 ACK 和 NACK 消費(fèi)端進(jìn)行消費(fèi)的時(shí)候,如果由于業(yè)務(wù)異常導(dǎo)致失敗了,返回 NACK 達(dá)到最大重試次數(shù),此時(shí)我們可以進(jìn)行日志的記...