com.seeyon.ctp.component.cache.redis

类 RedisCacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

java.lang.Object

com.seeyon.ctp.component.cache.AbstractGroupCacheable

com.seeyon.ctp.component.cache.AbstractCacheMap<K,V>

com.seeyon.ctp.component.cache.redis.RedisCacheMap<K,V>

所有已实现的接口:

CacheMap<K,V>, GroupCacheable, NoCheckCacheMap, java.io.Serializable

public class RedisCacheMap<K extends java.io.Serializable,V extends java.io.Serializable>
extends AbstractCacheMap<K,V>
implements NoCheckCacheMap, java.io.Serializable

另请参阅:

序列化表格

字段概要

从类继承的字段 com.seeyon.ctp.component.cache.AbstractCacheMap

cacheConfiguration, cacheMapDataLoader

从类继承的字段 com.seeyon.ctp.component.cache.AbstractGroupCacheable

statistics

从接口继承的字段 com.seeyon.ctp.component.cache.GroupCacheable

isCacheDisabled

构造器概要

构造器

构造器和说明
RedisCacheMap(java.lang.String group, java.lang.String cacheName, CacheConfiguration cacheConfiguration, com.seeyon.ctp.component.cache.redis.L2CacheMapLoader_Inner<K,V,java.lang.String> dataLoader, java.lang.Boolean isRestartReload)
RedisCacheMap(java.lang.String group, java.lang.String cacheName, CacheConfiguration cacheConfiguration, com.seeyon.ctp.component.cache.redis.L2CacheMapLoader_Inner<K,V,java.lang.String> dataLoader, java.lang.Boolean isRestartReload, java.lang.Boolean refreshFlag, int noCheckTime)
RedisCacheMap(java.lang.String group, java.lang.String cacheName, CacheConfiguration cacheConfiguration, com.seeyon.ctp.component.cache.redis.L2CacheMapLoader_Inner<K,V,java.lang.String> dataLoader, java.lang.Boolean isRestartReload, int noCheckTime)
RedisCacheMap(java.lang.String group, java.lang.String cacheName, CacheConfiguration cacheConfiguration, MapDataLoader<K,V> dataLoader, java.lang.Boolean isRestartReload)
RedisCacheMap(java.lang.String group, java.lang.String cacheName, CacheConfiguration cacheConfiguration, MapDataLoader<K,V> dataLoader, java.lang.Boolean isRestartReload, java.lang.Boolean refreshFlag, int noCheckTime)
RedisCacheMap(java.lang.String group, java.lang.String cacheName, CacheConfiguration cacheConfiguration, MapDataLoader<K,V> dataLoader, java.lang.Boolean isRestartReload, int noCheckTime)

方法概要

