使用roketmq发送了一个字符串,为什么consumer收到的是数字?
发送:
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;
}
});
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论