摘要:每个记录完整的路由信息,提供相应的读写服务,并支持快速存储扩展。此外,提供灾难恢复,丰富的指标统计数据和警报机制,而传统的消息传递系统都缺乏这些机制。发送过程支持并具有低延迟。
概览
Apache RocketMQ是一款具有低延迟,高性能和可靠性,数十亿容量和灵活可扩展性的分布式消息传递和流媒体平台。它由四部分组成:Name Servers,brokers,producers和consumers。 它们中的每一个都可以在没有单点故障的情况下进行水平扩展。
NameServer集群Name Servers提供轻量级服务发现和路由。每个Name Server记录完整的路由信息,提供相应的读写服务,并支持快速存储扩展。
Broker集群Brokers通过提供轻量级的TOPIC和QUEUE机制来实现消息存储。 它们支持Push和Pull模式,包含容错机制(2个或3个副本),并提供强大的峰值填充和按原始时间顺序累积数千亿条消息的能力。此外,broker提供灾难恢复,丰富的指标统计数据和警报机制,而传统的消息传递系统都缺乏这些机制。
Producer集群Producer集群支持分布式部署。分布式producer通过多种负载均衡模式向Broker集群发送消息。发送过程支持fast failure并具有低延迟。
Consumer集群Consumer也支持Push和Pull模型的分布式部署。 它还支持群集消费和消息广播。 它提供了实时的消息订阅机制,可以满足大多数消费者的需求。
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/68997.html
摘要:和之间的关系通过来绑定,来定义,即相同的,等于表示节点,非表示节点。所有的节点与集群的所有节点保持长连接,定时注册信息到所有的。对磁盘的访问串行化,避免磁盘竟争,不会因为队列增加导致增高。要保证与完全的一致,增加了编程的复杂度。 Apache RocketMQ™是一个开源的分布式消息和流数据平台。 1、既然是消息系统,最核心的功能就是要提供消息的发布与订阅功能,最简单的概念模型如下: ...
摘要:通过以上分析我们可以得出消息队列具有很好的削峰作用的功能即通过异步处理,将短时间高并发产生的事务消息存储在消息队列中,从而削平高峰期的并发事务。 该文已加入开源项目:JavaGuide(一份涵盖大部分Java程序员所需要掌握的核心知识的文档类项目,Star 数接近 16k)。地址:https://github.com/Snailclimb... 本文内容思维导图:showImg(ht...
阅读 2265·2021-10-09 09:41
阅读 1728·2019-08-30 15:53
阅读 966·2019-08-30 15:52
阅读 3414·2019-08-30 11:26
阅读 744·2019-08-29 16:09
阅读 3380·2019-08-29 13:25
阅读 2217·2019-08-26 16:45
阅读 1908·2019-08-26 11:51