问题描述
我正在向我的 restController 发送一个 Json 对象,它的一个属性是一个 String 字段,它将接收一个 json Stringified 对象。
邮递员请求发送的JSON:
{
"queueName":"queue.sample","message": "{\"id\" : \"89EA5456\",\"cob\" : \"17\",\"apo\" : \"999999\"}"
}
这里我们可以看到消息内容:
public void sendMessage(MessageDto message) {
this.rabbitService.convertAndSend( message.getQueueName(),message.getMessage());
log.info("Mensagem enviada - queue: {} - message: {}",message.getQueueName(),message.getMessage());
}
Mensagem enviada - queue: queue.sample - message: {"id": "89EA5456","cob": "17","numApo" : "999999"}
问题发生在流程的消费者部分。
@RabbitListener(queues = "queue.sample")
public void onMessage(Message message) {
log.info("Mensagem consumida: "+ new String(message.getBody()));
}
Mensagem consumida: "{\"id\" : \"89EA5456\",\"apo\" : \"999999\" }"
为什么这些引号(在消息的开头和结尾)和转义字符随消息一起出现?
解决方法
完美的加里。我确实在使用 Jackson2JsonMessageConvert。我已经改成在发送端使用默认的消息转换器并解决了问题。