RabbitMQ介绍与python操作RabbitMQ
admin
2024-03-29 08:45:36
0

目录

RabbitMQ介绍

RabbitMQ基本使用

ack机制

持久化

闲置消费


RabbitMQ介绍

MQ:消息队列,就是基础数据结构中的先进先出的一种数据结构。像生活中买东西,需要排队,先排的人先买消费,就是典型的先进先出。

Linux安装

# 安装erlang
yum -y install erlang
# 安装RabbitMQ
yum -y install rabbitmq-server

windows安装

【Windows安装RabbitMQ详细教程】_慕之寒的博客-CSDN博客_rabbitmq安装windows

docker安装

# 拉取镜像
docker pull rabbitmq:management
# 启动,设置用户名为admin,密码为admin
docker run -di --name Myrabbitmq -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin -p 15672:15672 -p 5672:5672 rabbitmq:management
# 访问服务器的15672端口

RabbitMQ基本使用

安装模块:

pip install pika

消息进队列:

import pika# 没有用户名密码情况
# connection = pika.BlockingConnection(pika.ConnectionParameters(host='10.0.0.200',port=5672))# 有密码的情况
credentials = pika.PlainCredentials("admin", "admin")
connection = pika.BlockingConnection(pika.ConnectionParameters(host='10.0.0.200', port=5672, credentials=credentials))
channel = connection.channel()# 声明一个消息队列叫hello
channel.queue_declare(queue='hello')
# 往消息队列中放一条消息
# routing_key必须等于队列的名字,body是发送的消息
channel.basic_publish(exchange='', routing_key='hello', body='你好')
print("send success")
connection.close()

队列出消息:

import pikadef main():credentials = pika.PlainCredentials("admin", "admin")connection = pika.BlockingConnection(pika.ConnectionParameters(host='10.0.0.200', port=5672, credentials=credentials))channel = connection.channel()# 创建一个hello的对列channel.queue_declare(queue='hello')# 回调函数,队列中有消息就会触发def callback(ch, method, properties, body):print("来自队列:%r" % str(body, encoding='utf8'))channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)print('等待中...')channel.start_consuming()if __name__ == '__main__':main()

ack机制

消费者收到消息后,要回复给消息队列,消息队列收到回复,该消息就删除,如果收不到,就一直放在消息队列中,再起一个消费者,还会消费这个消息。

自动

channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)

auto_ack参数为True指的是收到消息后自动回复给消息队列。

手动

# 回调函数,队列中有消息就会触发
def callback(ch, method, properties, body):print("来自队列:%r" % str(body, encoding='utf8'))# 数据使用完了后在回复给队列ch.basic_ack(delivery_tag=method.delivery_tag)

持久化

消息是放在内存中的,如果RabbitMQ服务挂掉了,消息就没了,通过持久化,保证队列和消息都不丢失。

队列持久化要是一个新队列

