SpringBoot日记——MQ消息队列整合（一）

　　除了以前讲到的缓存，咱们还会用到消息队列来存储一些消息，为了提高系统的异步性能等等；

　　消息服务有两个概念须要知道：消息代理-message broker，目的地-destination。消息发送由代理接管并传递到指定目的地：

　　　　—— 消息只有惟一的发送和接受者，消息从队列中取出就不在了。

　　目的地有两种形式：queue-点对点的消息队列、topic-发布（publish）和订阅（subscribe）的消息通讯主题；

　　　　—— 发送一个消息主题，多个订阅者经过监听得知消息的发布并取得；0

　　我要介绍的以AMQP协议的RabbitMQ为例：

RabbitMQ

　　

　　1、基本概念及结构关系：

　　Message-消息，它是由几个属性组成的，具有消息头和消息体；

　　Publish-消息生产者，向交换器发布消息的一个应用程序；

　　Exchange-交换器，接收消息，并把消息路由给服务器中的队列，属于分配的角色； Exchange有四种类型：direct、fanout、topic和headers。这四种转发消息的策略有区别：

　　Queue-消息队列，保存消息的容器，一个Broker中能够有多个消息队列；

　　Binding-绑定，将Exchange和Queue绑定；

　　Connection-网络链接，好比Tcp链接；

　　Channel-信道，创建在TCP链接中的虚拟的，双向数据流通道；AMQP命令就是经过信道将消息发送、发布、订阅和接收的；

　　Consumer-消息接收者，也叫消息的消费者，用来接收和获取消息的一端应用；

　　Virtual Host-虚拟主机，每一个虚拟主机相对独立，至关于一个独立的mini的RabbitMQ服务器，默认是“/”；

　　Broker-消息队列服务器实体；

　　这些基本概念的关系如图：（不细说）

　　

 

　　2、运行机制：

　　Exchange咱们上边介绍了，有4种策略类型，其中header是对消息中的header进行匹配的，使用相对少。下边主要介绍另外三种都是匹配路由键（routing key）的：

　　　　direct：以单播的模式，若是发送的路由键和咱们绑定的key一致，那么就发送到该队列中。好比咱们发送aaa，那么就只有介绍aaa的Queue的key才会接收和取走这条消息，即彻底匹配、1v1收发；

　　　　fanout：广播模式发送消息到每个消息队列中，不管路由键是什么。好比咱们发送aaa，那么不管有多少个消息队列，咱们都发；

　　　　topic：将咱们发出的消息，按照匹配规则模糊的来收发。好比，咱们发送aaa.bb，那么咱们就发送到aaa.#和*.bb中，而不会发送到其余好比ccc.#的消息队列中；

　　　　　　　　（*匹配一个单词，#匹配0或多个单词-好比aa.bb.cc）

　　　　

RabbitMQ的安装测试

　　这里介绍两种安装和启用的方法：（windows和docker）

　　1.windows环境下的安装和使用：

　　1）、在windows环境下，咱们须要先依赖一个ErLang的语言开发包，下载地址：http://www.erlang.org/downloads，根据你的系统选择32或64位版本的安装

　　而后配置一下环境变量：

　　ERLANG_HOME = C:\Program Files\er21.0　　（你的安装目录）
　　Path 中加入 %ERLANG_HOME%\bin;

　　测一下是否安装成功，以下图，OK（输入：erl）

　　2）、下载和安装RabbitMQ，下载地址：http://www.rabbitmq.com/download.html ，选择windows版本

　　一样安装和配置环境变量：

　　RABBITMQ_SERVER = C:\Program Files\RabbitMQ Server\rabbitmq_server-3.7.1　　（安装目录）
　　在path中加入：%RABBITMQ_SERVER%\sbin;

　　而后安装插件-用来实现界面管理的，在命令行中输入： rabbitmq-plugins.bat enable rabbitmq_management　　（图片是网上扒的，不要在乎细节~）

　　启动MQ服务，为了防止异常状况，咱们这里要求使用管理员模式的命令行窗口输入：

net stop RabbitMQ && net start RabbitMQ

　　若是想中止服务：rabbitmq-service stop

 

　　2.docker下的安装和使用：

　　1）、首先连接服务器，而后检查镜像，若是没有MQ的，咱们去官方hub网站查看一下，咱们选择标签中带有management的进行下载，这个是带有web管理界面的；

　　在服务器中键入该命令进行下载：

docker pull registry.docker-cn.com/library/rabbitmq:3-management

　　这样，镜像就安装好了。那么咱们来启动这个mq服务：(mq默认端口就是这两个)

docker run -d -p 5672:5672 -p 15672:15672 --name myrabbitmq df0ee1f2343b

 

使用RabbitMQ的web管理界面

　　使用上边的方法，咱们成功的安装和启动了MQ服务，那么咱们来使用web管理界面来检查下，是否可使用吧。

　　在浏览器的地址栏输入(默认帐户密码是guest/guest，有须要本身再添加设置)

　　ip:15672
　　若是是windows本地搭建：localhost:15672
　　若是是docker搭建的：xx.xx.xx.xx:15672　　ip是服务器地址，能够经过ip addr查看你服务器的ip地址

　　登陆之后，能够看到咱们以前讲的那些字段，而后添加咱们须要的东西就能够了，下边不具体介绍，几个图本身领会一下吧~

　　步骤：添加Exchange、添加Queue、进入Exchange绑定Queue、在Exchange内发送消息、到Queue中获取该消息

 　　这里单独说一下关于topic键的输入，按照以前说过的规则来写：

 

 　　　将RabbitMQ整合到SpringBoot中

　　web客户端咱们应该有一些了解了，那如何在代码中应用呢？先来看如何作关联，很简单，在pom.xml中加入这一段：

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>

　　1）、关于使用，这里其实跟redis缓存同样，咱们使用注解：

@EnableRabbit　　  //使用rabbitMQ的注解
@RabbitListener　　//监听rabbitMQ消息

　　一样，为了获得的数据是json格式的，咱们直接本身自定义一个类：

import org.springframework.amqp.rabbit.annotation.EnableRabbit;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
@EnableRabbit　　//启动rabbit注解
public class MyAMQPConfig {
　　// 将消息以json格式传递
    @Bean
    public MessageConverter messageConverter() {
        return new Jackson2JsonMessageConverter();
    }
}

　　来测试一下，咱们添加的MQ是否可用吧：……有点长，换下一篇文章=。=b