rabbitmq 基本信息

ny3259

　　两个或多个系统间需要通过定时任务来同步数据，异构系弘的不同进程间想互调用　通讯的问题，可以用rabbitmq解决。rabbitmq擅长解决多系统　异构系统音的数据交换，也可以用于系统间服务的相互调用RPC。
　　ＡＭＱＰ，即Advanced Message Queuing Protocol,高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。消息中间件主要用于组件之间的解耦，肖息的发关者无需知道消息使用者的存在，反之亦然。
　　ＡＭＱＰ主要特征是面向消息　队列　路由（点对点和发布　订阅）可靠性　安全。
　　RabbitMQ是一个开源的ＡＭＱＰ实现，用于分布式系统中存储转发消息　在易用性　扩展性　高可用性方面表现不错。
　　

　　ConnectionFactoryConnectionChannel都是RabbitMQ对外提供的ＡＰＩ中最基本的对象。Connection是RabbitMQ的socket链接，它封装了socket协议相关部分逻辑。ConnectionFactory为Connection的制造工厂。Channel是我们与RabbitMQ打交道的最重要的一个接口，我们大部分的业务操作是在Channel这个接口中完成的，包括定义Queue定义Exchange绑定queue与exchange发布消息等。
　　Queue:队列，是RabbitMQ的内部的对象，用于存储消息。

　　

　　

　　

　　

　　

　　RabbitMQ中的消息都能存储在Queue中，生产者下图的Ｐ，生产消息并最终投递到Queue中，消费者下图的Ｃ，可以从Queue中获取消息并消费。

　　

　　

　　

　　

　　多个消费者可能订阅同一个Queue,这时Queue中的消息会被平均分摊给多个消费者进行处理，而不是每个消费者都收到所有的消息并处理。
　　

　　

　　

　　

　　

　　

　　

　　Messageacknowledgement:在实际应用中，可能会发生消费者收到Queue中的消息，但没有处理完成就宕机或出现其它的意外的情况，这种情况下就可能会导致消息丢失。为了避免这咱情况的发生，我们可以要求消费者在消费完消息后发一个回执给RabbitMQ,RabbitMQ收到消息回执(Messageacknowledgment)后才将该消息从Queue中移除；如果RabbitMQ没有收到回执并检测到消费者的RabbitMQ连接断开，刚RabbitMQ会将该消息发送给其他消费者如果　存在多个消费者　进行除理。这里不存在timeout的概念，一个消费者外理消息的时间再长也不会导致该消息被　发送给其他消费者，除非它的RabbitMQ连接断开。
　　Messagedurability:在RabbitMQ服务器重启的情况下，也不会丢失消息，我们可以将Queue与Message都设置为可持久化的durable，这样可以保证绝大部分情况下我们的RabbitMQ消息不会丢失。但依然解决不了小概率丢失事件的发生　比如RabbitMQ服务器已经接收到生产者的消息，但还没来得及持久化该消息时RabbitMQ服务器就断电了，如果我们需要对这种小概率事件也要管理起来，那么我们要用到事务。
　　Prefetchcount:前面我们讲到如果有多个消费者同时订阅同一个Queue中的消息，Queue中的消息，Queue中的消息会被平摊给多个消费者。这时如果每个消息的处理时间不同，就有可能导致某些消费者一直在忙，而另外一些消费者很快就处理完手洋工作并一直空闲的情况。我们可以通过设置prefetchCount来限制Queue每次发关给每个消费都的消息数，比如我们设prefetchCount=1,则Queue每次给每个消费者发送一条消息；消费者处理完这条消息后Queue会再给该消费者发送一条消息。

　　

　　

　　

　　

　　

　　

　　Exchange:生产者将消息发送到Exchange(交换器，下图中的x),由于Exchange将消息路由到一个或多个Queue中或丢弃。

　　

　　

　　

　　

　　

　　

　　RabitMQ中的Exchange有四种类型，不同的类型有着不同的路由策略。
　　Routeingkey:生产者在将消息发送给Exchange的时候，一般会指定一个routingkey，来指定这个消息的路由规则，而这个routingkey需要与ExchangType 及bindingkey联合使用才能最终生效。在ExchangType与bindingkey固定的情况下“在正常使用时一般这些内容都是固定配置好的”，我们的生产者就可以在发送消息给Exchange时，通过指定routingkey来决定消息流向哪里。RabbitMQ为routingkey设定长度为255bytes.
　　Binding:RabbitMQ中通过Binding将Exchange与Queue关联起来，这样RabbitMQ就知道如何正确地将消息路由到指定的Queue了。

　　

　　

　　

　　

　　

