模块 org.redkale

程序包 org.redkale.source

类 CacheMemorySource

java.lang.Object

org.redkale.service.AbstractService

org.redkale.source.AbstractCacheSource

org.redkale.source.CacheMemorySource

所有已实现的接口:

AutoCloseable, Resourcable, Service, CacheSource

@Local
@AutoLoad(false)
@ResourceType(CacheSource.class)
public final class CacheMemorySource
extends AbstractCacheSource

CacheSource的默认实现--内存缓存 注意: url 需要指定为 memory:cachesource

详情见: https://redkale.org

作者:

zhangjx

嵌套类概要

嵌套类

修饰符和类型	类	说明
static class	CacheMemorySource.CacheEntry
static class	CacheMemorySource.CacheEntryType
static class	CacheMemorySource.RateLimitEntry

字段概要

从类继承的字段 org.redkale.source.AbstractCacheSource

CACHE_SOURCE_DB, CACHE_SOURCE_ENCODING, CACHE_SOURCE_MAXCONNS, CACHE_SOURCE_NODES, CACHE_SOURCE_NON_BLOCKING, CACHE_SOURCE_PASSWORD, CACHE_SOURCE_PIPELINES, CACHE_SOURCE_RESOURCE, CACHE_SOURCE_TYPE, CACHE_SOURCE_USER

构造器概要

构造器

构造器	说明
CacheMemorySource(String resourceName)

方法概要

