com.fr.collections.cluster.redis

类 RedisCacheMap<K,V>

java.lang.Object

com.fr.collections.cluster.redis.RedisObject

com.fr.collections.cluster.redis.RedisMap<K,V>

com.fr.collections.cluster.redis.RedisCacheMap<K,V>

所有已实现的接口:

FineCacheMap<K,V>, FineCacheObject, FineMap<K,V>, RedisCacheObject, RedisCommandsResultCovert, java.util.concurrent.ConcurrentMap<K,V>, java.util.Map<K,V>

public class RedisCacheMap<K,V>
extends RedisMap<K,V>
implements FineCacheMap<K,V>, RedisCacheObject

作者:

andrew_asa

嵌套类概要

从接口继承的嵌套类/接口 java.util.Map

java.util.Map.Entry<K,V>

字段概要

从类继承的字段 com.fr.collections.cluster.redis.RedisObject

codec, DEFAULT_ENCODE_CHARSET, name, nameBytes, RET_FAIL, RET_FAIL_OBJ, RET_SUCCESS, RET_SUCCESS_OBJ

从接口继承的字段 com.fr.collections.cluster.redis.RedisCacheObject

DEFAULT_CLEAN_EXPIRE_ITEM, DEFAULT_LATCH_EXPIRE_TIME

从接口继承的字段 com.fr.collections.cluster.redis.RedisCommandsResultCovert

BOOLEAN_CONVERTOR, EVAL_HSCAN_CONVERTOR, INT_CONVERTOR, LONG_CONVERTOR, MORE_THAN_ZERO, RPUSH_BOOLEAN

构造器概要

构造器

构造器和说明
RedisCacheMap(java.lang.String name, RedisCollectionsClient collectionsClient, RedisCollectionConfig config, FineJedisPool pool)

方法概要

方法

限定符和类型	方法和说明
boolean	containsKeyOperation(java.lang.Object key) ----------------------------内部实现------------------------
protected boolean	containsValueOperation(V value)
void	destroy() 销毁 因为有清过期key线程，所以需要支持 外层手动调用销毁方法
protected V	getOperation(K key)
protected com.fr.third.redis.clients.jedis.ScanResult<java.util.Map.Entry<byte[],byte[]>>	getScanResult(long nextIterPos, int count)
V	put(K key, V value, long ttl) 设置一个key-value 值，可以设置过期时间，单位毫秒
V	put(K key, V value, long ttl, long maxIdleTime) 设置key-value值单位为毫秒
V	put(K key, V value, long ttl, java.util.concurrent.TimeUnit unit) 设置一个key-value 值，可以设置过期时间
V	put(K key, V value, long ttl, java.util.concurrent.TimeUnit ttlUnit, long maxIdleTime, java.util.concurrent.TimeUnit maxIdleUnit) 设置一个key-value 值，可以设置过期时间，最大空闲时间
void	putAll(java.util.Map<? extends K,? extends V> map, long ttl)
void	putAll(java.util.Map<? extends K,? extends V> map, long ttl, java.util.concurrent.TimeUnit ttlUnit)
protected void	putAllOperation(java.util.Map<? extends K,? extends V> map)
V	putIfAbsent(K key, V value, long ttl) 当且仅当key不存在是进行保存，如果存在则返回原先的值
V	putIfAbsent(K key, V value, long ttl, long maxIdleTime) 缺失则设置key-value值单位为毫秒
V	putIfAbsent(K key, V value, long ttl, java.util.concurrent.TimeUnit ttlUnit) 当且仅当key不存在是进行保存，如果存在则返回原先的值
V	putIfAbsent(K key, V value, long ttl, java.util.concurrent.TimeUnit ttlUnit, long maxIdleTime, java.util.concurrent.TimeUnit maxIdleUnit) 缺失则设置一个key-value 值，可以设置过期时间，最大空闲时间
V	putIfAbsentOperation(K key, V value)
V	putIfAbsentOperation(K key, V value, long ttlTimeout, long maxIdleTimeout, long maxIdleDelta)
protected V	putOperation(K key, V value) ------------------------------- 内部实现 ------------------------------
protected V	putOperation(K key, V value, long ttlTimeout, long maxIdleTimeout, long maxIdleDelta)
long	remainTimeToLive(K key) 关联的key值还有多久才过期
long	remainTimeToLiveOperation(K key)
protected V	removeOperation(K key)
protected boolean	removeOperation(java.lang.Object key, java.lang.Object value)
protected V	replaceOperation(K key, V value)
int	size() 注意这边返回的大小可能包括已经失效的key值 如果清理进程没有来的急清理过期的key KeySet， Values，Entry 这些对象的迭代器的能保证获取出来的对象不是过期的

