我们用java来举例子， 打个比方 我们客户端发送一个下单请求给订单系统（order）订单系统发送了一个请求给我们的库存系统告诉他需要更改库存了， 我已经下单了， 这里， 每一个请求我们都可以看作一条消息。
但是我们客户端需要等待订单系统告诉我这条消息的处理结果（我到底有没有下单成功）。
可是订单系统不需要知道库存系统这条消息的处理情况，因为无论你库存有没有改动成功，我订单还是下了，因为是先下完了订单（下成功了）才去更改库存，库存如果更改出BUG了，那是库存系统的问题， 这个BUG不会影响订单系统。
如果这里你能理解的话，那么我们就能发现我们用户发送的这条消息（下订单），是需要同步的（我需要知道结果），订单发送给库存的消息，是可以异步的（我不想知道你库存到底改了没，我只是通知你我这边成功下了一个订单）那么如果我们还按原来的方式去实现这个需求的话， 那么结果会是这样： 这时我们可以启用线程去访问库存系统 使用线程池解决 确实可以， 但是也有他的缺点， 那么 到底怎么来完美解决这个问题呢？
下面这个消息系统， 就是我们的消息中间件
我们刚刚介绍了什么是消息中间件， 那么RabbitMq就是对于消息中间件的一种实现，市面上还有很多很多实现， 比如RabbitMq、ActiveMq、ZeroMq、kafka，以及阿里开源的RocketMQ等等，我们这节主要讲RabbitMq
想要了解RabbitMq就要先了解AMQP
这里引用百度的一句话，再加以我的理解：AMQP 其实和Http一样，都是一种协议， 只不过 Http是针对网络传输的， 而AMQP是基于消息队列的。
这种类型的交换机的路由规则是根据一个routingKey的标识，交换机通过一个routingKey与队列绑定 ，在生产者生产消息的时候指定一个routingKey，当绑定的队列的routingKey与生产者发送的一样，那么交换机会把这个消息发送给对应的队列。
fanout这种类型的交换机路由规则很简单，只要与他绑定了的队列， 他就会把消息发送给对应队列（与routingKey没关系）。
topic这种类型的交换机路由规则也是和routingKey有关，只不过topic可以根据*和#（ *代表过滤一单词，#代表过滤后面所有单词， 用.隔开）来识别routingKey。
假设我绑定的routingKey有队列A和B，A的routingKey是*.user，B的routingKey是#.user。
那么我生产一条消息routingKey为error.user那么此时 2个队列都能接受到， 如果改为topic.error.user那么这时候，只有B能接受到了。
headers这个类型的交换机很少用到，他的路由规则 与routingKey无关 而是通过判断header参数来识别的， 基本上没有应用场景，因为上面的三种类型已经能应付了。
MQ：Message Queue 顾名思义是消息队列， 队列大家都知道， 存放内容的一个东西， 存放的内容先进先出， 消息队列， 只是里面存放的内容是消息而已。
RabbitMq是一个开源的，基于AMQP协议实现的一个完整的企业级消息中间件，服务端语言由Erlang（面向并发编程）语言编写对于高并发的处理有着天然的优势，客户端支持非常多的语言：
PythonJavaRubyPHPC#JavaScriptGoElixirObjective-CSwift在介绍消息中间件的时候所提到的“消息系统”便是我们这节的主题。RabbitMq如同redis一样，他也是采用c/s架构，由服务端与客户端组成，我们现在我们计算机上部署他的服务端。
安装Erlang和RabbitMQ由于我们刚刚介绍过了RabbitMQ服务端是由Erlang语言编写所以我们这里先下载Erlang语言的环境。
注意：如果是在官网下的RabbitMQ服务端的话 Erlang语言的版本不能太低， 不然要卸载掉旧的去装新的， 我们这里下载OTP21.0版本直接从外网下载会很慢， 我这里直接贴上百度网盘的地址（因为这个东西还是有点大的）。
https://pan.baidu.com/s/1pZJ8l2f3omrgnuCm9a8DVA
我们再去官网下载RabbitMq的服务端安装包
http://www.rabbitmq.com/download.html
注意需要先下载Erlang再下载安装包安装， 不然安装RabbitMQ服务端的时候会提示你本地没有Erlang环境。
启动RabbitMQ在系统-服务中找到如下即可
启动RabbitMQ管理工具RabbitMQ安装会附带一个管理工具（方便我们能直观的查看整个RabbitMQ的运行状态和详细数据等，有点像Navicat 对应Mysql的关系） 值得一提的是， 管理工具和RabbitMQ是两码事，希望不要混稀了。
到你们安装的RabbitMQ Server\rabbitmq_server-3.7.12\sbin目录下面执行一条cmd命令
rabbitmq-plugins enable rabbitmq_management当然也可以配置一个环境变量或者在我们的开始菜单栏中找到下面这个Command
然后就可以访问http://127.0.0.1:15672管理页面 存在默认的账号，密码和账号都是guest 下面演示一下如何删除和添加用户
首先点击admin页签， 在下面找到Add User 然后输入账号 密码 确认密码 这个Tags其实是一个用户权限标签， 关于他的介绍可以看官方介绍（点旁边那个小问号就好了，我这里直接翻译他的介绍） 填写完之后点击AddUser 就可以添加一个用户了， 添加完用户之后还要给这个用户添加对应的权限（注：Targ不等于权限），比如说刚刚添加了一个jojo角色 点击这个jojo可以进去给他添加权限，这个权限可以是 Virtual host 级别的，也可以是交换机级别的，甚至是细化到某一个读写操作，这里就给他添加一个Virtual host权限 这里 我们给了他 testhost这个Virtual host的权限 正则匹配都是* 也就是所有权限 然后点击set添加完毕。这里简单介绍一下java代码如何连接RabbitMq和使用RabbitMq的。而且在消息系统中存在两个角色，生产者和消费者，顾名思义，一个负责生产信息，将信息放到RabbitMq消息队列中，而另一个则是从RabbitMq消息队列中拿到想要的信息。
下面会分别介绍两种角色是如何通过java代码使用完成自己的工作的。
不论是生产者还是消费者都需要和RabbitMq连接，而且两者连接的代码都是一样的，因为两者都属于是RabbitMq的客户端。
public class ConnectionUtil { public static final String QUEUE_NAME = "testQueue"; public static final String EXCHANGE_NAME = "exchange"; public static Connection getConnection() throws Exception{ //创建一个连接工厂 ConnectionFactory connectionFactory = new ConnectionFactory(); //设置rabbitmq 服务端所在地址 我这里在本地就是本地 connectionFactory.setHost("127.0.0.1"); //设置端口号，连接用户名，虚拟地址等 connectionFactory.setPort(5672); connectionFactory.setUsername("jojo"); connectionFactory.setPassword("jojo"); connectionFactory.setVirtualHost("testhost"); return connectionFactory.newConnection(); } }