triton develop document
本小节主要介绍如何使用triton快速完成rocketmq消息的生产,在此不再对rocketmq做相关的介绍,不太了解rocketmq的可以去rocketmq官网阅读相关文档。
sh mqnamesrv
sh mqbroker -n localhost:9876 autoCreateTopicEnable=true
{
"enabled": {
"rocketmq": true
},
"rocketmq": [
{
"consumerGroup": "test0",
"consumerMode": 0,
"nameServer": [
"127.0.0.1:9876"
],
"topic": "TopicTest",
"tags": "stu_test_0",
"retry": 2,
"consumerCount": 1,
"tplMode": 1
}
]
}
[stu_test_0]
-=
-=@NONE
这个模板其实对应的是tpl/init.go中funcMap中的printf逻辑,将消费到的消息进行打印。
- 如果tplMode为1,[stu_test_0]指的就是消费topic为TopicTest,tag为stu_test_0的消息,然后执行printf方法
- tplMode为0,我们不建议在rocketmq中这么使用,tplMode是为了kafka不支持相同topic不同tag而设置的
4、编译
make
5、运行
./bin/triton -c ../conf/conf.ini