【Redis缓存机制】详解Java连接Redis_Jedis_事务
Jedis事务
我们使用JDBC连接Mysql的时候,每次执行sql语句之前,都需要开启事务;在MyBatis中,也需要使用openSession()来获取session事务对象,来进行sql执行、查询等操作。当我们对数据库的操作结束的时候,是事务对象负责关闭数据库连接。
事务对象用于管理、执行各种数据库操作的动作。它能够开启和关闭数据库连接,执行sql语句,回滚错误的操作。
我们的Redis也有事务管理对象,其位于redis.clients.jedis.Transaction下。
Jedis事务的相关代码:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 | 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()语句:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 | 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的事务来处理一些逻辑:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 | 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 = t.transMethod( 100 ); if (retValue){ System.out.println( "使用信用卡消费成功!" ); } else { System.out.println( "使用信用卡消费失败!" ); } } /** * 通俗点讲,watch命令就是标记一个键,如果标记了一个键, * 在提交事务前如果该键被别人修改过,那事务就会失败,这种情况通常可以在程序中 * 重新再尝试一次。 * * 首先标记了balance,然后检查余额是否足够,不足就取消标记,并不做扣减; * 足够的话,就启动事务进行更新操作。 * 如果在此期间键balance被其他人修改,拿在提交事务(执行exec)时就会报错, * 程序中通常可以捕获这类错误再重新执行一次,直到成功。 * */ private boolean transMethod( int amount) { System.out.println( "您使用信用卡预付款" +amount+ "元" ); Jedis jedis = new Jedis( "192.168.248.129" , 6379 ); int balance = 1000 ; //可用余额 int debt; //欠额 int amtToSubtract = amount; //实刷额度 jedis.set( "balance" , String.valueOf(balance)); jedis.watch( "balance" ); //jedis.set("balance", "1100");//此句不该出现,为了模拟其他程序已经修改了该条目 balance = Integer.parseInt(jedis.get( "balance" )); if (balance < amtToSubtract){ //可用余额小于实刷金额,拒绝交易 jedis.unwatch(); System.out.println( "可用余额不足!" ); return false ; } else { //可用余额够用的时候再去执行扣费操作 System.out.println( "扣费transaction事务开始执行..." ); Transaction transaction = jedis.multi(); transaction.decrBy( "balance" ,amtToSubtract); //余额减去amtToSubtract的钱数 transaction.incrBy( "debt" , amtToSubtract); //信用卡欠款增加amtToSubtract的钱数 transaction.exec(); //执行事务 balance = Integer.parseInt(jedis.get( "balance" )); debt = Integer.parseInt(jedis.get( "debt" )); System.out.println( "扣费transaction事务执行结束..." ); System.out.println( "您的可用余额:" +balance); System.out.println( "您目前欠款:" +debt); return true ; } } } |
此代码就是模拟用户使用信用卡刷了100元的东西,此时应该减去信用卡的可用余额100元,增加100元的欠款。
运行结果:
redis的结果:
证明我们的操作是成功的。
加watch命令是为了在事务执行的过程中,防止其它的操作打断事务,或者是影响事务的计算结果,导致“幻读”、“脏数据”等异常情况的发生。watch命令建立了一个键,一旦发现执行过程中该键被别人修改过,那事务就会失败,程序中通常可以捕获这类错误再重新执行一次,直到成功。所以watch命令可以保证数据的同步安全。
为了证明watch命令的用途,我们把上面代码里面的jedis.set("balance", "1100");注释释放,然后transMethod方法抛出打断异常:throws InterruptedException,main方法捕获打断异常,然后弹出相应警告框。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 | 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= false ; boolean Interrupted = false ; try { retValue = t.transMethod( 100 ); } catch (InterruptedException e) { Interrupted = true ; System.out.println( "事务被打断,请重新执行!" ); } finally { if (retValue){ System.out.println( "使用信用卡消费成功!" ); } else { if (!Interrupted){ System.out.println( "使用信用卡消费失败!余额不足!" ); } } } } /** * 通俗点讲,watch命令就是标记一个键,如果标记了一个键, * 在提交事务前如果该键被别人修改过,那事务就会失败,这种情况通常可以在程序中 * 重新再尝试一次。 * * 首先标记了balance,然后检查余额是否足够,不足就取消标记,并不做扣减; * 足够的话,就启动事务进行更新操作。 * 如果在此期间键balance被其他人修改,拿在提交事务(执行exec)时就会报错, * 程序中通常可以捕获这类错误再重新执行一次,直到成功。 * */ private boolean transMethod( int amount) throws InterruptedException{ System.out.println( "您使用信用卡预付款" +amount+ "元" ); Jedis jedis = new Jedis( "192.168.248.129" , 6379 ); int balance = 1000 ; //可用余额 int debt; //欠额 int amtToSubtract = amount; //实刷额度 jedis.set( "balance" , String.valueOf(balance)); jedis.watch( "balance" ); jedis.set( "balance" , "1100" ); //此句不该出现,为了模拟其他程序已经修改了该条目 balance = Integer.parseInt(jedis.get( "balance" )); if (balance < amtToSubtract){ //可用余额小于实刷金额,拒绝交易 jedis.unwatch(); System.out.println( "可用余额不足!" ); return false ; } else { //可用余额够用的时候再去执行扣费操作 System.out.println( "扣费transaction事务开始执行..." ); Transaction transaction = jedis.multi(); transaction.decrBy( "balance" ,amtToSubtract); //余额减去amtToSubtract的钱数 transaction.incrBy( "debt" , amtToSubtract); //信用卡欠款增加amtToSubtract的钱数 List<Object> result = transaction.exec(); //执行事务 if (result== null ){ //事务提交失败,说明在执行期间数据被修改过 System.out.println( "扣费transaction事务执行中断..." ); throw new InterruptedException(); } else { //事务提交成功 balance = Integer.parseInt(jedis.get( "balance" )); debt = Integer.parseInt(jedis.get( "debt" )); System.out.println( "扣费transaction事务执行结束..." ); System.out.println( "您的可用余额:" +balance); System.out.println( "您目前欠款:" +debt); return true ; } } } } |
再运行一下,看一下效果:
这就说明了,如果在watch命令执行后和事务提交之前,如果数据发生了修改操作,事务执行就不会成功,此举保证了数据的安全性。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。
微信公众号搜索 “ 脚本之家 ” ,选择关注
程序猿的那些事、送书等活动等着你
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若内容造成侵权/违法违规/事实不符,请将相关资料发送至 reterry123@163.com 进行投诉反馈,一经查实,立即处理!
相关文章
SpringBoot常用计量与bean属性校验和进制数据转换规则全面分析
这篇文章主要介绍了SpringBoot常用计量、bean属性校验与进制数据转换规则,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习吧2022-10-10
最新评论