EVCache缓存在 Spring Boot中的实战
16lz
2021-01-22
文章共 727字，阅读大约需要 2分钟，文尾有计时器可自行对时！
概 述
EVCache 是 Netflix开源的分布式缓存系统，基于 memcached缓存和 spymemcached客户端实现，其用在了大名鼎鼎的 AWS亚马逊云上，并且为云计算做了优化，提供高效的缓存服务。
本文利用 memcached作为后端缓存实例服务器，并结合 Spring Boot，来实践一下 EVCache客户端的具体使用。
注： 本文首发于 作者公众号 CodeSheep ，可 长按 / 扫描 下面的 小心心 来订阅 ↓ ↓ ↓
编译 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实例：
192.168.199.77:11211
- 192.168.199.78:11211
接下来搭建一个 Spring Boot工程，过程不再赘述，需要注意的一点是 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容器中
@Configurationpublic class EVCacheConfig { @Bean public EVCacheClient evcacheClient() { EVCacheClient evCacheClient = new EVCacheClient(); return evCacheClient; }}编写 EVCache Service
上面几步完成之后，Service的编写自然顺理成章，仅仅是一层封装而已
@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，从而便于观察实验结果
@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分钟后再次验证会发现数据已过期
[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等服务发现服务进行一个结合，实现灵活运用，这就不在本文进行赘述。
后 记
由于能力有限，若有错误或者不当之处，还请大家批评指正，一起学习交流！
个人网站：www.codesheep.cn (程序羊)我的更多系列原创文章：
● 我的半年技术博客之路
● 利用K8S技术栈打造个人私有云系列连载文章
● 从一份配置清单详解Nginx服务器配置
● Spring Boot Admin 2.0开箱体验
● 一文上手 Elasticsearch常用可视化管理工具
● Docker容器可视化监控中心搭建
● 利用ELK搭建Docker容器化应用日志中心
● RPC框架实践之：Google gRPC
● 一文详解 Linux系统常用监控工具
作者更多 务实、能看懂、可复现的 原创文章尽在公众号 CodeSheep，欢迎订阅 ⬇️⬇️⬇️
©著作权归作者所有：来自51CTO博客作者mb5fdcae83766b7的原创作品，如需转载，请注明出处，否则将追究法律责任更多相关文章
- 轻量级 Memcached缓存代理 twemproxy实践
- Springboot应用缓存实践之：Ehcache加持
- 从输入 URL 到展现涉及哪些缓存环节(非常详细)
- 熔断器 Hystrix 源码解析 —— 执行结果缓存
- 【前端词典】输入 URL 到展现涉及的缓存环节
- Mybatis 配置 自定义缓存 ehcache
- 动画：深入浅出从根上理解 HTTP 缓存机制及原理！
- 使用pkg打包编译nodejs程序，手动设置缓存内容