从类继承的方法 com.fr.collections.cluster.redis.RedisMap

clear, containsKey, containsValue, decodeMapKey, decodeMapValue, encodeMapKey, encodeMapValue, entrySet, get, getScanResult, isEmpty, keySet, put, putAll, putIfAbsent, remove, remove, replace, replace, values

从类继承的方法 com.fr.collections.cluster.redis.RedisObject

append, bitcount, bitcount, bitfield, checkKey, checkValue, decodeValue, decodeValue, decodeValues, decr, del, delete, echo, encodeIntParameter, encodeLongParameter, encodeParameters, encodeString, encodeValue, encodeValue, eval, eval, eval, eval, evalsha, evalsha, evalsha, execute, execute, exists, expire, expireAt, geoadd, geoadd, get, getCodec, getCollectionsClient, getEncodeName, getName, getNameBytes, getParamsWithBinary, getrange, getScriptById, getSet, hdel, hexists, hget, hgetAll, hincrBy, hincrByFloat, hkeys, hlen, hmget, hmset, hscan, hscan, hset, hset, hsetnx, hstrlen, hvals, incr, incrBy, incrByFloat, lindex, linsert, llen, lpop, lpush, lpushx, lrange, lrem, lset, ltrim, persist, pexpire, pexpireAt, pfadd, pfcount, prefixName, psetex, pttl, restore, rpop, rpush, rpushx, sadd, scard, set, set, setnx, setrange, sismember, smembers, sort, sort, spop, spop, srandmember, srandmember, srem, sscan, sscan, strlen, substr, suffixName, toNameBytesList, toNameBytesList, toNameBytesList, toNamesBytesList, ttl, type, unlink, zadd, zadd, zadd, zadd, zcard, zcount, zcount, zincrby, zincrby, zrange, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeWithScores, zrank, zrem, zremrangeByRank, zrevrange, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeWithScores, zrevrank, zscan, zscan, zscore

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

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

从接口继承的方法 com.fr.collections.api.FineCacheMap

keySet

从接口继承的方法 java.util.concurrent.ConcurrentMap

putIfAbsent, remove, replace, replace

从接口继承的方法 java.util.Map

clear, containsKey, containsValue, entrySet, equals, get, hashCode, isEmpty, put, putAll, remove, values

构造器详细资料

RedisCacheMap

public RedisCacheMap(java.lang.String name,
             RedisCollectionsClient collectionsClient,
             RedisCollectionConfig config,
             FineJedisPool pool)

方法详细资料

put

public V put(K key,
    V value,
    long ttl,
    java.util.concurrent.TimeUnit ttlUnit,
    long maxIdleTime,
    java.util.concurrent.TimeUnit maxIdleUnit)

从接口复制的说明: FineCacheMap

设置一个key-value 值，可以设置过期时间，最大空闲时间

指定者:

put 在接口中 FineCacheMap<K,V>

ttl - 过期时间 为0时表示没有过期时间

ttlUnit - 时间单位

maxIdleTime - 最大过期时间应该大于最大空闲时间，最大空闲时间表示，如果有多长时间这个key值没有用 则失效 为0时表示没有最大空闲时间期限

maxIdleUnit - 最大空闲时间时间单位

返回:

put

public V put(K key,
    V value,
    long ttl,
    long maxIdleTime)

从接口复制的说明: FineCacheMap

设置key-value值单位为毫秒

指定者:

put 在接口中 FineCacheMap<K,V>

返回:

put

public V put(K key,
    V value,
    long ttl,
    java.util.concurrent.TimeUnit unit)

从接口复制的说明: FineCacheMap

设置一个key-value 值，可以设置过期时间

指定者:

put 在接口中 FineCacheMap<K,V>

ttl - 过期时间 为0时表示没有过期时间

unit - 时间单位

返回:

put

public V put(K key,
    V value,
    long ttl)

从接口复制的说明: FineCacheMap

设置一个key-value 值，可以设置过期时间，单位毫秒

指定者:

put 在接口中 FineCacheMap<K,V>

ttl - 过期时间

返回:

putIfAbsent

public V putIfAbsent(K key,
            V value,
            long ttl,
            java.util.concurrent.TimeUnit ttlUnit,
            long maxIdleTime,
            java.util.concurrent.TimeUnit maxIdleUnit)

从接口复制的说明: FineCacheMap

缺失则设置一个key-value 值，可以设置过期时间，最大空闲时间

指定者:

putIfAbsent 在接口中 FineCacheMap<K,V>

ttl - 过期时间 为0时表示没有过期时间

ttlUnit - 时间单位

maxIdleTime - 最大过期时间应该大于最大空闲时间，最大空闲时间表示，如果有多长时间这个key值没有用 则失效 为0时表示没有最大空闲时间期限

