两个或多个系统间需要通过定时任务来同步数据，异构系弘的不同进程间想互调用 通讯的问题，可以用rabbitmq解决。rabbitmq擅长解决多系统 异构系统音的数据交换，也可以用于系统间服务的相互调用RPC。
ＡＭＱＰ，即Advanced Message Queuing Protocol,高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。消息中间件主要用于组件之间的解耦，肖息的发关者无需知道消息使用者的存在，反之亦然。
ＡＭＱＰ主要特征是面向消息 队列 路由（点对点和发布 订阅）可靠性 安全。
RabbitMQ是一个开源的ＡＭＱＰ实现，用于分布式系统中存储转发消息 在易用性 扩展性 高可用性方面表现不错。
ConnectionFactory
Connection
Channel都是RabbitMQ对外提供的ＡＰＩ中最基本的对象。Connection是RabbitMQ的socket链接，它封装了socket协议相关部分逻辑。ConnectionFactory为Connection的制造工厂。Channel是我们与RabbitMQ打交道的最重要的一个接口，我们大部分的业务操作是在Channel这个接口中完成的，包括定义Queue
定义Exchange
绑定queue与exchange
发布消息等。
Queue:队列，是RabbitMQ的内部的对象，用于存储消息。
Message
durability:在RabbitMQ服务器重启的情况下，也不会丢失消息，我们可以将Queue与Message都设置为可持久化的durable，这样可以保证绝大部分情况下我们的RabbitMQ消息不会丢失。但依然解决不了小概率丢失事件的发生 比如RabbitMQ服务器已经接收到生产者的消息，但还没来得及持久化该消息时RabbitMQ服务器就断电了，如果我们需要对这种小概率事件也要管理起来，那么我们要用到事务。
Prefetch
count:前面我们讲到如果有多个消费者同时订阅同一个Queue中的消息，Queue中的消息，Queue中的消息会被平摊给多个消费者。这时如果每个消息的处理时间不同，就有可能导致某些消费者一直在忙，而另外一些消费者很快就处理完手洋工作并一直空闲的情况。我们可以通过设置prefetchCount来限制Queue每次发关给每个消费都的消息数，比如我们设prefetchCount=1,则Queue每次给每个消费者发送一条消息；消费者处理完这条消息后Queue会再给该消费者发送一条消息。
Routeing
key:生产者在将消息发送给Exchange的时候，一般会指定一个routing
key，来指定这个消息的路由规则，而这个routing
key需要与Exchang
Type 及binding
key联合使用才能最终生效。在Exchang
Type与binding
key固定的情况下“在正常使用时一般这些内容都是固定配置好的”，我们的生产者就可以在发送消息给Exchange时，通过指定routing
key来决定消息流向哪里。RabbitMQ为routing
key设定长度为255
bytes.
Binding:RabbitMQ中通过Binding将Exchange与Queue关联起来，这样RabbitMQ就知道如何正确地将消息路由到指定的Queue了。
Exchange
Type:RabbitMQ常用Exchange
Type有fanout
direct topic headers这四种
direct类型的Exchange
路由规则也很简单，它会把消息路由到那些binding
key与routing
key完全匹配的 Queue中。
routing
key为一个句号“.”分隔的字符串我们将被句点号'.'分隔的每一段独立的字符串称为一个单词，如'stock.usd.nyse'
binding key与routing
key一样也是句点号'.'分隔的字符串
binding
key中可以存在两种特殊字符'*'与'#',用于做模糊匹配，其中'*'用于匹配一个单词，'#'用于匹配多个单词也可以为０个。
上图中的配置为例，routingKey=“quick.orange.rabbit”
的消息会同时路由到Q1与Q2，routingKey=”lazy.orange.fox”的消息会路由到Q1与Q2,routingKey='lazy.brown.fox'的消息会路由到Q2,routingKey='lazy.pink.rabbit'的消息会路由到Q2(只会投递Q2－次，虽然这个routingkey与Q2的两个bindingKey都区);routingKey='quick.brown.fox',routingKey='orange',routingKey='quick.orange.male.rabbit'的消息将会被 丢弃，因为它们没有匹配任何bindingKey.
Headers:headers烊型的Exchange不依赖于routing
key与bindingkey的匹配规则来路由消息，而是根据发送的消息内容中的header属性进行匹配。在绑定Queue与Exchange时指定一组键值对；当消息发送到 Exchange时，RabbitMQ会取到该消息的headers(也是一个键值对的形式)，对比其中的键值对是否完全匹配Queue与Exchange绑定时指定的键值对；如果完全匹配则消息会路由到该Queue，否则不会路由到Queue.
RPC:MQ本身是基于异步的消息处理，前面的示例中所有的生产者(P)将消息发关到RabbitMQ后不会知道消费者c处理成功或者失败，甚至连有没有消费者来除理这条消息都不知道。但实际的应用场景中，我们很可能需要一些同步等待服务端将我的消息处理完后再进行下一步处理。这相当于RPC(Remote
Procedure Call,远程过程调用)。在RabbitMQ中也支持RPC
服务器端收到消息并处理
服务器端处理完消息后，将生成一条应答消息到replyTo指定的Queue，同时带上correlationId属性
客户端之前订阅replyTo指定的Queue，从中收到服务器的应答消息后，根据其中的correlationId属性分析哪条请求被执行了，要据执行结果时行后续业务处理。
AMQP协议是一个高级抽象层消息通信协议，RabbitMQ 是AMQP协议的实现。
每个rabbitmq-server叫做一个broker,等着tcp连接进入。
Binding联系Exchane与Queue.
Routing key由生产者指定。Binding key由消费者指定。二者联合决定一条消息的来去。