基于Java8的緩存框架Caffeine是怎樣的

Caffeine是一個基于Java8的高性能緩存框架，號稱趨于完美。Caffeine受啟發(fā)于Guava Cache的API，使用API和Guava是一致的。它借鑒了Guava Cache和ConcurrentLinkedHashMap的設(shè)計經(jīng)驗。

性能比較

基準測試使用Java microbenchmark工具提供準確的分析。緩存配置為

• Caffeine和ConcurrentLinkedHashMap根據(jù)CPU數(shù)量確定其內(nèi)部結(jié)構(gòu)的大小
• Guava的并發(fā)級別配置為64（默認為4，以減少內(nèi)存使用）。
• Ehcache v2在內(nèi)部被硬編碼為100個段，而v3未分段

100%的讀操作

 

讀75% 寫25%

 

寫100%

 

上面三種測試圖來自于Caffeine官網(wǎng)，從圖可知，Caffeine的性能玩爆其他緩存框架。

在Matrix-Web中使用Caffeine

在工程的pom文件引入caffeine的依賴，如下：

<dependency>
	<groupId>com.github.ben-manes.caffeine</groupId>
	<artifactId>caffeine</artifactId>
	<version>${caffeine.version}</version>
</dependency>

創(chuàng)建一個抽象類AbstractCaffineCache，該類使用范型來約束緩存的數(shù)據(jù)類型，并實現(xiàn)了三個方法，put、get、clear。

public abstract class AbstractCaffineCache<T> {

    protected LoadingCache<String, T> loadingCache;


    abstract LoadingCache<String, T>  createLoadingCache();

    public boolean put(String key, T value) {
        if(loadingCache==null){
            loadingCache=createLoadingCache();
        }
        loadingCache.put(key, value);

        return Boolean.TRUE;
    }

    public T get(String key) {
        if(loadingCache==null){
            loadingCache=createLoadingCache();
        }
        try {

            return loadingCache.get(key);
        } catch (Exception e) {
            return null;
        }
    }

    public boolean clear(String key) {
        if(loadingCache==null){
            loadingCache=createLoadingCache();
        }
        loadingCache.invalidate(key);
        return Boolean.TRUE;
    }

}

創(chuàng)建UserRolePermissionCache的緩存類，該類緩存類用戶的信息、用戶的角色信息、用戶的權(quán)限信息。創(chuàng)建LoadingCache類，該類設(shè)置了緩存過期的時間，最大的緩存?zhèn)€數(shù)。

public class UserRolePermissionCache<SysUser> extends AbstractCaffineCache {

    @Override
    LoadingCache createLoadingCache() {

         loadingCache = Caffeine.newBuilder()
                .expireAfterWrite(10 , TimeUnit.MINUTES)
                .initialCapacity(10)
                .maximumSize(99999999)
                .recordStats()
                .build(new CacheLoader<String, SysUser>() {
                    @Override
                    public SysUser load(String key) throws Exception {
                        return null;
                    }
                });
        return loadingCache;
    }
}

將UserRolePermissionCache注入到spring ioc中，代碼如下：

@Configuration
public class CaffineCacheConfig {
    @Bean
    public UserRolePermissionCache userRolePermissionCache(){
        return new UserRolePermissionCache();
    }
}

如何使用，在UserPermissonService中，查詢SysUser信息，如果緩存中有數(shù)據(jù)，則在緩存中取，如果沒有，則在數(shù)據(jù)庫中讀，并做緩存。

@Component
public class UserPermissonService {

    @Autowired
    SysUserMapper sysUserMapper;

    @Autowired
    UserRolePermissionCache<SysUser> userRolePermissionCache;

    public SysUser getUserRolePerssion(String userId) {
        SysUser sysUser = (SysUser) userRolePermissionCache.get(userId);
        if (sysUser == null) {
            sysUser = sysUserMapper.selectUserRolePermission(userId);
            userRolePermissionCache.put(userId, sysUser);
        }
        return sysUser;
    }
}