maxIdleUnit - 最大空闲时间时间单位

返回:

putIfAbsent

public V putIfAbsent(K key,
            V value,
            long ttl,
            long maxIdleTime)

从接口复制的说明: FineCacheMap

缺失则设置key-value值单位为毫秒

指定者:

putIfAbsent 在接口中 FineCacheMap<K,V>

返回:

putIfAbsent

public V putIfAbsent(K key,
            V value,
            long ttl,
            java.util.concurrent.TimeUnit ttlUnit)

从接口复制的说明: FineCacheMap

当且仅当key不存在是进行保存，如果存在则返回原先的值

指定者:

putIfAbsent 在接口中 FineCacheMap<K,V>

ttl - 过期时间 为0时表示没有过期时间

ttlUnit - 时间单位

返回:

之前key值存放value

putIfAbsent

public V putIfAbsent(K key,
            V value,
            long ttl)

从接口复制的说明: FineCacheMap

当且仅当key不存在是进行保存，如果存在则返回原先的值

指定者:

putIfAbsent 在接口中 FineCacheMap<K,V>

ttl - 过期时间 为0时表示没有过期时间 时间毫秒

返回:

之前key值存放value

putAll

public void putAll(java.util.Map<? extends K,? extends V> map,
          long ttl,
          java.util.concurrent.TimeUnit ttlUnit)

指定者:

putAll 在接口中 FineCacheMap<K,V>

ttl - 过期时间

ttlUnit - - 时间单位

putAll

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

指定者:

putAll 在接口中 FineCacheMap<K,V>

ttl - 过期时间 单位毫秒

remainTimeToLive

public long remainTimeToLive(K key)

从接口复制的说明: FineCacheMap

关联的key值还有多久才过期

指定者:

remainTimeToLive 在接口中 FineCacheMap<K,V>

参数:

key - - map key

返回:

time in milliseconds -2 key 不存在 -1 没有设置过期时间

destroy

public void destroy()

从接口复制的说明: FineCacheMap

销毁 因为有清过期key线程，所以需要支持 外层手动调用销毁方法

指定者:

destroy 在接口中 FineCacheMap<K,V>

size

public int size()

从接口复制的说明: FineCacheMap

注意这边返回的大小可能包括已经失效的key值 如果清理进程没有来的急清理过期的key KeySet， Values，Entry 这些对象的迭代器的能保证获取出来的对象不是过期的

指定者:

size 在接口中 FineCacheMap<K,V>

指定者:

size 在接口中 java.util.Map<K,V>

覆盖:

size 在类中 RedisMap<K,V>

putOperation

protected V putOperation(K key,
             V value)

------------------------------- 内部实现 ------------------------------

覆盖:

putOperation 在类中 RedisMap<K,V>

replaceOperation

protected V replaceOperation(K key,
                 V value)

覆盖:

replaceOperation 在类中 RedisMap<K,V>

removeOperation

protected V removeOperation(K key)

覆盖:

removeOperation 在类中 RedisMap<K,V>

putOperation

protected V putOperation(K key,
             V value,
             long ttlTimeout,
             long maxIdleTimeout,
             long maxIdleDelta)

removeOperation

protected boolean removeOperation(java.lang.Object key,
                      java.lang.Object value)

覆盖:

removeOperation 在类中 RedisMap<K,V>

getOperation

protected V getOperation(K key)

覆盖:

getOperation 在类中 RedisMap<K,V>

putIfAbsentOperation

public V putIfAbsentOperation(K key,
                     V value)

覆盖:

putIfAbsentOperation 在类中 RedisMap<K,V>

putIfAbsentOperation

public V putIfAbsentOperation(K key,
                     V value,
                     long ttlTimeout,
                     long maxIdleTimeout,
                     long maxIdleDelta)

putAllOperation

protected void putAllOperation(java.util.Map<? extends K,? extends V> map)

覆盖:

putAllOperation 在类中 RedisMap<K,V>

remainTimeToLiveOperation

public long remainTimeToLiveOperation(K key)

containsKeyOperation

public boolean containsKeyOperation(java.lang.Object key)

从类复制的说明: RedisMap

----------------------------内部实现------------------------

覆盖:

containsKeyOperation 在类中 RedisMap<K,V>

containsValueOperation

protected boolean containsValueOperation(V value)

覆盖:

containsValueOperation 在类中 RedisMap<K,V>

getScanResult

protected com.fr.third.redis.clients.jedis.ScanResult<java.util.Map.Entry<byte[],byte[]>> getScanResult(long nextIterPos,
                                                                                            int count)

覆盖:

getScanResult 在类中 RedisMap<K,V>