位置: 编程技术 - 正文

详解Python操作RabbitMQ服务器消息队列的远程结果返回(python操作命令)

编辑:rootadmin

推荐整理分享详解Python操作RabbitMQ服务器消息队列的远程结果返回(python操作命令),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:python 怎么操作,python的基本操作方法,python操作命令,python如何操作,python操作命令,pythonzero,python操作步骤,python操作步骤,内容如对您有帮助,希望把文章链接给更多的朋友!

先说一下笔者这里的测试环境:Ubuntu. + Python 2.7.4RabbitMQ服务器

Python使用RabbitMQ需要Pika库

远程结果返回消息发送端发送消息出去后没有结果返回。如果只是单纯发送消息,当然没有问题了,但是在实际中,常常会需要接收端将收到的消息进行处理之后,返回给发送端。

处理方法描述:发送端在发送信息前,产生一个接收消息的临时队列,该队列用来接收返回的结果。其实在这里接收端、发送端的概念已经比较模糊了,因为发送端也同样要接收消息,接收端同样也要发送消息,所以这里笔者使用另外的示例来演示这一过程。

示例内容:假设有一个控制中心和一个计算节点,控制中心会将一个自然数N发送给计算节点,计算节点将N值加1后,返回给控制中心。这里用center.py模拟控制中心,compute.py模拟计算节点。

compute.py代码分析

计算节点的代码比较简单,值得一提的是,原来的接收方法都是直接将消息打印出来,这边进行了加一的计算,并将结果发送回控制中心。

center.py代码分析

上例代码定义了接收返回数据的队列和处理方法,并且在发送请求的时候将该队列赋值给reply_to,在计算节点代码中就是通过这个参数来获取返回队列的。

打开两个终端,一个运行代码python compute.py,另外一个终端运行center.py,如果执行成功,应该就能看到效果了。

笔者在测试的时候,出了些小问题,就是在center.py发送消息时没有指明返回队列,结果compute.py那边在计算完结果要发回数据时报错,提示routing_key不存在,再次运行也报错。用rabbitmqctl list_queues查看队列,发现compute_queue队列有1条数据,每次重新运行compute.py的时候,都会重新处理这条数据。后来使用/etc/init.d/rabbitmq-server restart重新启动下rabbitmq就ok了。

详解Python操作RabbitMQ服务器消息队列的远程结果返回(python操作命令)

相互关联编号correlation id上一遍演示了远程结果返回的示例,但是有一个没有提到,就是correlation id,这个是个什么东东呢?

假设有多个计算节点,控制中心开启多个线程,往这些计算节点发送数字,要求计算结果并返回,但是控制中心只开启了一个队列,所有线程都是从这个队列里获取消息,每个线程如何确定收到的消息就是该线程对应的呢?这个就是correlation id的用处了。correlation翻译成中文就是相互关联,也表达了这个意思。

correlation id运行原理:控制中心发送计算请求时设置correlation id,而后计算节点将计算结果,连同接收到的correlation id一起返回,这样控制中心就能通过correlation id来标识请求。其实correlation id也可以理解为请求的唯一标识码。

示例内容:控制中心开启多个线程,每个线程都发起一次计算请求,通过correlation id,每个线程都能准确收到相应的计算结果。

compute.py代码分析

和上面一篇相比,只需修改一个地方:将计算结果发送回控制中心时,增加参数correlation_id的设定,该参数的值其实是从控制中心发送过来的,这里只是再次发送回去。代码如下:

center.py代码分析

控制中心代码稍微复杂些,其中比较关键的有三个地方:

使用python的uuid来产生唯一的correlation_id。发送计算请求时,设定参数correlation_id。定义一个字典来保存返回的数据,并且键值为相应线程产生的correlation_id。代码如下:

笔者开启了两个终端,来运行compute.py,开启一个终端来运行center.py,最后结果输出截图如下:

可以看到虽然获取的结果不是顺序输出,但是结果和源数据都是对应的。

这边示例的做法就是创建一个队列,使用correlation id来标识每次请求。也有做法可以不使用correlation id,就是每请求一次,就创建一个临时队列,不过这样太消耗性能了,官方也不推荐这么做。

