DDMQ DDMQ is a distributed messaging product w @codeKK AndroidOpen Source Website

DDMQ

Introduction: DDMQ is a distributed messaging product with low latency, high throughput and high availability.

Tags:

English | 中文

DDMQ is a distributed messaging product built by DiDi Infrastructure Team based on Apache RocketMQ. As a distributed messaging middleware, DDMQ provides low latency, high throughput and high available messaging service to many important large-scale distributed systems inside DiDi. DDMQ provides realtime messaging, delay-time messaging and transactional messaging to satisfy different scenarios. Through an easy-to-use Web Console and simple SDK Client, developers can experience producing and consuming messages in the most simple and stable way.

Features

Messaging model: support both P2P and Pub/Sub messaging model
Massive message storage, support both RocketMQ and Kafka as storage engine
Low latency & High throughput
Delay message, use RocksDB as storage engine
Transactional message: provide transaction similar to X/Open XA
Multiple language client SDK: provide client SDK in PHP, Java, Go, C/C++, Python
Message transition and filter with user-defined Groovy script
An easy-to-use Web Console

Architecture Overview

Modules

carrera-common: common code for other modules, such as encapsulate zk operations.
carrera-producer: message producer proxy with built-in Thrift Server, responsible for forwarding message from SDK client to broker.
carrera-consumer: message consumer proxy with built-in Thrift Server, provide SDK PULL and HTTP PUSH for message consumption.
carrera-chronos: delay message module, use RocksDB as storage engine.
carrera-sdk: producer and consumer SDK, support Java/C/C++/Go/PHP/Python.
rocketmq: based on RocketMQ (Ver 4.2.0)，add new features such as broker auto fail-over.
carrera-console: a Spring-based User Web Console.
carrera-monitor: consumer lag monitor and DDMQ cluster monitor.
carrera-docker: provide a DDMQ docker image that runs in standalone mode.