我正在使用 NetMQ 将消息从许多客户端发送到接收消息并处理它们的服务器。如果我使用pub/sub模式,我可以(ab)使用订阅者套接字并将其用于服务器,客户端将成为发布者(相反的流程,不是吗?)。但是,我无法向客户发送确认消息。
如果我使用该REQ/RESP
模式,我可以使用服务器的响应套接字,甚至可以发送一个可以被客户端接收的确认消息。但是,如果服务器错过了来自客户端的消息,我无法重新发送消息(在等待 a 之后timespan
),因为我收到异常
Req.XSend - 无法发送另一个请求
- 即使在断开客户端套接字并关闭它之后(它接缝服务器套接字会跟踪它)。
最后,根据文档,我不确定这是否Dealer/Router
是正确的模式。由于我很确定我陷入了一个非常常见的情况,是否有任何模式可以使用 NetMQ 实现这个场景?