com.base4j.j2cache

类 RedisCacheChannel

java.lang.Object

redis.clients.jedis.BinaryJedisPubSub

com.base4j.j2cache.RedisCacheChannel

所有已实现的接口:

CacheChannel, CacheExpiredListener

public class RedisCacheChannel
extends redis.clients.jedis.BinaryJedisPubSub
implements CacheExpiredListener, CacheChannel

缓存Redis PUB/SUB监听通道

作者:

flyfox 330627517@qq.com

字段概要

从接口继承的字段 com.base4j.j2cache.CacheChannel

LEVEL_1, LEVEL_2

方法概要

限定符和类型	方法和说明
void	batchEvict(String region, List keys) 批量删除缓存
void	clear(String region) Clear the cache
void	close() 关闭到通道的连接
void	evict(String region, Object key) 删除缓存
CacheObject	get(String region, Object key) 获取缓存中的数据
static RedisCacheChannel	getInstance() 单例方法
List	keys(String region) Get cache region keys
void	notifyElementExpired(String region, Object key) 为了保证每个节点缓存的一致，当某个缓存对象因为超时被清除时，应该通知群组其他成员
protected void	onClearCacheKey(String region) 清除一级缓存的键对应内容
protected void	onDeleteCacheKey(String region, Object key) 删除一级缓存的键对应内容
void	onMessage(byte[] channel, byte[] message) 消息接收
void	set(String region, Object key, Object value) 写入缓存
void	set(String region, Object key, Object value, Integer expireInSec) 写入缓存，并设置过期时间

从类继承的方法 redis.clients.jedis.BinaryJedisPubSub

getSubscribedChannels, isSubscribed, onPMessage, onPSubscribe, onPUnsubscribe, onSubscribe, onUnsubscribe, proceed, proceedWithPatterns, psubscribe, punsubscribe, punsubscribe, subscribe, unsubscribe, unsubscribe

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

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

方法详细资料

getInstance

public static final RedisCacheChannel getInstance()

单例方法

返回:

返回 CacheChannel 单实例

get

public CacheObject get(String region,
                       Object key)

获取缓存中的数据

指定者:

get 在接口中 CacheChannel

参数:

region - : Cache Region name

key - : Cache key

返回:

cache object

set

public void set(String region,
                Object key,
                Object value)

写入缓存

指定者:

set 在接口中 CacheChannel

参数:

region - : Cache Region name

key - : Cache key

value - : Cache value

set

public void set(String region,
                Object key,
                Object value,
                Integer expireInSec)

从接口复制的说明: CacheChannel

写入缓存，并设置过期时间

指定者:

set 在接口中 CacheChannel

evict

public void evict(String region,
                  Object key)

删除缓存

指定者:

evict 在接口中 CacheChannel

参数:

region - : Cache Region name

key - : Cache key

batchEvict

public void batchEvict(String region,
                       List keys)

批量删除缓存

指定者:

batchEvict 在接口中 CacheChannel

参数:

region - : Cache region name

keys - : Cache key

clear

public void clear(String region)
           throws CacheException

Clear the cache

指定者:

clear 在接口中 CacheChannel

参数:

region - : Cache region name

抛出:

CacheException

keys

public List keys(String region)
          throws CacheException

Get cache region keys

指定者:

keys 在接口中 CacheChannel

参数:

region - : Cache region name

返回:

key list

抛出:

CacheException

notifyElementExpired

public void notifyElementExpired(String region,
                                 Object key)

为了保证每个节点缓存的一致，当某个缓存对象因为超时被清除时，应该通知群组其他成员

指定者:

notifyElementExpired 在接口中 CacheExpiredListener

参数:

region - : Cache region name

key - : cache key

onDeleteCacheKey

protected void onDeleteCacheKey(String region,
                                Object key)

删除一级缓存的键对应内容

参数:

region - : Cache region name

key - : cache key

onClearCacheKey

protected void onClearCacheKey(String region)

清除一级缓存的键对应内容

参数:

region - Cache region name

onMessage

public void onMessage(byte[] channel,
                      byte[] message)

消息接收

覆盖:

onMessage 在类中 redis.clients.jedis.BinaryJedisPubSub

参数:

channel - 缓存 Channel

message - 接收到的消息

close

public void close()

关闭到通道的连接

指定者:

close 在接口中 CacheChannel