修饰符和类型	方法	说明
static boolean	acceptsConf(AnyValue config)
void	close()
long	dbsize()
CompletableFuture<Long>	dbsizeAsync()
long	decr(String key)
CompletableFuture<Long>	decrAsync(String key)
long	decrby(String key, long num)
CompletableFuture<Long>	decrbyAsync(String key, long num)
long	del(String... keys)
CompletableFuture<Long>	delAsync(String... keys)
long	delex(String key, String expectedValue)
CompletableFuture<Long>	delexAsync(String key, String expectedValue)
void	destroy(AnyValue conf)	进程退出时，调用Service销毁 远程模式下该方法会重载成空方法 注意： 在此方法内不能调用MessageClient.sendMessage 方法，因为Application关闭时会先destroy掉MessageClient
boolean	exists(String key)
CompletableFuture<Boolean>	existsAsync(String key)
void	expire(String key, int expireSeconds)
CompletableFuture<Void>	expireAsync(String key, int expireSeconds)
void	expireAt(String key, long secondsTime)
CompletableFuture<Void>	expireAtAsync(String key, long secondsTime)
long	expireTime(String key)
CompletableFuture<Long>	expireTimeAsync(String key)
protected CacheMemorySource.CacheEntry	find(String key)
protected CacheMemorySource.CacheEntry	find(String key, CacheMemorySource.CacheEntryType cacheType)
void	flushall()
CompletableFuture<Void>	flushallAsync()
void	flushdb()
CompletableFuture<Void>	flushdbAsync()
<T> T	get(String key, Type type)
<T> CompletableFuture<T>	getAsync(String key, Type type)
<T> Collection<T>	getCollection(String key, Type componentType)	已过时。
<T> CompletableFuture<Collection<T>>	getCollectionAsync(String key, Type componentType)	已过时。
<T> Map<String,Collection<T>>	getCollectionMap(boolean set, Type componentType, String... keys)	已过时。
<T> CompletableFuture<Map<String,Collection<T>>>	getCollectionMapAsync(boolean set, Type componentType, String... keys)	已过时。
int	getCollectionSize(String key)	已过时。
CompletableFuture<Integer>	getCollectionSizeAsync(String key)	已过时。
<T> T	getDel(String key, Type type)
<T> CompletableFuture<T>	getDelAsync(String key, Type type)
<T> T	getex(String key, int expireSeconds, Type type)
<T> CompletableFuture<T>	getexAsync(String key, int expireSeconds, Type type)	获取key的值并可选择设置其过期时间
<T> Collection<T>	getexCollection(String key, int expireSeconds, Type componentType)	已过时。
<T> CompletableFuture<Collection<T>>	getexCollectionAsync(String key, int expireSeconds, Type componentType)	已过时。
Collection<Long>	getexLongCollection(String key, int expireSeconds)	已过时。
CompletableFuture<Collection<Long>>	getexLongCollectionAsync(String key, int expireSeconds)	已过时。
Collection<String>	getexStringCollection(String key, int expireSeconds)	已过时。
CompletableFuture<Collection<String>>	getexStringCollectionAsync(String key, int expireSeconds)	已过时。
Long[]	getLongArray(String... keys)	已过时。
CompletableFuture<Long[]>	getLongArrayAsync(String... keys)	已过时。
Collection<Long>	getLongCollection(String key)	已过时。
CompletableFuture<Collection<Long>>	getLongCollectionAsync(String key)	已过时。
Map<String,Collection<Long>>	getLongCollectionMap(boolean set, String... keys)	已过时。
CompletableFuture<Map<String,Collection<Long>>>	getLongCollectionMapAsync(boolean set, String... keys)	已过时。
Map<String,Long>	getLongMap(String... keys)	已过时。
CompletableFuture<Map<String,Long>>	getLongMapAsync(String... keys)	已过时。
<T> Map<String,T>	getMap(Type componentType, String... keys)	已过时。
<T> CompletableFuture<Map<String,T>>	getMapAsync(Type componentType, String... keys)	已过时。
<T> T	getSet(String key, Convert convert, Type type, T value)
<T> CompletableFuture<T>	getSetAsync(String key, Convert convert, Type type, T value)
String[]	getStringArray(String... keys)	已过时。
CompletableFuture<String[]>	getStringArrayAsync(String... keys)	已过时。
Collection<String>	getStringCollection(String key)	已过时。
CompletableFuture<Collection<String>>	getStringCollectionAsync(String key)	已过时。
Map<String,Collection<String>>	getStringCollectionMap(boolean set, String... keys)	已过时。
CompletableFuture<Map<String,Collection<String>>>	getStringCollectionMapAsync(boolean set, String... keys)	已过时。
Map<String,String>	getStringMap(String... keys)	已过时。
CompletableFuture<Map<String,String>>	getStringMapAsync(String... keys)	已过时。
String	getType()
long	hdecr(String key, String field)
CompletableFuture<Long>	hdecrAsync(String key, String field)
long	hdecrby(String key, String field, long num)
CompletableFuture<Long>	hdecrbyAsync(String key, String field, long num)
long	hdel(String key, String... fields)
CompletableFuture<Long>	hdelAsync(String key, String... fields)
boolean	hexists(String key, String field)
CompletableFuture<Boolean>	hexistsAsync(String key, String field)
<T> T	hget(String key, String field, Type type)
<T> Map<String,T>	hgetall(String key, Type type)
<T> CompletableFuture<Map<String,T>>	hgetallAsync(String key, Type type)
<T> CompletableFuture<T>	hgetAsync(String key, String field, Type type)
long	hincr(String key, String field)
CompletableFuture<Long>	hincrAsync(String key, String field)
long	hincrby(String key, String field, long num)
CompletableFuture<Long>	hincrbyAsync(String key, String field, long num)
double	hincrbyFloat(String key, String field, double num)
CompletableFuture<Double>	hincrbyFloatAsync(String key, String field, double num)
List<String>	hkeys(String key)
CompletableFuture<List<String>>	hkeysAsync(String key)
long	hlen(String key)
CompletableFuture<Long>	hlenAsync(String key)
<T> List<T>	hmget(String key, Type type, String... fields)
<T> CompletableFuture<List<T>>	hmgetAsync(String key, Type type, String... fields)
void	hmset(String key, Serializable... values)
void	hmset(String key, Map map)
CompletableFuture<Void>	hmsetAsync(String key, Serializable... values)
CompletableFuture<Void>	hmsetAsync(String key, Map map)
<T> Map<String,T>	hscan(String key, Type type, AtomicLong cursor, int limit, String pattern)
<T> CompletableFuture<Map<String,T>>	hscanAsync(String key, Type type, AtomicLong cursor, int limit, String pattern)
<T> void	hset(String key, String field, Convert convert, Type type, T value)
<T> CompletableFuture<Void>	hsetAsync(String key, String field, Convert convert, Type type, T value)
<T> boolean	hsetnx(String key, String field, Convert convert, Type type, T value)
<T> CompletableFuture<Boolean>	hsetnxAsync(String key, String field, Convert convert, Type type, T value)
long	hstrlen(String key, String field)
CompletableFuture<Long>	hstrlenAsync(String key, String field)
<T> List<T>	hvals(String key, Type type)
<T> CompletableFuture<List<T>>	hvalsAsync(String key, Type type)
long	incr(String key)
CompletableFuture<Long>	incrAsync(String key)
long	incrby(String key, long num)
CompletableFuture<Long>	incrbyAsync(String key, long num)
double	incrbyFloat(String key, double num)
CompletableFuture<Double>	incrbyFloatAsync(String key, double num)
void	init(AnyValue conf)	该方法必须是可以重复调用， 当reload时需要重复调用init方法 远程模式下该方法会重载成空方法
CompletableFuture<Boolean>	isOpenAsync()
List<String>	keys(String pattern)
CompletableFuture<List<String>>	keysAsync(String pattern)
List<String>	keysStartsWith(String startsWith)
CompletableFuture<List<String>>	keysStartsWithAsync(String startsWith)
<T> T	lindex(String key, Type componentType, int index)
<T> CompletableFuture<T>	lindexAsync(String key, Type componentType, int index)
protected <T> long	linsert(String key, Type componentType, boolean before, T pivot, T value)
<T> long	linsertAfter(String key, Type componentType, T pivot, T value)
<T> CompletableFuture<Long>	linsertAfterAsync(String key, Type componentType, T pivot, T value)
<T> long	linsertBefore(String key, Type componentType, T pivot, T value)
<T> CompletableFuture<Long>	linsertBeforeAsync(String key, Type componentType, T pivot, T value)
long	llen(String key)
CompletableFuture<Long>	llenAsync(String key)
<T> T	lpop(String key, Type componentType)
<T> CompletableFuture<T>	lpopAsync(String key, Type componentType)
<T> void	lpush(String key, Type componentType, T... values)
<T> CompletableFuture<Void>	lpushAsync(String key, Type componentType, T... values)
<T> void	lpushx(String key, Type componentType, T... values)
<T> CompletableFuture<Void>	lpushxAsync(String key, Type componentType, T... values)
<T> List<T>	lrange(String key, Type componentType, int start, int stop)
<T> CompletableFuture<List<T>>	lrangeAsync(String key, Type componentType, int start, int stop)
<T> Map<String,List<T>>	lranges(Type componentType, String... keys)
<T> CompletableFuture<Map<String,List<T>>>	lrangesAsync(Type componentType, String... keys)
<T> long	lrem(String key, Type componentType, T value)
<T> CompletableFuture<Long>	lremAsync(String key, Type componentType, T value)
void	ltrim(String key, int start, int stop)
CompletableFuture<Void>	ltrimAsync(String key, int start, int stop)
<T> List<T>	mget(Type componentType, String... keys)
<T> CompletableFuture<List<T>>	mgetAsync(Type componentType, String... keys)
void	mset(Serializable... keyVals)
void	mset(Map map)
CompletableFuture<Void>	msetAsync(Serializable... keyVals)
CompletableFuture<Void>	msetAsync(Map map)
boolean	msetnx(Serializable... keyVals)
boolean	msetnx(Map map)
CompletableFuture<Boolean>	msetnxAsync(Serializable... keyVals)
CompletableFuture<Boolean>	msetnxAsync(Map map)
void	onResourceChange(ResourceEvent[] events)
boolean	persist(String key)
CompletableFuture<Boolean>	persistAsync(String key)
void	pexpire(String key, long milliSeconds)
CompletableFuture<Void>	pexpireAsync(String key, long milliSeconds)
void	pexpireAt(String key, long milliTime)
CompletableFuture<Void>	pexpireAtAsync(String key, long milliTime)
long	pexpireTime(String key)
CompletableFuture<Long>	pexpireTimeAsync(String key)
<T> void	psetex(String key, long milliSeconds, Convert convert, Type type, T value)
<T> CompletableFuture<Void>	psetexAsync(String key, long milliSeconds, Convert convert, Type type, T value)
long	pttl(String key)
CompletableFuture<Long>	pttlAsync(String key)
CompletableFuture<Integer>	publishAsync(String topic, byte[] message)
CompletableFuture<List<String>>	pubsubChannelsAsync(String pattern)
long	rateLimit(String key, long rate, long capacity, long requested)	令牌桶算法限流， 返回负数表示无令牌， 其他为有令牌
CompletableFuture<Long>	rateLimitAsync(String key, long rate, long capacity, long requested)	令牌桶算法限流， 返回负数表示无令牌， 其他为有令牌
boolean	rename(String oldKey, String newKey)
CompletableFuture<Boolean>	renameAsync(String oldKey, String newKey)
boolean	renamenx(String oldKey, String newKey)
CompletableFuture<Boolean>	renamenxAsync(String oldKey, String newKey)
String	resourceName()
<T> T	rpop(String key, Type componentType)
<T> CompletableFuture<T>	rpopAsync(String key, Type componentType)
<T> T	rpoplpush(String key, String key2, Type componentType)
<T> CompletableFuture<T>	rpoplpushAsync(String key, String key2, Type componentType)
<T> void	rpush(String key, Type componentType, T... values)
<T> CompletableFuture<Void>	rpushAsync(String key, Type componentType, T... values)
<T> void	rpushx(String key, Type componentType, T... values)
<T> CompletableFuture<Void>	rpushxAsync(String key, Type componentType, T... values)
protected CompletableFuture<Void>	runAsync(Runnable runner, Executor executor)
protected CompletableFuture<Void>	runFuture(Runnable runner)
<T> void	sadd(String key, Type componentType, T... values)
<T> CompletableFuture<Void>	saddAsync(String key, Type componentType, T... values)
List<String>	scan(AtomicLong cursor, int limit, String pattern)
CompletableFuture<List<String>>	scanAsync(AtomicLong cursor, int limit, String pattern)
long	scard(String key)
CompletableFuture<Long>	scardAsync(String key)
<T> Set<T>	sdiff(String key, Type componentType, String... key2s)
<T> CompletableFuture<Set<T>>	sdiffAsync(String key, Type componentType, String... key2s)
long	sdiffstore(String key, String srcKey, String... srcKey2s)
CompletableFuture<Long>	sdiffstoreAsync(String key, String srcKey, String... srcKey2s)
<T> void	set(String key, Convert convert, Type type, T value)
<T> CompletableFuture<Void>	setAsync(String key, Convert convert, Type type, T value)
<T> void	setex(String key, int expireSeconds, Convert convert, Type type, T value)
<T> CompletableFuture<Void>	setexAsync(String key, int expireSeconds, Convert convert, Type type, T value)
<T> boolean	setnx(String key, Convert convert, Type type, T value)
<T> CompletableFuture<Boolean>	setnxAsync(String key, Convert convert, Type type, T value)
<T> boolean	setnxex(String key, int expireSeconds, Convert convert, Type type, T value)
<T> CompletableFuture<Boolean>	setnxexAsync(String key, int expireSeconds, Convert convert, Type type, T value)
<T> boolean	setnxpx(String key, long milliSeconds, Convert convert, Type type, T value)
<T> CompletableFuture<Boolean>	setnxpxAsync(String key, long milliSeconds, Convert convert, Type type, T value)
<T> Set<T>	sinter(String key, Type componentType, String... key2s)
<T> CompletableFuture<Set<T>>	sinterAsync(String key, Type componentType, String... key2s)
long	sinterstore(String key, String srcKey, String... srcKey2s)
CompletableFuture<Long>	sinterstoreAsync(String key, String srcKey, String... srcKey2s)
<T> boolean	sismember(String key, Type type, T value)
<T> CompletableFuture<Boolean>	sismemberAsync(String key, Type type, T value)
<T> Map<String,Set<T>>	smembers(Type componentType, String... keys)
<T> Set<T>	smembers(String key, Type componentType)
<T> CompletableFuture<Map<String,Set<T>>>	smembersAsync(Type componentType, String... keys)
<T> CompletableFuture<Set<T>>	smembersAsync(String key, Type componentType)
List<Boolean>	smismembers(String key, String... members)
CompletableFuture<List<Boolean>>	smismembersAsync(String key, String... members)
<T> boolean	smove(String key, String key2, Type componentType, T member)
<T> CompletableFuture<Boolean>	smoveAsync(String key, String key2, Type componentType, T member)
<T> Set<T>	spop(String key, int count, Type componentType)
<T> T	spop(String key, Type componentType)
<T> CompletableFuture<Set<T>>	spopAsync(String key, int count, Type componentType)
<T> CompletableFuture<T>	spopAsync(String key, Type componentType)
<T> List<T>	srandmember(String key, Type componentType, int count)
<T> CompletableFuture<List<T>>	srandmemberAsync(String key, Type componentType, int count)
<T> long	srem(String key, Type type, T... values)
<T> CompletableFuture<Long>	sremAsync(String key, Type type, T... values)
<T> Set<T>	sscan(String key, Type componentType, AtomicLong cursor, int limit, String pattern)
<T> CompletableFuture<Set<T>>	sscanAsync(String key, Type componentType, AtomicLong cursor, int limit, String pattern)
protected ExecutorService	subExecutor()
CompletableFuture<Void>	subscribeAsync(CacheEventListener<byte[]> listener, String... topics)
<T> Set<T>	sunion(String key, Type componentType, String... key2s)
<T> CompletableFuture<Set<T>>	sunionAsync(String key, Type componentType, String... key2s)
long	sunionstore(String key, String srcKey, String... srcKey2s)
CompletableFuture<Long>	sunionstoreAsync(String key, String srcKey, String... srcKey2s)
protected <U> CompletableFuture<U>	supplyAsync(Supplier<U> supplier)
protected <U> CompletableFuture<U>	supplyAsync(Supplier<U> supplier, Executor executor)
protected <U> CompletableFuture<U>	supplyFuture(Supplier<U> supplier)
String	toString()
long	ttl(String key)
CompletableFuture<Long>	ttlAsync(String key)
CompletableFuture<Integer>	unsubscribeAsync(CacheEventListener listener, String... topics)
void	zadd(String key, CacheScoredValue... values)
CompletableFuture<Void>	zaddAsync(String key, CacheScoredValue... values)
long	zcard(String key)
CompletableFuture<Long>	zcardAsync(String key)
<T extends Number> T	zincrby(String key, CacheScoredValue value)
<T extends Number> CompletableFuture<T>	zincrbyAsync(String key, CacheScoredValue value)
<T extends Number> List<T>	zmscore(String key, Class<T> scoreType, String... members)
<T extends Number> CompletableFuture<List<T>>	zmscoreAsync(String key, Class<T> scoreType, String... members)
List<String>	zrange(String key, int start, int stop)
CompletableFuture<List<String>>	zrangeAsync(String key, int start, int stop)
Long	zrank(String key, String member)
CompletableFuture<Long>	zrankAsync(String key, String member)
long	zrem(String key, String... members)
CompletableFuture<Long>	zremAsync(String key, String... members)
Long	zrevrank(String key, String member)
CompletableFuture<Long>	zrevrankAsync(String key, String member)
List<CacheScoredValue>	zscan(String key, Type scoreType, AtomicLong cursor, int limit, String pattern)
CompletableFuture<List<CacheScoredValue>>	zscanAsync(String key, Type scoreType, AtomicLong cursor, int limit, String pattern)
<T extends Number> T	zscore(String key, Class<T> scoreType, String member)
<T extends Number> CompletableFuture<T>	zscoreAsync(String key, Class<T> scoreType, String member)

