模块 org.redkale

程序包 org.redkale.source

类 AbstractCacheSource

java.lang.Object

org.redkale.service.AbstractService

org.redkale.source.AbstractCacheSource

所有已实现的接口:

AutoCloseable, Resourcable, Service, CacheSource

直接已知子类:

CacheMemorySource

@Local
@AutoLoad(false)
@ResourceType(CacheSource.class)
public abstract class AbstractCacheSource
extends AbstractService
implements CacheSource, AutoCloseable, Resourcable

CacheSource的S抽象实现类
详情见: https://redkale.org

从以下版本开始:

2.7.0

作者:

zhangjx

字段概要

字段

修饰符和类型	字段	说明
static String	CACHE_SOURCE_DB
static String	CACHE_SOURCE_ENCODING
static String	CACHE_SOURCE_MAXCONNS
static String	CACHE_SOURCE_NODES
static String	CACHE_SOURCE_NON_BLOCKING
static String	CACHE_SOURCE_PASSWORD
static String	CACHE_SOURCE_PIPELINES
static String	CACHE_SOURCE_RESOURCE
static String	CACHE_SOURCE_TYPE
static String	CACHE_SOURCE_USER

构造器概要

构造器

构造器	说明
AbstractCacheSource()

方法概要

修饰符和类型	方法	说明
static CacheSource	createCacheSource(ClassLoader serverClassLoader, ResourceFactory resourceFactory, AnyValue sourceConf, String sourceName, boolean compileMode)
static CacheSource	createCacheSource(Properties sourceProperties, String sourceName)
abstract void	onResourceChange(ResourceEvent[] events)

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

getExecutor, runAsync, serviceName, serviceType

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

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

从接口继承的方法 java.lang.AutoCloseable

close

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