浅谈python中set使用 浅谈python中set使用In[2]:a=set()#常用操作1In[3]:aOut[3]:set()In[4]:type(a)Out[4]:setIn[5]:b=set([1,3])In[6]:bOut[6]:{1,3}In[7]:type(b)Out[7]:setIn[8]:b.update(2)------------------------------

python中set常用操作汇总 sets支持xinset,len(set),和forxinset。作为一个无序的集合,sets不记录元素位置或者插入点。因此,sets不支持indexing,slicing,或其它类序列(sequence-like)的操作

python dict.get()和dict['key']的区别详解 先看代码:In[1]:a={'name':'wang'}In[2]:a.get('age')In[3]:a['age']---------------------------------------------------------------------------KeyErrorTraceback(mostrecentcalllast)ipython-input-3-a6

标签: python操作命令

本文链接地址:https://www.jiuchutong.com/biancheng/386985.html 转载请保留说明!

上一篇:Python操作RabbitMQ服务器实现消息队列的路由功能(python操作mongodb数据库)

下一篇:浅谈python中set使用(python中set用法)

  • 定期定额征收的个体户怎么报个人所得税
  • 一般纳税人企业所得税多久申报一次
  • 如何成为一般纳税人的条件
  • 扣缴义务人和纳税人举例
  • 机动车销售统一专票图片
  • 有限责任公司需要几个股东
  • 软件无形资产摊销年限是多久
  • 全年一次性奖金税率表
  • 电子发票冲红处理
  • 预付款项包括哪些项目
  • 机场工作人员的家属票
  • 接收商业承兑汇票需要到银行办手术吗
  • 研发费用加计扣除留存备查资料
  • 库存现金盘点表是不是原始凭证
  • 未进行账务处理违反什么
  • 企业必须要现金流入吗
  • 公司借别的公司的钱再借给别的公司
  • 购销合同印花税最新政策2023
  • 吊车租赁费计入什么会计科目
  • 税控盘没有反写会怎样
  • 计提税金和缴纳税金的会计分录
  • 交叉持股的合并财务报表
  • 哪些银行承兑汇票比较好
  • 购买股权属于什么科目
  • 账务中如何把短期借款转变为实收资本?
  • 代征税款手续费规定
  • 补缴的公积金可以取出来吗
  • 报税文件是纳税申报表吗
  • 装饰公司收到客户工程款做分录
  • 预付账款供应商类别怎么填
  • 电子发票上的电子税章如何才能自动生成
  • windows10如何更改时间
  • k210中文手册
  • 最贵的游戏宣传片
  • 工程未审计资金能支付到多少
  • 认缴制下实收资本需要验资吗
  • 销售方红字发票账务处理?
  • 多目标pso
  • 蜈蚣什么情况下出现
  • 工资一定要对公发吗
  • imx6ul开源项目
  • php怎么转go
  • 海关缴款书能重开吗
  • 电汇跟支票的区别
  • 新公司不开户需要交税吗
  • js怎么执行函数
  • 小规模纳税人的税率是多少
  • 金税三期个人所得税申报
  • 研发支出资本化计入什么科目
  • 政府补助属于营业外收入吗
  • 用友t3软件财务软件具体操作
  • 不能抵扣的普通发票如何做分录
  • 上级补助收入科目
  • 不按规定纳税的违法行为
  • 企业接收到政府信息
  • 车辆保险费会计账务处理
  • 未开票收入是否代表可以不开发票
  • 企业购买土地如何缴税
  • winxp系统怎么投屏
  • 怎么修改注册表的权限
  • windowsserver2008无线网不能连接
  • vmware怎么放大虚拟机
  • mac修改用户名称
  • e ink launcher
  • win8关机立马自动重启
  • win8应用商店废了
  • 计算机的硬盘
  • win7保存桌面不见了怎么办
  • OpenGL ES2.0-iPhone开发-part1
  • js 操作excel
  • Node.js中的construct
  • 一篇文章让你彻底读懂德国历史
  • 生成0-100的随机数,直到生成88为止,停止循环
  • jq filter过滤
  • javascript面向对象编程指南
  • 发票查验明细怎么截屏
  • 国税局官网发票查验平台
  • 江苏省生育登记服务网
  • 上海市国家税务局地址
  • 请问各位专家金线吊乌龟有什么功效
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设