从类继承的方法 org.redkale.source.AbstractCacheSource

createCacheSource, createCacheSource

从类继承的方法 org.redkale.service.AbstractService

getExecutor, runAsync, serviceName, serviceType

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

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

从接口继承的方法 org.redkale.source.CacheSource

appendListItem, appendListItemAsync, appendLongListItem, appendLongListItemAsync, appendLongSetItem, appendLongSetItemAsync, appendSetItem, appendSetItemAsync, appendStringListItem, appendStringListItemAsync, appendStringSetItem, appendStringSetItemAsync, decr, existsLongSetItem, existsLongSetItemAsync, existsSetItem, existsSetItemAsync, existsStringSetItem, existsStringSetItemAsync, getAndRefresh, getAndRefreshAsync, getDelLong, getDelLong, getDelLongAsync, getDelLongAsync, getDelString, getDelStringAsync, getexLong, getexLong, getexLongAsync, getexLongAsync, getexString, getexStringAsync, getKeySize, getKeySizeAsync, getLong, getLong, getLongAndRefresh, getLongAndRefreshAsync, getLongAsync, getLongAsync, getSet, getSetAsync, getSetLong, getSetLong, getSetLongAsync, getSetLongAsync, getSetString, getSetStringAsync, getString, getStringAndRefresh, getStringAndRefreshAsync, getStringAsync, hgetallLong, hgetallLongAsync, hgetallString, hgetallStringAsync, hgetLong, hgetLong, hgetLongAsync, hgetLongAsync, hgetString, hgetStringAsync, hmap, hmap, hmapAsync, hmapAsync, hmgetLong, hmgetLongAsync, hmgetString, hmgetStringAsync, hremove, hremoveAsync, hscan, hscanAsync, hset, hsetAsync, hsetLong, hsetLongAsync, hsetnx, hsetnxAsync, hsetnxLong, hsetnxLongAsync, hsetnxString, hsetnxStringAsync, hsetString, hsetStringAsync, hsize, hsizeAsync, hvalsLong, hvalsLongAsync, hvalsString, hvalsStringAsync, incr, isOpen, keys, keysAsync, lindexLong, lindexLongAsync, lindexString, lindexStringAsync, linsertAfterLong, linsertAfterLongAsync, linsertAfterString, linsertAfterStringAsync, linsertBeforeLong, linsertBeforeLongAsync, linsertBeforeString, linsertBeforeStringAsync, lock, lockAsync, lpopLong, lpopLongAsync, lpopString, lpopStringAsync, lpushLong, lpushLongAsync, lpushString, lpushStringAsync, lpushxLong, lpushxLongAsync, lpushxString, lpushxStringAsync, lrange, lrangeAsync, lrangeLong, lrangeLong, lrangeLongAsync, lrangeLongAsync, lrangesLong, lrangesLongAsync, lrangesString, lrangesStringAsync, lrangeString, lrangeString, lrangeStringAsync, lrangeStringAsync, lremLong, lremLongAsync, lremString, lremStringAsync, mgetLong, mgetLongAsync, mgets, mgetsAsync, mgetsLong, mgetsLongAsync, mgetsString, mgetsStringAsync, mgetString, mgetStringAsync, psetex, psetexAsync, psetexLong, psetexLongAsync, psetexString, psetexStringAsync, publish, publish, publish, publish, publish, publishAsync, publishAsync, publishAsync, publishAsync, pubsubChannels, queryKeys, queryKeysAsync, queryKeysEndsWith, queryKeysEndsWithAsync, queryKeysStartsWith, queryKeysStartsWithAsync, rateLimit, rateLimitAsync, refresh, refreshAsync, remove, removeAsync, removeListItem, removeListItemAsync, removeLongListItem, removeLongListItemAsync, removeLongSetItem, removeLongSetItemAsync, removeSetItem, removeSetItemAsync, removeStringListItem, removeStringListItemAsync, removeStringSetItem, removeStringSetItemAsync, rpopLong, rpopLongAsync, rpoplpushLong, rpoplpushLongAsync, rpoplpushString, rpoplpushStringAsync, rpopString, rpopStringAsync, rpushLong, rpushLongAsync, rpushString, rpushStringAsync, rpushxLong, rpushxLongAsync, rpushxString, rpushxStringAsync, saddLong, saddLongAsync, saddString, saddStringAsync, scan, scanAsync, sdiffLong, sdiffLongAsync, sdiffString, sdiffStringAsync, set, set, set, set, setAsync, setAsync, setAsync, setAsync, setex, setexAsync, setexLong, setexLongAsync, setExpireSeconds, setExpireSecondsAsync, setexString, setexStringAsync, setLong, setLong, setLongAsync, setnx, setnxAsync, setnxex, setnxexAsync, setnxexLong, setnxexLongAsync, setnxexString, setnxexStringAsync, setnxLong, setnxLongAsync, setnxpx, setnxpxAsync, setnxpxLong, setnxpxLongAsync, setnxpxString, setnxpxStringAsync, setnxString, setnxStringAsync, setString, setString, setStringAsync, sinterLong, sinterLongAsync, sinterString, sinterStringAsync, sismemberLong, sismemberLongAsync, sismemberString, sismemberStringAsync, smembersLong, smembersLong, smembersLongAsync, smembersLongAsync, smembersString, smembersString, smembersStringAsync, smembersStringAsync, smismember, smoveLong, smoveLongAsync, smoveString, smoveStringAsync, spopLong, spopLong, spopLongAsync, spopLongAsync, spopLongSetItem, spopLongSetItem, spopLongSetItemAsync, spopLongSetItemAsync, spopSetItem, spopSetItem, spopSetItemAsync, spopSetItemAsync, spopString, spopString, spopStringAsync, spopStringAsync, spopStringSetItem, spopStringSetItem, spopStringSetItemAsync, spopStringSetItemAsync, srandmember, srandmemberAsync, srandmemberLong, srandmemberLong, srandmemberLongAsync, srandmemberLongAsync, srandmemberString, srandmemberString, srandmemberStringAsync, srandmemberStringAsync, sremLong, sremLongAsync, sremString, sremStringAsync, sscan, sscanAsync, sscanLong, sscanLong, sscanLongAsync, sscanLongAsync, sscanString, sscanString, sscanStringAsync, sscanStringAsync, subscribe, subscribe, subscribe, subscribeAsync, subscribeAsync, sunionLong, sunionLongAsync, sunionString, sunionStringAsync, unlock, unlockAsync, unsubscribe, zadd, zadd, zadd, zaddAsync, zaddAsync, zaddAsync, zincrby, zincrby, zincrby, zincrbyAsync, zincrbyAsync, zincrbyAsync, zmscoreDouble, zmscoreDoubleAsync, zmscoreInteger, zmscoreIntegerAsync, zmscoreLong, zmscoreLongAsync, zscan, zscanAsync, zscanDouble, zscanDouble, zscanDoubleAsync, zscanDoubleAsync, zscanInteger, zscanInteger, zscanIntegerAsync, zscanIntegerAsync, zscanLong, zscanLong, zscanLongAsync, zscanLongAsync, zscoreDouble, zscoreDoubleAsync, zscoreInteger, zscoreIntegerAsync, zscoreLong, zscoreLongAsync

