1、异步处理

RabbitMQ是一个开源的消息中间件基于AMQPAdvanced

Message

Protocol高级消息队列协议协议实现。

RabbitMQ被广泛应用于各种应用场景如异步任务处理、日志传输、实时消息推送等。

在微服务架构中RabbitMQ是一个常见的消息中间件选择它可以帮助服务之间实现解耦和异步通信提高系统的可扩展性和稳定性。

RabbitMQ提供了一个简单的用户页面用户可以监控和管理消息、队列、交换器、绑定等资源。

通过管理界面用户可以直观地了解系统的运行状态并进行相应的配置和管理操作。

1、异步处理

在Web应用中当用户提交表单时可以将表单处理任务发送给RabbitMQ由后台服务异步处理从而提高用户界面的响应速度。

在电商系统中用户下单后订单处理、库存更新、支付通知等任务可以异步执行避免阻塞主线程。

2、服务解耦

在微服务架构中不同服务之间通过RabbitMQ进行通信可以降低服务之间的耦合度提高系统的可扩展性和可维护性。

当某个服务需要升级或维护时可以通过RabbitMQ实现服务的平滑过渡而不会影响其他服务的正常运行。

3、流量削峰

在高并发场景中RabbitMQ可以作为一个缓冲层接收并存储大量的请求然后按照设定的速率将请求转发给后端服务从而避免后端服务因过载而崩溃。

通过RabbitMQ的限流和队列机制可以有效地控制请求的速率和数量保护后端服务的稳定性。

4、日志收集

RabbitMQ可以用于收集分散在各个服务器上的日志信息将它们集中到一个或多个日志处理服务中进行统一的分析和处理。

通过RabbitMQ可以实现日志的实时收集、分析和报警提高系统的运维效率和故障排查能力。

5、发布订阅

在需要向多个客户端推送消息的场景中如实时通知、消息推送等可以使用RabbitMQ的Fanout交换器将消息广播给所有绑定的队列。

通过RabbitMQ的消息广播机制可以实现实时、可靠的消息推送服务提高用户体验。

6、任务调度

RabbitMQ可以与其他任务调度框架如Quartz结合使用实现定时任务、延迟任务等复杂任务调度需求。

通过RabbitMQ的任务调度功能可以灵活地控制任务的执行时间和频率提高系统的自动化程度和运行效率。

三、python如何使用Rabbitmq

Rabbitmq网址https://www.rabbitmq.com/tutorials

1、安装依赖

https://pypi.tuna.tsinghua.edu.cn/simple

pika

https://pypi.tuna.tsinghua.edu.cn/simple

pika

pika.BlockingConnection(pika.ConnectionParameters(localhost))

channel

channel.queue_declare(queuelist)

channel.basic_publish(exchange,routing_keylist,

向那个队列发布信息bodylol,#

pika.BlockingConnection(pika.ConnectionParameters(localhost))

channel

channel.queue_declare(queuelist)

为确保队列存在创建一个list队列def

{body})channel.basic_consume(queuelist,on_message_callbackcallback,auto_ackTrue)

接收信息queue表示监听的队列on_message_callback表示接收到信息执行的函数auto_ack表示默认执行回复

3、消息确认

需要将auto_ack改为False然后在回调函数里加入ch.basic_ack(delivery_tagmethod.delivery_tag)

import

pika.BlockingConnection(pika.ConnectionParameters(localhost))

channel

channel.queue_declare(queuelist)

创建一个队列def

{body})ch.basic_ack(delivery_tagmethod.delivery_tag)

给队列回复进行确认channel.basic_consume(queuelist2,on_message_callbackcallback,auto_ackFalse)

auto_ack改为False

durableTrue在创建队列时声明持久化delivery_modepika.DeliveryMode.Persistent让信息做持久化

import

pika.BlockingConnection(pika.ConnectionParameters(localhost))

channel

channel.queue_declare(queuelist2,durableTrue)

channel.basic_publish(exchange,routing_keylist2,

向那个队列发布信息bodylol,#

发布的信息propertiespika.BasicProperties(delivery_modepika.DeliveryMode.Persistent

让信息做持久化))

channel.basic_qos(prefetch_count1)进行闲置派发

import

pika.BlockingConnection(pika.ConnectionParameters(localhost))

channel

channel.queue_declare(queuelist)

为确保队列存在创建一个list队列def

{body})channel.basic_qos(prefetch_count1)

闲置派发

channel.basic_consume(queuelist,on_message_callbackcallback,auto_ackTrue)

接收信息queue表示监听的队列on_message_callback表示接收到信息执行的函数auto_ack表示默认执行回复

6、发布订阅

channel.exchange_declare(exchangem1,exchange_typefanout)声明一个交换机类型为fanout是将信息发给所有的订阅者

发布者代码如下

pika.BlockingConnection(pika.ConnectionParameters(localhost))

连接rabbitmq

连接通道channel.exchange_declare(exchangem1,exchange_typefanout)

channel.basic_publish(exchangem1,routing_key,

队列名称bodylol,)#

pika.BlockingConnection(pika.ConnectionParameters(localhost))

连接rabbitmq

connection.channel()channel.exchange_declare(exchangem1,exchange_typefanout,)

resultchannel.queue_declare(exclusiveTrue,queue)

创建一个随机队列

channel.queue_bind(exchangem1,queuequeue_name)

callback(ch,

{body})channel.basic_consume(queuequeue_name,on_message_callbackcallback,auto_ackTrue)

7、关键字发布

关键字发布就是在发布订阅模式基础上将不同信息发布给不同的订阅者。

channel.exchange_declare(exchangem2,exchange_typedirect)

声明一个交换机交换机的类型为direct将信息发布给指定的订阅者。

发布者代码如下

pika.BlockingConnection(pika.ConnectionParameters(localhost))

连接rabbitmq

连接通道channel.exchange_declare(exchangem2,exchange_typedirect)

channel.basic_publish(exchangem2,routing_keyhhq,

队列名称bodycf,)#

pika.BlockingConnection(pika.ConnectionParameters(localhost))

连接rabbitmq

connection.channel()channel.exchange_declare(exchangem2,exchange_typedirect)

exchange:交易所的名称fanout将信息发给所有的队列

resultchannel.queue_declare(exclusiveTrue,queue)

创建一个随机队列

channel.queue_bind(exchangem2,queuequeue_name,routing_keyhhq)

callback(ch,

{body})channel.basic_consume(queuequeue_name,on_message_callbackcallback,auto_ackTrue)