# 声明一个新消息队列叫Q,做持久化
channel.queue_declare(queue='Q', durable=True)
# 消息也做持久化
channel.basic_publish(exchange='',routing_key='hello',body='你好',properties=pika.BasicProperties(delivery_mode=2,  # 消息也做持久化)
)

生产者:

import pika# 没有用户名密码情况
# connection = pika.BlockingConnection(pika.ConnectionParameters(host='10.0.0.200',port=5672))# 有密码的情况
credentials = pika.PlainCredentials("admin", "admin")
connection = pika.BlockingConnection(pika.ConnectionParameters(host='10.0.0.200', port=5672, credentials=credentials))
channel = connection.channel()# 声明一个新消息队列叫Q,做持久化
channel.queue_declare(queue='Q', durable=True)
# 往消息队列中放一条消息
# routing_key必须等于队列的名字,body是发送的消息
channel.basic_publish(exchange='',routing_key='hello',body='你好',properties=pika.BasicProperties(delivery_mode=2,  # 消息也做持久化)
)
print("send success")
connection.close()

闲置消费

正常情况如果有多个消费者,是按照顺序第一个消息给第一个消费者,第二个消息给第二个消费者。

但是可能第一个消息的消费者处理消息很耗时,一直没结束,就可以让第二个消费者优先获得闲置的消息

channel.basic_qos(prefetch_count=1) # 谁闲置谁获取,没必要按照顺序一个一个来

消费者:

import pikadef main():credentials = pika.PlainCredentials("admin", "admin")connection = pika.BlockingConnection(pika.ConnectionParameters(host='10.0.0.200', port=5672, credentials=credentials))channel = connection.channel()# 创建一个hello的对列channel.queue_declare(queue='hello')# 回调函数,队列中有消息就会触发def callback(ch, method, properties, body):print("来自队列:%r" % str(body, encoding='utf8'))# 数据使用完了后在回复给队列ch.basic_ack(delivery_tag=method.delivery_tag)channel.basic_qos(prefetch_count=1)  # 谁闲置谁获取,没必要按照顺序一个一个来channel.basic_consume(queue='hello', on_message_callback=callback)print('等待中...')channel.start_consuming()if __name__ == '__main__':main()

相关内容

热门资讯

怎么解除订阅安卓系统,安卓系统... 你是不是也和我一样,手机里订阅了好多服务,结果现在想解除订阅,却一头雾水?别急,今天就来手把手教你如...
安卓系统停用怎么开启,轻松恢复... 亲爱的手机控们,你是否曾经遇到过安卓系统突然停用的情况,让你手忙脚乱,不知所措?别担心,今天就来教你...
安卓系统电池健康度,电池健康度... 你有没有发现,你的安卓手机最近是不是有点儿不给力了?电池续航能力大不如前,充电速度也慢了不少?别急,...
安卓系统按键怎么截图,安卓系统... 你是不是也和我一样,有时候想截个图分享给朋友,却发现安卓手机的截图功能有点神秘呢?别急,今天就来手把...
购票系统安卓源代码,架构设计与... 你有没有想过,那些我们每天离不开的购票系统,它们背后的秘密是什么呢?今天,就让我带你一探究竟,揭开购...
安卓手机系统后台测试,深度解析... 你有没有发现,你的安卓手机后台总是悄悄地忙碌着?别小看了这些后台程序,它们可是手机系统稳定运行的关键...
安卓系统重启的图标,解锁设备新... 手机突然重启,是不是心里有点慌?别急,今天就来和你聊聊安卓系统重启的图标,让你一眼就能认出它,再也不...
车载智慧屏安卓系统,智能出行新... 你有没有发现,现在的车载智慧屏越来越智能了?尤其是那些搭载了安卓系统的,简直就像是个移动的小电脑,不...
安卓系统连上网权限,解锁设备无... 你有没有发现,你的安卓手机里有些应用总是偷偷连上网?别小看这个小小的网络权限,它可是能影响你隐私、消...
安卓谷歌操作系统,探索安卓谷歌... 你知道吗?在智能手机的世界里,有一个操作系统可是无人不知、无人不晓,那就是安卓谷歌操作系统。它就像一...
安卓系统手写%怎样调出,具体实... 你有没有遇到过这种情况:在使用安卓手机的时候,突然想用手写输入法来记录一些灵感或者重要信息,可是怎么...
安卓手机重置 系统设置,轻松恢... 手机用久了是不是感觉卡顿得厉害?别急,今天就来教你怎么给安卓手机来个大变身——重置系统设置!想象你的...
win如何安装安卓系统,Win... 哇,你有没有想过,让你的Win系统也能玩转安卓应用?没错,就是那种在手机上轻松自如的安卓系统,现在也...
苹果qq和安卓系统,跨平台体验... 你有没有发现,现在手机市场上,苹果和安卓的较量可是越来越激烈了呢!咱们就来聊聊这个话题,看看苹果QQ...
显示最好的安卓系统,探索最新旗... 你有没有想过,为什么安卓系统那么受欢迎呢?它就像一个魔法盒子,里面装满了各种神奇的魔法。今天,就让我...
安卓app怎么降级系统,系统版... 你有没有发现,有时候安卓手机的系统更新后,新功能虽然炫酷,但老系统用起来更顺手呢?别急,今天就来教你...
雷军脱离安卓系统,引领科技变革... 你知道吗?最近科技圈可是炸开了锅,因为我们的雷军大大竟然宣布要脱离安卓系统,这可真是让人大跌眼镜啊!...
安卓系统自动开网络,安卓系统自... 你有没有发现,手机里的安卓系统有时候会自动开启网络连接,这可真是让人又爱又恨啊!有时候,你正专心致志...
安卓系统怎样控制后台,因为服务... 手机里的安卓系统是不是感觉越来越卡了?后台程序太多,不仅耗电还影响性能。别急,今天就来教你怎么巧妙地...
安卓系统打游戏推荐,一触即达! 你有没有发现,现在手机游戏越来越好玩了?不管是休闲小游戏还是大型MMORPG,都能在手机上畅玩。但是...