xcache

<dependency>
    <groupId>com.xuanner</groupId>
    <artifactId>xcache-core</artifactId>
    <version>1.0</version>
</dependency>

/**
 * 获取spy客户端
 *
 * @return
 */
public static CacheClient getSpyClient() {
    SpyClientConfig config = new SpyClientConfig();
    config.setHost("xxx");
    config.setPort(11211);
    config.setUsername("xxx");
    config.setPassword("xxx");
    return new CacheClientBuilder().config(config).build();
}

/**
 * 获取xmemcached客户端
 *
 * @return
 */
public static CacheClient getXmemcacheClient() {
    XMemcachedClientConfig config = new XMemcachedClientConfig();
    config.setHost("xxx");
    config.setPort(11211);
    config.setUsername("xxx");
    config.setPassword("xxx");
    return new CacheClientBuilder().config(config).build();
}

public class ClientTest {

    private CacheClient cacheClient;

    @Before
    public void setup() {
        cacheClient = getSpyClient();
    }

    @Test
    public void test() {
        //删除
        cacheClient.delete("testKey");
        //设置
        cacheClient.put("testKey", "testValue", 2000, TimeUnit.MILLISECONDS);
        //获取
        String testValue = (String) cacheClient.get("testKey");
    }

}

/**
 * 缓存的全局配置，一般一个应用一个配置，可以用全局版本号控制全缓存失效
 *
 * @return
 */
public static GlobalCacheConfig getGlobalCacheConfig() {
    GlobalCacheConfig globalCacheConfig = new GlobalCacheConfig();
    globalCacheConfig.setAppName("xuannerApp");
    globalCacheConfig.setAppCacheVersion(1);
    return globalCacheConfig;
}

/**
 * 缓存的模块配置，表示需要缓存的一类数据，例如一个电商有商品数据，类目数据等,可以用模块的版本控制本模块的缓存失效
 *
 * @return
 */
public static ModuleCacheConfig getModuleCacheConfig() {
    ModuleCacheConfig moduleCacheConfig = new ModuleCacheConfig();
    moduleCacheConfig.setCacheName("itemData");
    moduleCacheConfig.setCacheVersion(1);
    moduleCacheConfig.setExpTime(2000);//超时时间
    return moduleCacheConfig;
}

/**
 * 当缓存不存在或者过期时，需要回源到DB查询时的查询接口
 *
 * @return
 */
public static CacheLoader getCacheLoader() {
    return new CacheLoader() {

        @Override
        public Map loadData(Collection keys) {
            System.out.println("多个loader...");
            Map key2DataMap = new HashMap<>();
            keys.forEach(key -> key2DataMap.put(key, key + "_data"));
            return null;
        }

        @Override
        public String loadData(String key) {
            System.out.println("单个loader...");
            return key + "_data";
        }
    };
}

/**
 * 构建一个缓存
 *
 * @param strategy
 * @return
 */
public static Cache getCache(String strategy) {
    return new CacheBuilder().setCacheClient(getSpyClient()).setCacheLoader(
            getCacheLoader()).setGlobalCacheConfig(getGlobalCacheConfig()).setModuleCacheConfig(
            getModuleCacheConfig()).build(strategy);
}

public class CacehTest {

    private Cache cache;

    @Before
    public void setup() {
        //ASYNC表示异步设置缓存策略，SIMPLE表示同步设置缓存策略
        cache = getCache(CacheBuilder.ASYNC);
    }

    @Test
    public void test() {
        //删除缓存
        cache.delete("testKey");
        
        //获取缓存，当缓存不存在，会触发CacheLoader接口获取数据，并自动设置缓存，返回结果
        cache.get("testKey");
        
        //设置缓存，会触发CacheLoader接口获取数据，并自动设置缓存
        cache.set("testKey");
    }
}