分布式缓存技术memcached学习（五）—— memcached java客户端的使用

Memcached的客户端简介

我们已经知道，memcached是一套分布式的缓存系统，memcached的服务端只是缓存数据的地方，并不能实现分布式，而memcached的客户端才是实现分布式的地方。

Memcached现在已被广泛使用，客户端实现也有较多的版本，基本上各个语言的都有。比如：Memcached client for Java、Spymemcached、xMemcached，各自有各自的优缺点。由于Memcached client for Java是Memcached官方发布的客户端，应用广泛，运行比较稳定，新版本在性能上也有所提高。我们接下来将使用该客户端进行实战演示。

Memcached的客户端下载

下载地址：https://github.com/gwhalin/Memcached-Java-Client/downloads

Memcached的客户端使用

下载下来的Memcached客户端有四个jar包，分别是：commons-pool-1.5.6.jar、java_memcached-release_2.6.6.jar、slf4j-api-1.6.1.jar、slf4j-simple-1.6.1.jar。将这四个jar包添加到项目的构建路径即可。

Memcached使用实例

我们将以缓存菜单列表进行实例演示，当访问后台首页加载系统菜单列表时，先判断菜单列表是否存在memcached中，如果不存在则从数据读取系统菜单列表，并存到memcached，否则直接从memcached中读取。如下：

MemcachedFactory.java

public class MemcachedFactory {

// 创建MemCachedClient全局对象

private static MemCachedClient memCachedClient = new MemCachedClient();

static {

// 创建服务器列表及其权重

String[] servers = { "127.0.0.1:11211" };

Integer[] weights = { 3 };

// 创建Socket连接池

SockIOPool pool = SockIOPool.getInstance();

// 设置服务器信息

pool.setServers(servers);

pool.setWeights(weights);

pool.setFailover(true);

// 设置初始连接数、最小和最大连接数以及最大处理时间

pool.setInitConn(5);

pool.setMinConn(5);

pool.setMaxConn(250);

pool.setMaxIdle(1000 * 60 * 60 * 6);

// 设置主线程睡眠时间

pool.setMaintSleep(30);

// 设置TCP参数、连接超时等

pool.setNagle(false);

pool.setSocketTO(3000);

pool.setSocketConnectTO(0);

pool.setAliveCheck(true);

// 初始化连接池

pool.initialize();

}

protected MemcachedFactory() {

}

// Memcached 实例

protected static MemcachedFactory instance = new MemcachedFactory();

public static MemcachedFactory getInstance() {

return instance;

}

/**

* 添加缓存记录

* @param key

* @param value

* @return

*/

public boolean add(String key, Object value) {

return memCachedClient.add(key, value);

}

/**

* 添加缓存记录，有效期为expiry

* @param key

* @param value

* @param expiry

* @return

*/

public boolean add(String key, Object value, Date expiry) {

return memCachedClient.add(key, value, expiry);

}

/**

* 缓存查询结果对象QueryResult

* @param key

* @param value

* @return

*/

public boolean add(String key, QueryResult<Menu> value) {

return memCachedClient.add(key, value);

}

/**

* 提取缓存记录

* @param key

* @return

*/

public Object get(String key) {

return memCachedClient.get(key);

}

/**

* 判断缓存是否存在

* @param key

* @return

*/

public boolean keyExist(String key) {

return memCachedClient.keyExists(key);

}

}

 

IndexController.java

@Controller

public class IndexCtroller{

@Autowired

private IIndexService indexService;

@RequestMapping(value = "/back/index")

public String index(HttpServletRequest request) {

MemcachedFactory mcInstance = MemcachedFactory.getInstance();

String jsonTree = null;

//不存在key缓存记录则查询数据库并添加存入memcached

if(!mcInstance.keyExist("jsonTree")) {

List<Menu> menuList = indexService.queryMenu();

List2JsonUtil<Menu> list2JsonUtil = new List2JsonUtil<Menu>(new Menu());

jsonTree = list2JsonUtil.getJosnStrFromList(menuList, null);

mcInstance.add("jsonTree", jsonTree);

//否则直接从memcached中提取

}else {

jsonTree = (String) mcInstance.get("jsonTree");

}

if(null != jsonTree){

request.setAttribute("jsonTree", jsonTree);

}

return "/back/index";

}

}

页面效果

首次从数据库读取菜单列表耗时

 

我们注释掉IndexController.java中memcached的相关代码来看看首次从数据库读取菜单列表耗时。

 

从上图可以看到，首次访问数据加载菜单列表耗时1.17s，这些时间包括从数据库查询记录和将查询结果转为json格式数据的时间。

首次从memcached读取菜单列表耗时

放开IndexController.java中memcached的相关代码，来看看首次从memcached读取菜单列表耗时。

从上图可以看到，当菜单列表已经存入memcached中后，首次从memcached读取菜单列表的耗时21.970ms，这里省去了从数据库查询记录和将查询结果转为json格式数据的耗时。显然，从首次访问数据库和和首次访问memcached来看，响应速度确实快了不少。在memcached后台，我们看到了存取菜单列表jsonTree的信息，如下：

上面的读取菜单列表的耗时可能并不是很准确，由于浏览器等各方面因素的影响，随着访问频率的增加，访问数据库和访问memcached的耗时都会减少，然后在某一个范围内波动。但可以确定的是，访问memcached省去了从数据库查询记录和将查询结果转为json格式数据的耗时，减少了数据库的访问频率和服务器的压力。