关于消息队列——ZeroMQ的pipeline模型

官方给的那个pipeline例子很直观，当我们有些一大堆任务（如分析日志）需要用多个worker来工作时，可以不用hadoop这么重量级的产品，使用pipeline完全可以做到。这里做点点修改如下：   pipeline模型图如下： 1，首先需要个任务生成器：taskcreate.php 任务生成器负责PUSH任务内容到套接口，需要指定类型为SOCKET_PUSH。生成一堆随机数模拟每个任务所需时

>>阅读原文<<