前言

本篇博客主要是实现RabbitMQ最简单的模式，一个生产者，一个队列，一个消费者。通过本篇博客能够掌握RabbitMQ最基本的运用。
本篇博客主要学习至RabbitMQ官网的教程，RabbitMQ官网教程地址
入门教程选择最简单的模式，本篇博客选择的是Java语言
在这里插入图片描述

RabbitMQ相关术语

RabbitMQ是一个消息代理，RabbitMQ接收和转发消息。可以把它看做一个邮局，当你把邮件放进邮箱中，邮递员一定会将邮件邮递到接收邮件的人那里。在这个实例中，RabbitMQ可以是邮箱、邮局、和邮递员。

Producer（生产者）：
一个发送消息的程序是一个生产者
在这里插入图片描述
queue(队列）：
队列可以看做是一个邮箱，队列只受主机的内存和磁盘限制，它本质上是一个大的消息缓冲区。许多生产者可以向一个队列发送消息，许多消费者可以尝试从一个队列接收数据。

consumer（消费者）：
一个主要等待接收消息的程序

RabbitMQ简单模式示例

**业务场景：**使用JAVA编写两个程序，一个生产者发送一条消息，一个消费者接受消息并把消息打印出来。

首先创建一个Maven项目在pom文件中引入RabbitMQ java client依赖

<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>5.10.0</version>
</dependency>

编写生产者Send.java类

import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
/**
 * @author : [WangWei]
 * @version : [v1.0]
 * @className : Send
 * @description : [消息生产者类]
 * @createTime : [2023/1/13 8:21]
 * @updateUser : [WangWei]
 * @updateTime : [2023/1/13 8:21]
 * @updateRemark : [描述说明本次修改内容]
 */
public class Send {
    private final static String QUEUE_NAME = "hello";
    public static void main(String[] argv) throws Exception {
    	//创建工厂
        ConnectionFactory factory = new ConnectionFactory();
        //RabbitMQ服务器ip地址
        factory.setHost("ip");
        //端口号  默认值为5672
        factory.setPort(5672);
        //为用户分配的虚拟主机 默认值为/
        factory.setVirtualHost("/");
        //用户名  默认为guest
        factory.setUsername("用户名");
        //密码   默认为guest
        factory.setPassword("密码");
        //创建连接
        try (Connection connection = factory.newConnection();
        	//创建Channel
             Channel channel = connection.createChannel()) {
            //声明队列，声明一个队列是幂等的——它只会在它不存在的情况下被创建。
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            //生产的消息
            String message = "Hello World!";
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
            System.out.println(" [x] Sent '" + message + "'");
        }
    }
}

编写消费者Recv.java类

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DeliverCallback;
/**
 * @author : [WangWei]
 * @version : [v1.0]
 * @className : Recv
 * @description : [消费者类]
 * @createTime : [2023/1/13 8:27]
 * @updateUser : [WangWei]
 * @updateTime : [2023/1/13 8:27]
 * @updateRemark : [描述说明本次修改内容]
 */
public class Recv {
    private final static String QUEUE_NAME = "hello";

    public static void main(String[] argv) throws Exception {
        //创建工厂
        ConnectionFactory factory = new ConnectionFactory();
        //RabbitMQ服务器ip地址
        factory.setHost("ip");
        //端口号  默认值为5672
        factory.setPort(5672);
        //为用户分配的虚拟主机 默认值为/
        factory.setVirtualHost("/");
        //用户名  默认为guest
        factory.setUsername("用户名");
        //密码   默认为guest
        factory.setPassword("密码");
        
        //打开一个连接和通道，并声明队列
        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 deliverCallback = (consumerTag, delivery) -> {
            String message = new String(delivery.getBody(), "UTF-8");
            System.out.println(" [x] Received '" + message + "'");
        };
        channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> { });
    }
}

运行生产者类生产消息，执行Send类中的Main方法，执行的结果图
在这里插入图片描述
访问RabbitMQ Web端，可以在queue中找到名为hello的队列，可以看到已经有一条消息在队列中了。

运行消费者类，消费这条消息，并将消息内容打印到控制台上。

再次访问RabbitMQ web端，可以在hello队列中看到消息已经被消费了。
在这里插入图片描述