Redis で RedisTemplate のシーケンスと逆シリアル化を構成する方法

RedisTemplate の構成シーケンスと逆シリアル化

Spring Data Redis は、Redis 操作の使用を容易にする優れたカプセル化を提供します。高度にカプセル化された RedisTemplate クラスが一連の Redis 操作を実行するために提供され、接続プールが自動的に管理され、同時にトランザクションのカプセル化操作が処理のためにコンテナーに渡されます。

データの「シリアル化と逆シリアル化」のためにさまざまな戦略 (RedisSerializer) が提供されています。

デフォルトでは、JdkSerializationRedisSerializer に加え、StringRedisSerializer、JacksonJsonRedisSerializer、OxmSerializer、および GenericFastJsonRedisSerializer を使用します。

はじめに

JdkSerializationRedisSerializer: POJO オブジェクト アクセス シナリオは、JDK 独自のシリアル化メカニズムを使用し、ObjectInputStream/ObjectOutputStream を通じて pojo クラスをシリアル化し、最後に単語を redis-server セクション シーケンスに保存します。これが現在のデフォルトのシリアル化戦略です。

StringRedisSerializer: キーまたは値が文字列の場合、データのバイト シーケンスは、指定された文字セット (「new String(bytes, charset)」および「string.getBytes」) に従って文字列にエンコードされます。 (charset)」を直接カプセル化します。は最も軽量で効率的な戦略です。

JacksonJsonRedisSerializer: jackson-json ツールは、javabean と json 間の変換機能を提供し、pojo インスタンスを json 形式にシリアル化して redis に保存したり、json 形式のデータを pojo インスタンスに変換したりできます。 Jackson ツールはシリアル化および逆シリアル化するときにクラス タイプを明示的に指定する必要があるため、この戦略のカプセル化は少し複雑になります。 [jackson-mapper-asl ツールのサポートが必要]

GenericFastJsonRedisSerializer: Javabean と json 間の別の変換、およびクラス型も指定する必要があります。

OxmSerializer: Javabeans を xml に変換する機能を提供します。現在利用可能なサードパーティ サポートには、jaxb、apache-xmlbeans が含まれます。redis に保存されるデータは xml ツールになります。ただし、この戦略を使用すると、プログラミングがより困難になり、最も効率的になるため、お勧めできません。 [spring-oxm モジュールのサポートが必要]

実践

1) 依存関係 (バージョンは SpringBoot バージョンを継承します)

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

2) RedisConfig class

Bean を追加し、キー/値を指定し、HashKey と HashValue を FastJson にシリアル化および逆シリアル化します。

package com.sleb.springcloud.common.config;
import com.alibaba.fastjson.support.spring.GenericFastJsonRedisSerializer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericToStringSerializer;
/**
 * redis配置
 * @author 追到乌云的尽头找太阳（Jacob）
 **/
@Configuration
public class RedisConfig {
    @Bean
    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(redisConnectionFactory);
        // 使用 GenericFastJsonRedisSerializer 替换默认序列化
        GenericFastJsonRedisSerializer genericFastJsonRedisSerializer = new GenericFastJsonRedisSerializer();
        // 设置key和value的序列化规则
        redisTemplate.setKeySerializer(new GenericToStringSerializer<>(Object.class));
        redisTemplate.setValueSerializer(genericFastJsonRedisSerializer);
        // 设置hashKey和hashValue的序列化规则
        redisTemplate.setHashKeySerializer(new GenericToStringSerializer<>(Object.class));
        redisTemplate.setHashValueSerializer(genericFastJsonRedisSerializer);
        // 设置支持事物
        redisTemplate.setEnableTransactionSupport(true);
        redisTemplate.afterPropertiesSet();
        return redisTemplate;
    }
}

RedisTemplate シリアル化の問題

シリアル化ルールと逆シリアル化ルールが矛盾しているため、エラー報告が発生します

1. redisTemplate を構成します

<!-- redis数据源 -->
    <bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">
        <!-- 最大空闲数 -->
        <property name="maxIdle" value="${redis.maxIdle}"/>
        <!-- 最大空连接数 -->
        <property name="maxTotal" value="${redis.maxTotal}"/>
        <!-- 最大等待时间 -->
        <property name="maxWaitMillis" value="${redis.maxWaitMillis}"/>
        <!-- 返回连接时，检测连接是否成功 -->
        <property name="testOnBorrow" value="${redis.testOnBorrow}"/>
    </bean>
<!-- Spring-data-redis连接池管理工厂 -->
    <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
        <!-- IP地址 -->
        <property name="hostName" value="${redis.host}"/>
        <!-- 端口号 -->
        <property name="port" value="${redis.port}"/>
        <!-- 密码 -->
<!--        <property name="password" value="${redis.password}"/>-->
        <!-- 超时时间 默认2000 -->
        <property name="timeout" value="${redis.timeout}"/>
        <!-- 连接池配置引用 -->
        <property name="poolConfig" ref="poolConfig"/>
        <!-- 是否使用连接池 -->
        <property name="usePool" value="true"/>
        <!-- 指定使用的数据库 -->
        <property name="database" value="0"/>
    </bean>
<!-- redis template definition -->
    <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
        <property name="connectionFactory" ref="jedisConnectionFactory"/>
        <property name="keySerializer">
            <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>
        </property>
        <property name="valueSerializer">
            <bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/>
        </property>
        <property name="hashKeySerializer">
            <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>
        </property>
        <property name="hashValueSerializer">
            <bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/>
        </property>
    </bean>

