修改lbbroker后ZeroMQ REQ socket静默丢包是否为正常现象？

结论 #

你观察到的消息静默丢弃现象完全符合ZeroMQ的设计规范，属于预期正常行为。

REQ socket的核心运行规则 #

ZeroMQ的REQ类型socket严格遵循发送-接收交替的状态机约束：

• 一个REQ socket完成一次发送操作后，必须先执行一次接收操作，才能进行下一次发送
• 反之，完成一次接收操作后，必须先执行一次发送操作，才能进行下一次接收
• 违反上述状态顺序时，socket会直接静默丢弃不符合当前状态可处理的消息，不会抛出显式错误

场景问题拆解 #

结合你修改后的代码逻辑，丢包的原因完全匹配上述规则：

1. 你将worker_addr改为静态变量后，所有客户端请求都会被强制转发到第一个就绪的worker，完全忽略worker_queue中存储的实际空闲worker列表，甚至你每次处理请求时worker_queue.pop()弹出的其他空闲worker地址会被直接浪费，不会被用到。
2. worker侧的REQ socket逻辑是：先发送READY/回复消息→进入可接收状态→接收一个请求→进入等待发送状态→处理业务逻辑→发送回复→回到可接收状态。
3. 在worker处理业务逻辑的等待发送状态阶段，broker又转发了新的请求到这个worker的REQ socket，此时REQ不符合接收条件，新的消息会被直接丢弃。
4. 就算worker已经回到可接收状态，同一时间如果broker转发了多个请求过来，REQ也只会处理第一个，剩余的全部静默丢弃。

问题补充解答 #

REQ socket在worker业务逻辑运行过程中确实无法接收其他消息，这是REQ类型的固有设计。如果需要支持worker同时接收多个请求缓存后续处理，你可以将worker侧的REQ socket替换为ROUTER socket，或者使用DEALER socket实现异步的请求处理逻辑。

内容的提问来源于stack exchange，提问作者lewis