Protobuf怎么与Redis集成_自定义Redis序列化器-Redis-PHP中文网

会。redis只认byte[]或字符串，protobuf java类默认不可序列化，需自定义redisserializer实现serialize()/deserialize()，注意空值、类型擦除及版本兼容问题。

protobuf怎么与redis集成_自定义redis序列化器

Protobuf对象直接存Redis会报错吗？

会。Redis只认byte[]或字符串，而Protobuf生成的Java类（比如UserProto.User）默认没有实现Serializable，也不带无参构造器，直接用JdkSerializationRedisSerializer会抛NotSerializableException或InvalidClassException。更关键的是，Protobuf二进制格式本身是紧凑、无schema的，Redis不理解它——所以必须自己控制序列化/反序列化环节。

怎么写一个Protobuf专用的Redis序列化器？

核心是实现RedisSerializer<t></t>接口，重点覆盖serialize()和deserialize()。注意三点：类型擦除问题、空值处理、proto message的toByteArray()与parseFrom()调用安全。

serialize()里判空，非空才调message.toByteArray()，返回原始字节数组（不要Base64编码，浪费空间）
deserialize()里先判空字节数组，再用对应Message.getDefaultInstance().getParserForType().parseFrom(bytes)，避免硬写UserProto.User.parseFrom(bytes)导致泛型丢失
构造器接收Class<t></t>，内部缓存Parser<t></t>，避免每次反序列化都反射获取

示例片段：

Redis Skill - 高性能缓存管理

Redis 缓存和数据结构管理技能。通过自然语言操作 Redis，支持 String、Hash、List、Set、ZSet、Stream 等数据结构操作。当用户提到 Redis、缓存、消息队列、会话存储时使用此技能。

下载

public class ProtobufRedisSerializer<t extends message> implements RedisSerializer<t> {
    private final Class<t> targetClass;
    private final Parser<t> parser;

    public ProtobufRedisSerializer(Class<t> targetClass) {
        this.targetClass = targetClass;
        this.parser = (Parser<t>) targetClass.getDeclaredMethod("getParserForType")
            .invoke(targetClass.getDeclaredMethod("getDefaultInstance").invoke(null));
    }

    @Override
    public byte[] serialize(T object) throws SerializationException {
        return object == null ? new byte[0] : object.toByteArray();
    }

    @Override
    public T deserialize(byte[] bytes) throws SerializationException {
        if (bytes == null || bytes.length == 0) return null;
        try {
            return parser.parseFrom(bytes);
        } catch (InvalidProtocolBufferException e) {
            throw new SerializationException("Failed to parse protobuf", e);
        }
    }
}</t></t></t></t></t></t>

Spring Boot里怎么配置Protobuf序列化器？

不能直接塞进RedisTemplate的defaultSerializer，否则所有key/value都走Protobuf，连String类型都崩。正确做法是按业务场景显式指定——比如专门存用户proto时用定制template，其他仍用默认JSON或JDK序列化器。

定义独立的RedisTemplate<string userproto.user></string>，设置valueSerializer为你的ProtobufRedisSerializer<userproto.user></userproto.user>
key保持StringRedisSerializer，别动key的序列化逻辑
如果多个proto类型共存，别搞“通用泛型template”，每个类型配一个template Bean，用@Qualifier区分
注意RedisCacheManager不支持这种细粒度value序列化，缓存注解（@Cacheable）没法直接用Protobuf对象，得退回到手动redisTemplate.opsForValue().set()