在做專案過程中，多個客戶端可能同時讀寫Redis資料庫，set和get命令是否為原子操作，關係到命令是否需要加鎖機制的必要性。網上資料或者看書都說set和get等Redis命令為原子操作，但是程式裡怎麼測試呢？

試想開1000個寫執行緒，1000個讀執行緒同時操作Redis中的一個值，假如set和get不是原子的，那麼當set的時候，把原來資料塗掉，還沒來得及寫進去，get操作已經執行，這個時候get到的值就可能為髒資料。如果get得到的值都為正確的資料，基本能判斷set和get命令為原子操作。

下面程式碼測試：

封裝好的Redis讀寫類：

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;


public class RedisUtils {

	private Jedis jedis;
	private JedisPool jedisPool;

	public RedisUtils() {
		initialPool();
		jedis = jedisPool.getResource();
	}


	private void initialPool() {
		JedisPoolConfig config = new JedisPoolConfig();
		config.setMaxActive(100);
		config.setMaxIdle(20);
		config.setMaxWait(1000l);
		config.setTestOnBorrow(false);
		
		jedisPool = new JedisPool(config, "127.0.0.1", 6379);

	}


	public String get(String key) {
		String getStr = jedis.get(key);
		return getStr;
	}

	public String set(String key, String value) {
		String setStr = jedis.set(key, value);
		return setStr;
	}

}
 

1000個寫執行緒：

package writeTest;

public class writeTest extends Thread {

	public writeTest(String s) {
		super(s);
	}

	public void run() {
		RedisUtils ru = new RedisUtils();
		while (true) {
			try {
				String s = ru.set("test", "100");
				System.out.println(getName() + "===" + "done");
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}

	public static void main(String[] args) {
		for (int i = 0; i < 1000; i++) {
			String threadName = "WThread" + i;
			new writeTest(threadName).start();
		}
	}
}
 

1000個讀執行緒：

package readTest;

public class readTest extends Thread {

	public readTest(String s) {
		super(s);
	}

	public void run() {
		RedisUtils ru = new RedisUtils();
		while (true) {
			try {
				String s = ru.get("test");
				System.out.println(getName() + "===" + s);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}

	public static void main(String[] args) {
		for (int i = 0; i < 1000; i++) {
			String threadName = "RThread" + i;
			new readTest(threadName).start();
		}
	}
}
 

同時執行上述讀執行緒，和寫執行緒，看控制檯輸出get到的值是否有髒資料。

發現RThread執行緒get讀出來的數都是100，沒有髒資料，即可判斷set和get為原子操作。