设为首页 收藏本站

运维网

查看: 341|回复: 0

[经验分享] saltstack系列(四)——zmq Paraller Pipeline模式

[复制链接]

尚未签到

发表于 2018-1-4 09:13:45 | 显示全部楼层 |阅读模式
push/pull模式
  push/pull模式,这是一个什么模式呢?战争时期,食物紧缺,实行配给制,大家都排好队,有人专门发放食物,前一个人领取了食物,后一个人跟上继续领取食物,这个push端就是发放食物的,pull端就是领取食物的,所不同的是,现实中,你领取完了食物就不能排队等候了,但zmq的push/pull模式中,一个pull端领取完了食物,可以继续排队等待push端发放食物。

  我们发送出一条信息的时候worker会进行分配,按照分配进行转发
  上代码,Ventilator端
  

#coding:utf-8  

  
import zmq
  

  
print("这是发送端,我的ip和端口是127.0.0.1:8001")
  
cont = zmq.Context()
  

  
sock = cont.socket(zmq.PUSH)
  
sock.bind("tcp://127.0.0.1:8001")
  
while True:
  data = raw_input(">>>")
  sock.send(data)
  

  

  Sink端
  

#coding:utf-8  

  
import zmq
  

  
print("这是接收端,我的ip和端口是127.0.0.1:8000")
  
cont = zmq.Context()
  

  
sock = cont.socket(zmq.PULL)
  
sock.bind("tcp://127.0.0.1:8002")
  
while True:
  recv = sock.recv()
  print(recv)
  

  

  Worker
  

#coding:utf-8  
import zmq
  

  
print("I am worker 1")
  

  
cont = zmq.Context()
  

  
recv_sock = cont.socket(zmq.PULL)
  
recv_sock.connect("tcp://127.0.0.1:8001")
  

  
send_sock = cont.socket(zmq.PUSH)
  
send_sock.connect("tcp://127.0.0.1:8002")
  

  
while True:
  recv = recv_sock.recv()
  send_sock.send(recv)
  print("worker 1 is worked,it's content is %s"%recv) 
  

运维网声明 1、欢迎大家加入本站运维交流群:群①:263444886群②:197202523群③:485755530群④:201730672群⑤:202807635运维网交流群⑥:281548029
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、其他单位或个人使用、转载或引用本文时必须注明原文的出处
4、如本帖侵犯到任何版权问题,请立即告知本站,本站将及时予与删除并致以最深的歉意
5、运维网 - 服务您的运维操作管理专家!
6、联系人Email:admin@yunvn.com 网址:www.iyunv.com

点击关注更多内容
您需要登录后才可以回帖 登录 | 立即注册  

本版积分规则  允许回帖邮件提醒楼主

关注运维网官方微信X

关注运维网官方微信

扫描二维码关注运维网官方微信,最新一手资源尽在官方微信!快快关注我们吧...

扫描微信二维码查看详情

客服 E-mail:kefu@yunvn.com

本站由安畅网络和青云提供云计算服务

运维网--中国最专业的运维工程师交流社区

京ICP备14039699号-1 Copyright © 2012-2018

使用手机软件扫描微信二维码

关注我们可获取更多热点资讯

Good good study day day up !


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


合作伙伴: 青云cloud 安畅网络

快速回复 返回顶部 返回列表