限定符和类型	方法和说明
boolean	allowRedisFlush() 检查是否按需或者可以补偿回来
K[]	checkInValidKeys() 检查版本标记已经无效的Key集合
void	clear() 清除所有缓存项。
void	clearAllTenantKey()
int	clearAndPutAll(java.util.Map<? extends K,? extends V> map) 清除缓存并将Map中的所有项目设置到缓存中。
boolean	contains(K key) 判断是否存在指定的缓存项
void	endLocalMode() 结束本地操作模式,需要根据本地操作模式下的相关缓存操作进行数据和标记位的统一处理
V	get(K key) 获取key对应的值
java.util.Map<K,V>	getBatch(java.util.Collection<K> keys) 获取keys对应的值
java.util.Map<K,V>	getBatchFromLocal(K... keys)
java.util.List<com.seeyon.ctp.component.cache.redis.CacheEntryInfo>	getCacheEntryInfo(java.lang.String... keys)
java.lang.String	getCacheInfo(K... keys)
java.lang.String	getCacheKey()
V	getFromLocal(K key) 从一级缓存（本地）获取数据,不检查版本标记也不击穿缓存从数据库加载，以此提升某些场景的获取效率,必须在调用startPutToLocal才能使用.
V	getNotUseL2Cache(K aKey) 直接访问redis获取数据,仅用于排查缓存问题
java.util.Set<K>	keySet() Returns a set view of the keys contained in this map.
boolean	needConsistent() 是否需要保持一级缓存一致性
void	pauseNoCheckOnce() 暂停一次noCheck读取模式，下次get会获取会检验标记get到最新数据，用于put操作，避免更新前的脏读问题
int	put(K key, V value) 插入、更新map对象结构中的mapKey key 在初始化时预制， 每一个RedisCacheMap实例，对应一个key
int	putAll(java.util.Map<? extends K,? extends V> map) 将Map中的所有项目设置到缓存中。
void	putNoWait(K key, V value) 写入值,不等待缓存标记更新,在批量写入时能加快速度,异步清除本地缓存,和Redis上的缓存数据.不等待标志返回.
void	putToLocal(K key, V value) 更新一级缓存（本地）指定key的数据,不更新标志,必须在调用startPutToLocal才能使用.
int	remove(K key) 移除缓存项。
int	removeAll(java.util.Collection<K> keys) 移除缓存项
int	size() 该方法提供的为本地大小，不代表Redis缓存大小，谨慎使用 Returns the number of elements in this list.
void	startLocalMode() 开始本地操作模式，get put操作不更新或check Redis版本标记，在CacheMap.endLocalMode() 调用时统一处理标记和本地缓存
void	startNoCheckMode(NoCheckRange range) 手动开启noCheck读取模式
void	stopNoCheckMode(NoCheckRange range) 手动关闭noCheck读取模式
java.util.Map<K,V>	toMap() 将缓存转化为Map表示
void	updateKey(K key) 更新缓存标记，下次get可从db进行load
java.util.Collection<V>	values() Returns a collection view of the values contained in this map.

从类继承的方法 com.seeyon.ctp.component.cache.AbstractCacheMap

getCacheConfiguration, getCacheMapDataLoader, isEmpty, setCacheConfiguration

从类继承的方法 com.seeyon.ctp.component.cache.AbstractGroupCacheable

checkBatchCacheMiss, checkBatchInProtectCache, checkCacheMiss, checkInProtectCache, clearProtectCache, getFullName, getGroup, getName, getStatistics, invalidateProtectCache, invalidateProtectCache, setBatchProtectCache, setProtectCache, setProtectDataExpire

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

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

从接口继承的方法 com.seeyon.ctp.component.cache.GroupCacheable

getFullName, getGroup, getName, getStatistics, isEmpty

构造器详细资料

RedisCacheMap

public RedisCacheMap(java.lang.String group,
                     java.lang.String cacheName,
                     CacheConfiguration cacheConfiguration,
                     MapDataLoader<K,V> dataLoader,
                     java.lang.Boolean isRestartReload)

RedisCacheMap

public RedisCacheMap(java.lang.String group,
                     java.lang.String cacheName,
                     CacheConfiguration cacheConfiguration,
                     MapDataLoader<K,V> dataLoader,
                     java.lang.Boolean isRestartReload,
                     int noCheckTime)

RedisCacheMap

public RedisCacheMap(java.lang.String group,
                     java.lang.String cacheName,
                     CacheConfiguration cacheConfiguration,
                     com.seeyon.ctp.component.cache.redis.L2CacheMapLoader_Inner<K,V,java.lang.String> dataLoader,
                     java.lang.Boolean isRestartReload)

RedisCacheMap

public RedisCacheMap(java.lang.String group,
                     java.lang.String cacheName,
                     CacheConfiguration cacheConfiguration,
                     com.seeyon.ctp.component.cache.redis.L2CacheMapLoader_Inner<K,V,java.lang.String> dataLoader,
                     java.lang.Boolean isRestartReload,
                     int noCheckTime)

RedisCacheMap

public RedisCacheMap(java.lang.String group,
                     java.lang.String cacheName,
                     CacheConfiguration cacheConfiguration,
                     com.seeyon.ctp.component.cache.redis.L2CacheMapLoader_Inner<K,V,java.lang.String> dataLoader,
                     java.lang.Boolean isRestartReload,
                     java.lang.Boolean refreshFlag,
                     int noCheckTime)

RedisCacheMap

