EVCache快取在 Spring Boot中的實戰

SpringBoot · 發表 2018-12-04 07:06:13

摘要： Profile 文章共 727字，閱讀大約需要 2分鐘！概述 EVCache 是 Netflix 開源的分散式快取系統，基於 Memcached快取和 Spymemcached客戶端實現，其用在了大名鼎鼎的 AWS亞馬遜雲上，並且為雲...

Profile

文章共 727字，閱讀大約需要 2分鐘！

概述

Netflix/EVCache" target="_blank" rel="nofollow,noindex">EVCache 是 Netflix 開源的分散式快取系統，基於 Memcached快取和 Spymemcached客戶端實現，其用在了大名鼎鼎的 AWS 亞馬遜雲上，並且為雲端計算做了優化，提供高效的快取服務。

本文利用 Memcached作為後端快取例項伺服器，並結合 Spring Boot，來實踐一下 EVCache客戶端的具體使用。

注：本文首發於 My Personal Blog：CodeSheep·程式羊 ，歡迎光臨小站

編譯 EVCache

第一步：Clone

git clone [email protected]:Netflix/EVCache.git

第二步：編譯構建

./gradlew build
Downloading https://services.gradle.org/distributions/gradle-2.10-bin.zip
.................................................................................................................................

...

:evcache-client:check
:evcache-client:build
:evcache-client-sample:writeLicenseHeader
:evcache-client-sample:licenseMain
Missing 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:build

BUILD SUCCESSFUL

Total time: 22.866 secs

第三步：得到構建生成物

得到 EVCache構建生成物

同時 ~/EVCache/evcache-client/build/reports 目錄下會生成相應構建報告：

EVCache構建報告

接下來我們結合 Spring工程，來實戰一下 EVCache Client的具體使用。

環境準備 / 工程搭建

首先準備好兩臺 memcached例項：

192.168.199.77:11211
192.168.199.78:11211

接下來搭建一個SpringBoot工程，過程不再贅述，需要注意的一點是 pom中需加入 EVCache的依賴支援

<dependency>
<groupId>com.netflix.evcache</groupId>
<artifactId>evcache-client</artifactId>
<version>4.137.0-SNAPSHOT</version>
</dependency>

注：我將 Spring工程設定在 8899埠啟動

EVCache Client匯入

編寫 EVCache Client包裝類

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容器中

@Configuration
public class EVCacheConfig {

@Bean
public EVCacheClient evcacheClient() {
EVCacheClient evCacheClient = new EVCacheClient();
return evCacheClient;
}
}

編寫 EVCache Service

上面幾步完成之後，Service的編寫自然順理成章，僅僅是一層封裝而已

@Service
public 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 ，從而便於觀察實驗結果

@RestController
public 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叢集中插入十條資料

從後端 memcached叢集中讀取剛插入的 10條資料

從後端 memcached叢集中讀取剛插入的 10條資料

為了驗證資料確實寫入到後端 memcached，我們可以 telnet到後端 memcached中進行一一驗證

而且這些資料的有效時間僅3分鐘，3分鐘後再次驗證會發現資料已過期

[root@localhost ~]# telnet 127.0.0.1 11211
Trying 127.0.0.1...
Connected to 127.0.0.1.
Escape character is '^]'.
get key_0
VALUE key_0 0 6
data_0
END
get key_1
VALUE key_1 0 6
data_1
END
get key_2
VALUE key_2 0 6
data_2
END
get key_3
VALUE key_3 0 6
data_3
END
get key_4
VALUE key_4 0 6
data_4
END
get key_5
VALUE key_5 0 6
data_5
END
get key_6
VALUE key_6 0 6
data_6
END
get key_7
VALUE key_7 0 6
data_7
END
get key_8
VALUE key_8 0 6
data_8
END
get key_9
VALUE key_9 0 6
data_9
END

本文擴充套件

當然本文所演示的 EVCache配合 memcached使用時，memcached被硬編碼進程式碼，實際過程中使用，可以將其與 ZK等服務發現服務進行一個結合，實現靈活運用，這就不在本文進行贅述。

結合服務發現靈活運用

後記

由於能力有限，若有錯誤或者不當之處，還請大家批評指正，一起學習交流！

My Personal Blog： CodeSheep 程式羊
我的半年技術部落格之路