消息中间件RabbitMQ

一.RabbitMq 概念：

RabbitMq是开源的AMQP（Advance Message Queuing Protocol，高级消息队列协议；）,服务端是通过Erlang语言编写的，该协议是应用层的面向消息的中间设计，该特点是面向消息，路由，队列并提供可靠型，安全型的队列协议，支持跨平台，然而其中最大的特点就是异步。

RabbitMqAPI中基本对象就是ConnectionFactory，connnetion和channel；ConnectionFactory负责创建Connection，而Connection对socket进行了封装负责端与端之间的链接；Channel是消息发送与接受的重要接口，该类定义了路由Exchange，队列queue以及发送和接受消息的接口；

Rabbitmq一样提供了一对一与一对多的消息发送模式；

图一是一个生成者对一个消费者：



图二是一个生成者对对多个消费者模式：



由于RabbitMq是异步的，也就是生成者只负责发送消息到队列，甚至不负责消息是否发送成功，我个人觉得这里如果发送消息过程中宕机的话，这样一样会丢失消息，所以不知道大家有和看法；但在针对消费者，当消费者每次从队列处理消息的后会默认发送一个ack回执给服务端，服务收不到该ack的话，则会将该消息包留在队列，并递送给下一个消费者。当然服务侧也可能出现宕机，而rabbitmq是支持消息持久化，队列持久话的；

而在实际开发中我们更多通过Exchange来了将消息转发到相应的队列中，而不是直接将消息存入队列中；这样以来即我们消息发送更具备灵活性；

图一是通过Exchange广播形式的推送消息：



图二是通过Exchange以制定的方式发送消息：



error类型的消息存放队列1供C1消费，infowarning，error存放队列2供C2消费；

图像是通过Exchange以匹配的方式发送消息：



routingKey=”quick.orange.rabbit”的消息会同时路由到Q1与Q2，routingKey=”lazy.orange.fox”的消息会路由到Q1，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。

而一topic方式在实际业务中运用更多；

以上主要介绍了RabbitMQ的基本重要的概念，下面将介绍RabbitMQJava的实例开发；