首页 > 代码库 > 【Redis缓存机制】13.Java连接Redis_Jedis_事务

【Redis缓存机制】13.Java连接Redis_Jedis_事务

2024-08-26 17:55:24   212人阅读

Jedis事务
我们使用JDBC连接Mysql的时候，每次执行sql语句之前，都需要开启事务；在MyBatis中，
也需要使用openSession()来获取session事务对象，来进行sql执行、查询等操作。当我们
对数据库的操作结束的时候，是事务对象负责关闭数据库连接。

事务对象用于管理、执行各种数据库操作的动作。它能够开启和关闭数据库连接，执行sql
语句，回滚错误的操作。

我们的Redis也有事务管理对象，其位于redis.clients.jedis.Transaction下。

Jedis事务的相关代码:
package cn.com.redis;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Transaction;

public class Test7 {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("192.168.248.129",6379);
        
        Transaction transaction=jedis.multi();//返回一个事务控制对象
        
        //预先在事务对象中装入要执行的操作
        transaction.set("k4", "v4");
        transaction.set("k5", "v5");
        
        transaction.exec();//执行
    }
}
我们查看一下redis:
技术分享
发现数据已经加入进去

我们把k4的value和k5的value改为“v44”和“v55”,
然后在transaction.exec()语句后加入transaction.discard()语句:
package cn.com.redis;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Transaction;

public class Test7 {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("192.168.248.129",6379);
        
        Transaction transaction=jedis.multi();//返回一个事务控制对象
        
        //预先在事务对象中装入要执行的操作
        transaction.set("k4", "v44");
        transaction.set("k5", "v55");

        transaction.discard();//回滚
    }
}
会发现数据插入操作被回滚，redis中那两个值未被改变:
技术分享

我们模拟一个刷一次信用卡的交易，使用redis的事务来处理一些逻辑:
package cn.com.redis;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Transaction;

public class TestTransaction {
    //模拟信用卡消费和还款
    public static void main(String[] args) {
        TestTransaction t = new TestTransaction();
        boolean retValue = http://www.mamicode.com/t.transMethod(100);>
此代码就是模拟用户使用信用卡刷了100元的东西，此时应该减去信用卡的可用余额100元，
增加100元的欠款。

运行结果:
技术分享

redis的结果:
技术分享
证明我们的操作是成功的。

加watch命令是为了在事务执行的过程中，防止其它的操作打断事务，或者是影响事务的计算结果，
导致“幻读”、“脏数据”等异常情况的发生。watch命令建立了一个键，一旦发现执行过程中该
键被别人修改过，那事务就会失败，程序中通常可以捕获这类错误再重新执行一次，直到成功。
所以watch命令可以保证数据的同步安全。

为了证明watch命令的用途，我们把上面代码里面的jedis.set("balance", "1100");注释释放，
然后transMethod方法抛出打断异常:throws InterruptedException，main方法捕获打断异常，
然后弹出相应警告框。
package cn.com.redis;

import java.util.List;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Transaction;

public class TestTransaction {
    //模拟信用卡消费和还款
    public static void main(String[] args) {
        TestTransaction t = new TestTransaction();
        boolean retValue=http://www.mamicode.com/false;>再运行一下，看一下效果：
技术分享

这就说明了，如果在watch命令执行后和事务提交之前，如果数据发生了修改操作，事务执行就不会成功，
此举保证了数据的安全性。
转载请注明出处：http://blog.csdn.net/acmman/article/details/53579378
【Redis缓存机制】13.Java连接Redis_Jedis_事务


联系
我们