mq消息序列化

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/mq/MqConsumer.java

 package com.mmc.iuav.user.mq;
 
+import com.alibaba.fastjson2.JSONObject;
 import com.mmc.iuav.user.model.vo.UserAccountVO;
 import com.rabbitmq.client.Channel;
 import lombok.extern.slf4j.Slf4j;
@@ -17,7 +18,8 @@ import org.springframework.stereotype.Component;
 public class MqConsumer {
 
 //    @RabbitListener(queues = RabbitmqConstant.USER_INFO_UPDATE_FANOUT_FORUM_QUEUE)
-//    public void subscribeFanoutQueue(@Payload UserAccountVO userAccountVO, Channel channel, Message message){
-//        log.info("receive:" + userAccountVO);
+//    public void subscribeFanoutQueue(@Payload String userAccountVO, Channel channel, Message message){
+//        UserAccountVO userAccountVO1 = JSONObject.parseObject(userAccountVO, UserAccountVO.class);
+//        log.info("receive:" + userAccountVO1);
 //    }
 }
\ No newline at end of file

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/mq/impl/MqProducerImpl.java

@@ -22,6 +22,6 @@ public class MqProducerImpl implements MqProducer {
     @Override
     public void sentUserInfoChangedMsg(UserAccountVO userAccountVO) {
         log.info("sentUserInfoChangedMsg:{}", JSONObject.toJSONString(userAccountVO));
-        rabbitTemplate.convertAndSend(RabbitmqConstant.USER_INFO_UPDATE_FANOUT_EXCHANGE, "", userAccountVO);
+        rabbitTemplate.convertAndSend(RabbitmqConstant.USER_INFO_UPDATE_FANOUT_EXCHANGE, "", JSONObject.toJSONString(userAccountVO));
     }
 }