这篇文章主要介绍了RabbitMQ的功能和特点。RabbitMQ是一款由Erlang语言开发的消息队列工具，支持多种编程语言和协议，通过队列实现程序间的通信，无需直接连接。它具有高可靠性和可扩展性，适合构建分布式系统。
文章详细讲解了RabbitMQ的核心组件Exchange（交换机）和Queue（队列），以及它们如何通过绑定键进行消息路由。还提供了安装教程，包括插件启用、管理界面访问等步骤，并展示了生产者和消费者的基本创建流程。
作为开发者，我觉得RabbitMQ的可视化管理和多语言支持非常友好，特别适合需要处理异步通信和高并发场景的应用。不过，初次接触的朋友可能需要花时间熟悉其配置和使用细节。总体来说，它是一个功能强大且灵活的消息中间件工具。
RabbitMQ官方版全称为Rabbit Message Queue，它是由erlang语言编写的一款应用程序通信方法插件。有了它，应用程序可通过读写出入队列的消息（针对应用程序的数据）来通信，而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，直接调用通常是用于诸如远程过程调用的技术。排队指的是应用程序通过 队列来通信。队列的使用除去了接收和发送应用程序同时执行的要求。其中较为成熟的MQ产品有IBM WEBSPHERE MQ等。
RabbitMQ是由LShift提供的一个Advanced Message Queuing Protocol(AMQP)的开源实现，由以高性能、健壮以及可伸缩性出名，因此也是继承了这些优点。AMQP里主要要说两个组件：Exchange 和 Queue，如下图所示，绿色的X 就是Exchange，红色的是Queue ，这两者都在Server端，这部分是RabbitMQ实现的，而蓝色的则是客户端，通常有Producer 和Consumer两种类型TIFF, VDA, VST, WBMP 和 WMF等，它使用了不同的图像滤镜和图像效果，功能非常强大，有需要的朋友可以来多多软件站下载使用哦~
软件亮点
1、可靠性
RabbitMQ可通过队列持久化，交换机持久化，消息持久化及ACK回应等机制保证可靠性。
2、支持多种语言与协议
RabbitMQ几乎支持所有的编程语言，还支持AMQP，STOMP，MQTT等多种协议。
3、管理界面
RabbitMQ有一个可视化的管理界面可以用来直观的查看RabbitMQ的状态及运行情况。
4、可灵活的扩展
多个RabbitMQ节点可以组成一个集群，队列可以在集群中的机器上设置镜像，使得在部分节点出现问题的情况下队仍然可用。
软件特色
1、支持producer：消息生产者
2、支持consumer：消息消费者
3、支持virtual host：虚拟主机，在RabbitMQ中，用户只能在虚拟主机的层面上进行一些权限设置，比如我可以访问哪些队列，我可以处理哪些请求等等
4、broker：消息转发者，也就是我们RabbitMQ服务端充当的功能了，那么消息是按照什么规则进行转发的呢，需要用到下面几个概念：
①exchange：交换机，他是和producer直接进行打交道的，有点类似于路由器的功能，主要就是进行转发操作的呗，那么producer到底用哪个exchange进行路由呢，这个取决于routing key(路由键)，每个消息都有这个键，我们也可以自己设定，其实就是一字符串
②queue：消息队列，用于存放消息，他接收exchange路由过来的消息，我们可以对队列内容进行持久化操作，那么queue到底接收那个exchange路由的消息呢，这个时候就要用到binding key(绑定键)了，绑定键会将队列和exchange进行绑定
RabbitMQ安装使用教程
1、双击安装下载好的RabbitMQ插件，安装完成之后，点击计算机属性，高级系统设置，创建一个名为ERLANG_HOME的环境变量，其值指向erlang的安装目录，同时将%ERLANG_HOME%\bin加入到Path中，最后打开命令行，输入erl，如果出现erlang的版本信息就表示erlang语言环境安装成功
2、打开命令行cd进入rabbitmq的sbin目录(我的目录是：E:\software\rabbitmq\rabbitmq_server-3.6.5\sbin)，输入：rabbitmq-plugins enable rabbitmq_management命令，稍等会会发现出现plugins安装成功的提示，默认是安装6个插件
3、插件安装完之后，在浏览器输入http://localhost:15672进行验证，你会看到下面界面，输入用户名：guest，密码：guest你就可以进入管理界面，当然用户名密码你都可以变的
4、producer(生产者)端创建步骤：
①：创建ConnectionFactory，并且设置一些参数，比如hostname,portNumber等等
②：利用ConnectionFactory创建一个Connection连接
③：利用Connection创建一个Channel通道
④：创建queue并且和Channel进行绑定
⑤：创建消息，并且发送到队列中
注意：在我们当前的例子中，并没有用到exchange交换机，RabbitMQ默认情况下是会创建一个空字符串名字的exchange的，如果我们没有创建自己的exchange的话，默认就是使用的这个exchange
5、consumer(消费者)端创建步骤：
①：创建ConnectionFactory，并且设置一些参数，比如hostname,portNumber等等
②：利用ConnectionFactory创建一个Connection连接
③：利用Connection创建一个Channel通道
④：将queue和Channel进行绑定，注意这里的queue名字要和前面producer创建的queue一致
⑤：创建消费者Consumer来接收消息，同时将消费者和queue进行绑定
共有 0条评论