全部产品
弹性计算 会员服务 网络 安全 移动云 数加·大数据分析及展现 数加·大数据应用 管理与监控 云通信 阿里云办公 培训与认证 更多
存储与CDN 数据库 域名与网站(万网) 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 开发者工具 解决方案 物联网 智能硬件
云数据库 Redis 版

事务处理

更新时间:2017-06-07 13:26:11

场景介绍

云数据库 Redis 版支持 Redis 中 定义的“事务(transaction)”机制,即用户可以使用 MULTI,EXEC,DISCARD,WATCH,UNWATCH 指令用来执行原子性的事务操作。

需要强调的是,Redis 中定义的事务,并不是关系数据库中严格意义上的事务。当 Redis 事务中的某个操作执行失败,或者用 DISCARD 取消事务时候,Redis 并不执行“事务回滚”,在使用时要注意这点。

代码示例1:两个 client 操作不同的 key

  1. package transcation.kvstore.aliyun.com;
  2. import java.util.List;
  3. import redis.clients.jedis.Jedis;
  4. import redis.clients.jedis.Transaction;
  5. public class KVStoreTranscationTest {
  6. static final String host = "xxxxxx.m.cnhza.kvstore.aliyuncs.com";
  7. static final int port = 6379;
  8. static final String password = "password";
  9. //**注意这两个key的内容是不同的
  10. static String client1_key = "KVStore-Transcation-1";
  11. static String client2_key = "KVStore-Transcation-2";
  12. public static void main(String[] args) {
  13. Jedis jedis = new Jedis(host, port);
  14. // ApsaraDB for Redis的实例密码
  15. String authString = jedis.auth(password);//password
  16. if (!authString.equals("OK")) {
  17. System.err.println("认证失败: " + authString);
  18. jedis.close();
  19. return;
  20. }
  21. jedis.set(client1_key, "0");
  22. //启动另一个thread,模拟另外的client
  23. new KVStoreTranscationTest().new OtherKVStoreClient().start();
  24. Thread.sleep(500);
  25. Transaction tx = jedis.multi();//开始事务
  26. //以下操作会集中提交服务器端处理,作为“原子操作”
  27. tx.incr(client1_key);
  28. tx.incr(client1_key);
  29. Thread.sleep(400);//此处Thread的暂停对事务中前后连续的操作并无影响,其他Thread的操作也无法执行
  30. tx.incr(client1_key);
  31. Thread.sleep(300);//此处Thread的暂停对事务中前后连续的操作并无影响,其他Thread的操作也无法执行
  32. tx.incr(client1_key);
  33. Thread.sleep(200);//此处Thread的暂停对事务中前后连续的操作并无影响,其他Thread的操作也无法执行
  34. tx.incr(client1_key);
  35. List<Object> result = tx.exec();//提交执行
  36. //解析并打印出结果
  37. for(Object rt : result){
  38. System.out.println("Client 1 > 事务中> "+rt.toString());
  39. }
  40. jedis.close();
  41. }
  42. class OtherKVStoreClient extends Thread{
  43. @Override
  44. public void run() {
  45. Jedis jedis = new Jedis(host, port);
  46. // ApsaraDB for Redis的实例密码
  47. String authString = jedis.auth(password);// password
  48. if (!authString.equals("OK")) {
  49. System.err.println("AUTH Failed: " + authString);
  50. jedis.close();
  51. return;
  52. }
  53. jedis.set(client2_key, "100");
  54. for (int i = 0; i < 10; i++) {
  55. try {
  56. Thread.sleep(300);
  57. } catch (InterruptedException e) {
  58. e.printStackTrace();
  59. }
  60. System.out.println("Client 2 > "+jedis.incr(client2_key));
  61. }
  62. jedis.close();
  63. }
  64. }
  65. }

运行结果1

在输入了正确的云数据库 Redis 版实例访问地址和密码之后,运行以上 Java 程序,输出结果如下。从中可以看到 client1 和 client2 在两个不同的 Thread 中,client1 所提交的事务操作都是集中顺序执行的,在此期间尽管 client2 是对另外一个 key 进行操作,它的命令操作也都被阻塞等待,直至 client1 事务中的全部操作执行完毕。

  1. Client 2 > 101
  2. Client 2 > 102
  3. Client 2 > 103
  4. Client 2 > 104
  5. Client 1 > 事务中> 1
  6. Client 1 > 事务中> 2
  7. Client 1 > 事务中> 3
  8. Client 1 > 事务中> 4
  9. Client 1 > 事务中> 5
  10. Client 2 > 105
  11. Client 2 > 106
  12. Client 2 > 107
  13. Client 2 > 108
  14. Client 2 > 109
  15. Client 2 > 110

代码示例2:两个 client 操作相同的 key

对以上的代码稍作改动,使得两个 client 操作同一个 key,其余部分保持不变。

  1. ... ...
  2. //**注意这两个key的内容现在是相同的
  3. static String client1_key = "KVStore-Transcation-1";
  4. static String client2_key = "KVStore-Transcation-1";
  5. ... ...

运行结果2

再次运行修改后的此 Java 程序,输出结果如下。可以看到不同 Thread 中的两个 client 在操作同一个 key,但是当 client1 利用事务机制来操作这个 key 时,client2 被阻塞不得不等待 client1 事务中的操作完全执行完毕。

  1. Client 2 > 101
  2. Client 2 > 102
  3. Client 2 > 103
  4. Client 2 > 104
  5. Client 1 > 事务中> 105
  6. Client 1 > 事务中> 106
  7. Client 1 > 事务中> 107
  8. Client 1 > 事务中> 108
  9. Client 1 > 事务中> 109
  10. Client 2 > 110
  11. Client 2 > 111
  12. Client 2 > 112
  13. Client 2 > 113
  14. Client 2 > 114
  15. Client 2 > 115
本文导读目录