0消息队列服务简介

消息队列服务简介1任务描述华云数据集团承建无锡地铁云计算平台，通过应用虚拟化技术和云计算平台来整合内部IT系统，实现资源统筹管理，提升现有资源的可靠性和可用性，大幅度节约企业硬件成本和管理成本，提高资源使用率，为应用提供动态、灵活、弹性、虚拟、共享和高效的资源服务，以加快生产和开发的效率，满足无锡地铁信息化建设构建统一管理平台的发展需求。在无锡地铁云计算平台的项目实施中，华云数据集团采用RabbitMQ服务作为云平台统一的消息队列服务，提供通信功能，本节主要学习消息队列服务简介。目录RabbitMQ简介RabbitMQ集群RabbitMQ工作原理2RabbitMQ简介3MQ全称为MessageQueue,消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息(针对应用程序的数据)来通信，而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，直接调用通常是用于诸如远程过程调用的技术。排队指的是应用程序通过队列来通信。队列的使用除了接收和发送应用程序同时还有执行的要求。RabbitMQ是流行的开源消息队列系统，用erlang语言开发。RabbitMQ是一个在AMQP基础上完成的，可复用的企业消息系统。他遵循MozillaPublicLicense开源协议。RabbitMQ简介4MQ特点MQ是消费-生产者模型的一个典型的代表，一端往消息队列中不断写入消息，而另一端则可以读取或者订阅队列中的消息。MQ和JMS类似，但不同的是JMS是SUNJAVA消息中间件服务的一个标准和API定义，而MQ则是遵循了AMQP协议的具体实现和产品。使用场景在项目中，将一些无需即时返回且耗时的操作提取出来，进行了异步处理，而这种异步处理的方式大大的节省了服务器的请求响应时间，从而提高了系统的吞吐量。RabbitMQ工作原理5RabbitMQ工作原理6消息队列的使用过程大概如下:(1)客户端连接到消息队列服务器，打开一个channel。(2)客户端声明一个exchange，并设置相关属性。(3)客户端声明一个queue，并设置相关属性。(4)客户端使用routingkey，在exchange和queue之间建立好绑定关系。(5)客户端投递消息到exchange。(6)exchange接收到消息后，就根据消息的key和已经设置的binding，进行消息路由，将消息投递到一个或多个队列里。RabbitMQ集群7Rabbit模式大概分为以下三种：单主机模式、普通集群模式、镜像集群模式。单主机模式：RabbitMQ服务运行在单独的一台主机中，通常生产环境不使用该模式，性能有限，并且如果服务器宕机服务将完全不可用。普通集群模式：首先对于Queue来说消息实体只存在于其中一个节点，集群中其他节点仅有相同的元数据，即队列结构。当消息进入A节点的Queue中后，Consumer从B节点拉取消息时，RabbitMQ会临时在两个节点间进行消息传输，把A中的消息实体取出并经过B发送给Consumer。所以Consumer应尽量连接每一个节点，从中取消息。即对于同一个逻辑队列，要在多个节点建立Queue。否则Consumer如果只连接一个节点区消息会造成该节点的性能瓶颈。该模式存在一个问题就是当其中一个节点故障后，其他节点无法取到故障节点中还未消费的消息。如果做了消息持久化，那么得等A节点恢复，然后才可被消费！RabbitMQ集群8Rabbit模式大概分为以下三种：单主机模式、普通集群模式、镜像集群模式。镜像集群模式前面讲到RabbitMQ的普通集群模式不同节点间只同步队列结构不同步消息。镜像模式会把队列结构和消息都存在于多个节点，属于RabbitMQ的HA方案。其实质和普通模式不同之处在于，消息实体会主动在镜像节点间同步。该模式