(轉)ZeroMQ的模式-Requset-Reply

咱們先來看看第一種模式:Request-Reply Pattern。 請求應答模式。

Request-Reply這個名字很直白，口語點說就是一問一答。可使同步的遵循請求序的一問一答，也能夠 是異步的不按請求序的一問一答；其中也能夠包含各類不一樣的路由策略——讓誰來回答。zeromq定義的爲這個模式服務的socket有：ZMQ_REQ, ZMQ_REP, ZMQ_ROUTER以及ZMQ_DEALER. 用他們進行合理的組合，就能夠實現現實世界中各類不一樣的請求應答模式。

分別來看：

ZMQ_REQ

ZMQ_REQ作的事情就是發問，而後收答。發、收必須是嚴格按序進行。請求時對對端進行Round Robin，遇到異常則阻塞。官方對這個socket的總結以下：

Summary of ZMQ_REQ characteristics
Compatible peer sockets	ZMQ_REP
Direction	Bidirectional
Send/receive pattern	Send, Receive, Send, Receive, …
Outgoing routing strategy	Round-robin
Incoming routing strategy	Last peer
ZMQ_HWM option action	Block

ZMQ_REP

ZMQ_REP作的事情是收問題而後回答。收、發嚴格按序調用。對收到的問題公平排隊,逐一做答。回答發出時遇到異常則直接丟棄，不會阻塞。

Summary of ZMQ_REP characteristics
Compatible peer sockets	ZMQ_REQ
Direction	Bidirectional
Send/receive pattern	Receive, Send, Receive, Send, …
Incoming routing strategy	Fair-queued
Outgoing routing strategy	Last peer
ZMQ_HWM option action	Drop

能夠發現，上述兩種socket是純同步的，連用在它們身上的api的調用順序都有嚴格定義。並且沒有辦法動態決定請求的去向。若是要實現更復雜的請求應答模式，就要藉助於下面兩種socket了。

ZMQ_DEALER

其實ZMQ_DEALER也是同步的，ZMQ_DEALER也叫做ZMQ_XREQ，概念上是request/reply socket的擴展(實現上恰好相反哦)。從名字上可知它是一個代理層。它對收到的消息公平排隊，並以RR方式發送消息，在遇到異常時發送阻塞。它的主要 做用是將come in的請求load balance地發送給到對端們。

Summary of ZMQ_DEALER characteristics
Compatible peer sockets	ZMQ_ROUTER, ZMQ_REQ, ZMQ_REP
Direction	Bidirectional
Send/receive pattern	Unrestricted
Outgoing routing strategy	Round-robin
Incoming routing strategy	Fair-queued
ZMQ_HWM option action	Block

ZMQ_ROUTER

ZMQ_ROUTER是真正的異步。ZMQ_ROUTER socket收到消息時會在消息棧上加一層包含消息來源地址的消息；發送消息時，會將這一層消息取出，將其做爲發送的目的地。若是發送時遇到異常，則丟棄 消息。ZMQ_ROUTER經過這種方式作到了不須要保存任何狀態即可異步地轉發消息，而這一切應用層是看不到的。

Summary of ZMQ_ROUTER characteristics
Compatible peer sockets	ZMQ_DEALER, ZMQ_REQ, ZMQ_REP
Direction	Bidirectional
Send/receive pattern	Unrestricted
Outgoing routing strategy	See text
Incoming routing strategy	Fair-queued
ZMQ_HWM option action	Drop

總結

概括總結一下，0mq的Request-Reply模式下有四種socket類型：

• DEALER： 給鏈接的對端RR地分發消息，對收到的消息公平排隊。
• REQ：在應用層外發的消息上加一層空消息再發送；在收到消息後去掉分隔空消息再返回應用層。它實質上是在DEALER上構建的，只是在此基礎上強制加入了發、收循環。
• ROUTER：針對每個收到的消息：加一層來源地址段，而後再交給應用層；針對每個要發出的消息：去掉最上層的地址段，並以該地址段爲目的地進行發送。
• REP：對收到的消息：儲存全部的消息內容直到第一個分隔空消息段，把剩餘的消息體傳給應用層；對發出的消息：把以前儲存的消息體加回來，並像ROUTER同樣發送出去。它實質上實在ROUTER上構建的，只是在此基礎上強制加入了收、發循環。

有了這幾種socket，即可以組合成各類Request-Reply模式了：

[REQ] <--> [REP] [REQ] <--> [ROUTER--DEALER] <--> [REP] [REQ] <--> [ROUTER--DEALER] <--> [ROUTER--DEALER] <--> [REP]...

舉個例子，N個client要給M個worker提交任務，worker完成任務後返回給client；worker須要平衡負載以免某一 worker過於勞累，client發出的請求也有前後之說，不能讓後發的請求先於以前的被交給worker。這番描述的socket組合即可以下圖 (from the guide)方式構建：