io.jboot.components.cache.ehredis

类 JbootEhredisCacheImpl

java.lang.Object

io.jboot.components.cache.JbootCacheBase

io.jboot.components.cache.ehredis.JbootEhredisCacheImpl

所有已实现的接口:

com.jfinal.plugin.activerecord.cache.ICache, JbootCache, Cloneable, net.sf.ehcache.event.CacheEventListener

public class JbootEhredisCacheImpl
extends JbootCacheBase
implements net.sf.ehcache.event.CacheEventListener

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

字段概要

字段

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

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

config

构造器概要

构造器

构造器和说明
JbootEhredisCacheImpl(JbootCacheConfig config)

方法概要

限定符和类型	方法和说明
private void	clearKeysCache(String cacheName)
Object	clone()
void	dispose()
<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)
JbootEhcacheImpl	getEhcacheImpl()
List	getKeys(String cacheName)
List	getNames()
JbootRedisCacheImpl	getRedisCacheImpl()
Integer	getTtl(String cacheName, Object key)
void	notifyElementEvicted(net.sf.ehcache.Ehcache cache, net.sf.ehcache.Element element)
void	notifyElementExpired(net.sf.ehcache.Ehcache cache, net.sf.ehcache.Element element)
void	notifyElementPut(net.sf.ehcache.Ehcache cache, net.sf.ehcache.Element element)
void	notifyElementRemoved(net.sf.ehcache.Ehcache cache, net.sf.ehcache.Element element)
void	notifyElementUpdated(net.sf.ehcache.Ehcache cache, net.sf.ehcache.Element element)
void	notifyRemoveAll(net.sf.ehcache.Ehcache cache)
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

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

另请参阅:

常量字段值

ehcacheImpl

private JbootEhcacheImpl ehcacheImpl

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.LoadingCache<String,List> keysCache

构造器详细资料

JbootEhredisCacheImpl

public JbootEhredisCacheImpl(JbootCacheConfig config)

方法详细资料

get

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

指定者:

get 在接口中 com.jfinal.plugin.activerecord.cache.ICache

指定者:

get 在接口中 JbootCache

put

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

指定者:

put 在接口中 com.jfinal.plugin.activerecord.cache.ICache

指定者:

put 在接口中 JbootCache

put

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

指定者:

put 在接口中 JbootCache

remove

public void remove(String cacheName,
                   Object key)

指定者:

remove 在接口中 com.jfinal.plugin.activerecord.cache.ICache

指定者:

remove 在接口中 JbootCache

removeAll

public void removeAll(String cacheName)

指定者:

removeAll 在接口中 com.jfinal.plugin.activerecord.cache.ICache

指定者:

removeAll 在接口中 JbootCache

get

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

指定者:

get 在接口中 JbootCache

get

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

指定者:

get 在接口中 JbootCache

getTtl

public Integer getTtl(String cacheName,
                      Object key)

指定者:

getTtl 在接口中 JbootCache

setTtl

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

指定者:

setTtl 在接口中 JbootCache

publishMessage

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

clearKeysCache

private void clearKeysCache(String cacheName)

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()

指定者:

getNames 在接口中 JbootCache

getKeys

public List getKeys(String cacheName)

指定者:

getKeys 在接口中 JbootCache

onMessage

public void onMessage(String channel,
                      Object obj)

getEhcacheImpl

public JbootEhcacheImpl getEhcacheImpl()

getRedisCacheImpl

public JbootRedisCacheImpl getRedisCacheImpl()

notifyElementRemoved

public void notifyElementRemoved(net.sf.ehcache.Ehcache cache,
                                 net.sf.ehcache.Element element)
                          throws net.sf.ehcache.CacheException

指定者:

notifyElementRemoved 在接口中 net.sf.ehcache.event.CacheEventListener

抛出:

net.sf.ehcache.CacheException

notifyElementPut

public void notifyElementPut(net.sf.ehcache.Ehcache cache,
                             net.sf.ehcache.Element element)
                      throws net.sf.ehcache.CacheException

指定者:

notifyElementPut 在接口中 net.sf.ehcache.event.CacheEventListener

抛出:

net.sf.ehcache.CacheException

notifyElementUpdated

public void notifyElementUpdated(net.sf.ehcache.Ehcache cache,
                                 net.sf.ehcache.Element element)
                          throws net.sf.ehcache.CacheException

指定者:

notifyElementUpdated 在接口中 net.sf.ehcache.event.CacheEventListener

抛出:

net.sf.ehcache.CacheException

notifyElementExpired

public void notifyElementExpired(net.sf.ehcache.Ehcache cache,
                                 net.sf.ehcache.Element element)

指定者:

notifyElementExpired 在接口中 net.sf.ehcache.event.CacheEventListener

notifyElementEvicted

public void notifyElementEvicted(net.sf.ehcache.Ehcache cache,
                                 net.sf.ehcache.Element element)

指定者:

notifyElementEvicted 在接口中 net.sf.ehcache.event.CacheEventListener

notifyRemoveAll

public void notifyRemoveAll(net.sf.ehcache.Ehcache cache)

指定者:

notifyRemoveAll 在接口中 net.sf.ehcache.event.CacheEventListener

clone

public Object clone()
             throws CloneNotSupportedException

指定者:

clone 在接口中 net.sf.ehcache.event.CacheEventListener

覆盖:

clone 在类中 Object

抛出:

CloneNotSupportedException

dispose

public void dispose()

指定者:

dispose 在接口中 net.sf.ehcache.event.CacheEventListener