已有网站域名 怎么做网站,苍强广州网站建设公司,微网站开发第三方平台,广州外贸公司有哪些目录
一、为什么会出现消息中间件#xff1f;
二、消息中间件是干嘛的#xff1f;
三、应用解耦
四、流量削峰
五、异步处理
1.串行方式#xff1a;
2.并行方式#xff1a;
3.引入消息队列#xff1a; 六、RocketMQ的架构及概念 一、为什么会出现消息中间件#…目录
一、为什么会出现消息中间件
二、消息中间件是干嘛的
三、应用解耦
四、流量削峰
五、异步处理
1.串行方式
2.并行方式
3.引入消息队列 六、RocketMQ的架构及概念 一、为什么会出现消息中间件
Http请求默认采用同步请求方式基于请求与响应模式在客户端与服务器进行通讯 时客户端调用服务端接口后必须等待服务端完成处理后返回结果给客户端才能继续执行这种情况 属于同步调用方式。如果服务器端发生网络延迟、不可达的情况可能客户端也会受到影响为了解决这个问题消息中间件就产生了。 二、消息中间件是干嘛的
消息中间件利用高效可靠的消息传递机制进行平台无关的数据交流并基于数据通信来进行分布式系统 的集成。通过提供消息传递和消息排队模型它可以在分布式环境下扩展进程间的通信。对于消息中间件常见的角色大致也就有Producer生产者、Consumer消费者例如寄快递 三、应用解耦 如果系统的耦合性越高容错性就越低以电商应用为例用户创建订单后 如果耦合调用库存系统、物流系统、支付系统任何一个子系统出了故障 或者因为升级等原因暂时不可用都会造成下单操作异常 使用消息队列解耦系统的耦合性就会下降了比如物流系统发生故障 需要几分钟才能修复在这段时间内物流系统要处理的数据被缓存到消息队列中用户的下单操作正常完成。当物流系统恢复后补充处理存在 消息队列中的订单消息即可终端系统感知不到物流系统发生过几分钟故障。 举例说明
订单系统用户下单后订单系统完成持久化处理将消息写入消息队列返回用户下单成功
库存系统订单下单的消息采用拉/推的方式获取下单信息库存系统根据下单信息进行 库存操作
假如在下单时库存系统不能正常使用也不影响正常下单因为下单后订单系统写入消息 队列就不再关心其他的后续操作了。实现了订单系统与库存系统的应用解耦。 四、流量削峰 应用系统如果遇到系统请求流量的瞬间猛增有可能将系统压垮有了消 息队列可以将大量请求缓存起来分散到很长一段时间处理这样可以大大提高系统的稳定性 举例说明
秒杀活动一般会因为流量过大导致流量暴增应用挂掉。为了解决这个问题一般需要 在应用前端加入消息队列。 五、异步处理
用户注册后需要发注册邮件和注册短信 传统的做法有两种
1.串行方式
将注册信息写入数据库成功后发送注册邮件再发送注册短信以上三个任务全部完成 后返回给客户端 2.并行方式
将注册信息写入数据库成功后发送注册邮件的同时发送注册短信以上三个任务完成 后返回给客户端与串行的差别是并行的方式可以提高处理的时间 3.引入消息队列 六、RocketMQ的架构及概念 Broker(邮递员) Broker是RocketMQ的核心负责消息的接收存储投递等功能
NameServer(邮局) 消息队列的协调者Broker向它注册路由信息同时Producer和Consumer向其获取路由信息
Producer(寄件人) 消息的生产者需要从NameServer获取Broker信息然后与Broker建立连接向Broker发送消息
Consumer(收件人) 消息的消费者需要从NameServer获取Broker信息然后与Broker建立连接从Broker获取消息
Topic(地区) 用来区分不同类型的消息发送和接收消息前都需要先创建Topic针对Topic来发送和接收 消息
Message Queue(邮件) 为了提高性能和吞吐量引入了Message Queue一个Topic可以设置一个或多个Message Queue这样消息就可以并行往各个Message Queue发送消息消费者也可以并行的从多个 Message Queue读取消息
Message Message 是消息的载体。
