消息中间件是指在分布式系统中完成消息的发送和接收的基础软件。
消息中间件也可以称消息队列（Message Queue / MQ），互联网场景中经常使用消息中间件进行消息路由、订阅发布、异步处理等操作，来缓解系统的压力。
引入消息队列主要是为了解决如下问题的：,
既然本身就是为了解决大流量场面而设计的，那他自身的稳定性、健壮性就显的无比重要，下面我们来看看消息队列怎么去保证可用性的。,分析高可用特性前先复习下消息队列的基本组件，无论是哪一种类型的消息队列，基本都包含以下构成：,
,上图中以kafka为例子，这是典型的集群模式，Kafka通过Zookeeper管理集群配置，选举leader，以及在Consumer Group发生变化时进行rebalance。Producer使用push模式将消息发布到broker，Consumer使用pull模式从broker订阅并消费消息。,了解了一个消息队列的构成之后，我们来看看这种结构是怎么保障高可用性的。
首先，高可用是指系统的出错概率和无故障运行时长，从消息队列角度出发，至少要保证一下几点：,以为RocketMQ为例，集群模式如下：,Producer 与 NameServer集群中的其中一个节点（随机或者RR选择）建立长连接，定期从 NameServer 获取 Topic 路由信息，既可以从 Broker Master 订阅消息，也可以从 Broker Slave 订阅消息。,Kafka集群中包含如下组成部分：,Kafka通过Zookeeper管理集群配置，选举leader，以及在Consumer Group发生变化时进行rebalance。,Producer使用push模式将消息发布到broker，Consumer使用pull模式从broker订阅并消费消息。
文章版权声明
1 原创文章作者：cmcc，如若转载，请注明出处： https://www.52hwl.com/17077.html
2 温馨提示：软件侵权请联系469472785#qq.com（三天内删除相关链接）资源失效请留言反馈
3 下载提示：如遇蓝奏云无法访问，请修改lanzous(把s修改成x)
4 免责声明：本站为个人博客，所有软件信息均来自网络 修改版软件，加群广告提示为修改者自留，非本站信息，注意鉴别
微信扫一扫 
支付宝扫一扫 