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）消息接收者对应的案例代码如下
代码仅作为案例参考，启动程序后，会消费掉发布者发布的数据，并持续监听消费
实现消息可靠性投递方案
设计方案一
网友评论