前言
RabbitMq大家再熟悉不過,這篇文章主要整對rabbitmq學(xué)習(xí)后封裝RabbitMQ.Client的一個分享。文章最后,我會把封裝組件和demo奉上。
Rabbitmq的運作
從下圖可以看出,發(fā)布者(Publisher)是把消息先發(fā)送到交換器(Exchange),再從交換器發(fā)送到指定隊列(Queue),而先前已經(jīng)聲明交換器與隊列綁定關(guān)系,最后消費者(Customer)通過訂閱或者主動取指定隊列消息進(jìn)行消費。
那么剛剛提到的訂閱和主動取可以理解成,推(被動),拉(主動)。
推,只要隊列增加一條消息,就會通知空閑的消費者進(jìn)行消費。(我不找你,就等你找我,觀察者模式)
拉,不會通知消費者,而是由消費者主動輪循或者定時去取隊列消息。(我需要才去找你)