mq消息结构

src/main/java/com/fdkankan/sale/mq/consumer/ManageToSaleConsumer.java

@@ -26,11 +26,14 @@ public class ManageToSaleConsumer {
     @RabbitListener(
             queuesToDeclare = @Queue("manageToSale")
     )
-    public void consumerQueue(Channel channel, Message message) throws IOException {
+    public void consumerQueue(Channel channel, Message message)  {
         try {
             String messageId = message.getMessageProperties().getMessageId();
             String msg = new String(message.getBody(), StandardCharsets.UTF_8);
             log.info("接受结果mq--messageId:{},msg:{}",messageId,msg);
+            msg = msg.substring(1, msg.length() - 1);
+
+            msg = StringEscapeUtils.unescapeJava(msg);
             ManageToSaleParam param = JSONObject.parseObject(msg, ManageToSaleParam.class);
             String command = param.getCommand();
             switch (command){
@@ -38,12 +41,12 @@ public class ManageToSaleConsumer {
                     sysUserService.updateByDb2(param.getData());
                     break;
             }
-
+            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
 
         }catch (Exception e){
             log.error("mq----消费失败",e);
         }finally {
-            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
+
         }
 
     }

src/main/java/com/fdkankan/sale/mq/param/ManageToSaleParam.java

@@ -1,5 +1,6 @@
 package com.fdkankan.sale.mq.param;
 
+import com.alibaba.fastjson.JSONObject;
 import com.fdkankan.sale.entity.SysUser;
 import lombok.AllArgsConstructor;
 import lombok.Data;