MQ笔记-MQ相关知识

**MQ笔记**

**什么是消息队列（MQ）**

消息队列（MQ）是一种用于在不同应用程序之间传递信息的技术。它允许生产者将信息发送到一个队列中，而消费者可以从同一个队列中读取这些信息。

**为什么需要消息队列**

1. **解耦**: 消息队列可以帮助解耦生产者和消费者，减少它们之间的依赖关系。
2. **异步处理**: 消息队列允许生产者继续执行其他任务，而不等待消费者处理信息。
3. **高吞吐量**: 消息队列可以处理大量信息，并且可以根据需要增加或减少吞吐量。

**常见的消息队列系统**

1. **RabbitMQ**
2. **Apache Kafka**
3. **Amazon SQS**
4. **Google Cloud Pub/Sub**
5. **ActiveMQ**

**RabbitMQ**

RabbitMQ 是一个开源的消息队列系统，支持多种协议和语言。它提供了以下特性：

* 支持多种消息类型（如文本、二进制等）
* 支持多种传输协议（如AMQP、MQTT等）
* 支持多种语言（如Java、Python等）

**RabbitMQ 的基本组件**

1. **Broker**: RabbitMQ 的核心组件，负责存储和路由消息。
2. **Exchange**: 消息的来源，负责将信息发送到队列中。
3. **Queue**: 消息的目的地，负责存储和传递信息给消费者。

**RabbitMQ 的基本操作**

1. **生产者**: 将信息发送到 Exchange 中。
2. **消费者**: 从 Queue 中读取信息并处理它。

**示例代码**

java// 生产者public class Producer {
 public static void main(String[] args) throws Exception {
 // 创建连接工厂 ConnectionFactory factory = new ConnectionFactory();
 // 创建连接 Connection connection = factory.newConnection();
 // 创建通道 Channel channel = connection.createChannel();
 // 声明交换器 channel.exchangeDeclare("my_exchange", "fanout");
 // 发送消息 String message = "Hello, RabbitMQ!";
 channel.basicPublish("my_exchange", "", null, message.getBytes());
 System.out.println("Sent: " + message);
 }
}

// 消费者public class Consumer {
 public static void main(String[] args) throws Exception {
 // 创建连接工厂 ConnectionFactory factory = new ConnectionFactory();
 // 创建连接 Connection connection = factory.newConnection();
 // 创建通道 Channel channel = connection.createChannel();
 // 声明队列 String queueName = "my_queue";
 channel.queueDeclare(queueName, true, false, false, null);
 // 绑定交换器和队列 channel.queueBind(queueName, "my_exchange", "");
 // 开始消费 channel.basicConsume(queueName, true, (consumerTag, message) -> {
 String body = new String(message.getBody());
 System.out.println("Received: " + body);
 });
 }
}