构造器详细资料

CacheMemorySource

public CacheMemorySource(String resourceName)

方法详细资料

getType

public final String getType()

onResourceChange

@ResourceChanged
public void onResourceChange(ResourceEvent[] events)

指定者:

onResourceChange 在类中 AbstractCacheSource

subExecutor

protected ExecutorService subExecutor()

acceptsConf

public static boolean acceptsConf(AnyValue config)

toString

public String toString()

覆盖:

toString 在类中 Object

init

public void init(AnyValue conf)

从接口复制的说明: Service

该方法必须是可以重复调用， 当reload时需要重复调用init方法 远程模式下该方法会重载成空方法

参数:

conf - 配置参数

close

public void close()
           throws Exception

抛出:

Exception

resourceName

public String resourceName()

destroy

public void destroy(AnyValue conf)

从接口复制的说明: Service

进程退出时，调用Service销毁 远程模式下该方法会重载成空方法 注意： 在此方法内不能调用MessageClient.sendMessage 方法，因为Application关闭时会先destroy掉MessageClient

参数:

conf - 配置参数

supplyFuture

protected <U> CompletableFuture<U> supplyFuture(Supplier<U> supplier)

runFuture

protected CompletableFuture<Void> runFuture(Runnable runner)

supplyAsync

protected <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier)

