滴滴开源基于 RocketMQ 的分布式消息队列 DDMQ

来源:https://github.com/didi/DDMQ/

近日滴滴开源了消息队列 DDMQ。



DDMQ 是滴滴出行架构部基于 Apache RocketMQ 构建的消息队列产品。作为分布式消息中间件,DDMQ 为滴滴出行各个业务线提供了低延迟、高并发、高可用、高可靠的消息服务。


DDMQ 提供了包括实时消息、延迟消息和事务消息在内的多种消息类型以满足不同的业务需求。 用户通过统一的 Web 控制台和傻瓜式的 SDK 即可轻松接入 DDMQ 生产和消费消息,体验功能丰富、稳定的消息服务。



目前,DDMQ 在 GitHub 上获得 386 Star,82 个Fork(GitHub地址:https://github.com/didi/DDMQ/blob/master/README_CN.md



DDMQ主要功能特性


  • 消息模型:支持 P2P, Pub/Sub 等消息模型

  • 海量消息存储,支持消息回溯:使用 RocketMQ 和 Kafka 作为消息的底层存储引擎。

  • 低延迟高吞吐:毫秒级延迟,单机百万条消息吞吐。

  • 延迟消息:单条消息设置精确到秒级的延迟时间,支持 Thrift、HTTP 形式的回调接口。提供了丰富的消息类型,包括延迟消息和循环延迟消息。

  • 事务消息: 提供类似 X/Open XA 的分布事务功能,通过 DDMQ 事务消息能够达到分布式事务的最终一致。

  • 多语言客户端: 提供了主流开发语言的 SDK,包括 PHP, Java, Go, C/C++, Python 等。API 上保持着最易使用的 High Level 形式。

  • 支持复杂的消息转换过滤功能:支持使用 Groovy 脚本在服务端进行消息内容的转化和过滤,能做大大地减少客户端和服务器的数据传输,同时减少客户端的处理消息的负载。

  • 易用性高的 Web 用户控制台,方便用户在控制台上申请 Topic, ConsumerGroup, Subscription 等资源。 提供消费进度的查看和重置功能。


DDMQ 架构图如下:



如果想了解更多DDMQ相关信息,可以到GitHub上查看项目详情

推荐↓↓↓
开源最前线
上一篇:从项目的 GitHub 星星数看 2018 年 JavaScript 生态圈 下一篇:Flutter从入门到能自己玩,你还需要这个开源助手flutter-go