關於消息隊列——ZeroMQ的pipeline模型

官方給的那個pipeline例子很直觀,當我們有些一大堆任務(如分析日誌)需要用多個worker來工作時,可以不用hadoop這麼重量級的產品,使用pipeline完全可以做到。這裏做點點修改如下:   pipeline模型圖如下: 1,首先需要個任務生成器:taskcreate.php 任務生成器負責PUSH任務內容到套接口,需要指定類型爲SOCKET_PUSH。生成一堆隨機數模擬每個任務所需時
相關文章
相關標籤/搜索