示例:kafka
原理说明:
Access表名 = 消息队列 topic
apijson发送mq消息:
单条
{
"@datasource": "kafka",
"Topic_User":{
"message":"test-101"
},
"tag": "Topic_User",
"@explain": false
}
多条
{
"Topic_User[]": [
{
"message":"test-100"
},
{
"message":"test-101"
}
],
"tag": "Topic_User[]",
"@datasource": "kafka",
"@explain": true
}
客户端接收消息:
offset = 47, key = null, value = test-101
offset = 48, key = null, value = test-100
offset = 49, key = null, value = test-101
用java代码方式,获取具体数据源,调用即可