拼多多面试官没想到RabbitMQ我早就入门了，人直接傻掉

小鱼儿 2021-05-12 11:50 447阅读 0赞

拼多多面试官没想到RabbitMQ我早就入门了，人直接傻掉。

人一辈子最值得炫耀的不应该是你的财富有多少（虽然这话说得有点违心，呵呵），而是你的学习能力。技术更新迭代的速度非常快，那作为程序员，我们就应该拥有一颗拥抱变化的心，积极地跟进。

在 RabbitMQ 入门之前，我已经入门了 [Redis][]、[Elasticsearch][] 和 [MongoDB][]，这让我感觉自己富有极客精神，非常良好。

![format_png][]

小伙伴们在继续阅读之前，我必须要声明一点，我对 RabbitMQ 并没有进行很深入的研究，仅仅是因为要用，就学一下。但作为一名负责任的技术博主，我是动了心的，这篇入门教程，小伙伴们读完后绝对会感到满意，忍不住无情地点赞，以及赤裸裸地转发。

当然了，小伙伴们遇到文章中有错误的地方，不要手下留情，可以组团过来捶我，但要保证一点，不要打脸，我怕毁容。

### 01、RabbitMQ 是什么 ###

首先，我知道，Rabbit 是一只兔子（哎呀妈呀，忍不住秀了一波自己的英语功底），可爱的形象已经跃然于我的脑海中了。那 MQ 又是什么呢？是 Message Queue 的首字母缩写，也就是说 RabbitMQ 是一款开源的消息队列系统。

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

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

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

![format_png 1][]

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

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

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

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

听我这样一解释，是不是对 RabbitMQ 的印象就很具象化了？小伙伴们，学起来吧！

### 02、安装 Erlang ###

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

![format_png 2][]

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

Erlang 下载地址如下：

