位置: 编程技术 - 正文

Python+Pika+RabbitMQ环境部署及实现工作队列的实例教程

编辑:rootadmin

推荐整理分享Python+Pika+RabbitMQ环境部署及实现工作队列的实例教程,希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:,内容如对您有帮助,希望把文章链接给更多的朋友!

rabbitmq中文翻译的话,主要还是mq字母上:Message Queue,即消息队列的意思。前面还有个rabbit单词,就是兔子的意思,和python语言叫python一样,老外还是蛮幽默的。rabbitmq服务类似于mysql、apache服务,只是提供的功能不一样。rabbimq是用来提供发送消息的服务,可以用在不同的应用程序之间进行通信。

安装rabbitmq先来安装下rabbitmq,在ubuntu .下可以直接通过apt-get安装:

安装好后,rabbitmq服务就已经启动好了。接下来看下python编写Hello World!的实例。实例的内容就是从send.py发送“Hello World!”到rabbitmq,receive.py从rabbitmq接收send.py发送的信息。

其中P表示produce,生产者的意思,也可以称为发送者,实例中表现为send.py;C表示consumer,消费者的意思,也可以称为接收者,实例中表现为receive.py;中间红色的表示队列的意思,实例中表现为hello队列。

python使用rabbitmq服务,可以使用现成的类库pika、txAMQP或者py-amqplib,这里选择了pika。

安装pika

安装pika可以使用pip来进行安装,pip是python的软件管理包,如果没有安装,可以通过apt-get安装

通过pip安装pika:

send.py代码

连接到rabbitmq服务器,因为是在本地测试,所以就用localhost就可以了。

声明消息队列,消息将在这个队列中进行传递。如果将消息发送到不存在的队列,rabbitmq将会自动清除这些消息。

发送消息到上面声明的hello队列,其中exchange表示交换器,能精确指定消息应该发送到哪个队列,routing_key设置为队列的名称,body就是发送的内容,具体发送细节暂时先不关注。

关闭连接

完整代码

先来执行下这个程序,执行成功的话,rabbitmqctl应该成功增加了hello队列,并且队列里应该有一条信息,用rabbitmqctl命令来查看下

在笔者的电脑上输出如下信息:

确实有一个hello队列,并且队列里有一条信息。接下来用receive.py来获取队列里的信息。

receive.py代码

和send.py的前面两个步骤一样,都是要先连接服务器,然后声明消息的队列,这里就不再贴同样代码了。

接收消息更为复杂一些,需要定义一个回调函数来处理,这边的回调函数就是将信息打印出来。

Python+Pika+RabbitMQ环境部署及实现工作队列的实例教程

告诉rabbitmq使用callback来接收信息

开始接收信息,并进入阻塞状态,队列里有信息才会调用callback进行处理。按ctrl+c退出。

完整代码

执行程序,就能够接收到队列hello里的消息Hello World!,然后打印在屏幕上。换一个终端,再次执行send.py,可以看到receive.py这边会再次接收到信息。

工作队列示例

1.准备工作(Preparation)

在实例程序中,用new_task.py来模拟任务分配者, worker.py来模拟工作者。

修改send.py,从命令行参数里接收信息,并发送

修改receive.py的回调函数。

这边先打开两个终端,都运行worker.py,处于监听状态,这边就相当于两个工作者。打开第三个终端,运行new_task.py

观察worker.py接收到任务,其中一个工作者接收到3个任务 :

另外一个工作者接收到2个任务 :

从上面来看,每个工作者,都会依次分配到任务。那么如果一个工作者,在处理任务的时候挂掉,这个任务就没有完成,应当交由其他工作者处理。所以应当有一种机制,当一个工作者完成任务时,会反馈消息。

2.消息确认(Message acknowledgment)

消息确认就是当工作者完成任务后,会反馈给rabbitmq。修改worker.py中的回调函数:

这边停顿5秒,可以方便ctrl+c退出。

去除no_ack=True参数或者设置为False也可以。

用这个代码运行,即使其中一个工作者ctrl+c退出后,正在执行的任务也不会丢失,rabbitmq会将任务重新分配给其他工作者。

3.消息持久化存储(Message durability)

虽然有了消息反馈机制,但是如果rabbitmq自身挂掉的话,那么任务还是会丢失。所以需要将任务持久化存储起来。声明持久化存储:

但是这个程序会执行错误,因为hello这个队列已经存在,并且是非持久化的,rabbitmq不允许使用不同的参数来重新定义存在的队列。重新定义一个队列:

在发送任务的时候,用delivery_mode=2来标记任务为持久化存储:

4.公平调度(Fair dispatch)

