From 24681c81c09022f584a57006f2534b5f74723414 Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期二, 30 六月 2026 09:27:31 +0800
Subject: [PATCH] 初始化项目
---
yudao-framework/yudao-spring-boot-starter-redis/src/main/java/cn/iocoder/yudao/framework/redis/config/YudaoRedisAutoConfiguration.java | 112 ++-----------------------------------------------------
1 files changed, 5 insertions(+), 107 deletions(-)
diff --git a/yudao-framework/yudao-spring-boot-starter-redis/src/main/java/cn/iocoder/yudao/framework/redis/config/YudaoRedisAutoConfiguration.java b/yudao-framework/yudao-spring-boot-starter-redis/src/main/java/cn/iocoder/yudao/framework/redis/config/YudaoRedisAutoConfiguration.java
index aa7d1b0..87d0b72 100644
--- a/yudao-framework/yudao-spring-boot-starter-redis/src/main/java/cn/iocoder/yudao/framework/redis/config/YudaoRedisAutoConfiguration.java
+++ b/yudao-framework/yudao-spring-boot-starter-redis/src/main/java/cn/iocoder/yudao/framework/redis/config/YudaoRedisAutoConfiguration.java
@@ -1,22 +1,11 @@
package cn.iocoder.yudao.framework.redis.config;
-import cn.iocoder.yudao.framework.common.util.json.JsonUtils;
-import cn.hutool.core.util.StrUtil;
import org.redisson.spring.starter.RedissonAutoConfigurationV4;
import org.springframework.boot.autoconfigure.AutoConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.RedisSerializer;
-
-import java.nio.charset.StandardCharsets;
-import java.util.HashSet;
-import java.util.LinkedHashSet;
-import java.util.Set;
-import java.util.TreeSet;
-
-import tools.jackson.core.type.TypeReference;
-import tools.jackson.databind.ObjectMapper;
/**
* Redis 閰嶇疆绫�
@@ -43,103 +32,12 @@
return template;
}
+ @SuppressWarnings("UnnecessaryLocalVariable")
public static RedisSerializer<?> buildRedisSerializer() {
- // 浣跨敤鑷畾涔夊簭鍒楀寲鍣紝瑙ｅ喅 Set/List 绛� Collection 鍙嶅簭鍒楀寲绫诲瀷闂
- return new TypedJsonRedisSerializer();
- }
-
- /**
- * 鑷畾涔� Redis 搴忓垪鍖栧櫒锛岃В鍐� Set/List 绛� Collection 鍙嶅簭鍒楀寲绫诲瀷闂
- */
- private static class TypedJsonRedisSerializer implements RedisSerializer<Object> {
-
- private static final String JAVA_TYPE_PREFIX = "@class:";
- private static final ObjectMapper OBJECT_MAPPER = JsonUtils.getObjectMapper();
- private static final TypeReference<HashSet<Object>> HASH_SET_TYPE = new TypeReference<>() {};
- private static final TypeReference<LinkedHashSet<Object>> LINKED_HASH_SET_TYPE = new TypeReference<>() {};
- private static final TypeReference<TreeSet<Object>> TREE_SET_TYPE = new TypeReference<>() {};
-
- @Override
- public byte[] serialize(Object value) {
- if (value == null) {
- return new byte[0];
- }
- // 灏嗙被鍨嬩俊鎭笌 JSON 涓�璧峰瓨鍌�
- String json = JsonUtils.toJsonString(value);
- String typePrefix = JAVA_TYPE_PREFIX + value.getClass().getName() + ":";
- return (typePrefix + json).getBytes(StandardCharsets.UTF_8);
- }
-
- @Override
- public Object deserialize(byte[] bytes) {
- if (bytes == null || bytes.length == 0) {
- return null;
- }
- String content = new String(bytes, StandardCharsets.UTF_8);
- if (!content.startsWith(JAVA_TYPE_PREFIX)) {
- // 鍏煎鏃ф暟鎹細娌℃湁绫诲瀷淇℃伅鐨勬儏鍐�
- // 妫�娴嬫槸鍚︿负 JSON 鏁扮粍锛岃嫢鏄垯杞崲涓� HashSet
- return deserializeLegacyData(content);
- }
- // 鎻愬彇绫诲瀷淇℃伅鍜� JSON
- int colonIndex = content.indexOf(':', JAVA_TYPE_PREFIX.length());
- if (colonIndex == -1) {
- return deserializeLegacyData(content);
- }
- String className = content.substring(JAVA_TYPE_PREFIX.length(), colonIndex);
- String json = content.substring(colonIndex + 1);
- try {
- Class<?> clazz = Class.forName(className);
- // 鐗规畩澶勭悊 Set 绫诲瀷锛屽洜涓� Jackson 榛樿浼氬皢 JSON 鏁扮粍鍙嶅簭鍒楀寲涓� List
- return deserializeWithTypeHint(json, clazz);
- } catch (ClassNotFoundException e) {
- // 绫诲瀷涓嶅瓨鍦ㄦ椂锛屽皾璇曞吋瀹硅В鏋�
- return deserializeLegacyData(json);
- } catch (Exception e) {
- // 瑙ｆ瀽澶辫触鏃讹紝灏濊瘯鍏煎瑙ｆ瀽
- return deserializeLegacyData(json);
- }
- }
-
- /**
- * 鍏煎鏃ф暟鎹紙娌℃湁绫诲瀷鍓嶇紑锛夌殑瑙ｆ瀽
- * 瀵逛簬 JSON 鏁扮粍锛岄粯璁よ浆鎹负 HashSet
- */
- private Object deserializeLegacyData(String content) {
- if (StrUtil.isEmpty(content)) {
- return null;
- }
- content = content.trim();
- // 鍒ゆ柇鏄惁涓� JSON 鏁扮粍
- if (content.startsWith("[") && content.endsWith("]")) {
- try {
- // 鏁扮粍绫诲瀷榛樿杞负 HashSet
- return OBJECT_MAPPER.readValue(content, HASH_SET_TYPE);
- } catch (Exception e) {
- return JsonUtils.parseObject(content, Object.class);
- }
- }
- // 鍏朵粬绫诲瀷鐩存帴瑙ｆ瀽
- return JsonUtils.parseObject(content, Object.class);
- }
-
- private Object deserializeWithTypeHint(String json, Class<?> clazz) {
- // 澶勭悊 Set 鎺ュ彛鐨勫疄鐜扮被
- if (HashSet.class.isAssignableFrom(clazz) ||
- "java.util.Collections$UnmodifiableSet".equals(clazz.getName()) ||
- "java.util.Collections$SingletonSet".equals(clazz.getName()) ||
- Set.class.isAssignableFrom(clazz)) {
- return OBJECT_MAPPER.readValue(json, HASH_SET_TYPE);
- }
- if (LinkedHashSet.class.isAssignableFrom(clazz)) {
- return OBJECT_MAPPER.readValue(json, LINKED_HASH_SET_TYPE);
- }
- if (TreeSet.class.isAssignableFrom(clazz)) {
- return OBJECT_MAPPER.readValue(json, TREE_SET_TYPE);
- }
- // 浣跨敤 Jackson 鐨� readValue 鎸囧畾绫诲瀷锛岀‘淇� POJO 姝ｇ‘鍙嶅簭鍒楀寲
- return OBJECT_MAPPER.readValue(json, clazz);
- }
+ RedisSerializer<Object> json = RedisSerializer.json();
+ // 鐗规畩锛歴pring boot 4.x 鏃犻渶瑙ｅ喅 LocalDateTime 鐨勫簭鍒楀寲
+ // 鍘熷洜锛歋pring Data Redis 4 浣跨敤 Jackson 3锛孯edisSerializer.json() 宸叉敮鎸� Java Time 绫诲瀷
+ return json;
}
}
--
Gitblit v1.9.3