From fa09d9dc23f60af67d33a65b5ce4db7835920f15 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=B5=B5=E5=BF=A0=E6=9E=97?= <170083662@qq.com>
Date: Tue, 7 Apr 2026 03:12:59 +0800
Subject: [PATCH] =?UTF-8?q?refactor(mq):=20=E4=BC=98=E5=8C=96RabbitMQ?=
 =?UTF-8?q?=E6=B6=88=E6=81=AF=E8=BD=AC=E6=8D=A2=E5=99=A8=E9=85=8D=E7=BD=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 移除自定义ObjectMapper实例，改用注入的@Primary ObjectMapper
- 删除对JavaTimeModule和序列化配置的显式设置
- 简化messageConverter方法实现，提高配置复用性
- 保持消息转换功能一致性和代码简洁性
---
 .../gxwebsoft/common/mq/config/RabbitMQConfig.java    | 11 +----------
 1 file changed, 1 insertion(+), 10 deletions(-)

diff --git a/src/main/java/com/gxwebsoft/common/mq/config/RabbitMQConfig.java b/src/main/java/com/gxwebsoft/common/mq/config/RabbitMQConfig.java
index 8b8d54e..851c0b7 100644
--- a/src/main/java/com/gxwebsoft/common/mq/config/RabbitMQConfig.java
+++ b/src/main/java/com/gxwebsoft/common/mq/config/RabbitMQConfig.java
@@ -1,9 +1,6 @@
 package com.gxwebsoft.common.mq.config;
 
-import com.fasterxml.jackson.databind.DeserializationFeature;
 import com.fasterxml.jackson.databind.ObjectMapper;
-import com.fasterxml.jackson.databind.SerializationFeature;
-import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
 import org.springframework.amqp.core.*;
 import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
 import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
@@ -68,13 +65,7 @@ public class RabbitMQConfig {
     // ==================== Message Converter ====================
 
     @Bean
-    public MessageConverter messageConverter() {
-        // 使用JacksonConfig中定义的@Primary objectMapper bean
-        ObjectMapper objectMapper = new ObjectMapper();
-        objectMapper.registerModule(new JavaTimeModule());
-        objectMapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
-        objectMapper.disable(SerializationFeature.WRITE_DATE_TIMESTAMPS_AS_NANOSECONDS);
-        objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
+    public MessageConverter messageConverter(ObjectMapper objectMapper) {
         return new Jackson2JsonMessageConverter(objectMapper);
     }