supplyAsync

protected <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier,
                                               Executor executor)

runAsync

protected CompletableFuture<Void> runAsync(Runnable runner,
                                           Executor executor)

isOpenAsync

public CompletableFuture<Boolean> isOpenAsync()

pubsubChannelsAsync

public CompletableFuture<List<String>> pubsubChannelsAsync(@Nullable
                                                           String pattern)

subscribeAsync

public CompletableFuture<Void> subscribeAsync(CacheEventListener<byte[]> listener,
                                              String... topics)

unsubscribeAsync

public CompletableFuture<Integer> unsubscribeAsync(CacheEventListener listener,
                                                   String... topics)

publishAsync

public CompletableFuture<Integer> publishAsync(String topic,
                                               byte[] message)

mset

public void mset(Serializable... keyVals)

mset

public void mset(Map map)

msetAsync

public CompletableFuture<Void> msetAsync(Serializable... keyVals)

msetnxAsync

public CompletableFuture<Boolean> msetnxAsync(Serializable... keyVals)

msetAsync

public CompletableFuture<Void> msetAsync(Map map)

msetnxAsync

public CompletableFuture<Boolean> msetnxAsync(Map map)

set

public <T> void set(String key,
                    Convert convert,
                    Type type,
                    T value)

setAsync

public <T> CompletableFuture<Void> setAsync(String key,
                                            Convert convert,
                                            Type type,
                                            T value)

setnx

public <T> boolean setnx(String key,
                         Convert convert,
                         Type type,
                         T value)

setnxAsync

public <T> CompletableFuture<Boolean> setnxAsync(String key,
                                                 Convert convert,
                                                 Type type,
                                                 T value)

setnxex

public <T> boolean setnxex(String key,
                           int expireSeconds,
                           Convert convert,
                           Type type,
                           T value)

setnxpx

public <T> boolean setnxpx(String key,
                           long milliSeconds,
                           Convert convert,
                           Type type,
                           T value)

setnxexAsync

public <T> CompletableFuture<Boolean> setnxexAsync(String key,
                                                   int expireSeconds,
                                                   Convert convert,
                                                   Type type,
                                                   T value)

setnxpxAsync

public <T> CompletableFuture<Boolean> setnxpxAsync(String key,
                                                   long milliSeconds,
                                                   Convert convert,
                                                   Type type,
                                                   T value)

getSet

public <T> T getSet(String key,
                    Convert convert,
                    Type type,
                    T value)

getSetAsync

public <T> CompletableFuture<T> getSetAsync(String key,
                                            Convert convert,
                                            Type type,
                                            T value)

getDel

public <T> T getDel(String key,
                    Type type)

getDelAsync

public <T> CompletableFuture<T> getDelAsync(String key,
                                            Type type)

msetnx

public boolean msetnx(Serializable... keyVals)

msetnx

public boolean msetnx(Map map)

setex

public <T> void setex(String key,
                      int expireSeconds,
                      Convert convert,
                      Type type,
                      T value)

setexAsync

public <T> CompletableFuture<Void> setexAsync(String key,
                                              int expireSeconds,
                                              Convert convert,
                                              Type type,
                                              T value)

psetex

public <T> void psetex(String key,
                       long milliSeconds,
                       Convert convert,
                       Type type,
                       T value)

psetexAsync

public <T> CompletableFuture<Void> psetexAsync(String key,
                                               long milliSeconds,
                                               Convert convert,
                                               Type type,
                                               T value)

expire

public void expire(String key,
                   int expireSeconds)

pexpire

public void pexpire(String key,
                    long milliSeconds)

expireAsync

public CompletableFuture<Void> expireAsync(String key,
                                           int expireSeconds)

pexpireAsync

public CompletableFuture<Void> pexpireAsync(String key,
                                            long milliSeconds)

ttl

public long ttl(String key)

pttl

public long pttl(String key)

ttlAsync

public CompletableFuture<Long> ttlAsync(String key)

pttlAsync

public CompletableFuture<Long> pttlAsync(String key)

expireAt

public void expireAt(String key,
                     long secondsTime)

pexpireAt

public void pexpireAt(String key,
                      long milliTime)

pexpireAtAsync

public CompletableFuture<Void> pexpireAtAsync(String key,
                                              long milliTime)

expireAtAsync

public CompletableFuture<Void> expireAtAsync(String key,
                                             long secondsTime)

expireTime

public long expireTime(String key)

pexpireTime

public long pexpireTime(String key)

expireTimeAsync

public CompletableFuture<Long> expireTimeAsync(String key)

pexpireTimeAsync

public CompletableFuture<Long> pexpireTimeAsync(String key)

persist

public boolean persist(String key)

persistAsync

public CompletableFuture<Boolean> persistAsync(String key)

rename

public boolean rename(String oldKey,
                      String newKey)

renameAsync

public CompletableFuture<Boolean> renameAsync(String oldKey,
                                              String newKey)

renamenx

public boolean renamenx(String oldKey,
                        String newKey)

renamenxAsync

public CompletableFuture<Boolean> renamenxAsync(String oldKey,
                                                String newKey)

del

public long del(String... keys)

delAsync

public CompletableFuture<Long> delAsync(String... keys)

delex

public long delex(String key,
                  String expectedValue)

delexAsync

public CompletableFuture<Long> delexAsync(String key,
                                          String expectedValue)

rateLimit

public long rateLimit(String key,
                      long rate,
                      long capacity,
                      long requested)

令牌桶算法限流， 返回负数表示无令牌， 其他为有令牌

 每秒限制请求1次:     rate:1,     capacity:1,     requested:1
 每秒限制请求10次:    rate:10,    capacity:10,    requested:1
 每分钟限制请求1次:   rate:1,     capacity:60,    requested:60
 每分钟限制请求10次:  rate:1,     capacity:60,    requested:6
 每小时限制请求1次:   rate:1,     capacity:3600,  requested:3600
 每小时限制请求10次:  rate:1,     capacity:3600,  requested:360
 

参数:

key - 限流的键

rate - 令牌桶每秒填充平均速率

capacity - 令牌桶总容量

requested - 需要的令牌数

返回:

可用令牌数

rateLimitAsync

public CompletableFuture<Long> rateLimitAsync(String key,
                                              long rate,
                                              long capacity,
                                              long requested)

从接口复制的说明: CacheSource

