一、消息队列的使用

1.1、消息队列七种模式

RabbitMQ官方提供了七种消息队列的使用方式，分别如下所示：

最简单的模式：最简单的模式就是生产者直接向消息队列发生消息，然后消费者从消息队列消费消息。
工作队列模式：这支持一个消息队列允许多个消费者同时进行消费，相当于是多线程并发消费，默认是采用轮询的策略分发消息。
发布订阅模式：这里就需要引入Exchange交换机了，每一个消息队列可以订阅这个Exchange交换机，当交换机接收到消息之后，会将这个一条消息发布到所有订阅的消息队列里面。
路由模式：路由模式允许消息队列从Exchange交换机里面接收指定RouteKey路由键的消息，不是这个路由键的消息将不会被分发到消息队列里面。
主题模式：这可以将一类消息全部分发到指定的消息队列里面，并且Topics模式支持通配符指定RouteKey路由键。
RPC模式：这种模式我没怎么学习。
发布确认模式：这种模式是为了保证生产者发送的消息一定能够到达RabbitMQ里面的一种方式，是解决消息丢失问题的。

1.2、最简单的模式使用

最简单的模式，只有一个消息队列，生成者向指定的消息队列里面发送消息，然后消费者从指定的消息队列里面消费消息。

注意：需要启动RabbitMQ消息队列服务哦，不然运行代码会报错。

（1）引入依赖

<!-- 引入 RabbitMQ 依赖 -->
<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>5.16.0</version>
</dependency>

（2）编写生产者

package com.rabbitmq.demo.simple;

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

/**
 * @version 1.0.0
 * @Date: 2023/2/25 16:23
 * @Copyright (C) ZhuYouBin
 * @Description: 消息生产者
 */
public class Producer {
    public static void main(String[] args) {
        // 1、创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        // 2、设置连接的 RabbitMQ 服务地址
        factory.setHost("127.0.0.1"); // 默认就是本机
        factory.setPort(5672); // 默认就是 5672 端口
        // 3、获取连接
        Connection connection = null; // 连接
        Channel channel = null; // 通道
        try {
            connection = factory.newConnection();
            // 4、获取通道
            channel = connection.createChannel();
            // 5、指定需要操作的消息队列，如果队列不存在，则会创建
            channel.queueDeclare("queue_demo_2023", false, false, false, null);
            // 6、发送消息
            String message = "这是最简单的模式，发送的消息数据";
            channel.basicPublish("", "queue_demo_2023", null, message.getBytes());
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (null != channel) {
                try {
                    channel.close();
                } catch (Exception e) {}
            }
            if (null != connection) {
                try {
                    connection.close();
                } catch (Exception e) {}
            }
        }
    }
}

运行上面的生产者代码，查看RabbitMQ控制台，可以发现此时有一条消息啦。

（3）编写消费者

package com.rabbitmq.demo.simple;

import com.rabbitmq.client.*;

import java.io.IOException;

/**
 * @version 1.0.0
 * @Date: 2023/2/25 16:30
 * @Copyright (C) ZhuYouBin
 * @Description: 消息消费者
 */
public class Consumer {
    public static void main(String[] args) {
        // 1、创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        // 2、设置连接的 RabbitMQ 服务地址
        factory.setHost("127.0.0.1"); // 默认就是本机
        factory.setPort(5672); // 默认就是 5672 端口
        // 3、获取连接
        Connection connection = null; // 连接
        Channel channel = null; // 通道
        try {
            connection = factory.newConnection();
            // 4、获取通道
            channel = connection.createChannel();
            // 5、指定需要操作的消息队列，如果队列不存在，则会创建
            channel.queueDeclare("queue_demo_2023", false, false, false, null);
            // 6、消费消息
            DeliverCallback callback = new DeliverCallback() {
                public void handle(String s, Delivery delivery) throws IOException {
                    // 接收消息
                    System.out.println("这是接收的消息：" + new String(delivery.getBody()));
                }
            };
            channel.basicConsume("queue_demo_2023", true, callback, i->{});
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

运行消费者代码，查看控制台输出，以及RabbitMQ控制界面，可以发现，此时消息队列中的消息不存在了。