= "RabbitMQ学习笔记

后端

2023-09-04 01:52:11

RabbitMQ：可靠的消息队列利器

在当今分布式系统和微服务架构盛行的时代，消息队列系统扮演着至关重要的角色。RabbitMQ ，一个开源且功能强大的消息队列系统，在众多选择中脱颖而出。

1. RabbitMQ 简介

RabbitMQ是一个开源的消息队列系统，旨在在分布式系统中可靠、高效地传递消息。它以其高可靠性、高可用性和高吞吐量而著称，使其成为各种场景的理想选择。

2. RabbitMQ 的基本概念

RabbitMQ的核心概念围绕其组件展开，包括：

交换机 (Exchange)： 接收消息并根据路由规则将其转发到相应的队列。
队列 (Queue)： 存储消息，等待消费者消费。
绑定 (Binding)： 关联交换机和队列，指定消息应该路由到哪些队列。
路由键 (Routing Key)： 决定消息路由到哪个队列的消息属性。

3. RabbitMQ 的使用

使用 RabbitMQ非常简单。只需几行代码，您就可以发送和接收消息。以下是一个示例：

import pika

# 创建连接
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))

# 创建信道
channel = connection.channel()

# 创建交换机
channel.exchange_declare(exchange='my_exchange', exchange_type='direct')

# 创建队列
channel.queue_declare(queue='my_queue')

# 将队列绑定到交换机
channel.queue_bind(exchange='my_exchange', queue='my_queue', routing_key='my_routing_key')

# 发送消息
channel.basic_publish(exchange='my_exchange', routing_key='my_routing_key', body='Hello, world!')

# 接收消息
def callback(ch, method, properties, body):
    print("Received message: %r" % body)

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

# 开始接收消息
channel.start_consuming()