rocketmq發送消息亂碼

rocketmq發送消息亂碼

 

@Async
public SendResult send(String businessCode, String ms, String springTopic) throws Exception {
    //生成message類型
    Message<byte[]> message = MessageBuilder.withPayload(ms.getBytes(StandardCharsets.UTF_8)).build();
    SendResult sendResult = rocketTemplate.syncSendOrderly(springTopic, message, springTopic);
    log.info("{},mq send business_code: {}", springTopic, businessCode);
    log.info("mq send message: {}", ms);
    log.info("mq send result: {}", sendResult);
    return sendResult;
}

　　

直接發送json的字符串亂碼，在windows上可以，但linux上就有問題了

解決方法：發送byte字節，接收方

ms.getBytes(StandardCharsets.UTF_8)