首页 > 代码库 > 【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事务的相关代码:
发现数据已经加入进去
我们把k4的value和k5的value改为“v44”和“v55”,
然后在transaction.exec()语句后加入transaction.discard()语句:
我们模拟一个刷一次信用卡的交易,使用redis的事务来处理一些逻辑:
我们使用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_事务
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。