前言

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

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

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

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

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

  4、消息隊列(Queue):消息的存儲載體

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

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

Rabbitmq的運作

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

大數(shù)據(jù)培訓(xùn),云培訓(xùn),數(shù)據(jù)挖掘培訓(xùn),云計算培訓(xùn),高端軟件開發(fā)培訓(xùn),項目經(jīng)理培訓(xùn)

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

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

  拉,不會通知消費者,而是由消費者主動輪循或者定時去取隊列消息。(我需要才去找你)

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

網(wǎng)友評論