相對我們對於redis的使用場景都已經想當的熟悉。對於大量的資料，為了緩解介面（資料庫）的壓力，我們對查詢的結果做了快取的策略。一開始我們的思路是這樣的。

1.執行查詢

2.快取中存在資料 -> 查詢快取 

3.快取中不存在資料 -> 查詢實時介面

對此，我簡單模擬了我們的快取機制 。

這是一個查詢實時的服務

package yyf.Jedis.toolsByRedis.cacheCacheTools;

/**
 * 模擬服務
 * @author yuyufeng
 *
 */
public class BaseService {
	public String query(String req) {
		
		return "hello:" + req;
	}
}
 

package yyf.Jedis.toolsByRedis.cacheCacheTools;

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

public class CacheCacheToolTest {
	static JedisPool jedisPool;
	static {
		JedisPoolConfig config = new JedisPoolConfig();
		config.setMaxTotal(100);
		config.setMaxIdle(5);
		config.setMaxWaitMillis(1000);
		config.setTestOnBorrow(false);

		jedisPool = new JedisPool(config, "127.0.0.1", 6379, 1000);
		Jedis jedis = jedisPool.getResource();
		jedisPool.returnResource(jedis);

	}

	public static void main(String[] args) {
		for (int i = 0; i < 5; i++) {
			new Thread(){@Override
			public void run() {
				//執行查詢
				query();
			}}.start();
			
		}

	}

	public static void query() {
		BaseService bs = new BaseService();
		Jedis jedis = jedisPool.getResource();
		String req = "test123";
		String res;
		if (jedis.get(req) == null) {
			System.out.println("##查詢介面服務");
			res = bs.query(req);
			jedis.setex(req, 10, res);
		} else {
			System.out.println("##查詢快取");
			res = jedis.get(req);
		}
		System.out.println(res);
		jedisPool.returnResource(jedis);
	}

}
 

##查詢介面服務
hello:test123
##查詢快取
##查詢快取
##查詢快取
hello:test123
hello:test123
hello:test123
##查詢快取
hello:test123

package yyf.Jedis.toolsByRedis.cacheCacheTools;

/**
 * 模擬服務
 * @author yuyufeng
 *
 */
public class BaseService {
	public String query(String req) {
		try {
			Thread.sleep(1000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		return "hello:" + req;
	}
}
 

##查詢介面服務
##查詢介面服務
##查詢介面服務
##查詢介面服務
##查詢介面服務
hello:test123
hello:test123
hello:test123
hello:test123
hello:test123

如果在查詢實時過程時，對於相同的請求，能夠讓其等待，那麼效率會有大大的提升：（為了模擬，加鎖處理）

public static void main(String[] args) {
		beginTime = System.currentTimeMillis();
		for (int i = 0; i < 5; i++) {
			new Thread(){@Override
			public void run() {
				//執行查詢
				synchronized (args) {
					query();
				}
				
				//System.out.println(System.currentTimeMillis()-beginTime);
			}}.start();
			
		}

	}

##查詢快取
hello:test123
##查詢快取
hello:test123
##查詢快取
hello:test123
##查詢快取
hello:test123
##查詢快取
hello:test123

一堆人需要從一個出口出去，這個出口有一個小門已經可以通過，還有一個大門未開啟，需要從小門出去開啟。這個大門非常大（redis查詢速度非常快）。如果大批的人同時出去（高併發），那麼必然在小門擠很長的時間。此時，如果現有一個人去把大門先開啟，那麼後面的人（包括本來要擠小門的人）可以直接從大門出去，效率肯定是後面的划算。

對於查詢實時一次比較慢的情況下，可以先讓一個執行緒進去。讓其它執行緒等待。

當然，這樣並不完美。當快取失效，那麼查詢就會卡頓一下。為了保證使用者能一直流暢的查詢，我有如下兩種方案：

1.在快取存在的時間裡的進行非同步查詢去更新快取。

2.使用二級快取，並且當一級快取失效的時候，會去讀取二級快取，二級快取非同步更新。（二級快取的時間可以很長）

下面是第一種策略的程式碼模擬：

public static void query() {
		BaseService bs = new BaseService();
		Jedis jedis = jedisPool.getResource();
		String req = "test123";
		String res;
		if (jedis.get(req) == null) {
			System.out.println("##查詢介面服務");
			res = bs.query(req);
			jedis.setex(req, 100, res);
		} else {
			System.out.println("##查詢快取");
			res = jedis.get(req);
			System.out.println("快取剩餘時間："+jedis.ttl(req));
			// 當時間超過10秒，非同步更新資料到快取
			if (jedis.ttl(req) < 90) {
				//模擬得到推送，接受推送，執行
				new Thread() {
					@Override
					public void run() {
						String res = bs.query(req);
						jedis.setex(req, 100, res);
						System.out.println("非同步更新資料："+req);
					}
				}.start();

			}

		}
		System.out.println(res);
		jedisPool.returnResource(jedis);
	}

##查詢快取
快取剩餘時間：67
hello:test123
##查詢快取
快取剩餘時間：67
hello:test123
##查詢快取
快取剩餘時間：67
hello:test123
##查詢快取
快取剩餘時間：67
hello:test123
##查詢快取
快取剩餘時間：67
hello:test123
非同步更新資料：test123
非同步更新資料：test123
非同步更新資料：test123
非同步更新資料：test123
非同步更新資料：test123

為了保證一段時間內，更新一個快取只執行一次，做如下鎖

public static void main(String[] args) {
		beginTime = System.currentTimeMillis();
		for (int i = 0; i < 5; i++) {
			new Thread() {
				@Override
				public void run() {
					// 執行查詢
						query();
					// System.out.println(System.currentTimeMillis()-beginTime);
				}
			}.start();

		}

	}

	public static void query() {
		BaseService bs = new BaseService();
		Jedis jedis = jedisPool.getResource();
		String req = "test123";
		String res;
		System.out.println(jedis.get(req));
		if (jedis.get(req) == null) {
			System.out.println("##查詢介面服務");
			res = bs.query(req);
			jedis.setex(req, 100, res);
		} else {
			System.out.println("##查詢快取");
			res = jedis.get(req);
			System.out.println("快取剩餘時間："+jedis.ttl(req));
			// 當時間超過10秒，非同步更新資料到快取
			if (jedis.ttl(req) < 90) {
				//模擬得到推送，接受推送，執行
				new Thread() {
					@Override
					public void run() {
						
						//保證5秒內，一條資料只更新一次
						Long incr = jedis.incr("incr-flag-"+req);
						jedis.expire("incr-flag-"+req, 5);
						
						if(1 == incr){
							String resT = bs.query(req);
							jedis.setex(req, 100, resT);
							System.out.println("非同步更新資料："+req);
						}
					}
				}.start();

			}

		}
		jedisPool.returnResource(jedis);
	}

hello:test123
##查詢快取
hello:test123
hello:test123
hello:test123
hello:test123
##查詢快取
##查詢快取
##查詢快取
##查詢快取
非同步更新資料：test123

這樣，即可保證一次查詢比較耗時的情況下，使用者能流暢的查詢。使用者體驗大大提升