FolkMQ v1.7.8

消息模型( 属性字典)

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