JCache是Java EE提供的统一缓存API规范，Redisson是基于Redis实现的分布式Java对象和服务的框架，二者结合使用时，序列化与反序列化机制负责将Java对象转换为可存储的字节流，以及将字节流还原为Java对象，是缓存数据流转的核心环节。
JCache with Redisson默认序列化机制
Redisson作为JCache规范的实现者，默认使用JsonJacksonCodec作为序列化器，该序列化器基于Jackson库实现，能够将Java对象序列化为JSON格式的字节流，反序列化时再将JSON字节流还原为对应的Java对象。
默认的JSON序列化有以下特点：
- 序列化后的数据是可读的JSON格式，方便调试和查看缓存内容
- 支持大部分常见的Java数据类型，包括基本类型、集合类型、自定义POJO等
- 不需要实现
Serializable接口，降低了对象的侵入性
以下是使用默认序列化存储和读取对象的简单示例：
// 配置Redisson客户端
Config config = new Config();
config.useSingleServer().setAddress("redis://127.0.0.1:6379");
RedissonClient redisson = Redisson.create(config);
// 获取JCache缓存实例，使用默认序列化
CacheManager cacheManager = Caching.getCachingProvider().getCacheManager();
Cache<String, User> cache = cacheManager.createCache("userCache",
new MutableConfiguration<String, User>()
.setStoreByValue(true)
.setTypes(String.class, User.class)
);
// 存储对象
User user = new User("1001", "张三", 25);
cache.put("user:1001", user);
// 读取对象
User cachedUser = cache.get("user:1001");
System.out.println(cachedUser.getName()); // 输出 张三
自定义序列化器配置
当默认的JSON序列化无法满足需求时，比如需要更高的性能、更小的存储体积，或者需要兼容特定的序列化格式，可以自定义序列化器。Redisson支持多种内置序列化器，也支持用户自定义实现。
使用内置序列化器
Redisson提供了多种内置的序列化器，常见的有：
| 序列化器类 | 特点 | 适用场景 |
|---|---|---|
| JsonJacksonCodec | JSON格式，可读性好 | 调试场景、需要跨语言兼容的场景 |
| KryoCodec | 序列化速度快，体积小 | 对性能要求高的场景 |
| FstCodec | 序列化速度优于Jackson，体积较小 | 对性能和存储体积有一定要求的场景 |
| SerializationCodec | 基于JDK原生序列化 | 需要兼容JDK原生序列化逻辑的场景 |
配置内置序列化器的示例，这里以KryoCodec为例：
Config config = new Config();
// 设置全局序列化器为KryoCodec
config.setCodec(new KryoCodec());
config.useSingleServer().setAddress("redis://127.0.0.1:6379");
RedissonClient redisson = Redisson.create(config);
// 后续获取JCache缓存实例时会使用配置的KryoCodec进行序列化
CacheManager cacheManager = Caching.getCachingProvider().getCacheManager();
Cache<String, User> cache = cacheManager.createCache("userCacheKryo",
new MutableConfiguration<String, User>()
.setStoreByValue(true)
.setTypes(String.class, User.class)
);
自定义序列化器实现
如果需要完全自定义序列化逻辑，可以实现Codec接口，重写序列化和反序列化方法。以下是一个简单的自定义序列化器示例，实现对象的简单字符串拼接序列化：
import org.redisson.client.codec.Codec;
import org.redisson.client.protocol.Decoder;
import org.redisson.client.protocol.Encoder;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
public class CustomStringCodec implements Codec {
@Override
public Decoder<Object> getValueDecoder() {
return (buf, state) -> {
byte[] bytes = new byte[buf.readableBytes()];
buf.readBytes(bytes);
String str = new String(bytes, StandardCharsets.UTF_8);
// 简单解析，假设格式为 id,name,age
String[] parts = str.split(",");
User user = new User();
user.setId(parts[0]);
user.setName(parts[1]);
user.setAge(Integer.parseInt(parts[2]));
return user;
};
}
@Override
public Encoder getValueEncoder() {
return obj -> {
User user = (User) obj;
String str = user.getId() + "," + user.getName() + "," + user.getAge();
return buf -> buf.writeBytes(str.getBytes(StandardCharsets.UTF_8));
};
}
@Override
public Decoder<Object> getMapKeyDecoder() {
return getValueDecoder();
}
@Override
public Encoder getMapKeyEncoder() {
return getValueEncoder();
}
@Override
public Decoder<Object> getMapValueDecoder() {
return getValueDecoder();
}
@Override
public Encoder getMapValueEncoder() {
return getValueEncoder();
}
}
配置自定义序列化器：
Config config = new Config();
config.setCodec(new CustomStringCodec());
config.useSingleServer().setAddress("redis://127.0.0.1:6379");
RedissonClient redisson = Redisson.create(config);
序列化机制注意事项
在使用JCache with Redisson的序列化机制时，需要注意以下几点：
- 自定义POJO如果包含不能被序列化的属性，比如InputStream、Thread等类型的属性，需要排除这些属性，否则序列化会失败
- 如果更换了序列化器，之前使用旧序列化器存储的缓存数据将无法被正确反序列化，需要清理旧缓存或者做兼容处理
- 序列化器的性能会影响缓存的读写效率，高并发场景下建议选择Kryo、Fst这类高性能序列化器
- 跨服务使用缓存时，需要保证所有服务的序列化器配置一致，否则会出现反序列化失败的问题
序列化机制的选择需要结合业务场景综合考虑，没有绝对最优的方案，只有最适合当前场景的方案。
常见问题排查
如果遇到反序列化失败的问题，可以按照以下步骤排查：
- 检查缓存中存储的字节流格式是否和当前使用的序列化器匹配
- 检查自定义POJO的类结构是否发生变化，比如新增或删除了字段，导致反序列化时字段不匹配
- 检查序列化器的配置是否生效，是否存在多个配置覆盖的情况
- 查看Redisson的日志输出，获取更详细的序列化错误信息