Tair(Redis OSS-compatible)支援Redis中定義的事務(transaction)機制。您可以使用MULTI,EXEC,DISCARD,WATCH,UNWATCH指令用來執行原子性的事務操作。
Redis中定義的事務,並不是關聯式資料庫中嚴格意義上的事務。當Redis事務中的某個操作執行失敗,或者用DISCARD取消事務時候,Redis不會執行交易回復。
程式碼範例
樣本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的內容是不同的
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("認證失敗: " + authString);
jedis.close();
return;
}
jedis.set(client1_key, "0");
// 啟動另一個thread,類比另外的client
new KVStoreTranscationTest().new OtherKVStoreClient().start();
Thread.sleep(500);
Transaction tx = jedis.multi();//開始事務
// 以下操作會集中提交伺服器端處理,作為“原子操作”
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);
// 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();
}
}
}
在輸入了正確的Tair(Redis OSS-compatible)執行個體訪問地址和密碼之後,運行以上Java程式,輸出結果如下。從中可以看到client1和 client2在兩個不同的Thread中,client1所提交的事務操作都是集中順序執行的,在此期間儘管client2是對另外一個key進行操作,它的命令操作也都被阻塞等待,直至client1事務中的全部操作執行完畢。
預計返回:
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
對樣本1的代碼稍作改動,使得兩個Client操作同一個Key,其餘部分保持不變。
... ...
// 注意這兩個key的內容現在是相同的
static String client1_key = "KVStore-Transcation-1";
static String client2_key = "KVStore-Transcation-1";
... ...
再次運行修改後的此Java程式,輸出結果如下。可以看到不同線程中的兩個client在操作同一個key,但是當client1利用事務機制來操作這個key時,client2被阻塞不得不等待client1事務中的操作完全執行完畢。
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