代码拉取完成,页面将自动刷新
同步操作将从 DiDi-opensource/DDMQ 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
English | 中文
Producer Proxy(PProxy) is the producer module of DDMQ. PProxy is responsible for forwarding messages to message storage engine(RocketMQ or Kafka). PProxy provides features such as ratelimit, auto-batch and auto-retry.
struct Result {
1: i32 code
2: string msg
3: optional string key
}
struct Message {
1: string topic; // topic
2: string key; // uniq key to trace or get the partition
3: string value; // msg body
4: i64 hashId; // hashId for kafka partation.
5: string tags; // tags for RocketMQ message.
6: i32 partitionId = -1; // partition id for kafka, -1: use hashId; -2: rand to get
7: optional binary body; // binary msg body
8: optional string version; // sdk version
9: optional map<string, string> properties // properties
}
struct DelayResult {
1: i32 code
2: string msg
3: string uniqDelayMsgId // unique identifier for a delay message, can be used to cancel or trace a delay message
}
struct DelayMessage {
1: string topic; // topic
2: optional string uniqDelayMsgId; // use to cancel or trace a message
3: optional binary body; // binary msg body
4: string tags; // tags for delay message
5: i32 action; // action, 1: add; 2: cancel
6: optional i64 timestamp; // timestamp to trigger
7: optional i32 dmsgtype; // dmsgtype, 2: delay; 3: loop delay
8: optional i64 interval // interval of loop message, if not loop, just leave it
9: optional i64 expire; // expire time
10: optional i64 times; // loop times
11: optional string uuid; // uuid for delay message
13: optional string version; // sdk version
14: optional map<string, string> properties // properties
}
service ProducerService {
// sync send normal message
Result sendSync(1: Message message, 2: i64 timeout)
// sync send batch normal message
Result sendBatchSync(1: list<Message> messages)
// async send normal message
Result sendAsync(1: Message message)
// sync send delay message
DelayResult sendDelaySync(1: DelayMessage delayMessage, 2: i64 timeout)
}
zookeeperAddr: 127.0.0.1:2181/carrera/v4/config # config zk cluster address here.
host: 127.0.0.1 # proxy ip (optional)
port: 9613 # thrift server port.
build.sh
to build packagecontrol.sh start
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。