我应该在 zeroMQ 程序初始化中添加睡眠以避免 heisenbugs 吗？

Question

我正在做一个 zeroMQ 概念证明，它涉及一个主进程，该进程发布控制命令并从任意数量的工作进程推送和拉取数据。

似乎在初始化时，如果我使用 shell 脚本启动 master 和 worker（单独的进程）有时会不同步。但是，如果我以任何顺序手动启动它们（在单独的控制台窗口中），我从未见过这种情况。我开始考虑在每个进程绑定/连接到套接字之后添加一个 sleep() 以避免这种明显的 heisenbug - 但我也想知道我是否只是愚蠢。有什么建议吗？

下面是偶尔失败的 shell 脚本的样子。主人使用 PUB 和 PUSH 与工人交谈，并使用 PULL 套接字获取信息。我认为 heisenbug 是由于某个工人有时看不到来自 master 的 PUB 消息引起的。

echo "starting worker A in background"
python pWorkerA.py > /tmp/A.out &
echo "starting worker B in background"
python pWorkerB.py > /tmp/B.out &
echo "starting master"
python abMaster.py

如果我使用 sleep()，我觉得我在作弊

Answer 1

您必须假设在 PUB 上发送的消息在建立连接之前不会到达 SUB 套接字。建立连接需要一些有限的时间（如果非常短的话），因此在那个小窗口中发送的任何消息都不会到达尚未连接的 SUB。正如您所建议的，避免这种情况的一种简单方法是在绑定后向主服务器添加睡眠。这并不完全可靠，因为从技术上讲，worker 的连接速度可能非常慢，或者在 master 之后启动，并且当它们成功时没有实际的信号。

如果您确实需要确认工作人员已连接，一种更可靠的方法是使用握手机制，以便工作人员向主设备发送一个小的“嗨，我准备好了”消息（在不同的频道上）连接后。然后，master 仅在收到必要数量的握手后才开始发布消息（取决于您的应用程序的适当逻辑）。