栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

RabbitMQ消费者接收Message乱码问题

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

RabbitMQ消费者接收Message乱码问题

问题描述:

使用Message来提取具体得消息内容时出现部分数据乱码的现象,byte[]数组用utf-8编码仍然无效

    @Override
    public void onMessage(Message message, Channel channel) throws Exception
     {
            String result = new String(message.getBody(),"utf-8");
            System.out.println(result);
            JSONObject jsonObject = JSONObject.parseObject(result);
     }

解决方法:
原因:发送时消息没有序列化。
解决方法:1.对实体类进行序列化(实体类情况下)
				  2.因为我使用的是Map作为消息,所以我选择将它转化为json字符串进行传输	
    @GetMapping("/sendDirectMessage")
    public String sendDirectMessage() {
        String messageId = String.valueOf(UUID.randomUUID());
        String messageData = "test message, 你好!!!";
        String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
        Map map=new HashMap<>();
        map.put("messageId",messageId);
        map.put("messageData",messageData);
        map.put("createTime",createTime);

        System.out.println("发送时打印消息内容:"+messageId);
        //将消息携带绑定键值:TestDirectRouting 发送到交换机TestDirectExchange
        rabbitTemplate.convertAndSend("TestDirectExchange", "TestDirectRouting", JSONObject.toJSONString(map),new CorrelationData(messageId));
        return "ok";
    }

运行结果:没有乱码 并且以json格式出现

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/955912.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号