令牌桶算法限流， 返回负数表示无令牌， 其他为有令牌

 每秒限制请求1次:     rate:1,     capacity:1,     requested:1
 每秒限制请求10次:    rate:10,    capacity:10,    requested:1
 每分钟限制请求1次:   rate:1,     capacity:60,    requested:60
 每分钟限制请求10次:  rate:1,     capacity:60,    requested:6
 每小时限制请求1次:   rate:1,     capacity:3600,  requested:3600
 每小时限制请求10次:  rate:1,     capacity:3600,  requested:360
 

参数:

key - 限流的键

rate - 令牌桶每秒填充平均速率

capacity - 令牌桶总容量

requested - 需要的令牌数

返回:

可用令牌数

incr

public long incr(String key)

incrAsync

public CompletableFuture<Long> incrAsync(String key)

incrby

public long incrby(String key,
                   long num)

incrbyAsync

public CompletableFuture<Long> incrbyAsync(String key,
                                           long num)

incrbyFloat

public double incrbyFloat(String key,
                          double num)

incrbyFloatAsync

public CompletableFuture<Double> incrbyFloatAsync(String key,
                                                  double num)

decr

public long decr(String key)

decrAsync

public CompletableFuture<Long> decrAsync(String key)

decrby

public long decrby(String key,
                   long num)

decrbyAsync

public CompletableFuture<Long> decrbyAsync(String key,
                                           long num)

mget

public <T> List<T> mget(Type componentType,
                        String... keys)

mgetAsync

public <T> CompletableFuture<List<T>> mgetAsync(Type componentType,
                                                String... keys)

exists

public boolean exists(String key)

existsAsync

public CompletableFuture<Boolean> existsAsync(String key)

get

public <T> T get(String key,
                 Type type)

getAsync

public <T> CompletableFuture<T> getAsync(String key,
                                         Type type)

getex

public <T> T getex(String key,
                   int expireSeconds,
                   Type type)

getexAsync

public <T> CompletableFuture<T> getexAsync(String key,
                                           int expireSeconds,
                                           Type type)

从接口复制的说明: CacheSource

获取key的值并可选择设置其过期时间

类型参数:

T - 泛型

参数:

key - 键

expireSeconds - 过期秒数

type - key值的类型

返回:

key的值

hdel

public long hdel(String key,
                 String... fields)

hdelAsync

public CompletableFuture<Long> hdelAsync(String key,
                                         String... fields)

hkeys

public List<String> hkeys(String key)

hkeysAsync

public CompletableFuture<List<String>> hkeysAsync(String key)

hlen

public long hlen(String key)

hlenAsync

public CompletableFuture<Long> hlenAsync(String key)

hincr

public long hincr(String key,
                  String field)

hincrAsync

public CompletableFuture<Long> hincrAsync(String key,
                                          String field)

hincrby

public long hincrby(String key,
                    String field,
                    long num)

hincrbyAsync

public CompletableFuture<Long> hincrbyAsync(String key,
                                            String field,
                                            long num)

hincrbyFloat

public double hincrbyFloat(String key,
                           String field,
                           double num)

hincrbyFloatAsync

public CompletableFuture<Double> hincrbyFloatAsync(String key,
                                                   String field,
                                                   double num)

hdecr

public long hdecr(String key,
                  String field)

hdecrAsync

public CompletableFuture<Long> hdecrAsync(String key,
                                          String field)

hdecrby

public long hdecrby(String key,
                    String field,
                    long num)

hdecrbyAsync

public CompletableFuture<Long> hdecrbyAsync(String key,
                                            String field,
                                            long num)

hexists

public boolean hexists(String key,
                       String field)

hexistsAsync

public CompletableFuture<Boolean> hexistsAsync(String key,
                                               String field)

hset

public <T> void hset(String key,
                     String field,
                     Convert convert,
                     Type type,
                     T value)

hsetAsync

public <T> CompletableFuture<Void> hsetAsync(String key,
                                             String field,
                                             Convert convert,
                                             Type type,
                                             T value)

hsetnx

public <T> boolean hsetnx(String key,
                          String field,
                          Convert convert,
                          Type type,
                          T value)

hsetnxAsync

public <T> CompletableFuture<Boolean> hsetnxAsync(String key,
                                                  String field,
                                                  Convert convert,
                                                  Type type,
                                                  T value)

hmset

public void hmset(String key,
                  Serializable... values)

hmsetAsync

public CompletableFuture<Void> hmsetAsync(String key,
                                          Serializable... values)

hmset

public void hmset(String key,
                  Map map)

hmsetAsync

public CompletableFuture<Void> hmsetAsync(String key,
                                          Map map)

hmget

public <T> List<T> hmget(String key,
                         Type type,
                         String... fields)

hmgetAsync

public <T> CompletableFuture<List<T>> hmgetAsync(String key,
                                                 Type type,
                                                 String... fields)

hgetall

public <T> Map<String,T> hgetall(String key,
                                       Type type)

hgetallAsync

public <T> CompletableFuture<Map<String,T>> hgetallAsync(String key,
                                                               Type type)

hvals

public <T> List<T> hvals(String key,
                         Type type)

hvalsAsync

public <T> CompletableFuture<List<T>> hvalsAsync(String key,
                                                 Type type)

hscan

public <T> Map<String,T> hscan(String key,
                                     Type type,
                                     AtomicLong cursor,
                                     int limit,
                                     String pattern)

hscanAsync

public <T> CompletableFuture<Map<String,T>> hscanAsync(String key,
                                                             Type type,
                                                             AtomicLong cursor,
                                                             int limit,
                                                             String pattern)

hget

public <T> T hget(String key,
                  String field,
                  Type type)

hgetAsync

public <T> CompletableFuture<T> hgetAsync(String key,
                                          String field,
                                          Type type)

hstrlen

public long hstrlen(String key,
                    String field)

hstrlenAsync

public CompletableFuture<Long> hstrlenAsync(String key,
                                            String field)

lrange

public <T> List<T> lrange(String key,
                          Type componentType,
                          int start,
                          int stop)

lrangeAsync

public <T> CompletableFuture<List<T>> lrangeAsync(String key,
                                                  Type componentType,
                                                  int start,
                                                  int stop)

lranges

public <T> Map<String,List<T>> lranges(Type componentType,
                                             String... keys)

lrangesAsync

public <T> CompletableFuture<Map<String,List<T>>> lrangesAsync(Type componentType,
                                                                     String... keys)

llen

public long llen(String key)

llenAsync

public CompletableFuture<Long> llenAsync(String key)

lindex

public <T> T lindex(String key,
                    Type componentType,
                    int index)

lindexAsync

public <T> CompletableFuture<T> lindexAsync(String key,
                                            Type componentType,
                                            int index)

linsertBefore

public <T> long linsertBefore(String key,
                              Type componentType,
                              T pivot,
                              T value)

linsertBeforeAsync

public <T> CompletableFuture<Long> linsertBeforeAsync(String key,
                                                      Type componentType,
                                                      T pivot,
                                                      T value)

linsertAfter

public <T> long linsertAfter(String key,
                             Type componentType,
                             T pivot,
                             T value)

linsertAfterAsync

