rabbitmq消息中间件一天.pptx

RabbitMQ;Contents;1.MQ的基本概念;1.MQ的基本概念;小结;应用解耦

异步提速

削峰填谷;1.应用解耦;1.MQ的基本概念;1.3MQ的优势;5ms;A系统;A系统;使用了MQ之后，限制消费消息的速度为1000，这样一来，高峰期产生的数据势必会被积压在MQ中，高峰就被“削”掉了，但是因为消息积压，在高峰期过后的一段时间内，消费消息的速度还是会维持在1000，直到消费完积压的消息，这就叫做“填谷”。

使用MQ后，可以提高系统稳定性。;小结;;生产者不需要从消费者处获得反馈。引入消息队列之前的直接调用，其接口的返回值应该为空，这才让明明下层的动作还没做，上层却当成动作做完了继续往后走，即所谓异步成为了可能。

容许短暂的不一致性。

确实是用了有效果。即解耦、提速、削峰这些方面的收益，超过加入MQ，管理MQ这些成本。;目前业界有很多的MQ产品，例如RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、MetaMq等，也有直接使用Redis充当消息队列的案例，而这些消息队列产品，各有侧重，在实际选型时，需要结合自身需求及MQ产品特征，综合考虑。;;1.MQ的基本概念;2007年，Rabbit技术公司基于AMQP标准开发的RabbitMQ1.0发布。RabbitMQ采用Erlang语言开发。Erlang语言由Ericson设计，专门为开发高并发和分布式系统的一种语言，在电信领域使用广泛。;Broker：接收和分发消息的应用，RabbitMQServer就是MessageBroker

Virtualhost：出于多租户和安全因素设计的，把AMQP的基本组件划分到一个虚拟的分组中，类似于网络中的namespace概念。当多个不同的用户使用同一个RabbitMQserver提供的服务时，可以划分出多个vhost，每个用户在自己的vhost创建exchange／queue等

Connection：publisher／consumer和broker之间的TCP连接

Channel：如果每一次访问RabbitMQ都建立一个Connection，在消息量大的时候建立TCPConnection的开销将是巨大的，效率也较低。Channel是在connection内部建立的逻辑连接，如果应用程序支持多线程，通常每个thread创建单独的channel进行通讯，AMQPmethod包含了channelid帮助客户端和messagebroker识别channel，所以channel之间是完全隔离的。Channel作为轻量级的Connection极大减少了操作系统建立TCPconnection的开销;Exchange：message到达broker的第一站，根据分发规则，匹配查询表中的routingkey，分发消息到queue中去。常用的类型有：direct(point-to-point),topic(publish-subscribe)andfanout(multicast)

Queue：消息最终被送到这里等待consumer取走

Binding：exchange和queue之间的虚拟连接，binding中可以包含routingkey。Binding信息被保存到exchange中的查询表中，用于message的分发依据;RabbitMQ提供了6种工作模式：简单模式、workqueues、Publish/Subscribe发布与订阅模式、Routing路由模式、Topics主题模式、RPC远程调用模式（远程调用，不太算MQ；暂不作介绍）。

官网对应模式介绍：;JMS即Java消息服务（JavaMessageService）应用程序接口，是一个Java平台中关于面向消息中间件的API

JMS是JavaEE规范中的一种，类比JDBC

很多消息中间件都实现了JMS规范，例如：ActiveMQ。RabbitMQ官方没有提供JMS的实现包，但是开源社区有;RabbitMQ是基于AMQP协议使用Erlang语言开发的一款消息队列产品。

RabbitMQ提供了6种工作模式，我们学习5种。这是今天的重点。

AMQP是协议，类比HTTP。

JMS是API规范接口，类比JDBC。;Contents;;Contents;3.RabbitMQ快速入门;3.RabbitMQ快速入门;Contents;4.RabbitMQ的工作模式;4.RabbitM