RabbitMQ学习（自用）

同步调用的流程图

异步调用的流程

异步调用的流程图，有有mq，就可以讲一些操作放在消息队列中，让他们异步去执行操作。

首先下载docker镜像

docker pull rabbitmq:3.12-management

创建并运行 RabbitMQ 容器
在powershell中输入

docker run -d `
  --name rabbitmq `
  -p 5672:5672 `
  -p 15672:15672 `
  -e RABBITMQ_DEFAULT_USER=admin `
  -e RABBITMQ_DEFAULT_PASS=password `
  rabbitmq:3.12-management

5672 端口：是 RabbitMQ 的核心通信端口，你的 Java 应用程序（如之前的MessageSender和MessageReceiver）会通过此端口连接到 RabbitMQ 服务器。
15672 端口：是 RabbitMQ 内置的 Web 管理界面端口，用于可视化监控和配置 RabbitMQ（访问地址：http://localhost:15672，用户名admin，密码password）。

使用java实现RabbitMQ
首先导入依赖

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid-spring-boot-starter</artifactId>
    <version>1.2.8</version>
</dependency>

消息队列发送方

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

public class MessageSender {
    private final static String QUEUE_NAME = "hello";

    public static void main(String[] argv) throws Exception {
        // 创建连接工厂并设置RabbitMQ服务器地址
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setUsername("admin");
        factory.setPassword("password");

        // 建立连接和通道
        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {

            // 声明队列（如果不存在）
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);

            // 准备消息内容
            String message = "Hello, RabbitMQ!";

            // 发布消息到队列
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));

            System.out.println(" [x] Sent '" + message + "'");
        }
    }
}

消息队列接收方

```java
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DeliverCallback;

public class MessageReceiver {
    private final static String QUEUE_NAME = "hello";

    public static void main(String[] argv) throws Exception {
        // 创建连接工厂并设置RabbitMQ服务器地址
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setUsername("admin");
        factory.setPassword("password");

        // 建立连接和通道
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();

        // 声明队列（如果不存在）
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        System.out.println(" [*] Waiting for messages. To exit press CTRL+C");

        // 定义消息处理回调
        DeliverCallback deliverCallback = (consumerTag, delivery) -> {
            String message = new String(delivery.getBody(), "UTF-8");
            System.out.println(" [x] Received '" + message + "'");
        };

        // 启动消费者并等待消息
        channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> { });
    }
}

整体框架

RabbitMQ使用虚拟主机实现隔离作用