高可用并行有序的消息消费设计
2016-11-09 13:59:17 0 举报
高可用并行有序的消息消费设计是一种在分布式系统中实现消息队列的关键技术。它通过将消息分布在多个消费者上并行处理,以提高系统的吞吐量和响应速度。同时,为了保证消息的顺序性,引入了消息队列的顺序性保障机制,确保同一订单或事务内的消息按照发送顺序被消费。此外,为了提高系统的可用性和容错能力,采用了主备复制、故障转移等技术,确保在某一消费者出现故障时,其他消费者能够接管其工作,保证消息不丢失。总之,高可用并行有序的消息消费设计为分布式系统提供了一种高效、可靠、可扩展的消息处理方案。
作者其他创作
大纲/内容
8、初始化MQ连接,已初始化则忽略
4、启动,获取消息队列配置
10、机器下线
7、获取分配策略
2、初始化MQ连接、exchange,绑定queue和设置routing
6、master制定分配策略
zookeeper
9、按分配策略释放原有消费队列或绑定新queue消费
queue2
queue4
消费者集群
queue3
5、竞争master
消费者3
rabbitMQ
3、发送消息并路由到队列
queue1
消费者2
11、监听变更,如果是master下线,从步骤5重新开始;否则从步骤6重新开始
1、启动,获取消息队列配置
生产者集群
消费者1
0 条评论
回复 删除
下一页