RabbitMQ安装入门教程。

01、RabbitMQ 是什么

RabbitMQ 是一款开源的消息队列系统。

RabbitMQ 的主要特点在于健壮性好、易于使用、高性能、高并发、集群易扩展，以及强大的开源社区支持。反正就是很牛逼的样子。

九年前我做大宗期货交易的时候，也需要消息推送，那时候还不知道去找这种现成的中间件，就用自定义的队列实现，结果搞了不少 bug，有些到现在还没有解决，真的是不堪回首的往事啊。

下图是 RabbitMQ 的消息模型图（来源于网络，侵删），小伙伴们来感受下。

1）P 是 Producer，代表生产者，也就是消息的发送者，可以将消息发送到 X

2）X 是 Exchange（为啥不是 E，我也很好奇），代表交换机，可以接受生产者发送的消息，并根据路由将消息发送给指定的队列

3）Q 是 Queue，也就是队列，存放交换机发送来的消息

4）C 是 Consumer，代表消费者，也就是消息的接受者，从队列中获取消息

02、安装 Erlang

咦，怎么不是安装 RabbitMQ 啊？先来看看官方的解释。

英文看不太懂，没关系，我来补充两人话。RabbitMQ 服务器是用 Erlang 语言编写的，它的安装包里并没有集成 Erlang 的环境，因此需要先安装 Erlang。小伙伴们不要担心，Erlang 安装起来没有任何难度。

Erlang 下载地址如下：

https://erlang.org/download/otp_versions_tree.html

最新的版本是 23.0.1，我选择的是 64 位的版本，104M 左右。下载完就可以双击运行安装，傻瓜式的。

需要注意的是，我安装的过程中，电脑重启了一次，好像要安装一个什么库，重启之前忘记保存图片了（sorry）。重启后，重新双击运行 otp_win64_23.0.1.exe 文件完成 Erlang 安装。

03、安装 RabbitMQ

Erlang 安装成功后，就可以安装 RabbitMQ 了。下载地址如下所示：

https://www.rabbitmq.com/install-windows.html

找到下图中的位置，选择红色框中的文件进行下载。

安装包只有 16.5M 大小，还是非常轻量级的。下载完后直接双击运行 exe 文件就可以傻瓜式地安装了。

安装成功后，就可以将 RabbitMQ 作为 Windows 服务启动，可以从“开始”菜单管理 RabbitMQ Windows 服务。

点击「RabbitMQ Command Prompt (sbin dir)」，进入命令行，输入 rabbitmqctl.bat status 可确认 RabbitMQ 的启动状态。

可以看到 RabbitMQ 一些状态信息：

• 进程 ID，也就是 PID 为 2816
• 操作系统为 Windows
• 当前的版本号为 3.8.4
• Erlang 的配置信息

命令行界面看起来不够优雅，因此我们可以输入以下命令来启用客户端管理 UI 插件：

rabbitmq-plugins enable rabbitmq_management

看到以下信息就可以确认插件启用成功了。

在浏览器地址栏输入 http://localhost:15672/ 可以进入管理端界面，如下图所示：

04、在 Java 中使用 RabbitMQ

有些小伙伴可能会问，“二哥，我是一名 Java 程序员，我该如何在 Java 中使用 RabbitMQ 呢？”这个问题问得好，这就来，这就来。

第一步，在项目中添加 RabbitMQ 客户端依赖：

    com.rabbitmq    amqp-client    5.9.0

第二步，我们来模拟一个最简单的场景，一个生产者发送消息到队列中，一个消费者从队列中读取消息并打印。

官方对 RabbitMQ 有一个很好的解释，我就“拿来主义”的用一下。在我上高中的年代，同学们之间最流行的交流方式不是 QQ、微信，甚至短信这些，而是书信。因为那时候还没有智能手机，况且上学期间学校也是命令禁用手机的，所以书信是情感表达的最好方式。好怀念啊。

RabbitMQ 就像邮局一样，只不过处理的不是邮件，而是消息。之前解释过了，P 就是生产者，C 就是消费者。

新建生产者类 Wanger ：

public class Wanger {
    private final static String QUEUE_NAME = "love";
    public static void main(String[] args) throws IOException, TimeoutException {
        ConnectionFactory factory = new ConnectionFactory();

        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            String message = "小巷，我喜欢你。";
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes(StandardCharsets.UTF_8));
            System.out.println(" [王二] 发送 '" + message + "'");
        }
    }
}

1）QUEUE_NAME 为队列名，也就是说，生产者发送的消息会放到 love 队列中。

2）通过以下方式创建服务器连接：

ConnectionFactory factory = new ConnectionFactory();
try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {

ConnectionFactory 是一个非常方便的工厂类，可用来创建到 RabbitMQ 的默认连接（主机名为“localhost”）。然后，创建一个通道（ Channel）来发送消息。

Connection 和 Channel 类都实现了 Closeable 接口，所以可以使用 try-with-resource 语句，如果有小伙伴对 try-with-resource 语句不太熟悉，可以查看我之前写的我去文章。

3）在发送消息的时候，必须设置队列名称，通过 queueDeclare() 方法设置。

4）basicPublish() 方法用于发布消息：

• 第一个参数为交换机（exchange），当前场景不需要，因此设置为空字符串；
• 第二个参数为路由关键字（routingKey），暂时使用队列名填充；
• 第三个参数为消息的其他参数（BasicProperties），暂时不配置；
• 第四个参数为消息的主体，这里为 UTF-8 格式的字节数组，可以有效地杜绝中文乱码。

生产者类有了，接下来新建消费者类 XiaoXiang：