RabbitMQ消息中间件入门及实践

RabbitMQ简介、AMQP协议及流转机制

    RabbitMQ是一个开源的消息代理和队列服务器，用于通过普通协议在完全不同的应用之间共享数据，RabbitMQ是使用Erlang语言来编写并且基于AMQP（Advanced Message Queuing Protocol,高级消息队列协议），协议模型如下：

发布者发布消息到虚拟主机的交换机上，然后经过路由放到Message Queue，接收者只关注于Message Queue监听消息。

RabbitMQ在Window下的安装与使用

    Erlang下载地址：https://www.erlang.org/downloads                                                                                                      安装完成后添加系统变量：ERLANG_HOME/"安装地址"                                                                                            添加path环境变量：%ERLANG_HOME%\bin

    RabbitMQ下载地址：https://www.rabbitmq.com/（找到Downloads on Bintray - Windows installer)

    以上安装完成后，进入RabbitMQ目录下的sbin目录下运行命令行工具：rabbitmq-plugins enable     rabbitmq_management 来安装RabbitMQ-Plugins

    输入rabbitmqctl status，查看安装是否成功

    打开sbin目录，双击rabbitmq-server.bat，访问http://localhost:15672/，输入登录名和密码，初始值都为guest

RabbitMQ核心概念

    Server ：又称Broker，接受客户端的连接，实现AMQP实体服务；

    Connection ：连接，应用程序和Broker的网络连接；

    Channel：网络通道，几乎所有的操作都在Channel中进行，Channel是进行消息读写的通道。客户端可建立多个Channel，每个Channel代表一个会话任务。

    Message：消息，服务器和应用程序之间的传送数据，由Properties和Body组成。Properties可以对消息进行修饰，比如消息的优先级、延迟等高级特性；Body则是消息体内容。

    Virtual host：虚拟地址，用于进行逻辑隔离，最上层的消息路由。一个Virtual host里面可以有若干个Exchange和Queue，同一个Virtual host里面不能有相同名称的Exchange和Queue。

    Exchange：交换机，接收消息，根据路由键转发消息到绑定的队列。

    Binding：Exchange和Queue之间的虚拟连接，binding可以包含routing key。

    Routing key：一个路由规则，虚拟机可用它来确定如何路由一个特定消息。

    Queue：也称Message Queue，消息队列，保存消息并将它们转发给消费者。    

RabbitMQ整合springboot

    1）添加依赖

添加项目依赖，其余按照个人项目需求进行配置

    2）配置application.properties

消息接收、发送配置文件，仅供参考，部分数据并未写进参数

    3）消息发布者对应的案例代码如下

编写的Component类用做测试用 测试代码，执行成功后，会在管理后台生成一条数据

    4）消息接收者对应的案例代码如下

代码仅作为案例参考，启动程序后，会消费掉发布者发布的数据，并持续监听消费

实现消息可靠性投递方案

设计方案一