public <T> CompletableFuture<Long> linsertAfterAsync(String key,
                                                     Type componentType,
                                                     T pivot,
                                                     T value)

linsert

protected <T> long linsert(String key,
                           Type componentType,
                           boolean before,
                           T pivot,
                           T value)

lpush

public <T> void lpush(String key,
                      Type componentType,
                      T... values)

lpushAsync

public <T> CompletableFuture<Void> lpushAsync(String key,
                                              Type componentType,
                                              T... values)

lpushx

public <T> void lpushx(String key,
                       Type componentType,
                       T... values)

lpushxAsync

public <T> CompletableFuture<Void> lpushxAsync(String key,
                                               Type componentType,
                                               T... values)

lpop

public <T> T lpop(String key,
                  Type componentType)

lpopAsync

public <T> CompletableFuture<T> lpopAsync(String key,
                                          Type componentType)

ltrim

public void ltrim(String key,
                  int start,
                  int stop)

ltrimAsync

public CompletableFuture<Void> ltrimAsync(String key,
                                          int start,
                                          int stop)

rpoplpush

public <T> T rpoplpush(String key,
                       String key2,
                       Type componentType)

rpoplpushAsync

public <T> CompletableFuture<T> rpoplpushAsync(String key,
                                               String key2,
                                               Type componentType)

rpop

public <T> T rpop(String key,
                  Type componentType)

rpopAsync

public <T> CompletableFuture<T> rpopAsync(String key,
                                          Type componentType)

rpushx

public <T> void rpushx(String key,
                       Type componentType,
                       T... values)

rpushxAsync

public <T> CompletableFuture<Void> rpushxAsync(String key,
                                               Type componentType,
                                               T... values)

rpush

public <T> void rpush(String key,
                      Type componentType,
                      T... values)

rpushAsync

public <T> CompletableFuture<Void> rpushAsync(String key,
                                              Type componentType,
                                              T... values)

lrem

public <T> long lrem(String key,
                     Type componentType,
                     T value)

lremAsync

public <T> CompletableFuture<Long> lremAsync(String key,
                                             Type componentType,
                                             T value)

srandmember

public <T> List<T> srandmember(String key,
                               Type componentType,
                               int count)

srandmemberAsync

public <T> CompletableFuture<List<T>> srandmemberAsync(String key,
                                                       Type componentType,
                                                       int count)

smove

public <T> boolean smove(String key,
                         String key2,
                         Type componentType,
                         T member)

smoveAsync

public <T> CompletableFuture<Boolean> smoveAsync(String key,
                                                 String key2,
                                                 Type componentType,
                                                 T member)

sdiff

public <T> Set<T> sdiff(String key,
                        Type componentType,
                        String... key2s)

sdiffAsync

public <T> CompletableFuture<Set<T>> sdiffAsync(String key,
                                                Type componentType,
                                                String... key2s)

sdiffstore

public long sdiffstore(String key,
                       String srcKey,
                       String... srcKey2s)

sdiffstoreAsync

public CompletableFuture<Long> sdiffstoreAsync(String key,
                                               String srcKey,
                                               String... srcKey2s)

sinter

public <T> Set<T> sinter(String key,
                         Type componentType,
                         String... key2s)

sinterAsync

public <T> CompletableFuture<Set<T>> sinterAsync(String key,
                                                 Type componentType,
                                                 String... key2s)

sinterstore

public long sinterstore(String key,
                        String srcKey,
                        String... srcKey2s)

sinterstoreAsync

public CompletableFuture<Long> sinterstoreAsync(String key,
                                                String srcKey,
                                                String... srcKey2s)

sunion

public <T> Set<T> sunion(String key,
                         Type componentType,
                         String... key2s)

sunionAsync

public <T> CompletableFuture<Set<T>> sunionAsync(String key,
                                                 Type componentType,
                                                 String... key2s)

sunionstore

public long sunionstore(String key,
                        String srcKey,
                        String... srcKey2s)

sunionstoreAsync

public CompletableFuture<Long> sunionstoreAsync(String key,
                                                String srcKey,
                                                String... srcKey2s)

smembers

public <T> Set<T> smembers(String key,
                           Type componentType)

smembersAsync

public <T> CompletableFuture<Set<T>> smembersAsync(String key,
                                                   Type componentType)

smembers

public <T> Map<String,Set<T>> smembers(Type componentType,
                                             String... keys)

smembersAsync

public <T> CompletableFuture<Map<String,Set<T>>> smembersAsync(Type componentType,
                                                                     String... keys)

smismembers

public List<Boolean> smismembers(String key,
                                 String... members)

smismembersAsync

public CompletableFuture<List<Boolean>> smismembersAsync(String key,
                                                         String... members)

sadd

public <T> void sadd(String key,
                     Type componentType,
                     T... values)

saddAsync

public <T> CompletableFuture<Void> saddAsync(String key,
                                             Type componentType,
                                             T... values)

scard

public long scard(String key)

scardAsync

public CompletableFuture<Long> scardAsync(String key)

sismember

public <T> boolean sismember(String key,
                             Type type,
                             T value)

sismemberAsync

public <T> CompletableFuture<Boolean> sismemberAsync(String key,
                                                     Type type,
                                                     T value)

spop

public <T> T spop(String key,
                  Type componentType)

spopAsync

public <T> CompletableFuture<T> spopAsync(String key,
                                          Type componentType)

spop

public <T> Set<T> spop(String key,
                       int count,
                       Type componentType)

spopAsync

public <T> CompletableFuture<Set<T>> spopAsync(String key,
                                               int count,
                                               Type componentType)

sscan

public <T> Set<T> sscan(String key,
                        Type componentType,
                        AtomicLong cursor,
                        int limit,
                        String pattern)

sscanAsync

public <T> CompletableFuture<Set<T>> sscanAsync(String key,
                                                Type componentType,
                                                AtomicLong cursor,
                                                int limit,
                                                String pattern)

srem

public <T> long srem(String key,
                     Type type,
                     T... values)

sremAsync

public <T> CompletableFuture<Long> sremAsync(String key,
                                             Type type,
                                             T... values)

zadd

public void zadd(String key,
                 CacheScoredValue... values)

zaddAsync

public CompletableFuture<Void> zaddAsync(String key,
                                         CacheScoredValue... values)

zincrby

public <T extends Number> T zincrby(String key,
                                    CacheScoredValue value)

zincrbyAsync

public <T extends Number> CompletableFuture<T> zincrbyAsync(String key,
                                                            CacheScoredValue value)

zcard

public long zcard(String key)

zcardAsync

public CompletableFuture<Long> zcardAsync(String key)

zrank

public Long zrank(String key,
                  String member)

zrankAsync

public CompletableFuture<Long> zrankAsync(String key,
                                          String member)

zrevrank

public Long zrevrank(String key,
                     String member)

zrevrankAsync

public CompletableFuture<Long> zrevrankAsync(String key,
                                             String member)

zrange

public List<String> zrange(String key,
                           int start,
                           int stop)

zrangeAsync

