前言

  RabbitMq大家再熟悉不過(guò),這篇文章主要整對(duì)rabbitmq學(xué)習(xí)后封裝RabbitMQ.Client的一個(gè)分享。文章最后,我會(huì)把封裝組件和demo奉上。

Rabbitmq的運(yùn)作

  從下圖可以看出,發(fā)布者(Publisher)是把消息先發(fā)送到交換器(Exchange),再?gòu)慕粨Q器發(fā)送到指定隊(duì)列(Queue),而先前已經(jīng)聲明交換器與隊(duì)列綁定關(guān)系,最后消費(fèi)者(Customer)通過(guò)訂閱或者主動(dòng)取指定隊(duì)列消息進(jìn)行消費(fèi)。

Android培訓(xùn),安卓培訓(xùn),手機(jī)開(kāi)發(fā)培訓(xùn),移動(dòng)開(kāi)發(fā)培訓(xùn),云培訓(xùn)培訓(xùn)

  那么剛剛提到的訂閱和主動(dòng)取可以理解成,推(被動(dòng)),拉(主動(dòng))。

  推,只要隊(duì)列增加一條消息,就會(huì)通知空閑的消費(fèi)者進(jìn)行消費(fèi)。(我不找你,就等你找我,觀察者模式)

  拉,不會(huì)通知消費(fèi)者,而是由消費(fèi)者主動(dòng)輪循或者定時(shí)去取隊(duì)列消息。(我需要才去找你)

網(wǎng)友評(píng)論