设为首页收藏本站

番薯窝-网络爱好者交流社区

 找回密码
 立即注册

QQ登录

只需一步,快速开始

用新浪微博连接

一步搞定

搜索
查看: 865|回复: 0

KVStore最佳实践系列——事务处理(transcation)

[复制链接]
发表于 2015-7-26 16:54:14 | 显示全部楼层 |阅读模式
场景介绍


KVStore支持Redis中定义的“事务(transcation)”机制,即用户可以使用MULTI,EXEC,DISCARD,WATCH,UNWATCH指令用来执行原子性的事务操作
需要强调的是,Redis中定义的事务(http://redis.io/topics/transactions),并不是关系数据库中严格意义上的事务。当Redis事务中的某个操作执行失败,或者用DISCARD取消事务时候,Redis并不执行“事务回滚”,在使用时要注意这点。

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


[url=]复制代码[/url]
  • package transcation.kvstore.aliyun.com;
  • import java.util.List;
  • import redis.clients.jedis.Jedis;
  • import redis.clients.jedis.Transaction;
  • public class KVStoreTranscationTest {
  •     static final String host = "xxxxxx.m.cnhza.kvstore.aliyuncs.com";
  •     static final int port = 6379;
  •     static final String password = "instanceid:password";
  •     //**注意这两个key的内容是不同的
  •     static String client1_key = "KVStore-Transcation-1";
  •     static String client2_key = "KVStore-Transcation-2";
  •     public static void main(String[] args) {
  •         Jedis jedis = new Jedis(host, port);
  •         // KVStore的实例ID及密码
  •         String authString = jedis.auth(password);// kvstore_instance_id:password
  •         if (!authString.equals("OK")) {
  •             System.err.println("认证失败: " + authString);
  •             jedis.close();
  •             return;
  •         }
  •         jedis.set(client1_key, "0");
  •         //启动另一个thread,模拟另外的client
  •         new KVStoreTranscationTest().new OtherKVStoreClient().start();
  •         Thread.sleep(500);
  •         Transaction tx = jedis.multi();//开始事务
  •         //以下操作会集中提交KVStore服务器端处理,作为“原子操作”
  •         tx.incr(client1_key);
  •         tx.incr(client1_key);
  •         Thread.sleep(400);//此处Thread的暂停对事务中前后连续的操作并无影响,其他Thread的操作也无法执行
  •         tx.incr(client1_key);
  •         Thread.sleep(300);//此处Thread的暂停对事务中前后连续的操作并无影响,其他Thread的操作也无法执行
  •         tx.incr(client1_key);
  •         Thread.sleep(200);//此处Thread的暂停对事务中前后连续的操作并无影响,其他Thread的操作也无法执行
  •         tx.incr(client1_key);
  •         List<Object> result = tx.exec();//提交执行
  •         //解析并打印出结果
  •         for(Object rt : result){
  •             System.out.println("Client 1 > 事务中> "+rt.toString());
  •         }
  •         jedis.close();
  •     }
  •     class OtherKVStoreClient extends Thread{
  •         @Override
  •         public void run() {
  •             Jedis jedis = new Jedis(host, port);
  •             // KVStore的实例ID及密码
  •             String authString = jedis.auth(password);// kvstore_instance_id:password
  •             if (!authString.equals("OK")) {
  •                 System.err.println("AUTH Failed: " + authString);
  •                 jedis.close();
  •                 return;
  •             }
  •             jedis.set(client2_key, "100");
  •             for (int i = 0; i < 10; i++) {
  •                 try {
  •                     Thread.sleep(300);
  •                 } catch (InterruptedException e) {
  •                     e.printStackTrace();
  •                 }
  •                 System.out.println("Client 2 > "+jedis.incr(client2_key));
  •             }
  •             jedis.close();
  •         }
  •     }
  • }



运行结果1


在输入了正确的KVStore实例访问地址和密码之后,运行以上Java程序,输出结果如下。从中可以看到client1和client2在两个不同的Thread中,client1所提交的事务操作都是集中顺序执行的,在此期间尽管client2是对另外一个key进行操作,它的命令操作也都被阻塞等待,直至client1事务中的全部操作执行完毕。
[url=]复制代码[/url]
  • Client 2 > 101
  • Client 2 > 102
  • Client 2 > 103
  • Client 2 > 104
  • Client 1 > 事务中> 1
  • Client 1 > 事务中> 2
  • Client 1 > 事务中> 3
  • Client 1 > 事务中> 4
  • Client 1 > 事务中> 5
  • Client 2 > 105
  • Client 2 > 106
  • Client 2 > 107
  • Client 2 > 108
  • Client 2 > 109
  • Client 2 > 110




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


对以上的代码稍作改动,使得两个client操作同一个key,其余部分保持不变。
[url=]复制代码[/url]
  • ... ...
  • //**注意这两个key的内容现在是相同的
  •     static String client1_key = "KVStore-Transcation-1";
  •     static String client2_key = "KVStore-Transcation-1";
  •     ... ...



运行结果2


再次运行修改后的此Java程序,输出结果如下。可以看到不同Thread中的两个client在操作同一个key,但是当client1利用事务机制来操作这个key时,client2被阻塞不得不等待client1事务中的操作完全执行完毕。
[url=]复制代码[/url]
  • Client 2 > 101
  • Client 2 > 102
  • Client 2 > 103
  • Client 2 > 104
  • Client 1 > 事务中> 105
  • Client 1 > 事务中> 106
  • Client 1 > 事务中> 107
  • Client 1 > 事务中> 108
  • Client 1 > 事务中> 109
  • Client 2 > 110
  • Client 2 > 111
  • Client 2 > 112
  • Client 2 > 113
  • Client 2 > 114
  • Client 2 > 115



回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

手机版|番薯窝    

GMT+8, 2018-8-17 21:52 , Processed in 0.087572 second(s), 23 queries .

快速回复 返回顶部 返回列表