快速建企业网站,安徽芜湖网站建设,wordpress主题使用教程,珠宝 网站欣赏一、考虑可扩展性 分析 消息队列中的消息数量是不确定的#xff0c;有时一两万个#xff0c;出现流量高峰甚至消息积压的时候#xff0c;就会有上百万、千万的消息在队列中。所以#xff0c;为了增加系统的稳定性#xff0c;消息队列需要具备快速扩容的能力 实现 采用分布…一、考虑可扩展性 分析 消息队列中的消息数量是不确定的有时一两万个出现流量高峰甚至消息积压的时候就会有上百万、千万的消息在队列中。所以为了增加系统的稳定性消息队列需要具备快速扩容的能力 实现 采用分布式系统设计将消息队列的每一个topic 进行分区每一个分区放一个机器需要扩容就增加分区的数量进行数据迁移这样就可以进行快速扩容了
二、考虑持久化
分析
要保证机器重启或宕机时消息队列的数据不丢失就需要实现持久化
实现
消息队列的持久化可以通过两个组件实现队列索引queue index和消息存储message store。队列索引负责维护消息在队列中的位置以及消息是否已被传递和确认。每个队列都有一个队列索引。消息存储是用于存储消息的键值存储在每个虚拟主机vhost中的所有队列之间共享。消息可以直接存储在队列索引中也可以写入消息存储。
