高性能分布式缓存Redis

2018-08-27

在项目发展的初期，本地缓存比如 ehcache ,可以提供快速的数据访问能力，很大程度上减轻了数据库的压力，提升系统的吞吐量，但是它的局限性也很明显。

ehcache 的本质还是一个进程内的缓存技术，所以，它肯定会占用JVM虚拟机的内存，这也给我们本来就很紧张的内存雪上加霜，如果缓存占内存的比例较大，很有可能就会引发程序的内存溢出，更会使程序出现多个GC 和暂停时间延长，影响系统的吞吐量。

所以随着项目及业务的发展，本地缓存技术逐渐被分布式缓存技术所代替，当然这并不是否认本地缓存技术就没有用武之地，一些场景下分布式缓存也会出现它的瓶颈，所以本地缓存和分布式缓存的集合将是一个不错的方案。

画外音

Ehcache 开发团队也意识到这个问题，所以在ehcache3.x 的版本后，提供了off-heap(堆外内存)特性,该特性可以使 ehcache 避免占用 heap的空间，降低GC 及暂停次数，来提高吞吐量。

1
2

off-heap 技术与 JVM 底层机制紧密相关，对于JAVA 开发人员来说，大家都知道，Java程序始终是运行在JVM虚拟机中的，它与宿主环境是隔离的，因为一般给新对象分配 内存都在 heap 中进行，
在java 中 除了 heap 空间外，其他所有内存都可以称为 off-heap

off-heap 带来的好处

减少了GC 和暂停次数
拥有更大的内存空间
减去了物理内存与 heap 之间的数据复制

参考淘宝的TaobaoVM

步入主体，我们的分布式缓存技术 Redis,它是一个 C 语言编写的开源分布式Key-Value 储存系统，支持多种数据结构(如String,List,Set,zset,Hash)等等。

使用Jedis 操作客户端

引入依赖
   <dependency>
          <groupId>redis.clients</groupId>
          <artifactId>jedis</artifactId>
          <version>2.9.0</version>
      </dependency>
      
      
      
      
package com.redis.utils;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
/**
 * Description:
 * User: purui_zhang
 * Date: 2018-08-27
 * Time: 20:43
 */
public class RedisPools {

    private static JedisPool pool;

    public static void init(){
        JedisPoolConfig config = new JedisPoolConfig();
        //设置最大空间连接
        config.setMaxIdle(50);
        config.setMaxWaitMillis(6000);
        pool = new JedisPool(config, "127.0.0.1", 6379);
    }

    /**
     * 多线程环境同步初始化
     */
    public static synchronized void poolInit(){
        if(pool == null ){
            init();
        }
    }

    /**
     *  获得 Jedis 连接
     * @return
     */
    public static Jedis getJedis(){
        if(pool == null){
            init();
        }
        return  pool.getResource();
    }

    /**
     *  关闭连接
     * @param jedis
     */
    public static void closeJedis(Jedis jedis){
        jedis.close();
    }


}

```      
      
      
 ```     
package com.redis;

import com.redis.utils.RedisPools;
import redis.clients.jedis.Jedis;

/**
 * Description:
 * User: purui_zhang
 * Date: 2018-08-26
 * Time: 16:46
 */
public class Test {

    public static void main(String[] args){
       RedisPools.poolInit();
        Jedis jedis = RedisPools.getJedis();
        jedis.set("123","测试");
        System.out.println(jedis.get("123"));
        RedisPools.closeJedis(jedis);
    }
}

Redis整体性能非常高效，可以使用redis自带的工具 benchmark 来测试