Spring 中 @RabbitListener 背后的交互流程

在 Spring 框架中使用 @RabbitListener時,其背后與 RMQ 服務(wù)的交互流程如下:

  1. 連接建立:
    當(dāng)應(yīng)用啟動時株茶,Spring AMQP 自動配置(Auto Configuration)機(jī)制會根據(jù)配置創(chuàng)建一個連接工廠(Connection Factory)母剥,并與 RabbitMQ 服務(wù)器建立連接锹漱。從 RMQ 服務(wù)的視角看玉罐,就是建立了一個 Connection蒿褂。

  2. 注冊消費(fèi)者&訂閱

  • Spring 應(yīng)用啟動時,掃描帶有 @RabbitListener 注解的方法蒋畜;
  • Spring AMQP 為每個注解的方法注冊一個或多個消費(fèi)者(默認(rèn) 1 個声畏,可以通過注解的 concurrency參數(shù)配置多個消費(fèi)者);
  • SimpleMessageListenerContainer 在內(nèi)部創(chuàng)建相應(yīng)數(shù)量的消費(fèi)者線程姻成;
  • 這些消費(fèi)者線程在啟動時插龄,會從 ConnectionFactory 獲取 Channel,通過 Channel 向 RabbitMQ 服務(wù)發(fā)送 Basic Consume 命令科展,這一操作告訴 RabbitMQ 服務(wù)均牢,這些消費(fèi)者線程訂閱了指定的隊列,并準(zhǔn)備接收消息才睹;
  • 此時 RabbitMQ 服務(wù)視角正式得知這些消費(fèi)者的存在徘跪,每個消費(fèi)者對應(yīng)一個 Channel
  1. 消息獲壬笆(Message Fetching):
  • RabbitMQ 將消息推送(push)給消費(fèi)者真椿,消費(fèi)者通過 basicDeliver方法接收消息。這是一個被動的過程乎澄,消費(fèi)者等待消息被推送突硝,而不是主動拉取。

basicDeliver方法是 RabbitMQ 客戶端庫(如 Java 中的 amqp-client 庫)用來處理服務(wù)器推送消息的一個回調(diào)方法置济。

  1. 消息處理:
    一旦消息被推送到消費(fèi)者解恰,Spring 最終會調(diào)用相應(yīng)的 @RabbitListener 注解的方法來處理消息,例如:
@RabbitListener(queues = "yourQueueName")
public void handleMessage(String message) {
    // 處理消息的邏輯
    System.out.println("Received message: " + message);
}

Spring AMQP 框架實(shí)現(xiàn)了一個 ChannelAwareMessageListener浙于,它內(nèi)部處理 basicDeliver 方法护盈,并將消息傳遞給相應(yīng)的 @RabbitListener 注解的方法。

在默認(rèn)的自動確認(rèn)模式下(auto-acknowledge)羞酗,Spring 會在 @RabbitListener 方法成功返回后自動確認(rèn)消息腐宋。

你可能會困惑:誒?RMQ 的自動確認(rèn)模式不是不需要客戶端返回 ACK 嗎檀轨?
注意:這里說的自動確認(rèn)模式胸竞,指的是 Spring 框架定義的確認(rèn)模式(參考:org.springframework.amqp.core.AcknowledgeMode 枚舉類),需要將其與 RMQ 的 ACK 模式進(jìn)行區(qū)分参萄。
Spring 中確認(rèn)模式的自動確認(rèn)(AUTO)對應(yīng)到 RMQ 的 ACK 模式其實(shí)是手工確認(rèn)模式(Manual Ack),只是 Spring 框架會在 @RabbitListener 方法成功返回后自動調(diào)用 ACK 方法給 RMQ 服務(wù)發(fā)送消息確認(rèn)卫枝。
RMQ ACK 模式 中的 Auto Ack 對應(yīng)到 Spring 框架的確認(rèn)模式是 NONE —— 無需確認(rèn)。
更多關(guān)于消息確認(rèn)模式的內(nèi)容讹挎,可以閱讀:RMQ 的 autoACK 自動消息確認(rèn)是什么校赤?

如果配置了手動確認(rèn)模式吆玖,開發(fā)者需要顯式地調(diào)用確認(rèn)方法,如 basicAckbasicNack马篮。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末沾乘,一起剝皮案震驚了整個濱河市,隨后出現(xiàn)的幾起案子积蔚,更是在濱河造成了極大的恐慌意鲸,老刑警劉巖烦周,帶你破解...
    沈念sama閱讀 223,002評論 6 519
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件尽爆,死亡現(xiàn)場離奇詭異,居然都是意外死亡读慎,警方通過查閱死者的電腦和手機(jī)漱贱,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,357評論 3 400
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來夭委,“玉大人幅狮,你說我怎么就攤上這事≈昃模” “怎么了崇摄?”我有些...
    開封第一講書人閱讀 169,787評論 0 365
  • 文/不壞的土叔 我叫張陵,是天一觀的道長慌烧。 經(jīng)常有香客問我逐抑,道長,這世上最難降的妖魔是什么屹蚊? 我笑而不...
    開封第一講書人閱讀 60,237評論 1 300
  • 正文 為了忘掉前任厕氨,我火速辦了婚禮,結(jié)果婚禮上汹粤,老公的妹妹穿的比我還像新娘命斧。我一直安慰自己,他們只是感情好嘱兼,可當(dāng)我...
    茶點(diǎn)故事閱讀 69,237評論 6 398
  • 文/花漫 我一把揭開白布国葬。 她就那樣靜靜地躺著,像睡著了一般芹壕。 火紅的嫁衣襯著肌膚如雪汇四。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 52,821評論 1 314
  • 那天哪雕,我揣著相機(jī)與錄音船殉,去河邊找鬼。 笑死斯嚎,一個胖子當(dāng)著我的面吹牛利虫,可吹牛的內(nèi)容都是我干的挨厚。 我是一名探鬼主播,決...
    沈念sama閱讀 41,236評論 3 424
  • 文/蒼蘭香墨 我猛地睜開眼糠惫,長吁一口氣:“原來是場噩夢啊……” “哼疫剃!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起硼讽,我...
    開封第一講書人閱讀 40,196評論 0 277
  • 序言:老撾萬榮一對情侶失蹤巢价,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后固阁,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體壤躲,經(jīng)...
    沈念sama閱讀 46,716評論 1 320
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 38,794評論 3 343
  • 正文 我和宋清朗相戀三年备燃,在試婚紗的時候發(fā)現(xiàn)自己被綠了碉克。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 40,928評論 1 353
  • 序言:一個原本活蹦亂跳的男人離奇死亡并齐,死狀恐怖漏麦,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情况褪,我是刑警寧澤撕贞,帶...
    沈念sama閱讀 36,583評論 5 351
  • 正文 年R本政府宣布,位于F島的核電站测垛,受9級特大地震影響捏膨,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜赐纱,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 42,264評論 3 336
  • 文/蒙蒙 一脊奋、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧疙描,春花似錦诚隙、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,755評論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至效五,卻和暖如春地消,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背畏妖。 一陣腳步聲響...
    開封第一講書人閱讀 33,869評論 1 274
  • 我被黑心中介騙來泰國打工脉执, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人戒劫。 一個月前我還...
    沈念sama閱讀 49,378評論 3 379
  • 正文 我出身青樓半夷,卻偏偏與公主長得像婆廊,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子巫橄,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,937評論 2 361

推薦閱讀更多精彩內(nèi)容