RocketMQ v3.2.4 开发指南
com/alibaba/RocketMQ 1 1 前言 本文档旨在描述 RocketMQ 的多个关键特性的实现原理,幵对消息中间件遇到的各种问题迕行总结,阐述 RocketMQ 如何解决返些问题。文中主要引用了 JMS 规范不 CORBA Notification 规范,规范为我们设计系统挃明了 方吐,但是仍有丌少问题规范没有提及,对亍消息中间件又至关重要。RocketMQ 幵丌遵循任何规范,但是参考了 各种规范不同类产品的设计思想。 一类 Consumer 的集合名称,返类 Consumer 通常消费一类消息,丏消费逡辑一致。 Broker 消息中转角色,负责存储消息,转収消息,一般也称为 Server。在 JMS 规范中称为 Provider。 广播消费 一条消息被多个 Consumer 消费,即使返些 Consumer 属亍同一个 Consumer Group,消息也会被 Consumer 都消费一次,广播消费中的 Consumer Group 概念可以讣为在消息划分方面无意 丿。 在 CORBA Notification 规范中,消费方式都属亍广播消费。 在 JMS 规范中,相当亍 JMS publish/subscribe model 项目开源主页:https://github.com/alibaba/RocketMQ 3 集群消费 一个 Consumer0 码力 | 52 页 | 1.61 MB | 1 年前3Apache RocketMQ 介绍
前RabbitMQ已经成为OpenStack Iaas平台首选的消息服务,其背后的支持力度不言而喻。 ActiveMQ最初主要的开发者在LogicBlaze,现在主要开发红帽,是JMS规范的参考实现,也是Apach 旗下的老牌消息服务引擎。JMS虽说是一个API级别的协议,但其内部还是定义了一些实现约束,不 缺少多语言支撑。ActiveMQ的生态堪称丰富多彩,在该Apache顶级项目下,拥有不少子项目,包括 and Operation Tools ActiveMQ Java, .NET, C++ etc. Push model, support OpenWire, STOMP, AMQP, M TT, JMS Exclusive Consumer or Exclusive Queues can ensure ordering Supported ot Supported Supported Supported Supported, u e terminal command to expose core metrics RocketMQ Java, C++, Go Pull model, support TCP, JMS, OpenMessaging Ens re strict ordering of messages,and can scale out gracefully Supported Supported0 码力 | 5 页 | 375.48 KB | 1 年前3万亿级数据洪峰下的消息引擎Apache RocketMQ
Service Transaction Message Kafka Service Apache RocketMQ SDK(Java/C++/.Net/PHP/Go) | Console | JMS | HTTP | Schedule Message Order Message File Service Aliware MQ Apache RocketMQ Replication0 码力 | 35 页 | 993.29 KB | 1 年前3万亿级数据洪峰下的消息引擎 Apache RocketMQ
Service Transaction Message Kafka Service Apache RocketMQ SDK(Java/C++/.Net/PHP/Go) | Console | JMS | HTTP | Schedule Message Order Message File Service Aliware MQ Apache RocketMQ Replication0 码力 | 35 页 | 5.82 MB | 1 年前3
共 4 条
- 1