ZeroMQ指南-第1章-基础-分而治之(二)
= zmq_socket (context, ZMQ_PULL);
zmq_bind (receiver, "tcp://*:5558");
// Wait for start of batch
char *string = s_recv (receiver);
free (string);
// Start our clock now
int64_t start_time = s_clock ();
// Process 100 confirmations
int task_nbr;
for (task_nbr = 0; task_nbr < 100; task_nbr++) {
char *string = s_recv (receiver);
free (string);
if ((task_nbr / 10) * 10 == task_nbr)
printf (":");
else
printf (".");
fflush (stdout);
}
// Calculate and report duration of batch
printf ("Total elapsed time: %d msec\n",
(int) (s_clock () - start_time));
zmq_close (receiver);
zmq_ctx_destroy (context);
return 0;
}
批处理的平均消耗为5秒。当我们启动1个、2个、4个工人时，我们从水槽取得的结果是这样的：
[plain]
# 1 worker
Total elapsed time: 5034 msec
Total elapsed time: 2421 msec
# 4 workers
Total elapsed time: 1018 msec
让我们更细致的查看这段代码的某些方面：
工人们上游连接通风机，下游连接水槽。这意味着你可以任意添加工人。如果工人绑定到他们的端点，你会需要（a）更多的端点（b）每添加一个工人都得修改通风机或水槽。我们说通风机和水槽是结构中的“稳定”部分，而工人们是“动态”部分。
我们不得不在批次的开始与所有工人们都起来运行两者间做出同步。这是一个 MQ中特别常见的陷阱，也没有简单方案。“连接”方法需要一定时间。所以当一组工人连接到通风机，第一个成功连接的工人会在瞬间得到消息的全部负载，而其他人仍在连接。如果你总是不去同步批次的开始，
系统完全不会并行运转。试着移除等待看看。
通风机的推送（PUSH）套接字均匀的分发任务到工人们（假定批次开始送出之前他们都已连接）。这叫做负载均衡，我们会再详细看看。
水槽的拉取（PULL）套接字均匀的收集工人的成果。这叫做公平队列。
图6 - 公平队列
管道模式也表现出“迟钝加入者”综合症，导致了对推送套接字不能正确负载均衡的控诉。如果你使用推送和拉取，而且其中一个工人比其他人得到更多的消息，那是因为他的推送套接字比别人连接的更快，然后在其他人连接达成之前捕获了一大堆消息。如果你想要正确的负载均衡，你可能想要看看第3章 - 高级请求应答模式中的小节：负载均衡模式。