public class RedisConnection<K,V>
extends java.lang.Object
RedisConnection provided they avoid blocking and transactional
operations such as blpop(long, K...) and multi()/exec().
A ConnectionWatchdog monitors each connection and reconnects
automatically until close() is called. All pending commands will be
(re)sent after successful reconnection.| Modifier and Type | Field and Description |
|---|---|
protected RedisAsyncConnection<K,V> |
c |
protected long |
timeout |
protected java.util.concurrent.TimeUnit |
unit |
| Constructor and Description |
|---|
RedisConnection(RedisAsyncConnection<K,V> c)
Initialize a new connection.
|
| Modifier and Type | Method and Description |
|---|---|
java.lang.Long |
append(K key,
V value) |
java.lang.String |
auth(java.lang.String password) |
private <T> T |
await(java.util.concurrent.Future<T> future) |
private <T> T |
await(java.util.concurrent.Future<T> future,
long timeout,
java.util.concurrent.TimeUnit unit) |
java.lang.String |
bgrewriteaof() |
java.lang.String |
bgsave() |
java.lang.Long |
bitcount(K key) |
java.lang.Long |
bitcount(K key,
long start,
long end) |
java.lang.Long |
bitopAnd(K destination,
K... keys) |
java.lang.Long |
bitopNot(K destination,
K source) |
java.lang.Long |
bitopOr(K destination,
K... keys) |
java.lang.Long |
bitopXor(K destination,
K... keys) |
KeyValue<K,V> |
blpop(long timeout,
K... keys) |
KeyValue<K,V> |
brpop(long timeout,
K... keys) |
V |
brpoplpush(long timeout,
K source,
K destination) |
K |
clientGetname() |
java.lang.String |
clientKill(java.lang.String addr) |
java.lang.String |
clientList() |
java.lang.String |
clientSetname(K name) |
void |
close()
Close the connection.
|
java.util.List<java.lang.String> |
configGet(java.lang.String parameter) |
java.lang.String |
configResetstat() |
java.lang.String |
configSet(java.lang.String parameter,
java.lang.String value) |
java.lang.Long |
dbsize() |
java.lang.String |
debugObject(K key) |
java.lang.Long |
decr(K key) |
java.lang.Long |
decrby(K key,
long amount) |
java.lang.Long |
del(K... keys) |
java.lang.String |
digest(V script)
Generate SHA-1 digest for the supplied script.
|
java.lang.String |
discard() |
byte[] |
dump(K key) |
V |
echo(V msg) |
<T> T |
eval(V script,
ScriptOutputType type,
K... keys)
Eval the supplied script, which must result in the requested
type. |
<T> T |
eval(V script,
ScriptOutputType type,
K[] keys,
V... values) |
<T> T |
evalsha(java.lang.String digest,
ScriptOutputType type,
K... keys)
Eval a pre-loaded script identified by its SHA-1 digest, which must result
in the requested
type. |
<T> T |
evalsha(java.lang.String digest,
ScriptOutputType type,
K[] keys,
V... values) |
java.util.List<java.lang.Object> |
exec() |
java.lang.Boolean |
exists(K key) |
java.lang.Boolean |
expire(K key,
long seconds) |
java.lang.Boolean |
expireat(K key,
java.util.Date timestamp) |
java.lang.Boolean |
expireat(K key,
long timestamp) |
java.lang.String |
flushall() |
java.lang.String |
flushdb() |
V |
get(K key) |
java.lang.Long |
getbit(K key,
long offset) |
V |
getrange(K key,
long start,
long end) |
V |
getset(K key,
V value) |
java.lang.Long |
hdel(K key,
K... fields) |
java.lang.Boolean |
hexists(K key,
K field) |
V |
hget(K key,
K field) |
java.util.Map<K,V> |
hgetall(K key) |
java.lang.Long |
hincrby(K key,
K field,
long amount) |
java.lang.Double |
hincrbyfloat(K key,
K field,
double amount) |
java.util.List<K> |
hkeys(K key) |
java.lang.Long |
hlen(K key) |
java.util.List<V> |
hmget(K key,
K... fields) |
java.lang.String |
hmset(K key,
java.util.Map<K,V> map) |
java.lang.Boolean |
hset(K key,
K field,
V value) |
java.lang.Boolean |
hsetnx(K key,
K field,
V value) |
java.util.List<V> |
hvals(K key) |
java.lang.Long |
incr(K key) |
java.lang.Long |
incrby(K key,
long amount) |
java.lang.Double |
incrbyfloat(K key,
double amount) |
java.lang.String |
info() |
java.lang.String |
info(java.lang.String section) |
java.util.List<K> |
keys(K pattern) |
java.util.Date |
lastsave() |
V |
lindex(K key,
long index) |
java.lang.Long |
linsert(K key,
boolean before,
V pivot,
V value) |
java.lang.Long |
llen(K key) |
V |
lpop(K key) |
java.lang.Long |
lpush(K key,
V... values) |
java.lang.Long |
lpushx(K key,
V value) |
java.util.List<V> |
lrange(K key,
long start,
long stop) |
java.lang.Long |
lrem(K key,
long count,
V value) |
java.lang.String |
lset(K key,
long index,
V value) |
java.lang.String |
ltrim(K key,
long start,
long stop) |
java.util.List<V> |
mget(K... keys) |
java.lang.String |
migrate(java.lang.String host,
int port,
K key,
int db,
long timeout) |
java.lang.Boolean |
move(K key,
int db) |
java.lang.String |
mset(java.util.Map<K,V> map) |
java.lang.Boolean |
msetnx(java.util.Map<K,V> map) |
java.lang.String |
multi() |
java.lang.String |
objectEncoding(K key) |
java.lang.Long |
objectIdletime(K key) |
java.lang.Long |
objectRefcount(K key) |
java.lang.Boolean |
persist(K key) |
java.lang.Boolean |
pexpire(K key,
long milliseconds) |
java.lang.Boolean |
pexpireat(K key,
java.util.Date timestamp) |
java.lang.Boolean |
pexpireat(K key,
long timestamp) |
java.lang.String |
ping() |
java.lang.Long |
pttl(K key) |
java.lang.Long |
publish(K channel,
V message) |
java.lang.String |
quit() |
V |
randomkey() |
java.lang.String |
rename(K key,
K newKey) |
java.lang.Boolean |
renamenx(K key,
K newKey) |
java.lang.String |
restore(K key,
long ttl,
byte[] value) |
V |
rpop(K key) |
V |
rpoplpush(K source,
K destination) |
java.lang.Long |
rpush(K key,
V... values) |
java.lang.Long |
rpushx(K key,
V value) |
java.lang.Long |
sadd(K key,
V... members) |
java.lang.String |
save() |
java.lang.Long |
scard(K key) |
java.util.List<java.lang.Boolean> |
scriptExists(java.lang.String... digests) |
java.lang.String |
scriptFlush() |
java.lang.String |
scriptKill() |
java.lang.String |
scriptLoad(V script) |
java.util.Set<V> |
sdiff(K... keys) |
java.lang.Long |
sdiffstore(K destination,
K... keys) |
java.lang.String |
select(int db) |
java.lang.String |
set(K key,
V value) |
java.lang.Long |
setbit(K key,
long offset,
int value) |
java.lang.String |
setex(K key,
long seconds,
V value) |
java.lang.Boolean |
setnx(K key,
V value) |
java.lang.Long |
setrange(K key,
long offset,
V value) |
void |
setTimeout(long timeout,
java.util.concurrent.TimeUnit unit)
Set the command timeout for this connection.
|
void |
shutdown()
Deprecated.
|
void |
shutdown(boolean save) |
java.util.Set<V> |
sinter(K... keys) |
java.lang.Long |
sinterstore(K destination,
K... keys) |
java.lang.Boolean |
sismember(K key,
V member) |
java.lang.String |
slaveof(java.lang.String host,
int port) |
java.lang.String |
slaveofNoOne() |
java.util.List<java.lang.Object> |
slowlogGet() |
java.util.List<java.lang.Object> |
slowlogGet(int count) |
java.lang.Long |
slowlogLen() |
java.lang.String |
slowlogReset() |
java.util.Set<V> |
smembers(K key) |
java.lang.Boolean |
smove(K source,
K destination,
V member) |
java.util.List<V> |
sort(K key) |
java.util.List<V> |
sort(K key,
SortArgs sortArgs) |
java.lang.Long |
sortStore(K key,
SortArgs sortArgs,
K destination) |
V |
spop(K key) |
V |
srandmember(K key) |
java.util.Set<V> |
srandmember(K key,
long count) |
java.lang.Long |
srem(K key,
V... members) |
java.lang.Long |
strlen(K key) |
java.util.Set<V> |
sunion(K... keys) |
java.lang.Long |
sunionstore(K destination,
K... keys) |
java.lang.String |
sync() |
java.lang.Long |
ttl(K key) |
java.lang.String |
type(K key) |
java.lang.String |
unwatch() |
java.lang.String |
watch(K... keys) |
java.lang.Long |
zadd(K key,
double score,
V member) |
java.lang.Long |
zadd(K key,
java.lang.Object... scoresAndValues) |
java.lang.Long |
zcard(K key) |
java.lang.Long |
zcount(K key,
double min,
double max) |
java.lang.Long |
zcount(K key,
java.lang.String min,
java.lang.String max) |
java.lang.Double |
zincrby(K key,
double amount,
K member) |
java.lang.Long |
zinterstore(K destination,
K... keys) |
java.lang.Long |
zinterstore(K destination,
ZStoreArgs storeArgs,
K... keys) |
java.util.List<V> |
zrange(K key,
long start,
long stop) |
java.util.List<V> |
zrangebyscore(K key,
double min,
double max) |
java.util.List<V> |
zrangebyscore(K key,
double min,
double max,
long offset,
long count) |
java.util.List<V> |
zrangebyscore(K key,
java.lang.String min,
java.lang.String max) |
java.util.List<V> |
zrangebyscore(K key,
java.lang.String min,
java.lang.String max,
long offset,
long count) |
java.util.List<ScoredValue<V>> |
zrangebyscoreWithScores(K key,
double min,
double max) |
java.util.List<ScoredValue<V>> |
zrangebyscoreWithScores(K key,
double min,
double max,
long offset,
long count) |
java.util.List<ScoredValue<V>> |
zrangebyscoreWithScores(K key,
java.lang.String min,
java.lang.String max) |
java.util.List<ScoredValue<V>> |
zrangebyscoreWithScores(K key,
java.lang.String min,
java.lang.String max,
long offset,
long count) |
java.util.List<ScoredValue<V>> |
zrangeWithScores(K key,
long start,
long stop) |
java.lang.Long |
zrank(K key,
V member) |
java.lang.Long |
zrem(K key,
V... members) |
java.lang.Long |
zremrangebyrank(K key,
long start,
long stop) |
java.lang.Long |
zremrangebyscore(K key,
double min,
double max) |
java.lang.Long |
zremrangebyscore(K key,
java.lang.String min,
java.lang.String max) |
java.util.List<V> |
zrevrange(K key,
long start,
long stop) |
java.util.List<V> |
zrevrangebyscore(K key,
double max,
double min) |
java.util.List<V> |
zrevrangebyscore(K key,
double max,
double min,
long offset,
long count) |
java.util.List<V> |
zrevrangebyscore(K key,
java.lang.String max,
java.lang.String min) |
java.util.List<V> |
zrevrangebyscore(K key,
java.lang.String max,
java.lang.String min,
long offset,
long count) |
java.util.List<ScoredValue<V>> |
zrevrangebyscoreWithScores(K key,
double max,
double min) |
java.util.List<ScoredValue<V>> |
zrevrangebyscoreWithScores(K key,
double max,
double min,
long offset,
long count) |
java.util.List<ScoredValue<V>> |
zrevrangebyscoreWithScores(K key,
java.lang.String max,
java.lang.String min) |
java.util.List<ScoredValue<V>> |
zrevrangebyscoreWithScores(K key,
java.lang.String max,
java.lang.String min,
long offset,
long count) |
java.util.List<ScoredValue<V>> |
zrevrangeWithScores(K key,
long start,
long stop) |
java.lang.Long |
zrevrank(K key,
V member) |
java.lang.Double |
zscore(K key,
V member) |
java.lang.Long |
zunionstore(K destination,
K... keys) |
java.lang.Long |
zunionstore(K destination,
ZStoreArgs storeArgs,
K... keys) |
protected RedisAsyncConnection<K,V> c
protected long timeout
protected java.util.concurrent.TimeUnit unit
public RedisConnection(RedisAsyncConnection<K,V> c)
c - Underlying async connection.public void setTimeout(long timeout,
java.util.concurrent.TimeUnit unit)
timeout - Command timeout.unit - Unit of time for the timeout.public java.lang.String auth(java.lang.String password)
public java.lang.String bgrewriteaof()
public java.lang.String bgsave()
public java.lang.Long bitcount(K key)
public java.lang.Long bitcount(K key, long start, long end)
public K clientGetname()
public java.lang.String clientSetname(K name)
public java.lang.String clientKill(java.lang.String addr)
public java.lang.String clientList()
public java.util.List<java.lang.String> configGet(java.lang.String parameter)
public java.lang.String configResetstat()
public java.lang.String configSet(java.lang.String parameter,
java.lang.String value)
public java.lang.Long dbsize()
public java.lang.String debugObject(K key)
public java.lang.Long decr(K key)
public java.lang.Long decrby(K key, long amount)
public java.lang.Long del(K... keys)
public java.lang.String discard()
public byte[] dump(K key)
public <T> T eval(V script, ScriptOutputType type, K... keys)
type.T - Expected return type.script - Lua script to evaluate.type - Script output type.keys - Redis keys to pass to script.public <T> T eval(V script, ScriptOutputType type, K[] keys, V... values)
public <T> T evalsha(java.lang.String digest,
ScriptOutputType type,
K... keys)
type.T - Expected return type.digest - Lowercase hex string of script's SHA-1 digest.type - Script output type.keys - Redis keys to pass to script.public <T> T evalsha(java.lang.String digest,
ScriptOutputType type,
K[] keys,
V... values)
public java.lang.Boolean exists(K key)
public java.lang.Boolean expire(K key, long seconds)
public java.lang.Boolean expireat(K key, java.util.Date timestamp)
public java.lang.Boolean expireat(K key, long timestamp)
public java.util.List<java.lang.Object> exec()
public java.lang.String flushall()
throws java.lang.Exception
java.lang.Exceptionpublic java.lang.String flushdb()
throws java.lang.Exception
java.lang.Exceptionpublic java.lang.Long getbit(K key, long offset)
public java.lang.Long hlen(K key)
public java.lang.Long incr(K key)
public java.lang.Long incrby(K key, long amount)
public java.lang.Double incrbyfloat(K key, double amount)
public java.lang.String info()
public java.lang.String info(java.lang.String section)
public java.util.Date lastsave()
public java.lang.Long llen(K key)
public java.lang.String ltrim(K key, long start, long stop)
public java.lang.String migrate(java.lang.String host,
int port,
K key,
int db,
long timeout)
public java.lang.Boolean move(K key, int db)
public java.lang.String multi()
public java.lang.String objectEncoding(K key)
public java.lang.Long objectIdletime(K key)
public java.lang.Long objectRefcount(K key)
public java.lang.Boolean persist(K key)
public java.lang.Boolean pexpire(K key, long milliseconds)
public java.lang.Boolean pexpireat(K key, java.util.Date timestamp)
public java.lang.Boolean pexpireat(K key, long timestamp)
public java.lang.String ping()
public java.lang.Long pttl(K key)
public java.lang.String quit()
public V randomkey()
public java.lang.String restore(K key, long ttl, byte[] value)
public java.lang.String save()
public java.lang.Long scard(K key)
public java.util.List<java.lang.Boolean> scriptExists(java.lang.String... digests)
public java.lang.String scriptFlush()
public java.lang.String scriptKill()
public java.lang.String scriptLoad(V script)
public java.lang.String select(int db)
public java.lang.Long setbit(K key, long offset, int value)
@Deprecated public void shutdown()
public void shutdown(boolean save)
public java.lang.String slaveof(java.lang.String host,
int port)
public java.lang.String slaveofNoOne()
public java.util.List<java.lang.Object> slowlogGet()
public java.util.List<java.lang.Object> slowlogGet(int count)
public java.lang.Long slowlogLen()
public java.lang.String slowlogReset()
public java.lang.String sync()
public java.lang.Long strlen(K key)
public java.lang.Long ttl(K key)
public java.lang.String type(K key)
public java.lang.String watch(K... keys)
public java.lang.String unwatch()
public java.lang.Long zadd(K key, java.lang.Object... scoresAndValues)
public java.lang.Long zcard(K key)
public java.lang.Long zcount(K key, double min, double max)
public java.lang.Long zcount(K key, java.lang.String min, java.lang.String max)
public java.lang.Long zinterstore(K destination, ZStoreArgs storeArgs, K... keys)
public java.util.List<ScoredValue<V>> zrangeWithScores(K key, long start, long stop)
public java.util.List<V> zrangebyscore(K key, java.lang.String min, java.lang.String max)
public java.util.List<V> zrangebyscore(K key, double min, double max, long offset, long count)
public java.util.List<V> zrangebyscore(K key, java.lang.String min, java.lang.String max, long offset, long count)
public java.util.List<ScoredValue<V>> zrangebyscoreWithScores(K key, double min, double max)
public java.util.List<ScoredValue<V>> zrangebyscoreWithScores(K key, java.lang.String min, java.lang.String max)
public java.util.List<ScoredValue<V>> zrangebyscoreWithScores(K key, double min, double max, long offset, long count)
public java.util.List<ScoredValue<V>> zrangebyscoreWithScores(K key, java.lang.String min, java.lang.String max, long offset, long count)
public java.lang.Long zremrangebyrank(K key, long start, long stop)
public java.lang.Long zremrangebyscore(K key, double min, double max)
public java.lang.Long zremrangebyscore(K key, java.lang.String min, java.lang.String max)
public java.util.List<ScoredValue<V>> zrevrangeWithScores(K key, long start, long stop)
public java.util.List<V> zrevrangebyscore(K key, java.lang.String max, java.lang.String min)
public java.util.List<V> zrevrangebyscore(K key, double max, double min, long offset, long count)
public java.util.List<V> zrevrangebyscore(K key, java.lang.String max, java.lang.String min, long offset, long count)
public java.util.List<ScoredValue<V>> zrevrangebyscoreWithScores(K key, double max, double min)
public java.util.List<ScoredValue<V>> zrevrangebyscoreWithScores(K key, java.lang.String max, java.lang.String min)
public java.util.List<ScoredValue<V>> zrevrangebyscoreWithScores(K key, double max, double min, long offset, long count)
public java.util.List<ScoredValue<V>> zrevrangebyscoreWithScores(K key, java.lang.String max, java.lang.String min, long offset, long count)
public java.lang.Long zunionstore(K destination, ZStoreArgs storeArgs, K... keys)
public void close()
public java.lang.String digest(V script)
script - Lua script.private <T> T await(java.util.concurrent.Future<T> future,
long timeout,
java.util.concurrent.TimeUnit unit)
private <T> T await(java.util.concurrent.Future<T> future)