io.jboot.components.cache.caredis

类 JbootCaredisCacheImpl

java.lang.Object

io.jboot.components.cache.JbootCacheBase

io.jboot.components.cache.caredis.JbootCaredisCacheImpl

所有已实现的接口:

com.jfinal.plugin.activerecord.cache.ICache, JbootCache

public class JbootCaredisCacheImpl
extends JbootCacheBase

基于 caffeine和redis做的二级缓存 优点是：减少高并发下redis的io瓶颈

字段概要

字段

限定符和类型	字段和说明
private CaffeineCacheImpl	caffeineCacheImpl
private String	channel
private String	clientId
static String	DEFAULT_NOTIFY_CHANNEL
private com.github.benmanes.caffeine.cache.Cache<String,List>	keysCache
private JbootRedis	redis
private JbootRedisCacheImpl	redisCacheImpl
private JbootSerializer	serializer

从类继承的字段 io.jboot.components.cache.JbootCacheBase

config

构造器概要

构造器

构造器和说明
JbootCaredisCacheImpl(JbootCacheConfig config)

方法概要

限定符和类型	方法和说明
private void	clearKeysCache(String cacheName)
<T> T	get(String cacheName, Object key)
<T> T	get(String cacheName, Object key, com.jfinal.plugin.ehcache.IDataLoader dataLoader)
<T> T	get(String cacheName, Object key, com.jfinal.plugin.ehcache.IDataLoader dataLoader, int liveSeconds)
CaffeineCacheImpl	getCaffeineCacheImpl()
List	getKeys(String cacheName)
List	getNames()
JbootRedisCacheImpl	getRedisCacheImpl()
Integer	getTtl(String cacheName, Object key)
void	onMessage(String channel, Object obj)
private void	publishMessage(int action, String cacheName, Object key)
void	put(String cacheName, Object key, Object value)
void	put(String cacheName, Object key, Object value, int liveSeconds)
void	refresh(String cacheName)
void	refresh(String cacheName, Object key)
void	remove(String cacheName, Object key)
void	removeAll(String cacheName)
void	setTtl(String cacheName, Object key, int seconds)

从类继承的方法 io.jboot.components.cache.JbootCacheBase

addThreadCacheNamePrefixIngore, buildCacheName, clearThreadCacheNamePrefix, getConfig, println, removeThreadCacheNamePrefixIngore, setThreadCacheNamePrefix

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 io.jboot.components.cache.JbootCache

addThreadCacheNamePrefixIngores

字段详细资料

DEFAULT_NOTIFY_CHANNEL

public static final String DEFAULT_NOTIFY_CHANNEL

另请参阅:

常量字段值

caffeineCacheImpl

private CaffeineCacheImpl caffeineCacheImpl

redisCacheImpl

private JbootRedisCacheImpl redisCacheImpl

redis

private JbootRedis redis

serializer

private JbootSerializer serializer

channel

private String channel

clientId

private String clientId

keysCache

private com.github.benmanes.caffeine.cache.Cache<String,List> keysCache

构造器详细资料

JbootCaredisCacheImpl

public JbootCaredisCacheImpl(JbootCacheConfig config)

方法详细资料

get

public <T> T get(String cacheName,
                 Object key)

put

public void put(String cacheName,
                Object key,
                Object value)

put

public void put(String cacheName,
                Object key,
                Object value,
                int liveSeconds)

remove

public void remove(String cacheName,
                   Object key)

removeAll

public void removeAll(String cacheName)

get

public <T> T get(String cacheName,
                 Object key,
                 com.jfinal.plugin.ehcache.IDataLoader dataLoader)

get

public <T> T get(String cacheName,
                 Object key,
                 com.jfinal.plugin.ehcache.IDataLoader dataLoader,
                 int liveSeconds)

getTtl

public Integer getTtl(String cacheName,
                      Object key)

setTtl

public void setTtl(String cacheName,
                   Object key,
                   int seconds)

refresh

public void refresh(String cacheName,
                    Object key)

指定者:

refresh 在接口中 JbootCache

覆盖:

refresh 在类中 JbootCacheBase

refresh

public void refresh(String cacheName)

指定者:

refresh 在接口中 JbootCache

覆盖:

refresh 在类中 JbootCacheBase

getNames

public List getNames()

getKeys

public List getKeys(String cacheName)

publishMessage

private void publishMessage(int action,
                            String cacheName,
                            Object key)

clearKeysCache

private void clearKeysCache(String cacheName)

onMessage

public void onMessage(String channel,
                      Object obj)

getCaffeineCacheImpl

public CaffeineCacheImpl getCaffeineCacheImpl()

getRedisCacheImpl

public JbootRedisCacheImpl getRedisCacheImpl()