使用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;
        }
    });
阅读 1.6k
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进