- 其中 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 | 已派发次数 |