概 述
evcache 是 netflix開源的分布式緩存系統，基于 memcached緩存和 spymemcached客戶端實現，其用在了大名鼎鼎的 aws亞馬遜云上，并且為云計算做了優化，提供高效的緩存服務。
本文利用 memcached作為后端緩存實例服務器，并結合 spring boot，來實踐一下 evcache客戶端的具體使用。
編譯 evcache
第一步：clone
|
1
|
git clone git@github.com:netflix/evcache.git |
第二步：編譯構建
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
./gradlew builddownloading https://services.gradle.org/distributions/gradle-2.10-bin.zip....................................................................................................................................:evcache-client:check:evcache-client:build:evcache-client-sample:writelicenseheader:evcache-client-sample:licensemainmissing header in: evcache-client-sample/src/main/java/com/netflix/evcache/sample/evcacheclientsample.java:evcache-client-sample:licensetest up-to-date:evcache-client-sample:license:evcache-client-sample:compiletestjava up-to-date:evcache-client-sample:processtestresources up-to-date:evcache-client-sample:testclasses up-to-date:evcache-client-sample:test up-to-date:evcache-client-sample:check:evcache-client-sample:buildbuild successfultotal time: 22.866 secs |
第三步：得到構建生成物
同時 ~/evcache/evcache-client/build/reports 目錄下會生成相應構建報告：
接下來我們結合 spring工程，來實戰一下 evcache client的具體使用。
環境準備 / 工程搭建
首先準備好兩臺 memcached實例：
- 192.168.199.77:11211
- 192.168.199.78:11211
接下來搭建一個springboot工程，過程不再贅述，需要注意的一點是 pom中需加入 evcache的依賴支持
|
1
2
3
4
5
|
<dependency> <groupid>com.netflix.evcache</groupid> <artifactid>evcache-client</artifactid> <version>4.137.0-snapshot</version></dependency> |
注：我將 spring工程設置在 8899端口啟動
evcache client導入
編寫 evcache client包裝類
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
public class evcacheclient { private final evcache evcache; // 關鍵角色在此 public evcacheclient() { string deploymentdescriptor = system.getenv("evc_sample_deployment"); if ( deploymentdescriptor == null ) { deploymentdescriptor = "servergroup1=192.168.199.77:11211;servergroup2=192.168.199.78:11211"; } system.setproperty("evcache_app1.use.simple.node.list.provider", "true"); system.setproperty("evcache_app1-nodes", deploymentdescriptor); evcache = new evcache.builder().setappname("evcache_app1").build(); } public void setkey(string key, string value, int timetolive) throws exception { try { future<boolean>[] _future = evcache.set(key, value, timetolive); for (future<boolean> f : _future) { boolean didsucceed = f.get(); // system.out.println("per-shard set success code for key " + key + " is " + didsucceed); // 此處可以針對 didsucceed做相應判斷 } system.out.println("finished setting key " + key); } catch (evcacheexception e) { e.printstacktrace(); } } public string getkey(string key) { try { string _response = evcache.<string>get(key); return _response; } catch (exception e) { e.printstacktrace(); return null; } }} |
很明顯上述類主要提供了兩個關鍵工具函數： setkey 和 getkey
evcache config 配置導入
我們將 evcacheclient 注入到spring容器中
|
1
2
3
4
5
6
7
8
9
|
@configurationpublic class evcacheconfig { @bean public evcacheclient evcacheclient() { evcacheclient evcacheclient = new evcacheclient(); return evcacheclient; }} |
編寫 evcache service
上面幾步完成之后，service的編寫自然順理成章，僅僅是一層封裝而已
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
@servicepublic class evcacheservice { @autowired private evcacheclient evcacheclient; public void setkey( string key, string value, int timetolive ) { try { evcacheclient.setkey( key, value, timetolive ); } catch (exception e) { e.printstacktrace(); } } public string getkey( string key ) { return evcacheclient.getkey( key ); }} |
編寫測試 controller
我們編寫一個方便用于測試的控制器，里面進行一系列對于緩存的 set 和 get，從而便于觀察實驗結果
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
@restcontrollerpublic class evcachetestcontroller { @autowired private evcacheservice evcacheservice; @getmapping("/testevcache") public void testevcache() { try { for ( int i = 0; i < 10; i++ ) { string key = "key_" + i; string value = "data_" + i; int ttl = 180; // 此處將緩存設為三分鐘（180s）生存期，時間一過，緩存即會失效 evcacheservice.setkey(key, value, ttl); } for (int i = 0; i < 10; i++) { string key = "key_" + i; string value = evcacheservice.getkey(key); system.out.println("get of " + key + " returned " + value); } } catch (exception e) { e.printstacktrace(); } }} |
實驗驗證
工程啟動后，我們調用 rest接口：localhost:8899/testevcache，觀察控制臺中對于 key_0 到 key_9 等十個緩存 key的操作細節如下：
在 memcached集群中插入十條數據： key_0 到 key_9
注意此處是向每個后端 memcached緩存實例中都寫入了 10條測試數據
從后端 memcached集群中讀取剛插入的 10條數據
為了驗證數據確實寫入到后端 memcached，我們可以 telnet到后端 memcached中進行一一驗證
而且這些數據的有效時間僅3分鐘，3分鐘后再次驗證會發現數據已過期
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
[root@localhost ~]# telnet 127.0.0.1 11211trying 127.0.0.1...connected to 127.0.0.1.escape character is '^]'.get key_0value key_0 0 6data_0endget key_1value key_1 0 6data_1endget key_2 value key_2 0 6data_2endget key_3value key_3 0 6data_3endget key_4value key_4 0 6data_4endget key_5value key_5 0 6data_5endget key_6value key_6 0 6data_6endget key_7value key_7 0 6data_7endget key_8value key_8 0 6data_8endget key_9value key_9 0 6data_9end |
本文擴展
當然本文所演示的 evcache配合 memcached使用時，memcached被硬編碼進代碼，實際過程中使用，可以將其與 zk等服務發現服務進行一個結合，實現靈活運用，這就不在本文進行贅述。
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
原文鏈接：https://segmentfault.com/a/1190000017242987
