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()

相关内容

热门资讯

安卓怎么传到苹果系统,从安卓到... 你是不是也有过这样的烦恼:手机里存了好多好用的安卓应用,可是一换到苹果系统,就发现这些宝贝们都不见了...
安卓改系统字体app,安卓系统... 你有没有想过,手机上的字体也能变得个性十足?没错,就是那个安卓改系统字体app,它可是让手机界面焕然...
安卓系统重启密码错误,破解与预... 手机突然重启了,屏幕上竟然出现了密码输入的界面!这可怎么办?别急,让我来帮你一步步解决这个安卓系统重...
安卓系统怎么删除相片,照片删除... 手机里的相片越来越多,是不是感觉内存都要不够用了?别急,今天就来教你怎么在安卓系统里轻松删除那些不再...
什么安卓机系统最好,安卓系统最... 你有没有想过,手机里那个默默无闻的系统,其实才是决定你手机体验好坏的关键呢?没错,说的就是安卓机系统...
小米手环8安卓系统,智能生活新... 你有没有注意到,最近小米手环8安卓系统成了大家热议的话题呢?这款智能手环自从上市以来,就凭借其强大的...
虹膜系统怎么换为安卓,技术革新... 你有没有想过,你的虹膜系统怎么换为安卓呢?这可是个挺酷的话题,不是吗?想象你的手机上装了个高科技的虹...
安卓刷苹果mac系统,探索跨平... 你有没有想过,你的安卓手机竟然能变身成为苹果Mac系统的超级战士?没错,这就是今天我要跟你分享的神奇...
安卓系统不模仿苹果,不模仿苹果... 你知道吗?在科技圈里,有一场关于操作系统的大戏正在上演。没错,就是安卓系统和苹果iOS系统之间的较量...
安卓系统计步开启,开启健康生活... 你有没有发现,最近你的手机里多了一个小助手——计步器?没错,就是那个默默记录你每一步的小家伙。今天,...
怎么备份安卓系统 recove... 你有没有想过,如果你的安卓手机突然间像顽皮的小猫一样,把你的照片、视频和重要文件都给“藏”了起来?别...
安卓系统同步功能停用,安卓系统... 最近发现了一个让人有点小郁闷的消息——安卓系统的同步功能竟然被停用了!这可真是让人有点措手不及呢。想...
安卓系统的平板重装系统,轻松恢... 你那安卓平板是不是突然间卡得跟蜗牛似的,系统反应慢得跟乌龟赛跑似的?别急,今天就来给你支个招,教你怎...
安卓操作系统语言,引领智能时代... 你知道吗?在手机世界里,有一个超级厉害的操作系统,它就是安卓!这个操作系统可是全球最流行的,几乎每个...
安卓系统声音录音软件,声音记录... 你有没有想过,在安卓手机上,那些美妙的旋律、有趣的对话或者重要的会议内容,如何变成你随时可以回顾的宝...
coloros系统和安卓9,创... 你知道吗?最近手机圈里可是热闹非凡呢!一款名为ColorOS的系统,还有那个大家熟悉的安卓9,它们俩...
安卓个推系统搭建,基于个推系统... 你有没有想过,自己的手机里那些推送消息是怎么悄无声息地出现在你眼前的?没错,就是安卓个推系统在默默为...
设置系统时间app安卓,安卓时... 你有没有想过,手机里那个默默无闻的系统时间,竟然能通过一个小巧的App变得如此有趣和个性化?没错,今...
安卓系统输出开关量,安卓系统开... 你有没有想过,你的安卓手机里竟然隐藏着这么一个神奇的开关量输出功能?没错,就是那个你可能从未留意过的...
安卓系统音乐软件推荐,五大热门... 你有没有发现,手机里音乐软件那么多,挑一款适合自己的真心不容易啊!安卓系统上的音乐软件更是五花八门,...