EVCache緩存在Spring Boot中的實(shí)戰(zhàn)示例
概 述
EVCache 是 Netflix開源的分布式緩存系統(tǒng),基于 Memcached緩存和 Spymemcached客戶端實(shí)現(xiàn),其用在了大名鼎鼎的 AWS亞馬遜云上,并且為云計(jì)算做了優(yōu)化,提供高效的緩存服務(wù)。
本文利用 Memcached作為后端緩存實(shí)例服務(wù)器,并結(jié)合 Spring Boot,來實(shí)踐一下 EVCache客戶端的具體使用。
編譯 EVCache
第一步:Clone
git clone git@github.com:Netflix/EVCache.git
第二步:編譯構(gòu)建
./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
第三步:得到構(gòu)建生成物
同時(shí) ~/EVCache/evcache-client/build/reports
目錄下會(huì)生成相應(yīng)構(gòu)建報(bào)告:
接下來我們結(jié)合 Spring工程,來實(shí)戰(zhàn)一下 EVCache Client的具體使用。
環(huán)境準(zhǔn)備 / 工程搭建
首先準(zhǔn)備好兩臺(tái) memcached實(shí)例:
- 192.168.199.77:11211
- 192.168.199.78:11211
接下來搭建一個(gè)SpringBoot工程,過程不再贅述,需要注意的一點(diǎn)是 pom中需加入 EVCache的依賴支持
<dependency> <groupId>com.netflix.evcache</groupId> <artifactId>evcache-client</artifactId> <version>4.137.0-SNAPSHOT</version> </dependency>
注:我將 Spring工程設(shè)置在 8899端口啟動(dòng)
EVCache Client導(dǎo)入
編寫 EVCache Client包裝類
public class EVCacheClient { private final EVCache evCache; // 關(guān)鍵角色在此 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); // 此處可以針對(duì) didSucceed做相應(yīng)判斷 } 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; } } }
很明顯上述類主要提供了兩個(gè)關(guān)鍵工具函數(shù): setKey
和 getKey
EVCache Config 配置導(dǎo)入
我們將 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 ); } }
編寫測(cè)試 Controller
我們編寫一個(gè)方便用于測(cè)試的控制器,里面進(jìn)行一系列對(duì)于緩存的 set
和 get
,從而便于觀察實(shí)驗(yàn)結(jié)果
@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; // 此處將緩存設(shè)為三分鐘(180s)生存期,時(shí)間一過,緩存即會(huì)失效 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(); } } }
實(shí)驗(yàn)驗(yàn)證
工程啟動(dòng)后,我們調(diào)用 Rest接口:localhost:8899/testevcache
,觀察控制臺(tái)中對(duì)于 key_0
到 key_9
等十個(gè)緩存 key的操作細(xì)節(jié)如下:
在 memcached集群中插入十條數(shù)據(jù): key_0
到 key_9
注意此處是向每個(gè)后端 memcached緩存實(shí)例中都寫入了 10條測(cè)試數(shù)據(jù)
從后端 memcached集群中讀取剛插入的 10條數(shù)據(jù)
為了驗(yàn)證數(shù)據(jù)確實(shí)寫入到后端 memcached,我們可以 telnet到后端 memcached中進(jìn)行一一驗(yàn)證
而且這些數(shù)據(jù)的有效時(shí)間僅3分鐘,3分鐘后再次驗(yàn)證會(huì)發(fā)現(xiàn)數(shù)據(jù)已過期
[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
本文擴(kuò)展
當(dāng)然本文所演示的 EVCache配合 memcached使用時(shí),memcached被硬編碼進(jìn)代碼,實(shí)際過程中使用,可以將其與 ZK等服務(wù)發(fā)現(xiàn)服務(wù)進(jìn)行一個(gè)結(jié)合,實(shí)現(xiàn)靈活運(yùn)用,這就不在本文進(jìn)行贅述。
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
java使用Dijkstra算法實(shí)現(xiàn)單源最短路徑
這篇文章主要為大家詳細(xì)介紹了java使用Dijkstra算法實(shí)現(xiàn)單源最短路徑,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2019-01-01mybatisplus自動(dòng)填充屬性值的實(shí)現(xiàn)步驟
MyBatis-Plus提供自動(dòng)填充的功能,幫助自定設(shè)置這些字段的值,提升開發(fā)效率,本文就來介紹一下如何使用,感興趣的可以了解一下2023-12-12Mabatis錯(cuò)誤提示Parameter index out of range的處理方法
這篇文章主要介紹了Mabatis錯(cuò)誤提示Parameter index out of range 的處理方法,本文給大家介紹的非常詳細(xì),具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2018-08-08