示例1：兩個Client操作不同的Key

代碼示例：

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 = "password";
    //  注意這兩個key的內(nèi)容是不同的
    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);
        // ApsaraDB for Redis的實例密碼
        String authString = jedis.auth(password);//password
        if (!authString.equals("OK")) {
            System.err.println("認(rèn)證失敗: " + authString);
            jedis.close();
            return;
        }
        jedis.set(client1_key, "0");
        // 啟動另一個thread，模擬另外的client
        new KVStoreTranscationTest().new OtherKVStoreClient().start();
        Thread.sleep(500);
        Transaction tx = jedis.multi();//開始事務(wù)
        // 以下操作會集中提交服務(wù)器端處理，作為“原子操作”
        tx.incr(client1_key);
        tx.incr(client1_key);
        Thread.sleep(400);//此處Thread的暫停對事務(wù)中前后連續(xù)的操作并無影響，其他Thread的操作也無法執(zhí)行
        tx.incr(client1_key);
        Thread.sleep(300);//此處Thread的暫停對事務(wù)中前后連續(xù)的操作并無影響，其他Thread的操作也無法執(zhí)行
        tx.incr(client1_key);
        Thread.sleep(200);//此處Thread的暫停對事務(wù)中前后連續(xù)的操作并無影響，其他Thread的操作也無法執(zhí)行
        tx.incr(client1_key);
        List<Object> result = tx.exec();//提交執(zhí)行
        // 解析并打印出結(jié)果
        for(Object rt : result){
            System.out.println("Client 1 > 事務(wù)中> "+rt.toString());
        }
        jedis.close();
    }
    class OtherKVStoreClient extends Thread{
        @Override
        public void run() {
            Jedis jedis = new Jedis(host, port);
            // ApsaraDB for Redis的實例密碼
            String authString = jedis.auth(password);// 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();
        }
    }
}

在輸入了正確的云數(shù)據(jù)庫 Tair（兼容 Redis）實例訪問地址和密碼之后，運行以上Java程序，輸出結(jié)果如下。從中可以看到client1和 client2在兩個不同的Thread中，client1所提交的事務(wù)操作都是集中順序執(zhí)行的，在此期間盡管client2是對另外一個key進行操作，它的命令操作也都被阻塞等待，直至client1事務(wù)中的全部操作執(zhí)行完畢。

預(yù)計返回：

Client 2 > 101
Client 2 > 102
Client 2 > 103
Client 2 > 104
Client 1 > 事務(wù)中> 1
Client 1 > 事務(wù)中> 2
Client 1 > 事務(wù)中> 3
Client 1 > 事務(wù)中> 4
Client 1 > 事務(wù)中> 5
Client 2 > 105
Client 2 > 106
Client 2 > 107
Client 2 > 108
Client 2 > 109
Client 2 > 110

示例2：兩個Client操作相同的Key

對示例1的代碼稍作改動，使得兩個Client操作同一個Key，其余部分保持不變。

    ... ... 
//  注意這兩個key的內(nèi)容現(xiàn)在是相同的
    static String client1_key = "KVStore-Transcation-1";
    static String client2_key = "KVStore-Transcation-1";
    ... ...

再次運行修改后的此Java程序，輸出結(jié)果如下。可以看到不同線程中的兩個client在操作同一個key，但是當(dāng)client1利用事務(wù)機制來操作這個key時，client2被阻塞不得不等待client1事務(wù)中的操作完全執(zhí)行完畢。

Client 2 > 101
Client 2 > 102
Client 2 > 103
Client 2 > 104
Client 1 > 事務(wù)中> 105
Client 1 > 事務(wù)中> 106
Client 1 > 事務(wù)中> 107
Client 1 > 事務(wù)中> 108
Client 1 > 事務(wù)中> 109
Client 2 > 110
Client 2 > 111
Client 2 > 112
Client 2 > 113
Client 2 > 114
Client 2 > 115