public CompletableFuture<List<String>> zrangeAsync(String key,
                                                   int start,
                                                   int stop)

zscan

public List<CacheScoredValue> zscan(String key,
                                    Type scoreType,
                                    AtomicLong cursor,
                                    int limit,
                                    String pattern)

zscanAsync

public CompletableFuture<List<CacheScoredValue>> zscanAsync(String key,
                                                            Type scoreType,
                                                            AtomicLong cursor,
                                                            int limit,
                                                            String pattern)

zrem

public long zrem(String key,
                 String... members)

zremAsync

public CompletableFuture<Long> zremAsync(String key,
                                         String... members)

zmscore

public <T extends Number> List<T> zmscore(String key,
                                          Class<T> scoreType,
                                          String... members)

zmscoreAsync

public <T extends Number> CompletableFuture<List<T>> zmscoreAsync(String key,
                                                                  Class<T> scoreType,
                                                                  String... members)

zscore

public <T extends Number> T zscore(String key,
                                   Class<T> scoreType,
                                   String member)

zscoreAsync

public <T extends Number> CompletableFuture<T> zscoreAsync(String key,
                                                           Class<T> scoreType,
                                                           String member)

dbsize

public long dbsize()

dbsizeAsync

public CompletableFuture<Long> dbsizeAsync()

flushdb

public void flushdb()

flushdbAsync

public CompletableFuture<Void> flushdbAsync()

flushall

public void flushall()

flushallAsync

public CompletableFuture<Void> flushallAsync()

keys

public List<String> keys(String pattern)

keysAsync

public CompletableFuture<List<String>> keysAsync(String pattern)

scan

public List<String> scan(AtomicLong cursor,
                         int limit,
                         String pattern)

scanAsync

public CompletableFuture<List<String>> scanAsync(AtomicLong cursor,
                                                 int limit,
                                                 String pattern)

keysStartsWith

public List<String> keysStartsWith(String startsWith)

keysStartsWithAsync

public CompletableFuture<List<String>> keysStartsWithAsync(String startsWith)

find

protected CacheMemorySource.CacheEntry find(String key)

find

protected CacheMemorySource.CacheEntry find(String key,
                                            CacheMemorySource.CacheEntryType cacheType)

getexLongCollection

@Deprecated(since="2.8.0")
public Collection<Long> getexLongCollection(String key,
                                            int expireSeconds)

已过时。

getexCollectionAsync

@Deprecated(since="2.8.0")
public <T> CompletableFuture<Collection<T>> getexCollectionAsync(String key,
                                                                 int expireSeconds,
                                                                 Type componentType)

已过时。

getexStringCollectionAsync

@Deprecated(since="2.8.0")
public CompletableFuture<Collection<String>> getexStringCollectionAsync(String key,
                                                                        int expireSeconds)

已过时。

getexLongCollectionAsync

@Deprecated(since="2.8.0")
public CompletableFuture<Collection<Long>> getexLongCollectionAsync(String key,
                                                                    int expireSeconds)

已过时。

getCollectionMapAsync

@Deprecated(since="2.8.0")
public <T> CompletableFuture<Map<String,Collection<T>>> getCollectionMapAsync(boolean set,
                                                                                    Type componentType,
                                                                                    String... keys)

已过时。

getStringCollectionAsync

@Deprecated(since="2.8.0")
public CompletableFuture<Collection<String>> getStringCollectionAsync(String key)

已过时。

getStringCollectionMapAsync

@Deprecated(since="2.8.0")
public CompletableFuture<Map<String,Collection<String>>> getStringCollectionMapAsync(boolean set,
                                                                                           String... keys)

已过时。

getLongCollectionAsync

@Deprecated(since="2.8.0")
public CompletableFuture<Collection<Long>> getLongCollectionAsync(String key)

已过时。

getLongCollectionMapAsync

@Deprecated(since="2.8.0")
public CompletableFuture<Map<String,Collection<Long>>> getLongCollectionMapAsync(boolean set,
                                                                                       String... keys)

已过时。

getCollectionAsync

@Deprecated(since="2.8.0")
public <T> CompletableFuture<Collection<T>> getCollectionAsync(String key,
                                                               Type componentType)

已过时。

getCollection

@Deprecated(since="2.8.0")
public <T> Collection<T> getCollection(String key,
                                       Type componentType)

已过时。

getCollectionMap

@Deprecated(since="2.8.0")
public <T> Map<String,Collection<T>> getCollectionMap(boolean set,
                                                            Type componentType,
                                                            String... keys)

已过时。

getStringCollection

@Deprecated(since="2.8.0")
public Collection<String> getStringCollection(String key)

已过时。

getStringCollectionMap

@Deprecated(since="2.8.0")
public Map<String,Collection<String>> getStringCollectionMap(boolean set,
                                                                   String... keys)

已过时。

getLongMap

@Deprecated(since="2.8.0")
public Map<String,Long> getLongMap(String... keys)

已过时。

getLongArray

@Deprecated(since="2.8.0")
public Long[] getLongArray(String... keys)

已过时。

getLongMapAsync

@Deprecated(since="2.8.0")
public CompletableFuture<Map<String,Long>> getLongMapAsync(String... keys)

已过时。

getLongArrayAsync

@Deprecated(since="2.8.0")
public CompletableFuture<Long[]> getLongArrayAsync(String... keys)

已过时。

getStringMap

@Deprecated(since="2.8.0")
public Map<String,String> getStringMap(String... keys)

已过时。

getStringArray

@Deprecated(since="2.8.0")
public String[] getStringArray(String... keys)

已过时。

getStringMapAsync

@Deprecated(since="2.8.0")
public CompletableFuture<Map<String,String>> getStringMapAsync(String... keys)

已过时。

getStringArrayAsync

@Deprecated(since="2.8.0")
public CompletableFuture<String[]> getStringArrayAsync(String... keys)

已过时。

getMap

@Deprecated(since="2.8.0")
public <T> Map<String,T> getMap(Type componentType,
                                      String... keys)

已过时。

getMapAsync

@Deprecated(since="2.8.0")
public <T> CompletableFuture<Map<String,T>> getMapAsync(Type componentType,
                                                              String... keys)

已过时。

getLongCollection

@Deprecated(since="2.8.0")
public Collection<Long> getLongCollection(String key)

已过时。

getLongCollectionMap

@Deprecated(since="2.8.0")
public Map<String,Collection<Long>> getLongCollectionMap(boolean set,
                                                               String... keys)

已过时。

getCollectionSize

@Deprecated(since="2.8.0")
public int getCollectionSize(String key)

已过时。

getCollectionSizeAsync

@Deprecated(since="2.8.0")
public CompletableFuture<Integer> getCollectionSizeAsync(String key)

已过时。

getexCollection

@Deprecated(since="2.8.0")
public <T> Collection<T> getexCollection(String key,
                                         int expireSeconds,
                                         Type componentType)

已过时。

getexStringCollection

@Deprecated(since="2.8.0")
public Collection<String> getexStringCollection(String key,
                                                int expireSeconds)

已过时。