public RedisCacheMap(java.lang.String group,
                     java.lang.String cacheName,
                     CacheConfiguration cacheConfiguration,
                     MapDataLoader<K,V> dataLoader,
                     java.lang.Boolean isRestartReload,
                     java.lang.Boolean refreshFlag,
                     int noCheckTime)

方法详细资料

clearAllTenantKey

public void clearAllTenantKey()

getCacheKey

public java.lang.String getCacheKey()

覆盖:

getCacheKey 在类中 AbstractGroupCacheable

put

public int put(K key,
               V value)

插入、更新map对象结构中的mapKey key 在初始化时预制， 每一个RedisCacheMap实例，对应一个key

指定者:

put 在接口中 CacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

参数:

key -

value -

getNotUseL2Cache

public V getNotUseL2Cache(K aKey)

直接访问redis获取数据,仅用于排查缓存问题

参数:

aKey -

返回:

get

public V get(K key)

从接口复制的说明: CacheMap

获取key对应的值

指定者:

get 在接口中 CacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

参数:

key - 缓存的Key

getBatch

public java.util.Map<K,V> getBatch(java.util.Collection<K> keys)

从接口复制的说明: CacheMap

获取keys对应的值

指定者:

getBatch 在接口中 CacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

参数:

keys - 缓存的Key集合

remove

public int remove(K key)

从接口复制的说明: CacheMap

移除缓存项。

指定者:

remove 在接口中 CacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

参数:

key - 缓存的Key

返回:

被移除的缓存项。如果不存在返回null。

putAll

public int putAll(java.util.Map<? extends K,? extends V> map)

从接口复制的说明: CacheMap

将Map中的所有项目设置到缓存中。效果相当于循环调用put，但性能要高一些。不清除原有项目进行追加，如果Key冲突则覆盖原缓存项。

指定者:

putAll 在接口中 CacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

参数:

map - Java Map

clearAndPutAll

public int clearAndPutAll(java.util.Map<? extends K,? extends V> map)

从接口复制的说明: CacheMap

清除缓存并将Map中的所有项目设置到缓存中。效果相当于先clear再putAll。

指定者:

clearAndPutAll 在接口中 CacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

参数:

map - Java Map

removeAll

public int removeAll(java.util.Collection<K> keys)

从接口复制的说明: CacheMap

移除缓存项

指定者:

removeAll 在接口中 CacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

参数:

keys - 缓存的Key集合，所有以集合中元素为key的换成都会被移除。

返回:

如果有元素被移除返回true，否则返回false。

updateKey

public void updateKey(K key)

从接口复制的说明: CacheMap

更新缓存标记，下次get可从db进行load

指定者:

updateKey 在接口中 CacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

contains

public boolean contains(K key)

从接口复制的说明: CacheMap

判断是否存在指定的缓存项

指定者:

contains 在接口中 CacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

参数:

key - 缓存的Key

返回:

存在返回true，否则返回false。

toMap

public java.util.Map<K,V> toMap()

从接口复制的说明: CacheMap

将缓存转化为Map表示

指定者:

toMap 在接口中 CacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

返回:

Map，Key为缓存的Key，Value为缓存中的对象。

keySet

public java.util.Set<K> keySet()

从接口复制的说明: CacheMap

