文档章节

EVCache缓存在 Spring Boot中的实战

CodeSheep
 CodeSheep
发布于 2018/12/04 07:41
字数 1208
阅读 21
收藏 2

Profile

文章共 727字,阅读大约需要 2分钟 !


概 述

EVCacheNetflix开源的分布式缓存系统,基于 Memcached缓存和 Spymemcached客户端实现,其用在了大名鼎鼎的 AWS亚马逊云上,并且为云计算做了优化,提供高效的缓存服务。

本文利用 Memcached作为后端缓存实例服务器,并结合 Spring Boot,来实践一下 EVCache客户端的具体使用。

注: 本文首发于 My Personal Blog: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/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;
        }
    }

}

很明显上述类主要提供了两个关键工具函数: setKeygetKey

  • 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

我们编写一个方便用于测试的控制器,里面进行一系列对于缓存的 setget,从而便于观察实验结果

@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_0key_9 等十个缓存 key的操作细节如下:

  • 在 memcached集群中插入十条数据: key_0key_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等服务发现服务进行一个结合,实现灵活运用,这就不在本文进行赘述。

结合服务发现灵活运用


后 记

由于能力有限,若有错误或者不当之处,还请大家批评指正,一起学习交流!



© 著作权归作者所有

共有 人打赏支持
CodeSheep

CodeSheep

粉丝 217
博文 74
码字总数 101759
作品 0
南京
程序员
私信 提问
EVCache —— Netflix 的分布式内存数据存储

EVCache 是基于 memcached & spymemcached 的缓存解决方案,主要用在 AWS EC2 基础设施上,为了顺畅的使用数据而开发的缓存解决方案。

oschina
2015/05/19
22
0
OSChina 开源周刊第35期 —— 克服对 React 的恐惧,然后爱上它

每周技术抢先看,总有你想要的! 开源资讯 Java:持续革新的 20 年 要怎样和程序猿谈一场没有 bug 的恋爱 Windows 7 份额居高不下 微软肯定“恨疯了” 怎样尊重一个程序员 首款搭载龙芯1C开源...

OSC编辑部
2015/05/24
2.2K
0
新书上架:《Spring Boot 开发实战》(基于 Kotlin + Gradle + Spring Boot 2.0 的企业级服务端开发实战)

新书上架:《Spring Boot 开发实战》 — 基于 Kotlin + Gradle + Spring Boot 2.0 的企业级服务端开发实战 京东下单链接 https://item.jd.com/31178320122.html 天猫下单链接 https://detail...

程序员诗人
2018/08/05
0
0
新书上架:《Spring Boot 开发实战》基于 Kotlin + Gradle + Spring Boot 2.0 的企业级服务端开发实战

新书上架:《Spring Boot 开发实战》 — 基于 Kotlin + Gradle + Spring Boot 2.0 的企业级服务端开发实战 京东下单链接 https://item.jd.com/31178320122.html 天猫下单链接 https://detail...

程序员诗人
2018/08/22
0
0
【Spring Boot 开发实战】第1讲 Kotlin 的极简特性之:隐式类型与函数式编程

《Spring Boot 开发实战》—— 基于 Gradle + Kotlin 的企业级应用开发最佳实践 Spring Boot 是由 Pivotal 团队提供的全新框架,其设计目的是用来简化新 Spring 应用的初始搭建以及开发过程。...

程序员诗人
2018/04/18
0
0

没有更多内容

加载失败,请刷新页面

加载更多

cxf框架的介绍

小小小施爷
23分钟前
3
0
35K成功入职:蚂蚁金服面试Java后端经历!

上个月4号通过阿里工作的学长进行内推,7天简历评估,11号接到电话面试,尽管猝不及防回答仓促,但好在前期准备充分,通过。3天后进行现场面试,通知时间为早上10点。当日设了七点闹钟,结果...

别打我会飞
24分钟前
3
0
【HAVENT原创】让 IE6 ~ IE8 浏览器也支持 map 和 filter 方法

Array.prototype 扩展可以让 IE6 ~ IE8 浏览器也支持 map 的方法: if (typeof Array.prototype.map != "function") { Array.prototype.map = function (fn, context) { var arr = [......

HAVENT
24分钟前
2
0
SMSSDK的Unity3D的两种集成方式

SMSSDK的Unity3D插件主要为用户提供了两种集成的方式,一种是通过桥接文件直接调用SMSSDK的原生API,另外一种是集成SMSSDK_Demo中的UI,这两种方式的集成,方便用户根据自己的需要进行不同的...

佳妮
33分钟前
1
0
云计算、大数据、编程语言学习指南下载,100+技术课程免费学!这份诚意满满的新年技术大礼包,你Get了吗?

开发者认证、云学院、技术社群,更多精彩,尽在开发者会场 近年来,新技术发展迅速。互联网行业持续高速增长,平均薪资水平持续提升,互联网技术学习已俨然成为学生、在职人员都感兴趣的“业...

zhaowei121
36分钟前
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部