Python操作rabbitmq消息队列持久化
消息队列持久化
Python操作rabbit消息队列的持久化,如下:
# 创建一个名为balance的队列,对queue进行durable持久化设为True(持久化第一步)
channel.queue_declare(queue='balance', durable=True)
# 设置消息持久化(持久化第二步),将要发送的消息的属性标记为2,表示该消息要持久化
properties=pika.BasicProperties(delivery_mode=2, )
持久化后,即便是重启了rabbitmq服务,期间的消息仍存在队列中,不会因为重启而丢失。
延伸:
(1)rabbitmq循环调度,将消息循环发送给不同的消费者,如:消息1,3,5发送给消费者1;消息2,4,6发送给消费者2。
(2)消息确认机制,为了确保一个消息不会丢失,RabbitMQ支持消息的确认 , 一个 ack(acknowlegement) 是从消费者端发送一个确认去告诉RabbitMQ 消息已经接收了、处理了,RabbitMQ可以释放并删除掉了。如果一个消费者死掉了(channel关闭、connection关闭、或者TCP连接断开了)而没有发送ack,RabbitMQ 就会认为这个消息没有被消费者处理,并会重新发送到生产者的队列里,如果同时有另外一个消费者在线,rabbitmq将会将消息很快转发到另外一个消费者中。 那样的话你就能确保虽然一个消费者死掉,但消息不会丢失。
这个是没有超时的,当消费方(consumer)死掉后RabbitMQ会重新转发消息,即使处理这个消息需要很长很长时间也没有问题。消息的 acknowlegments 默认是打开的,在前面的例子中关闭了: no_ack = True . 现在删除这个标识 然后 发送一个 acknowledgment。
(3)消息持久化,将消息写入硬盘中。
RabbitMQ不允许你重新定义一个已经存在、但属性不同的queue。需要标记消息为持久化的 - 要通过设置 delivery_mode 属性为 2来实现。
消息持久化的注意点:
标记消息为持久化并不能完全保证消息不会丢失,尽管已经告诉RabbitMQ将消息保存到磁盘,但RabbitMQ接收到的消息在还没有保存的时候,仍然有一个短暂的时间窗口。RabbitMQ不会对每个消息都执行同步 --- 可能只是保存到缓存cache还没有写入到磁盘中。因此这个持久化保证并不是很强,但这比我们简单的任务queue要好很多,如果想要很强的持久化保证,可以使用 publisher confirms。
(4)公平调度。在一个消费者未处理完一个消息之前不要分发新的消息给它,而是将这个新消息分发给另一个不是很忙的消费者进行处理。为了解决这个问题我们可以在消费者代码中使用 channel.basic.qos ( prefetch_count = 1 ),将消费者设置为公平调度。
相关文章
- pycharm导入Python_python简单项目
- python字符串转化列表_Python列表到字符串的转换[通俗易懂]
- 推荐一款Python数据可视化神器
- unboundlocalerror python_Python问题:UnboundLocalError: local variable ‘xxx’ referenced before assignme
- python表情代码_Python实现表情包的代码实例[通俗易懂]
- 【说站】python os怎样处理系统文件
- vscode运行python_vscode python 调试
- 10 个 Python 脚本来自动化你的日常任务
- python抛出异常和捕获异常_Python异常
- python lambda表达式举例_Python中lambda表达式[通俗易懂]
- python使用opencv如何保存图片_OpenCV Python 保存图片
- 如何利用Python和wxpy进行群发
- python元编程
- 图嵌入概述:节点、边和图嵌入方法及Python实现
- 初识Python面向对象
- 网络工程师学Python-11-数组
- python下载大文件代码详解编程语言
- 一步一步学会在Linux上运行Python程序(linux运行python程序)
- python实现bitmap数据结构详解
- python改变日志(logging)存放位置的示例
- python基础教程之缩进介绍