前言

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

Rabbitmq的關(guān)鍵術(shù)語

  1、綁定器(Binding):根據(jù)路由規(guī)則綁定Queue和Exchange。

  2、路由鍵(Routing Key):Exchange根據(jù)關(guān)鍵字進(jìn)行消息投遞。

  3、交換機(jī)(Exchange):指定消息按照路由規(guī)則進(jìn)入指定隊(duì)列

  4、消息隊(duì)列(Queue):消息的存儲(chǔ)載體

  5、生產(chǎn)者(Producer):消息發(fā)布者。

  6、消費(fèi)者(Consumer):消息接收者。

Rabbitmq的運(yùn)作

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

大數(shù)據(jù)培訓(xùn),云培訓(xùn),數(shù)據(jù)挖掘培訓(xùn),云計(jì)算培訓(xùn),高端軟件開發(fā)培訓(xùn),項(xiàng)目經(jīng)理培訓(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ì)列消息。(我需要才去找你)

  使用場(chǎng)景我舉個(gè)例子,假如有兩套系統(tǒng) 訂單系統(tǒng)和發(fā)貨系統(tǒng),從訂單系統(tǒng)發(fā)起發(fā)貨消息指令,為了及時(shí)發(fā)貨,發(fā)貨系統(tǒng)需要訂閱隊(duì)列,只要有指令就處理。

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