Spring Framework 中启动 Redis 事务操作

时间：2023-03-09 18:37:11
Spring Framework 中启动 Redis 事务操作

背景：

项目中遇到有一系列对Redis的操作，并需要保持事务处理。

环境：

Spring version 4.1.8.RELEASE

Redis Server 2.6.12 （64位）

spring-data-redis version 1.6.1.RELEASE

jedis version 2.7.3

使用Spring的@Transactional对redis操作进行控制

Spring Redis的配置文件如下：

<description>Jedis配置</description>

    <!-- Redis 配置 -->

    <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">

        <property name="maxIdle" value="${redis.maxIdle}" />

        <property name="maxTotal" value="${redis.maxActive}" />

        <property name="maxWaitMillis" value="${redis.maxWait}" />

        <property name="testOnBorrow" value="${redis.testOnBorrow}" />

    </bean>

    <bean id="jedisConnectionFactory"

        class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"

        p:hostName="${redis.host}" p:port="${redis.port}" p:usePool="true"

        p:timeout="${redis.timeout}" p:password="${redis.pass}" p:database="${redis.default.db}"

        p:poolConfig-ref="jedisPoolConfig" />

    <bean id="stringRedisSerializer"

        class="org.springframework.data.redis.serializer.StringRedisSerializer" />

    <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate"

        p:connection-factory-ref="jedisConnectionFactory"

        p:defaultSerializer-ref="stringRedisSerializer"

        p:enableTransactionSupport="false" />

    <bean id="redisTemplateTransactional" class="org.springframework.data.redis.core.RedisTemplate"

        p:connection-factory-ref="jedisConnectionFactory"

        p:defaultSerializer-ref="stringRedisSerializer"

        p:enableTransactionSupport="true" />

其中的p:enableTransactionSupport 需要设置为true,才能开启Redis事务管理控制。

业务代码如下：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.RedisSystemException;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Autowired

private RedisTemplate<String, String> redisTemplateTransactional;

@Transactional

public void transactionalForRedis() throws Exception {

　　redisTemplateTransactional.boundValueOps("name").set("TEST_XXX");
　　redisTemplateTransactional.boundValueOps("age").set("11");

　　// 异常代码

　　for (int i = 0; i < 5; i++) {

　　　　if (i == 3) {
　　　　　　throw new RedisSystemException("dsd", new Exception("myself exception....."));

　　　　}

　　}

}

1.使用Spring的事务控制即可:@Transactional

2.其中会抛出异常处理,必须抛出RedisSystemException这个异常才能回滚，如果是自己封装的异常类，不能回滚。

下面是结合数据库操作与Redis，在同一个事务中进行控制的代码样例：

@Transactional

public void test() throws Exception {

        //操作Redis

        redisTemplateTransactional.boundValueOps("name").set("TEST_YYYY");

        redisTemplateTransactional.boundValueOps("age").set("80");

        //操作数据库: JPA保存操作

        SimpleDemoEntity simpleDemoEntity = new SimpleDemoEntity();

        simpleDemoEntity.setRemark("nima");

        simpleDemoEntity.setWeixinId("1000");

        simpleDemoDao.saveAndFlush(simpleDemoEntity);

}

当遇到数据库异常情况，比如，主键冲突，唯一索引值等数据库异常，Redis的操作也可以正常回滚。

原因:

使用@Transactional 事务控制后，Spring对数据库层面进行了完美的事务控制，那么当数据库层抛出的所有异常都可以被事务控制管理。

而Redis或者使用Jedis本身的异常，或者业务异常类并没有被Spring的事务控制管理。
而Spring-redis，给了我们一个可以抛出业务异常的渠道，那就是RedisSystemException。

相关文章