appendListItem, appendListItemAsync, appendLongListItem, appendLongListItemAsync, appendLongSetItem, appendLongSetItemAsync, appendSetItem, appendSetItemAsync, appendStringListItem, appendStringListItemAsync, appendStringSetItem, appendStringSetItemAsync, dbsize, dbsizeAsync, decr, decr, decrAsync, decrby, decrbyAsync, del, delAsync, delex, delexAsync, exists, existsAsync, existsLongSetItem, existsLongSetItemAsync, existsSetItem, existsSetItemAsync, existsStringSetItem, existsStringSetItemAsync, expire, expireAsync, expireAt, expireAtAsync, expireTime, expireTimeAsync, flushall, flushallAsync, flushdb, flushdbAsync, get, getAndRefresh, getAndRefreshAsync, getAsync, getCollection, getCollectionAsync, getCollectionMap, getCollectionMapAsync, getCollectionSize, getCollectionSizeAsync, getDel, getDelAsync, getDelLong, getDelLong, getDelLongAsync, getDelLongAsync, getDelString, getDelStringAsync, getex, getexAsync, getexCollection, getexCollectionAsync, getexLong, getexLong, getexLongAsync, getexLongAsync, getexLongCollection, getexLongCollectionAsync, getexString, getexStringAsync, getexStringCollection, getexStringCollectionAsync, getKeySize, getKeySizeAsync, getLong, getLong, getLongAndRefresh, getLongAndRefreshAsync, getLongArray, getLongArrayAsync, getLongAsync, getLongAsync, getLongCollection, getLongCollectionAsync, getLongCollectionMap, getLongCollectionMapAsync, getLongMap, getLongMapAsync, getMap, getMapAsync, getSet, getSet, getSetAsync, getSetAsync, getSetLong, getSetLong, getSetLongAsync, getSetLongAsync, getSetString, getSetStringAsync, getString, getStringAndRefresh, getStringAndRefreshAsync, getStringArray, getStringArrayAsync, getStringAsync, getStringCollection, getStringCollectionAsync, getStringCollectionMap, getStringCollectionMapAsync, getStringMap, getStringMapAsync, getType, hdecr, hdecrAsync, hdecrby, hdecrbyAsync, hdel, hdelAsync, hexists, hexistsAsync, hget, hgetall, hgetallAsync, hgetallLong, hgetallLongAsync, hgetallString, hgetallStringAsync, hgetAsync, hgetLong, hgetLong, hgetLongAsync, hgetLongAsync, hgetString, hgetStringAsync, hincr, hincrAsync, hincrby, hincrbyAsync, hincrbyFloat, hincrbyFloatAsync, hkeys, hkeysAsync, hlen, hlenAsync, hmap, hmap, hmapAsync, hmapAsync, hmget, hmgetAsync, hmgetLong, hmgetLongAsync, hmgetString, hmgetStringAsync, hmset, hmset, hmsetAsync, hmsetAsync, hremove, hremoveAsync, hscan, hscan, hscanAsync, hscanAsync, hset, hset, hsetAsync, hsetAsync, hsetLong, hsetLongAsync, hsetnx, hsetnx, hsetnxAsync, hsetnxAsync, hsetnxLong, hsetnxLongAsync, hsetnxString, hsetnxStringAsync, hsetString, hsetStringAsync, hsize, hsizeAsync, hstrlen, hstrlenAsync, hvals, hvalsAsync, hvalsLong, hvalsLongAsync, hvalsString, hvalsStringAsync, incr, incr, incrAsync, incrby, incrbyAsync, incrbyFloat, incrbyFloatAsync, isOpen, isOpenAsync, keys, keys, keysAsync, keysAsync, keysStartsWith, keysStartsWithAsync, lindex, lindexAsync, lindexLong, lindexLongAsync, lindexString, lindexStringAsync, linsertAfter, linsertAfterAsync, linsertAfterLong, linsertAfterLongAsync, linsertAfterString, linsertAfterStringAsync, linsertBefore, linsertBeforeAsync, linsertBeforeLong, linsertBeforeLongAsync, linsertBeforeString, linsertBeforeStringAsync, llen, llenAsync, lock, lockAsync, lpop, lpopAsync, lpopLong, lpopLongAsync, lpopString, lpopStringAsync, lpush, lpushAsync, lpushLong, lpushLongAsync, lpushString, lpushStringAsync, lpushx, lpushxAsync, lpushxLong, lpushxLongAsync, lpushxString, lpushxStringAsync, lrange, lrange, lrangeAsync, lrangeAsync, lrangeLong, lrangeLong, lrangeLongAsync, lrangeLongAsync, lranges, lrangesAsync, lrangesLong, lrangesLongAsync, lrangesString, lrangesStringAsync, lrangeString, lrangeString, lrangeStringAsync, lrangeStringAsync, lrem, lremAsync, lremLong, lremLongAsync, lremString, lremStringAsync, ltrim, ltrimAsync, mget, mgetAsync, mgetLong, mgetLongAsync, mgets, mgetsAsync, mgetsLong, mgetsLongAsync, mgetsString, mgetsStringAsync, mgetString, mgetStringAsync, mset, mset, msetAsync, msetAsync, msetnx, msetnx, msetnxAsync, msetnxAsync, persist, persistAsync, pexpire, pexpireAsync, pexpireAt, pexpireAtAsync, pexpireTime, pexpireTimeAsync, psetex, psetex, psetexAsync, psetexAsync, psetexLong, psetexLongAsync, psetexString, psetexStringAsync, pttl, pttlAsync, publish, publish, publish, publish, publish, publishAsync, publishAsync, publishAsync, publishAsync, publishAsync, pubsubChannels, pubsubChannelsAsync, queryKeys, queryKeysAsync, queryKeysEndsWith, queryKeysEndsWithAsync, queryKeysStartsWith, queryKeysStartsWithAsync, rateLimit, rateLimit, rateLimitAsync, rateLimitAsync, refresh, refreshAsync, remove, removeAsync, removeListItem, removeListItemAsync, removeLongListItem, removeLongListItemAsync, removeLongSetItem, removeLongSetItemAsync, removeSetItem, removeSetItemAsync, removeStringListItem, removeStringListItemAsync, removeStringSetItem, removeStringSetItemAsync, rename, renameAsync, renamenx, renamenxAsync, rpop, rpopAsync, rpopLong, rpopLongAsync, rpoplpush, rpoplpushAsync, rpoplpushLong, rpoplpushLongAsync, rpoplpushString, rpoplpushStringAsync, rpopString, rpopStringAsync, rpush, rpushAsync, rpushLong, rpushLongAsync, rpushString, rpushStringAsync, rpushx, rpushxAsync, rpushxLong, rpushxLongAsync, rpushxString, rpushxStringAsync, sadd, saddAsync, saddLong, saddLongAsync, saddString, saddStringAsync, scan, scan, scanAsync, scanAsync, scard, scardAsync, sdiff, sdiffAsync, sdiffLong, sdiffLongAsync, sdiffstore, sdiffstoreAsync, sdiffString, sdiffStringAsync, set, set, set, set, set, setAsync, setAsync, setAsync, setAsync, setAsync, setex, setex, setexAsync, setexAsync, setexLong, setexLongAsync, setExpireSeconds, setExpireSecondsAsync, setexString, setexStringAsync, setLong, setLong, setLongAsync, setnx, setnx, setnxAsync, setnxAsync, setnxex, setnxex, setnxexAsync, setnxexAsync, setnxexLong, setnxexLongAsync, setnxexString, setnxexStringAsync, setnxLong, setnxLongAsync, setnxpx, setnxpx, setnxpxAsync, setnxpxAsync, setnxpxLong, setnxpxLongAsync, setnxpxString, setnxpxStringAsync, setnxString, setnxStringAsync, setString, setString, setStringAsync, sinter, sinterAsync, sinterLong, sinterLongAsync, sinterstore, sinterstoreAsync, sinterString, sinterStringAsync, sismember, sismemberAsync, sismemberLong, sismemberLongAsync, sismemberString, sismemberStringAsync, smembers, smembers, smembersAsync, smembersAsync, smembersLong, smembersLong, smembersLongAsync, smembersLongAsync, smembersString, smembersString, smembersStringAsync, smembersStringAsync, smismember, smismembers, smismembersAsync, smove, smoveAsync, smoveLong, smoveLongAsync, smoveString, smoveStringAsync, spop, spop, spopAsync, spopAsync, spopLong, spopLong, spopLongAsync, spopLongAsync, spopLongSetItem, spopLongSetItem, spopLongSetItemAsync, spopLongSetItemAsync, spopSetItem, spopSetItem, spopSetItemAsync, spopSetItemAsync, spopString, spopString, spopStringAsync, spopStringAsync, spopStringSetItem, spopStringSetItem, spopStringSetItemAsync, spopStringSetItemAsync, srandmember, srandmember, srandmemberAsync, srandmemberAsync, srandmemberLong, srandmemberLong, srandmemberLongAsync, srandmemberLongAsync, srandmemberString, srandmemberString, srandmemberStringAsync, srandmemberStringAsync, srem, sremAsync, sremLong, sremLongAsync, sremString, sremStringAsync, sscan, sscan, sscanAsync, sscanAsync, sscanLong, sscanLong, sscanLongAsync, sscanLongAsync, sscanString, sscanString, sscanStringAsync, sscanStringAsync, subscribe, subscribe, subscribe, subscribeAsync, subscribeAsync, subscribeAsync, sunion, sunionAsync, sunionLong, sunionLongAsync, sunionstore, sunionstoreAsync, sunionString, sunionStringAsync, ttl, ttlAsync, unlock, unlockAsync, unsubscribe, unsubscribeAsync, zadd, zadd, zadd, zadd, zaddAsync, zaddAsync, zaddAsync, zaddAsync, zcard, zcardAsync, zincrby, zincrby, zincrby, zincrby, zincrbyAsync, zincrbyAsync, zincrbyAsync, zincrbyAsync, zmscore, zmscoreAsync, zmscoreDouble, zmscoreDoubleAsync, zmscoreInteger, zmscoreIntegerAsync, zmscoreLong, zmscoreLongAsync, zrange, zrangeAsync, zrank, zrankAsync, zrem, zremAsync, zrevrank, zrevrankAsync, zscan, zscan, zscanAsync, zscanAsync, zscanDouble, zscanDouble, zscanDoubleAsync, zscanDoubleAsync, zscanInteger, zscanInteger, zscanIntegerAsync, zscanIntegerAsync, zscanLong, zscanLong, zscanLongAsync, zscanLongAsync, zscore, zscoreAsync, zscoreDouble, zscoreDoubleAsync, zscoreInteger, zscoreIntegerAsync, zscoreLong, zscoreLongAsync

