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

相关内容

热门资讯

安卓系统音乐软件推荐,五大热门... 你有没有发现,手机里音乐软件那么多,挑一款适合自己的真心不容易啊!安卓系统上的音乐软件更是五花八门,...
安卓系统刷三星系统,轻松刷入最... 你有没有想过,你的安卓手机其实可以变身成三星的旗舰机呢?没错,就是那种屏幕大、性能强、系统流畅的旗舰...
塞班系统可以转为安卓,跨越时代... 你知道吗?现在科技的发展真是让人眼花缭乱,连我们曾经熟悉的塞班系统也能华丽转身,变成安卓系统呢!是不...
安卓系统如何录像剪辑,录像剪辑... 亲爱的手机控们,你是否有过这样的经历:在某个瞬间,你捕捉到了一段令人难忘的画面,却因为没来得及记录而...
安卓系统强行提高配置,配置提升... 最近你的安卓手机是不是感觉有点儿“发烧”了?没错,就是那种配置突然“升级”的感觉。你是不是也觉得,手...
安卓系统能做设计吗,探索安卓系... 你有没有想过,安卓系统竟然也能做设计?是的,你没听错,这个我们日常使用的手机操作系统,竟然也能成为设...
安卓系统几年后使用,探索多年使... 你有没有想过,那些陪伴我们多年的安卓手机,它们现在过得怎么样了呢?安卓系统,这个曾经让我们爱恨交加的...
平板安卓苹果双系统,安卓与苹果... 你有没有想过,拥有一台既能运行安卓系统,又能使用苹果系统的平板电脑,那该是多么酷炫的事情啊!想象一边...
嘉和病历系统安卓,便捷医疗信息... 你有没有听说过嘉和病历系统安卓版?这可是医疗行业的一大神器呢!想象医生们拿着手机就能轻松管理病历,患...
安卓10更改系统号,揭秘系统编... 你知道吗?最近安卓系统又来了一次大更新,安卓10正式上线了!这次更新可是带来了不少新功能,其中最引人...
小米墨水屏 安卓系统,融合科技... 你知道吗?在科技日新月异的今天,电子阅读器市场也迎来了新的活力。而小米,这个我们熟悉的品牌,最近推出...
系统软件最少的安卓系统,基于最... 你有没有想过,手机系统就像是我们生活的操作系统,有时候太复杂了,让人感觉头都大了。今天,我要给你介绍...
安卓系统关闭应用推荐,安卓系统... 你有没有发现,手机里的安卓系统最近有点儿“小情绪”,总是给你推荐一些你根本不感兴趣的应用?别急,今天...
车载安卓系统如何用,智能驾驶体... 你有没有想过,你的车载安卓系统其实是个隐藏的宝库呢?没错,就是那个你每天开车时几乎不离手的那个屏幕,...
安卓系统更新如何取消,```p... 你有没有遇到过这种情况:安卓手机的系统更新推送得让人有点头疼,有时候更新后的系统还各种不适应。别急,...
安卓系统源码修改练习,从零开始... 亲爱的技术爱好者,你是否曾梦想过深入安卓系统的内核,亲手修改源码,让手机变得更加个性化?那就让我们一...
安卓考勤系统论文,基于安卓平台... 你有没有想过,每天打卡上班,是不是也能变得有趣起来呢?没错,就是那个我们每天都要面对的安卓考勤系统。...
安卓系统哪家流畅度,安卓系统流... 手机里的安卓系统,就像是每个人的小世界,各有各的风采。但说到流畅度,这可是大家最关心的问题了。今天,...
安卓开不了定位系统,安卓设备定... 最近是不是发现你的安卓手机定位系统突然罢工了?别急,别慌,今天就来给你详细解析一下这个问题,让你轻松...
安卓系统怎么设置airpod,... 你有没有发现,自从AirPods问世以来,它就成为了科技界的宠儿?这款无线耳机不仅音质出众,而且连接...