　　Bindingkey:在绑定Exchange与Queue的同时，一般会指定一个bindingkey;消费者将消息发送给Exchange时，一般会指定一个routingkey；当bindingkey与routingkey相匹配时，消息将会被路由到对应的Queue中。在绑定多个Queue到同一个Exchange的时候，这些Binding允许使用相同的bindingkey.binding key并不是在所有情况下都生效，它信赖于ExchangeType，比如fanout烊型的Exchange就会无视bindingkey，而是将消息路由到所有绑定到该Exchange的Queue.
　　ExchangeType:RabbitMQ常用ExchangeType有fanoutdirect topic headers这四种

fanout类型的Exchange路由规则非常简单，它会把所有发送到该Exchange的消息路由到所有它绑定的Queue中。

　　

　　

　　

　　

　　

　　

　　

　　

　　上图中，生产者Ｐ发送到ExchangeX的所有消息都会路由到图中的两个Queue，并最终被两个消费者c1与c2消费。
　　direct类型的Exchange路由规则也很简单，它会把消息路由到那些bindingkey与routingkey完全匹配的　Queue中。

　　

　　

　　

　　

　　

　　

　　

　　

　　

　　以上图的配置为例，我们以routingKey=”error”发送消息到Exchange,则消息会路由到Queue1(amqp.gen-....,这是由RabbitMQ自动生成的Queue名称)和Queue2(amqp.gen-...);如果我们以routingKey=”info”或routingKey=”warning”来发送消息，则消息只会路由到Queue2,如果我们以其他routingKey发送消息，则消息不会路由到这两个Queue中。
　　

Topic:前面讲到direct类型的Exchange路由规则是完全匹配bindingkey与routingkey,但这咱严格的匹配方式在很多情况下不能满足实际业务需求。topic类型的Exchange在匹配规则上进行了扩展，它与direct类型的Exchange相似，也是将消息路由到bindingkey与routingkey相匹配的Queue中，但这里的匹配规则有些不同：

　　routingkey为一个句号“.”分隔的字符串我们将被句点号'.'分隔的每一段独立的字符串称为一个单词，如'stock.usd.nyse'
　　binding key与routingkey一样也是句点号'.'分隔的字符串
　　bindingkey中可以存在两种特殊字符'*'与'#',用于做模糊匹配，其中'*'用于匹配一个单词，'#'用于匹配多个单词也可以为０个。
　　

　　

　　

　　

　　

　　

　　

　　

　　

　　

　　

　　

　　上图中的配置为例，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不依赖于routingkey与bindingkey的匹配规则来路由消息，而是根据发送的消息内容中的header属性进行匹配。在绑定Queue与Exchange时指定一组键值对；当消息发送到　Exchange时，RabbitMQ会取到该消息的headers(也是一个键值对的形式)，对比其中的键值对是否完全匹配Queue与Exchange绑定时指定的键值对；如果完全匹配则消息会路由到该Queue，否则不会路由到Queue.
　　RPC:MQ本身是基于异步的消息处理，前面的示例中所有的生产者(P)将消息发关到RabbitMQ后不会知道消费者c处理成功或者失败，甚至连有没有消费者来除理这条消息都不知道。但实际的应用场景中，我们很可能需要一些同步等待服务端将我的消息处理完后再进行下一步处理。这相当于RPC(RemoteProcedure Call,远程过程调用)。在RabbitMQ中也支持RPC

　　

　　

　　

　　

　　

　　

　　

　　

　　

　　

　　RabbitMQ中实现发送请求（消息）时，在消息的属性(MessageProperties,在AMQP协议中定义了14种properties,这些属性会随着消息一起发送)中设置两个值replyTo（一个Queue名称，用于告诉服务处理完成后将通知我的消息发到这个Queue中）和correlationId(此次请求的标识号，服务器外理完成后需要将此属性返还，客户端将根据这个id了解哪条请求被成功执行了或执行失败)
　　服务器端收到消息并处理
　　服务器端处理完消息后，将生成一条应答消息到replyTo指定的Queue，同时带上correlationId属性
　　客户端之前订阅replyTo指定的Queue，从中收到服务器的应答消息后，根据其中的correlationId属性分析哪条请求被执行了，要据执行结果时行后续业务处理。
　　AMQP协议是一个高级抽象层消息通信协议，RabbitMQ 是AMQP协议的实现。
每个rabbitmq-server叫做一个broker,等着tcp连接进入。
Binding联系Exchane与Queue.
Routing key由生产者指定。Binding key由消费者指定。二者联合决定一条消息的来去。