更新时间:2022-08-22 11:55:53
我们先来看看第一种模式:Request-Reply Pattern。 请求应答模式。
Request-Reply这个名字很直白,口语点说就是一问一答。可以使同步的遵循请求序的一问一答,也可以是异步的不按请求序的一问一答;其中也可以包含各种不同的路由策略——让谁来回答。zeromq定义的为这个模式服务的socket有:ZMQ_REQ, ZMQ_REP, ZMQ_ROUTER以及ZMQ_DEALER. 用他们进行合理的组合,就可以实现现实世界中各种不同的请求应答模式。
分别来看:
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做的事情是收问题然后回答。收、发严格按序调用。对收到的问题公平排队,逐一作答。回答发出时遇到异常则直接丢弃,不会阻塞。
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_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 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类型:
有了这几种socket,便可以组合成各种Request-Reply模式了:
[REQ] <--> [REP]
[REQ] <--> [ROUTER--DEALER] <--> [REP]
[REQ] <--> [ROUTER--DEALER] <--> [ROUTER--DEALER] <--> [REP]
...