发送:
Message msg = new Message( //
// 在控制台创建的 Topic,即该消息所属的 Topic 名称
"RocketMQ_test_by_bsy",
// Message Tag,
// 可理解为 Gmail 中的标签,对消息进行再归类,方便 Consumer 指定过滤条件在 MQ 服务器过滤
"TagA",
// Message Body
// 任何二进制形式的数据, MQ 不做任何干预,
// 需要 Producer 与 Consumer 协商好一致的序列化和反序列化方式
"Hello MQ".getBytes());
接受:
Consumer consumer = ONSFactory.createConsumer(properties);
consumer.subscribe("RocketMQ_test_by_bsy", "*", new MessageListener() {
public Action consume(Message message, ConsumeContext context) {
System.out.println("Receive: " + message);
return Action.CommitMessage;
}
});