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

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

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_事务