中国菲律宾足球历史战绩,如何看网站是否优化,360房产网,网站建设企业网站建设第一章 RabbitMQ 概念 1.1.1 消息队列 MQ全称Message Queue#xff08;消息队列#xff09;#xff0c;是在消息的传输过程中保存消息的容器。多用于系统之间的异步通信。 1.1.2 消息 两台计算机间传送的数据单位。消息可以非常简单#xff0c;例如只包含文本字符串#x…第一章 RabbitMQ 概念 1.1.1 消息队列 MQ全称Message Queue消息队列是在消息的传输过程中保存消息的容器。多用于系统之间的异步通信。 1.1.2 消息 两台计算机间传送的数据单位。消息可以非常简单例如只包含文本字符串也可以更复杂可能包含嵌入对象。 1.1.3 队列 数据结构中概念。在队列中数据先进先出后进后出。 1.2 节 MQ优势
1.2.1 应用解耦 在电商平台中用户下订单需要调用订单系统此时订单系统还需要调用库存系统、支付系统、物流系统完成业务。此时会产生两个问题 如果库存系统出现故障会造成整个订单系统崩溃。 如果需求修改新增了一个X系统此时必须修改订单系统的代码。 如果在系统中引入MQ即订单系统将消息先发送到MQ中MQ再转发到其他系统则会解决以下问题 由于订单系统只发消息给MQ不直接对接其他系统如果库存系统出现故障不影响整个订单。 如果需求修改新增了一个X系统此时无需修改订单系统的代码只需修改MQ将消息发送给X系统即可。 1.2.2 异步提速 1.2.3 削峰填谷 假设我们的系统每秒只能承载1000请求如果请求瞬间增多到每秒5000则会造成系统崩溃。此时引入mq即可解决该问题。 使用了MQ之后限制消费消息的速度为1000这样一来高峰期产生的数据势必会被积压在MQ中高峰就被“削”掉了但是因为消息积压在高峰期过后的一段时间内消费消息的速度还是会维持在1000直到消费完积压的消息这就叫做“填谷”。 1.3 节 MQ劣势 系统可用性降低 系统引入的外部依赖越多系统稳定性越差。一旦MQ宕机就会对业务造成影响。 系统复杂度提高 MQ的加入大大增加了系统的复杂度以前系统间是同步的远程调用现在是通过MQ进行异步调用。 一致性问题 A系统处理完业务通过MQ给B、C、D三个系统发消息数据如果B系统、C系统处理成功D系统处理失败则会造成数据处理的不一致。 第二章 RabbitMQ工作原理 RabbitMQ是由Erlang语言编写的基于AMQP的MQ产品。
2.1 节 RabbitMQ工作过程 生产者(Publisher)将消息发布到交换机(Exchange)交换机根据规则将消息分发给交换机绑定的队列(Queue)队列再将消息投递 给订阅了此队列的消费者。 2.2 节 RabbitMQ 工作原理 Producer 消息的生产者。也是一个向交换机发布消息的客户端应用程序。 Connection 连接。生产者/消费者和RabbitMQ服务器之间建立的TCP连接。 Channel 信道。是TCP里面的虚拟连接。例如Connection相当于电缆 Channel相当于独立光纤束一条TCP连接中可以创建多条信道增加连接效率。无论是发布消息、接收消息、订阅队列都是 通过信道完成的。 Broker 消息队列服务器实体。即RabbitMQ服务器 Virtual host 虚拟主机。出于多租户和安全因素设计的把AMQP的基本组件划分到一个虚拟的分组中。每个vhost本质上就是一个mini版的RabbitMQ服务器拥有自己的队列、交换机、绑定和权限机制。当多个不同的用户使用同一个RabbitMQ服务器时可以划分出多个虚拟主机。RabbitMQ默认的虚拟主机路径是 / Exchange 交换机。用来接收生产者发送的消息并根据分发规则将这些消息分发给服务器中的队列中。不同的交换机有不同的分发规则。 Queue 消息队列。用来保存消息直到发送给消费者。它是消息的容器 也是消息的终点。消息一直在队列里面等待消费者链接到这个队列将其取走。 Binding 消息队列和交换机之间的虚拟连接绑定中包含路由规则绑定信息保存到交换机的路由表中作为消息的分发依据。 Consumer 消息的消费者。表示一个从消息队列中取得消息的客户端应用程序。
RabbitMQ为什么使用信道而不直接使用TCP连接通信 TCP连接的创建和销毁开销特别大。创建需要3次握手销毁需要4次分手。高峰时每秒成千上万条TCP连接的创建会造成资源巨大的浪费。而且操作系统每秒处理TCP连接数也是有限制的 会造成性能瓶颈。而如果一条线程使用一条信道一条TCP链接可以容纳无限的信道即使每秒成千上万的请求也不会成为性能的瓶颈。 第三章 RabbitMQ工作模式 RabbitMQ共有六种工作模式简单模式Simple、工作队列模式Work Queue、发布订阅模式Publish/Subscribe、路由模式Routing、通配符模式Topics、远程调用模式RPC 不常用)。 JMS 由于MQ产品很多操作方式各有不同于是JAVA提供了一套规则 ——JMS用于操作消息中间件。JMS即Java消息服务 JavaMessage Service应用程序接口是一个Java平台中关于面向消息中间件的API。JMS是JavaEE规范中的一种类比JDBC。很多MQ产品都实现了JMS规范例如ActiveMQ。RabbitMQ官方并没有实现JMS规范但是开源社区有JMS的实现包。 4.1 节 简单模式
4.1.1 简单模式介绍 特点 一个生产者对应一个消费者通过队列进行消息传递。 该模式使用direct交换机direct交换机是RabbitMQ默认交换机。
4.2 节 工作队列模式
4.2.1 工作队列模式概念 与简单模式相比工作队列模式(Work Queue)多了一些消费者该模式也使用direct交换机应用于处理消息较多的情况。特点如下 一个队列对应多个消费者。 一条消息只会被一个消费者消费。 消息队列默认采用轮询的方式将消息平均发送给消费者
4.3 节 发布订阅模式广播模式
4.3.1 发布订阅模式概念 在开发过程中有一些消息需要不同消费者进行不同的处理如电商网站的同一条促销信息需要短信发送、邮件发送、站内信发送等。此时可以使用发布订阅模式(Publish/Subscribe)
特点 生产者将消息发送给交换机交换机将消息转发到绑定此交换机的每个队列中。 工作队列模式的交换机只能将消息发送给一个队列发布订阅模式的交换机能将消息发送给多个队列。 发布订阅模式使用fanout交换机。 4.4 节 路由模式
4.4.1 路由模式概念 特点 每个队列绑定路由关键字RoutingKey 生产者将带有RoutingKey的消息发送给交换机交换机根据RoutingKey转发到指定队列。路由模式使用direct交换机。
4.5 节 通配符模式
4.5.1 通配符模式概念 通配符模式(Topic)是在路由模式的基础上给队列绑定带通配符的路由关键字只要消息的RoutingKey能实现通配符匹配就会将消息转发到该队列。通配符模式比路由模式更灵活使用topic交换机。
通配符规则 消息设置RoutingKey时RoutingKey由多个单词构成中间以 . 分割。 队列设置RoutingKey时 # 可以匹配任意多个单词 * 可以匹配任意一个单词。
第六章 总结
【1】说一下什么是MQ 答MQ是消息队列容器常见的MQ技术有RabbitMQ,RocketMQ。解决微服务异步通信问题场景如下 抢票、秒杀类场景目的只有一个将并行场景转为串行场景来缓解并发压力。 消息分发 促销活动需要将商品短链发送各个平台需要时效不高但数据量大可以交给消息队列处理。 数据同步redis、es与mysql数据同步 异步处理在电商系统中订单完成后需要及时的通知子系统进销存系统发货用户服务积分发送短信进行下一步操作。为了保证订单系统的高性能应该直接返回订单结果之后让MQ通知子系统做其他非实时的业务操作。这样能保证核心业务的高效及时。 离线处理比如查询10年历史账单可以用MQ离线处理。 【2】说一下MQ的优势与劣势 答优势 异步提速 订单系统 应用解耦 订单系统 削峰填谷 劣势 系统复杂度提高 编码难度提高 一致性和可用性降低 【3】RabbitMQ的工作原理 答首先消息生产端通过TCP三次握手与MQ服务器创建连接由于连接耗时链接一般不会释放会在连接内部创建虚拟连接既信道通过信道将消息发送给交换机然后交换机根据routingKey路由到指定队列。消费者与队列建立连接建立信道然后监听指定队列如有消息就消费消息。RabbitMQ服务器考虑到多租户和安全问题服务内部可以设置多个虚拟主机每个主机内部由上面的交换机routingKey,队列组成。 【4】说一下RabbitMQ的交换机类型 答:交换机类型有 direct fanout topic headers(几乎不用) 简单类型、工作队列类型都是通过默认的定向交换机处理的。广播类型是由fanout交换机处理的路由类型是由自定义的direct交换机处理的通配符类型是由topic交换机处理的。 【5】RabbitMQ的工作模式有哪些 答: 简单模式 1对1发送消息与接收 工作队列模式 1对多 发送消息多端轮询接收消息 广播模式1对多发送消息多端共同消费消息 路由模式1对多发送消息按照路由名字转发指定队列并消费
