我正在使用.NET中的ZeroMQ,并试图解决一个奇怪的问题 . 我有一个类型为PUSH的套接字和一个类型为PULL over TCP的套接字 . 当客户端断开连接时,服务器仍然能够发送消息(请注意,没有标志传递给Socket.Send方法),在开始阻塞并等待客户端重新连接并传递消息之前,它会获得完全的批量 . 之后发送 .
如何避免丢失消息(或者在最坏的情况下测试是否连接了客户端,如果没有发送我可以承受损失的虚假消息)?
提前致谢!
Edit: 进一步测试显示,如果我在客户端断开连接后发送第一条消息后等待1秒,则第二条消息将被阻止,但如果我没有丢失 . 那令人困惑......
1 回答
ZeroMQ文档指出这是PUSH / PULL设置的问题,并建议采用以下模式:添加REP / REQ设置,以便在您期望固定数量的订户时提供节点协调 . 但是,如果您无法提前知道订户数量,则应考虑更改协议以更好地适应这些条件 .
Synchronized publisher in C (from ZGuide)