[https://erlang.org/download/otp\_versions\_tree.html][https_erlang.org_download_otp_versions_tree.html]

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

![format_png 3][]

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

### 03、安装 RabbitMQ ###

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

[https://www.rabbitmq.com/install-windows.html][https_www.rabbitmq.com_install-windows.html]

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

![format_png 4][]

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

![format_png 5][]

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

![format_png 6][]

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

![format_png 7][]

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

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

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

rabbitmq-plugins enable rabbitmq_management

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

![format_png 8][]

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

![format_png 9][]

### 04、在 Java 中使用 RabbitMQ ###

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

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

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

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

![format_png 10][]

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

假如我向女朋友小巷写了一封情书，内容如下所示：

> 致小巷  
> 你好呀，小巷。  
> 你走了以后我每天都感到很闷，就像堂吉诃德一样，每天想念托波索的达辛妮亚。我现在已经养成了一种习惯，就是每两三天就要找你说几句不想对别人说的话。  
> 。。。。。。  
> 王二，5月20日

那这封情书要寄给小巷，我就需要跑到邮局，买上邮票，投递到邮箱当中。女朋友要收到这封情书，就需要邮递员尽心尽力，不要弄丢了。

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 语句不太熟悉，可以查看我之前写的[我去][Link 1]文章。

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

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

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

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

public class XiaoXiang { 
        private final static String QUEUE_NAME = "love";
        public static void main(String[] args) throws IOException, TimeoutException { 
            ConnectionFactory factory = new ConnectionFactory();
            Connection connection = factory.newConnection();
            Channel channel = connection.createChannel();
    
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            System.out.println("等待接收消息");
    
            DeliverCallback deliverCallback = (consumerTag, delivery) -> { 
                String message = new String(delivery.getBody(), "UTF-8");
                System.out.println(" [小巷] 接收到的消息 '" + message + "'");
            };
            channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> {  });
        }
    }

1）创建通道的代码和生产者差不多，只不过没有使用 try-with-resource 语句来自动关闭连接和通道，因为我们希望消费者能够一直保持连接，直到我们强制关闭它。

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

3）由于 RabbitMQ 将会通过异步的方式向我们推送消息，因此我们需要提供了一个回调，该回调将对消息进行缓冲，直到我们做好准备接收它们为止。

DeliverCallback deliverCallback = (consumerTag, delivery) -> { 
        String message = new String(delivery.getBody(), "UTF-8");
        System.out.println(" [小巷] 接收到的消息 '" + message + "'");
    };

`basicConsume()` 方法用于接收消息：

*  第一个参数为队列名（queue），和生产者相匹配（love）。
 *  第二个参数为 autoAck，如果为 true 的话，表明服务器要一次性交付消息。怎么理解这个概念呢？小伙伴们可以在运行消费者类 XiaoXiang 类之前，先多次运行生产者类 Wanger，向队列中发送多个消息，等到消费者类启动后，你就会看到多条消息一次性接收到了，就像下面这样。

等待接收消息
     [小巷] 接收到的消息 '小巷，我喜欢你。'
     [小巷] 接收到的消息 '小巷，我喜欢你。'
     [小巷] 接收到的消息 '小巷，我喜欢你。'

*  第三个参数为 DeliverCallback，也就是消息的回调函数。
 *  第四个参数为 CancelCallback，我暂时没搞清楚是干嘛的。

在消息发送的过程中，也可以使用 RabbitMQ 的管理面板查看到消息的走势图，如下所示。

![format_png 11][]

### 05、鸣谢 ###

好了，我亲爱的小伙伴们，以上就是本文的全部内容了，是不是看完后很想实操一把 RabbitMQ，赶快行动吧！如果你在学习的过程中遇到了问题，欢迎随时和我交流，虽然我也是个菜鸟，但我有热情啊。

另外，如果你想写入门级别的文章，这篇就是最好的范例。

我是沉默王二，一枚有趣的程序员。如果觉得文章对你有点帮助，请微信搜索「 **沉默王二** 」第一时间阅读，回复【**666**】更有我为你精心准备的 500G 高清教学视频（已分门别类）。

> 本文 [GitHub][] 已经收录，有大厂面试完整考点，欢迎 Star。

**原创不易，莫要白票，请你为本文点个赞吧**，这将是我写作更多优质文章的最强动力。

[Redis]: https://mp.weixin.qq.com/s/NPJkMy5RppyFk9QhzHxhrw
[Elasticsearch]: https://mp.weixin.qq.com/s/ZjsZxle7m_dfmVwVkq2ayg
[MongoDB]: https://mp.weixin.qq.com/s/qz0sNOFeS0GTW-H9cdnbJg
[format_png]: /images/20210511/3da614bfec2e45eba3bb63285498fc89.png
[format_png 1]: /images/20210511/1daecefebd0d45b793824764add74a66.png
[format_png 2]: /images/20210511/53b9f47a12cd43c9afc7bd91bcb11bb7.png
[https_erlang.org_download_otp_versions_tree.html]: https://erlang.org/download/otp_versions_tree.html
[format_png 3]: /images/20210511/9251c8835d5d467ab4d259c625afc322.png
[https_www.rabbitmq.com_install-windows.html]: https://www.rabbitmq.com/install-windows.html
[format_png 4]: /images/20210511/2bc22466d172413d9aa0f57be426aa00.png
[format_png 5]: /images/20210511/366a538e406c48078743c953d9091587.png
[format_png 6]: /images/20210511/e94ddcb1317b4ce294e72fab23a86d6e.png
[format_png 7]: /images/20210511/413b241d734d4198aa7fa83e99d6a1c7.png
[format_png 8]: /images/20210511/835a9e19034c490898014fca839cffab.png
[http_localhost_15672]: http://localhost:15672/
[format_png 9]: /images/20210511/695db40d66ab46e1873b8915dc9bb2db.png
[format_png 10]: /images/20210511/598881e38e194fbca5a258225b44db16.png
[Link 1]: https://mp.weixin.qq.com/s/fbTzH5B7mSr5v0tQ8mV2wA
[format_png 11]: /images/20210511/737a61dc96664717ab284cb80df62d86.png
[GitHub]: https://github.com/qinggee/itwanger.github.io