上面实例中,虽然每个工作者是依次分配到任务,但是每个任务不一定一样。可能有的任务比较重,执行时间比较久;有的任务比较轻,执行时间比较短。如果能公平调度就最好了,使用basic_qos设置prefetch_count=1,使得rabbitmq不会在同一时间给工作者分配多个任务,即只有工作者完成任务之后,才会再次接收到任务。

new_task.py完整代码

Python通过RabbitMQ服务器实现交换机功能的实例教程 快速回顾一下RabbitMQ服务器的安装:sudoapt-getinstallrabbitmq-serverPython使用RabbitMQ需要Pika库:sudopipinstallpika好了,接下来我们先看交换机的工作原理:消息发

Python操作RabbitMQ服务器实现消息队列的路由功能 Python使用Pika库(安装:sudopipinstallpika)可以操作RabbitMQ消息队列服务器(安装:sudoapt-getinstallrabbitmq-server),这里我们来看一下MQ相关的路由功能。路由

详解Python操作RabbitMQ服务器消息队列的远程结果返回 先说一下笔者这里的测试环境:Ubuntu.+Python2.7.4RabbitMQ服务器sudoapt-getinstallrabbitmq-serverPython使用RabbitMQ需要Pika库sudopipinstallpika远程结果返回消息发送端

标签: Python+Pika+RabbitMQ环境部署及实现工作队列的实例教程

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

上一篇:Python的消息队列包SnakeMQ使用初探(python消息队列感知消息被消费)

下一篇:Python通过RabbitMQ服务器实现交换机功能的实例教程(Python通过行和列提取数据)

  • 补缴以前年度企业所得税如何填报汇算清缴表
  • 开具红字专用发票的条件
  • 现代服务税目包含哪些
  • 美元利息结汇时结汇项目是什么
  • 小规模纳税人实收资本
  • 专用发票网上勾选不了
  • 坏账准备的会计分录怎么写例题
  • 公司转给法人备注怎么填
  • 税务机关如何正确行使代位权
  • 旅游的合同
  • 异常增值税扣税凭证
  • 季度流动比率怎么算
  • 购入材料过程中支付运费
  • 低价销售差额部分计入
  • 去年购进的货物今年才收到发票
  • 房子已买
  • 聘用人员工资福利待遇
  • 广告位的费用
  • 外籍人员劳务费税率表
  • 营改增行业销售额的规定
  • 生活垃圾处理项目基础金融产品包括
  • 应收账款的产生之一是由于销售
  • 固定资产直接进费用违背什么
  • 开票的时候开票人是管理员
  • 境外投资企业如何交税
  • 没有发票的怎么报账
  • 引入人工智能
  • services.exe
  • 前端大屏适配几寸显示器
  • 财政拨款结转的明细科目中,年末结转后有余额的是
  • 银行承兑汇票挂失手续费收费标准
  • 上飞机可以带2个充电宝吗
  • 购买材料支出明细表
  • 维多利亚国家艺术馆
  • 企业一次性收取租金如何缴纳增值税
  • VUE3.2 + vue-echarts + DataV 数据可视化大屏(项目)
  • vue项目更新后还是老代码
  • audit.exe
  • 商贸公司对加工的影响
  • 红字发票抵扣联要装订到凭证里吗
  • 怎么升级一般纳税人
  • 入库时的会计分录
  • 进口关税如何交
  • 待抵扣进项税额什么意思
  • 收货和入库的区别
  • mysql常见故障
  • 教育行业税收优势分析
  • 一般纳税人适用什么会计准则
  • 待抵扣进项税在贷方怎么冲掉
  • 存货盘盈的账务处理入什么费用
  • 成本少了怎么处理
  • 折扣如何做账
  • 手撕定额发票可以抵扣吗
  • 员工工资怎么核算
  • 支付兼职人员工资会计处理
  • 缴纳工会筹备金应该记什么科目
  • 未确认融资费用借贷方向
  • CentOS7下MySQL5.7安装配置方法图文教程(YUM)
  • MySQL数据迁移到oracle
  • win8开机错误
  • iis503如何解决
  • freebsd安装教程
  • win8系统怎么设置自动关机
  • centos查看硬件设备
  • win10更新提示错误
  • nodejs和mysql
  • css示范例子
  • nodejs的理解
  • 网吧保存区连接怎么设置
  • unity安卓手机游戏官网
  • js获取当前浏览器版本
  • python 判断中文字符
  • bootstrap要学多久
  • 如何计算白酒的出酒率
  • 销售货物免征增值税时收取的增值税税款需计入当期损益
  • 完税证明可以自己在家打印吗
  • 烟台市独生子女费 打什么电话咨询
  • 收心归位经典语录短句
  • 怎么删除天眼查的犯罪记录
  • 主管单位申请书
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

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

    友情链接: 武汉网站建设