- 其中 tag 和 attrMap,可为消息添加语义特性。比如:
client.publish("demo", new MqMessage("hello").attr("from", "noear"));
- 其中 qos=0 时,发布的消息只派发一次(不管消费成功与否)
1、发送消息模型(MqMessage)
属性 | 说明 |
key::String | 唯一标识 |
body:byte[] | 主题(即消息内容) |
scheduled:Date | 定时派发时间 |
expiration:Date | 过期时间 |
isTequence:bool | 是否为顺序消息 |
isTransaction:bool | 是否为事务消息 |
qos:int | 质量等级(0或1) |
| |
tag:String | 标签。相当于二级主题 |
attrMap:Map | 属性 |
2、接收消息模型(MqMessageReceived)
属性 | 说明 |
topic | 主题 |
consumerGroup | 消费者组(当前) |
| |
key::String | 唯一标识 |
body:byte[] | 主题(即消息内容) |
scheduled:Date | 定时派发时间 |
expiration:Date | 过期时间 |
isTequence:bool | 是否为顺序消息 |
isTransaction:bool | 是否为事务消息 |
qos:int | 质量等级(0或1) |
| |
tag:String | 标签。相当于二级主题 |
attrMap:Map | 属性 |
| |
times:int | 已派发次数 |