从接口继承的方法 org.redkale.inject.Resourcable

resourceName

从接口继承的方法 org.redkale.service.Service

destroy, init

字段详细资料

CACHE_SOURCE_RESOURCE

public static final String CACHE_SOURCE_RESOURCE

另请参阅:

常量字段值

CACHE_SOURCE_DB

public static final String CACHE_SOURCE_DB

另请参阅:

常量字段值

CACHE_SOURCE_USER

public static final String CACHE_SOURCE_USER

另请参阅:

常量字段值

CACHE_SOURCE_PASSWORD

public static final String CACHE_SOURCE_PASSWORD

另请参阅:

常量字段值

CACHE_SOURCE_ENCODING

public static final String CACHE_SOURCE_ENCODING

另请参阅:

常量字段值

CACHE_SOURCE_NODES

public static final String CACHE_SOURCE_NODES

另请参阅:

常量字段值

CACHE_SOURCE_TYPE

public static final String CACHE_SOURCE_TYPE

另请参阅:

常量字段值

CACHE_SOURCE_MAXCONNS

public static final String CACHE_SOURCE_MAXCONNS

另请参阅:

常量字段值

CACHE_SOURCE_PIPELINES

public static final String CACHE_SOURCE_PIPELINES

另请参阅:

常量字段值

CACHE_SOURCE_NON_BLOCKING

public static final String CACHE_SOURCE_NON_BLOCKING

另请参阅:

常量字段值

构造器详细资料

AbstractCacheSource

public AbstractCacheSource()

方法详细资料

onResourceChange

@ResourceChanged
public abstract void onResourceChange(ResourceEvent[] events)

createCacheSource

public static CacheSource createCacheSource(Properties sourceProperties,
                                            String sourceName)
                                     throws Exception

抛出:

Exception

createCacheSource

public static CacheSource createCacheSource(ClassLoader serverClassLoader,
                                            ResourceFactory resourceFactory,
                                            AnyValue sourceConf,
                                            String sourceName,
                                            boolean compileMode)
                                     throws Exception

抛出:

Exception