2. 値を格納します

今回は値が保存されます。redisTemplate のコールバック関数を使用して、文字列シリアル化メソッドに従って redisValue が保存されます

    public void testRedisListPush() {
        String redisKey = "testGoodsKey";
        List<String> redisValues = Arrays.asList("10002001", "10002002");
        // 使用管道向redis list结构中批量插入元素
        redisTemplate.executePipelined((RedisConnection redisConnection) -> {
            // 打开管道
            redisConnection.openPipeline();
            // 给本次管道内添加，一次性执行的多条命令
            for (String redisValue : redisValues) {
                redisConnection.rPush(redisKey.getBytes(), redisValue.getBytes());
            }
            return null;
        });
    }

redis クライアント: 値は文字列です

3. 値

今回は、返される結果は、1. redisTemplate の設定で設定した JdkSerializationRedisSerializer のシリアル化メソッドがデフォルトになります。保存と取得のシリアル化メソッドは統一されていないため、エラー状態が発生します。

	public void testRedisListPop() {
        String redisKey = "testGoodsKey";
        // 使用管道从redis list结构中批量获取元素
        List<Object> objects = redisTemplate.executePipelined((RedisConnection redisConnection) -> {
            // 打开管道
            redisConnection.openPipeline();
            for (int i = 0; i < 2; i++) {
                redisConnection.rPop(redisKey.getBytes());
            }
            return null;
        });
        System.out.println(objects);
    }

エラー レポートの詳細: 逆シリアル化に失敗しました

org.springframework.data.redis.serializer.SerializationException: 逆シリアル化できません。ネストされた例外は org.springframework.core.serializer です。 .support.SerializationFailedException: ペイロードの逆シリアル化に失敗しました。バイト配列は、DefaultDeserializer に対応するシリアル化の結果ですか?; ネストされた例外は java.io.StreamCorruptedException です: 無効なストリーム ヘッダー: 31303030
...
原因: org .springframework.core.serializer.support.SerializationFailedException: ペイロードの逆シリアル化に失敗しました。バイト配列は DefaultDeserializer に対応するシリアル化の結果ですか?; ネストされた例外は java.io.StreamCorruptedException: 無効なストリーム ヘッダー: 31303030
at org. springframework .core.serializer.support.DeserializingConverter.convert(DeserializingConverter.java:78)
at org.springframework.core.serializer.support.DeserializingConverter.convert(DeserializingConverter.java:36)
at org.springframework.data .redis.serializer.JdkSerializationRedisSerializer.deserialize(JdkSerializationRedisSerializer.java:80)
... 39 more
原因: java.io.StreamCorruptedException: 無効なストリーム ヘッダー: 31303030
( java.io.ObjectInputStream )。 readStreamHeader(ObjectInputStream.java:899)
at java.io.ObjectInputStream.(ObjectInputStream.java:357)
at org.springframework.core.ConfigurableObjectInputStream.(ConfigurableObjectInputStream.java : 63)
org.springframework.core.ConfigurableObjectInputStream.(ConfigurableObjectInputStream.java:49)
org.springframework.core.serializer.DefaultDeserializer.deserialize(DefaultDeserializer.java:68)
org.springframework.core.serializer.support.DeserializingConverter.convert(DeserializingConverter.java:73)
... 41 more

Solution

1. 値を取得

需要在redisTemplate.executePipelined入参中再加一个参数：redisTemplate.getStringSerializer()，取值成功，解决问题！！

    public void testRedisListPop() {
        String redisKey = "testGoodsKey";
        // 使用管道从redis list结构中批量获取元素
        List<Object> objects = redisTemplate.executePipelined((RedisConnection redisConnection) -> {
            // 打开管道
            redisConnection.openPipeline();
            for (int i = 0; i < 2; i++) {
                redisConnection.rPop(redisKey.getBytes());
            }
            return null;
        }, redisTemplate.getStringSerializer());
        System.out.println(objects);
    }

总结

1、使用原生redisTemplate操作数据和redisTemplate回调函数操作数据注意点：

a.原生redisTemplate操作数据

代码

    public void testRedisListPush() {
        String redisKey = "testGoodsKey";
        List<String> redisValues = Arrays.asList("10002001", "10002002");
        redisValues.forEach(redisValue -> redisTemplate.opsForList().rightPush(redisKey, redisValue));
    }

redis客户端数据展示

b.redisTemplate回调函数操作数据

代码

    public void testRedisListPush() {
        String redisKey = "testGoodsKey";
        List<String> redisValues = Arrays.asList("10002001", "10002002");
        // 使用管道向redis list结构中批量插入元素
        redisTemplate.executePipelined((RedisConnection redisConnection) -> {
            // 打开管道
            redisConnection.openPipeline();
            // 给本次管道内添加，一次性执行的多条命令
            for (String redisValue : redisValues) {
                redisConnection.rPush(redisKey.getBytes(), redisValue.getBytes());
            }
            return null;
        });
    }

redis客户端数据展示

c.不同点：

原生redisTemplate操作数据序列化方式是和redis配置统一的，redisTemplate回调函数操作数据序列化方式是自定义的。存值取值是需要注意。

以上がRedis で RedisTemplate のシーケンスと逆シリアル化を構成する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。