摘要:文章共字,阅读大约需要分钟概述是开源的分布式缓存系统,基于缓存和客户端实现,其用在了大名鼎鼎的亚马逊云上,并且为云计算做了优化,提供高效的缓存服务。本文利用作为后端缓存实例服务器,并结合,来实践一下客户端的具体使用。
文章共 727字,阅读大约需要 2分钟 !
EVCache 是 Netflix开源的分布式缓存系统,基于 Memcached缓存和 Spymemcached客户端实现,其用在了大名鼎鼎的 AWS亚马逊云上,并且为云计算做了优化,提供高效的缓存服务。
本文利用 Memcached作为后端缓存实例服务器,并结合 Spring Boot,来实践一下 EVCache客户端的具体使用。
注: 本文首发于 My Personal Blog:CodeSheep·程序羊,欢迎光临 小站
第一步: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
接下来搭建一个SpringBoot工程,过程不再赘述,需要注意的一点是 pom中需加入 EVCache的依赖支持
com.netflix.evcache evcache-client 4.137.0-SNAPSHOT
注:我将 Spring工程设置在 8899端口启动
编写 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[] _future = evCache.set(key, value, timeToLive); for (Future 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. 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; } }
上面几步完成之后,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 ); } }
我们编写一个方便用于测试的控制器,里面进行一系列对于缓存的 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等服务发现服务进行一个结合,实现灵活运用,这就不在本文进行赘述。
由于能力有限,若有错误或者不当之处,还请大家批评指正,一起学习交流!
My Personal Blog:CodeSheep 程序羊
我的半年技术博客之路
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/62068.html
摘要:文章共字,阅读大约需要分钟概述是开源的分布式缓存系统,基于缓存和客户端实现,其用在了大名鼎鼎的亚马逊云上,并且为云计算做了优化,提供高效的缓存服务。本文利用作为后端缓存实例服务器,并结合,来实践一下客户端的具体使用。 showImg(https://segmentfault.com/img/remote/1460000017242990); 文章共 727字,阅读大约需要 2分钟 ! ...
摘要:引入了新的环境和概要信息,是一种更揭秘与实战六消息队列篇掘金本文,讲解如何集成,实现消息队列。博客地址揭秘与实战二数据缓存篇掘金本文,讲解如何集成,实现缓存。 Spring Boot 揭秘与实战(九) 应用监控篇 - HTTP 健康监控 - 掘金Health 信息是从 ApplicationContext 中所有的 HealthIndicator 的 Bean 中收集的, Spring...
摘要:作为微服务的基础设施之一,背靠强大的生态社区,支撑技术体系。微服务实践为系列讲座,专题直播节,时长高达小时,包括目前最流行技术,深入源码分析,授人以渔的方式,帮助初学者深入浅出地掌握,为高阶从业人员抛砖引玉。 简介 目前业界最流行的微服务架构正在或者已被各种规模的互联网公司广泛接受和认可,业已成为互联网开发人员必备技术。无论是互联网、云计算还是大数据,Java平台已成为全栈的生态体系,...
摘要:前言如题,今天介绍的数据缓存。说明确实做了数据缓存,第二次的测试结果是从数据缓存中获取的,并没有直接查数据库。为为的数据做了缓存插入数据返回的结果数据库中的结果访问结果如下图。后语以上为数据缓存的教程。 微信公众号:一个优秀的废人如有问题或建议,请后台留言,我会尽力解决你的问题。 前言 如题,今天介绍 SpringBoot 的数据缓存。做过开发的都知道程序的瓶颈在于数据库,我们也知道内...
阅读 3078·2021-10-13 09:40
阅读 3905·2021-09-22 15:51
阅读 1474·2021-09-22 15:48
阅读 1037·2021-09-06 15:00
阅读 1779·2019-08-30 15:43
阅读 2342·2019-08-29 18:35
阅读 1641·2019-08-29 16:18
阅读 3582·2019-08-29 12:49