概 述
evcache 是 netflix开源的分布式缓存系统，基于 memcached缓存和 spymemcached客户端实现，其用在了大名鼎鼎的 aws亚马逊云上，并且为云计算做了优化，提供高效的缓存服务。
本文利用 memcached作为后端缓存实例服务器，并结合 spring boot，来实践一下 evcache客户端的具体使用。
编译 evcache
第一步：clone
git clone git@github.com: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-client/build/reports 目录下会生成相应构建报告：
接下来我们结合 spring工程，来实战一下 evcache client的具体使用。
环境准备 / 工程搭建
首先准备好两台 memcached实例：
接下来搭建一个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集群中读取刚插入的 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等服务发现服务进行一个结合，实现灵活运用，这就不在本文进行赘述。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持移动技术网。
如对本文有疑问， 点击进行留言回复！！
Algebra:Chapter 0 - 预备知识: 集合论和categories
springboot + vue上传图片在服务器并实现在线预览
请谨慎使用增强for循环，刚接触Java值得一看（手动狗头）
【Nginx】还不会使用Nginx解决跨域问题？肝这一篇就够了！！
网友评论