Returns a set view of the keys contained in this map. The set is backed by the map, so changes to the map are reflected in the set, and vice-versa. If the map is modified while an iteration over the set is in progress (except through the iterator's own remove operation), the results of the iteration are undefined. The set supports element removal, which removes the corresponding mapping from the map, via the Iterator.remove, Set.remove, removeAll retainAll, and clear operations. It does not support the add or addAll operations.

指定者:

keySet 在接口中 CacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

返回:

a set view of the keys contained in this map.

values

public java.util.Collection<V> values()

从接口复制的说明: CacheMap

Returns a collection view of the values contained in this map. The collection is backed by the map, so changes to the map are reflected in the collection, and vice-versa. If the map is modified while an iteration over the collection is in progress (except through the iterator's own remove operation), the results of the iteration are undefined. The collection supports element removal, which removes the corresponding mapping from the map, via the Iterator.remove, Collection.remove, removeAll, retainAll and clear operations. It does not support the add or addAll operations.

指定者:

values 在接口中 CacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

返回:

a collection view of the values contained in this map.

startLocalMode

public void startLocalMode()

从接口复制的说明: CacheMap

开始本地操作模式，get put操作不更新或check Redis版本标记，在CacheMap.endLocalMode() 调用时统一处理标记和本地缓存

指定者:

startLocalMode 在接口中 CacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

endLocalMode

public void endLocalMode()

从接口复制的说明: CacheMap

结束本地操作模式,需要根据本地操作模式下的相关缓存操作进行数据和标记位的统一处理

指定者:

endLocalMode 在接口中 CacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

putToLocal

public void putToLocal(K key,
                       V value)

从接口复制的说明: CacheMap

更新一级缓存（本地）指定key的数据,不更新标志,必须在调用startPutToLocal才能使用.

指定者:

putToLocal 在接口中 CacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

getFromLocal

public V getFromLocal(K key)

从接口复制的说明: CacheMap

从一级缓存（本地）获取数据,不检查版本标记也不击穿缓存从数据库加载，以此提升某些场景的获取效率,必须在调用startPutToLocal才能使用.

指定者:

getFromLocal 在接口中 CacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

返回:

getBatchFromLocal

public java.util.Map<K,V> getBatchFromLocal(K... keys)

checkInValidKeys

public K[] checkInValidKeys()

从接口复制的说明: CacheMap

检查版本标记已经无效的Key集合

指定者:

checkInValidKeys 在接口中 CacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

返回:

putNoWait

public void putNoWait(K key,
                      V value)

从接口复制的说明: CacheMap

写入值,不等待缓存标记更新,在批量写入时能加快速度,异步清除本地缓存,和Redis上的缓存数据.不等待标志返回.

指定者:

putNoWait 在接口中 CacheMap<K extends java.io.Serializable,V extends java.io.Serializable>

size

public int size()

从接口复制的说明: GroupCacheable

该方法提供的为本地大小，不代表Redis缓存大小，谨慎使用 Returns the number of elements in this list. If this list contains more than Integer.MAX_VALUE elements, returns Integer.MAX_VALUE.

指定者:

size 在接口中 GroupCacheable

返回:

the number of elements in this list.

clear

public void clear()

从接口复制的说明: GroupCacheable

清除所有缓存项。

指定者:

clear 在接口中 GroupCacheable

getCacheInfo

public java.lang.String getCacheInfo(K... keys)

getCacheEntryInfo

public java.util.List<com.seeyon.ctp.component.cache.redis.CacheEntryInfo> getCacheEntryInfo(java.lang.String... keys)

allowRedisFlush

public boolean allowRedisFlush()

从接口复制的说明: GroupCacheable

检查是否按需或者可以补偿回来

指定者:

allowRedisFlush 在接口中 GroupCacheable

needConsistent

public boolean needConsistent()

从接口复制的说明: GroupCacheable

是否需要保持一级缓存一致性

指定者:

needConsistent 在接口中 GroupCacheable

pauseNoCheckOnce

public void pauseNoCheckOnce()

从接口复制的说明: NoCheckCacheMap

暂停一次noCheck读取模式，下次get会获取会检验标记get到最新数据，用于put操作，避免更新前的脏读问题

指定者:

pauseNoCheckOnce 在接口中 NoCheckCacheMap

startNoCheckMode

public void startNoCheckMode(NoCheckRange range)

从接口复制的说明: NoCheckCacheMap

手动开启noCheck读取模式

指定者:

startNoCheckMode 在接口中 NoCheckCacheMap

参数:

range - 使用范围，参考NoCheckRange

stopNoCheckMode

public void stopNoCheckMode(NoCheckRange range)

从接口复制的说明: NoCheckCacheMap

手动关闭noCheck读取模式

指定者:

stopNoCheckMode 在接口中 NoCheckCacheMap

参数:

range - 使用范围，参考NoCheckRange，需要与start时对应 不调用时，超过noCheckTime时间后，忽略check数据标记的模式自动失效 *