RedisClusterClient instead. RedisClusterClient provides the same functionality
with a cleaner API and simplified constructor options. For basic usage, simple
constructors are available. For advanced configuration, use RedisClusterClient.builder().@Deprecated public class JedisCluster extends UnifiedJedis
| Modifier and Type | Class and Description |
|---|---|
static class |
JedisCluster.Builder
Deprecated.
Fluent builder for
JedisCluster (Redis Cluster). |
| Modifier and Type | Field and Description |
|---|---|
static int |
DEFAULT_MAX_ATTEMPTS
Deprecated.
Default amount of attempts for executing a command
|
static int |
DEFAULT_TIMEOUT
Deprecated.
Default timeout in milliseconds.
|
static java.lang.String |
INIT_NO_ERROR_PROPERTY
Deprecated.
|
commandObjects, executor, protocol, provider| Constructor and Description |
|---|
JedisCluster(ClusterConnectionProvider provider,
int maxAttempts,
java.time.Duration maxTotalRetriesDuration)
Deprecated.
|
JedisCluster(HostAndPort node)
Deprecated.
Creates a JedisCluster instance.
|
JedisCluster(HostAndPort node,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(HostAndPort node,
int timeout)
Deprecated.
Creates a JedisCluster instance.
|
JedisCluster(HostAndPort node,
int timeout,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(HostAndPort node,
int timeout,
int maxAttempts)
Deprecated.
Creates a JedisCluster instance.
|
JedisCluster(HostAndPort node,
int timeout,
int maxAttempts,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(HostAndPort node,
int connectionTimeout,
int soTimeout,
int maxAttempts,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(HostAndPort node,
int connectionTimeout,
int soTimeout,
int maxAttempts,
java.lang.String password,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(HostAndPort node,
int connectionTimeout,
int soTimeout,
int maxAttempts,
java.lang.String password,
java.lang.String clientName,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(HostAndPort node,
int connectionTimeout,
int soTimeout,
int maxAttempts,
java.lang.String password,
java.lang.String clientName,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig,
boolean ssl)
Deprecated.
|
JedisCluster(HostAndPort node,
int connectionTimeout,
int soTimeout,
int maxAttempts,
java.lang.String user,
java.lang.String password,
java.lang.String clientName,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(HostAndPort node,
int connectionTimeout,
int soTimeout,
int maxAttempts,
java.lang.String user,
java.lang.String password,
java.lang.String clientName,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig,
boolean ssl)
Deprecated.
|
JedisCluster(HostAndPort node,
JedisClientConfig clientConfig,
int maxAttempts,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> nodes)
Deprecated.
Creates a JedisCluster with multiple entry points.
|
JedisCluster(java.util.Set<HostAndPort> nodes,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> nodes,
int timeout)
Deprecated.
Creates a JedisCluster with multiple entry points.
|
JedisCluster(java.util.Set<HostAndPort> nodes,
int timeout,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> nodes,
int timeout,
int maxAttempts)
Deprecated.
Creates a JedisCluster with multiple entry points.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
int timeout,
int maxAttempts,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
int connectionTimeout,
int soTimeout,
int maxAttempts,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
int connectionTimeout,
int soTimeout,
int infiniteSoTimeout,
int maxAttempts,
java.lang.String user,
java.lang.String password,
java.lang.String clientName,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
int connectionTimeout,
int soTimeout,
int maxAttempts,
java.lang.String password,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
int connectionTimeout,
int soTimeout,
int maxAttempts,
java.lang.String password,
java.lang.String clientName,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
int connectionTimeout,
int soTimeout,
int maxAttempts,
java.lang.String password,
java.lang.String clientName,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig,
boolean ssl)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
int connectionTimeout,
int soTimeout,
int maxAttempts,
java.lang.String user,
java.lang.String password,
java.lang.String clientName,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
int connectionTimeout,
int soTimeout,
int maxAttempts,
java.lang.String user,
java.lang.String password,
java.lang.String clientName,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig,
boolean ssl)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
JedisClientConfig clientConfig)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
JedisClientConfig clientConfig,
Cache clientSideCache)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> hnp,
JedisClientConfig jedisClientConfig,
CacheConfig cacheConfig)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
JedisClientConfig clientConfig,
Cache clientSideCache,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
JedisClientConfig clientConfig,
Cache clientSideCache,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig,
java.time.Duration topologyRefreshPeriod,
int maxAttempts,
java.time.Duration maxTotalRetriesDuration)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
JedisClientConfig clientConfig,
Cache clientSideCache,
int maxAttempts,
java.time.Duration maxTotalRetriesDuration)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
JedisClientConfig clientConfig,
Cache clientSideCache,
int maxAttempts,
java.time.Duration maxTotalRetriesDuration,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
JedisClientConfig clientConfig,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
JedisClientConfig clientConfig,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig,
java.time.Duration topologyRefreshPeriod,
int maxAttempts,
java.time.Duration maxTotalRetriesDuration)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
JedisClientConfig clientConfig,
int maxAttempts)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
JedisClientConfig clientConfig,
int maxAttempts,
java.time.Duration maxTotalRetriesDuration)
Deprecated.
Creates a JedisCluster with multiple entry points.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
JedisClientConfig clientConfig,
int maxAttempts,
java.time.Duration maxTotalRetriesDuration,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> clusterNodes,
JedisClientConfig clientConfig,
int maxAttempts,
org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> nodes,
java.lang.String user,
java.lang.String password)
Deprecated.
|
JedisCluster(java.util.Set<HostAndPort> nodes,
java.lang.String user,
java.lang.String password,
HostAndPortMapper hostAndPortMap)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
static JedisCluster.Builder |
builder()
Deprecated.
Create a new builder for configuring JedisCluster instances.
|
<T> T |
executeCommandToReplica(CommandObject<T> commandObject)
Deprecated.
|
java.util.Map<java.lang.String,ConnectionPool> |
getClusterNodes()
Deprecated.
Returns all nodes that were configured to connect to in key-value pairs (
Map). |
Connection |
getConnectionFromSlot(int slot)
Deprecated.
Returns the connection for one of the 16,384 slots.
|
ClusterPipeline |
pipelined()
Deprecated.
Creates a new pipeline for executing commands in a Redis Cluster.
|
ClusterPipeline |
pipelined(java.util.concurrent.ExecutorService executorService)
Deprecated.
Creates a new pipeline for executing commands in a Redis Cluster using the provided executor.
|
long |
spublish(byte[] channel,
byte[] message)
Deprecated.
|
long |
spublish(java.lang.String channel,
java.lang.String message)
Deprecated.
|
void |
ssubscribe(BinaryJedisShardedPubSub jedisPubSub,
byte[]... channels)
Deprecated.
|
void |
ssubscribe(JedisShardedPubSub jedisPubSub,
java.lang.String... channels)
Deprecated.
|
AbstractTransaction |
transaction(boolean doMulti)
Deprecated.
|
append, append, bfAdd, bfCard, bfExists, bfInfo, bfInsert, bfInsert, bfLoadChunk, bfMAdd, bfMExists, bfReserve, bfReserve, bfScanDump, bitcount, bitcount, bitcount, bitcount, bitcount, bitcount, bitfield, bitfield, bitfieldReadonly, bitfieldReadonly, bitop, bitop, bitpos, bitpos, bitpos, bitpos, blmove, blmove, blmpop, blmpop, blmpop, blmpop, blpop, blpop, blpop, blpop, blpop, blpop, broadcastCommand, brpop, brpop, brpop, brpop, brpop, brpop, brpoplpush, brpoplpush, bzmpop, bzmpop, bzmpop, bzmpop, bzpopmax, bzpopmax, bzpopmin, bzpopmin, cfAdd, cfAddNx, cfCount, cfDel, cfExists, cfInfo, cfInsert, cfInsert, cfInsertNx, cfInsertNx, cfLoadChunk, cfMExists, cfReserve, cfReserve, cfScanDump, close, cmsIncrBy, cmsInfo, cmsInitByDim, cmsInitByProb, cmsMerge, cmsMerge, cmsQuery, configSet, copy, copy, dbSize, decr, decr, decrBy, decrBy, del, del, del, del, delex, delex, digestKey, digestKey, dump, dump, echo, eval, eval, eval, eval, eval, eval, eval, eval, evalReadonly, evalReadonly, evalsha, evalsha, evalsha, evalsha, evalsha, evalsha, evalsha, evalsha, evalshaReadonly, evalshaReadonly, executeCommand, executeCommand, exists, exists, exists, exists, expire, expire, expire, expire, expireAt, expireAt, expireAt, expireAt, expireTime, expireTime, fcall, fcall, fcallReadonly, fcallReadonly, flushAll, flushDB, ftAggregate, ftAggregateIteration, ftAliasAdd, ftAliasDel, ftAliasUpdate, ftAlter, ftAlter, ftConfigGet, ftConfigGet, ftConfigSet, ftConfigSet, ftCreate, ftCreate, ftCursorDel, ftCursorRead, ftDictAdd, ftDictAddBySampleKey, ftDictDel, ftDictDelBySampleKey, ftDictDump, ftDictDumpBySampleKey, ftDropIndex, ftDropIndexDD, ftExplain, ftExplainCLI, ftHybrid, ftInfo, ftList, ftProfileAggregate, ftProfileSearch, ftProfileSearch, ftSearch, ftSearch, ftSearch, ftSearch, ftSearchIteration, ftSearchIteration, ftSpellCheck, ftSpellCheck, ftSugAdd, ftSugAddIncr, ftSugDel, ftSugGet, ftSugGet, ftSugGetWithScores, ftSugGetWithScores, ftSugLen, ftSynDump, ftSynUpdate, ftTagVals, functionDelete, functionDelete, functionDump, functionFlush, functionFlush, functionKill, functionList, functionList, functionList, functionListBinary, functionListWithCode, functionListWithCode, functionListWithCode, functionListWithCodeBinary, functionLoad, functionLoad, functionLoadReplace, functionLoadReplace, functionRestore, functionRestore, functionStats, functionStatsBinary, geoadd, geoadd, geoadd, geoadd, geoadd, geoadd, geodist, geodist, geodist, geodist, geohash, geohash, geopos, geopos, georadius, georadius, georadius, georadius, georadiusByMember, georadiusByMember, georadiusByMember, georadiusByMember, georadiusByMemberReadonly, georadiusByMemberReadonly, georadiusByMemberReadonly, georadiusByMemberReadonly, georadiusByMemberStore, georadiusByMemberStore, georadiusReadonly, georadiusReadonly, georadiusReadonly, georadiusReadonly, georadiusStore, georadiusStore, geosearch, geosearch, geosearch, geosearch, geosearch, geosearch, geosearch, geosearch, geosearch, geosearch, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStoreStoreDist, geosearchStoreStoreDist, get, get, getbit, getbit, getCache, getDel, getDel, getEx, getEx, getrange, getrange, getSet, getSet, hdel, hdel, hexists, hexists, hexpire, hexpire, hexpire, hexpire, hexpireAt, hexpireAt, hexpireAt, hexpireAt, hexpireTime, hexpireTime, hget, hget, hgetAll, hgetAll, hgetdel, hgetdel, hgetex, hgetex, hincrBy, hincrBy, hincrByFloat, hincrByFloat, hkeys, hkeys, hlen, hlen, hmget, hmget, hmset, hmset, hotkeysGet, hotkeysReset, hotkeysStart, hotkeysStop, hpersist, hpersist, hpexpire, hpexpire, hpexpire, hpexpire, hpexpireAt, hpexpireAt, hpexpireAt, hpexpireAt, hpexpireTime, hpexpireTime, hpttl, hpttl, hrandfield, hrandfield, hrandfield, hrandfield, hrandfieldWithValues, hrandfieldWithValues, hscan, hscan, hscanNoValues, hscanNoValues, hset, hset, hset, hset, hsetex, hsetex, hsetex, hsetex, hsetnx, hsetnx, hsetObject, hsetObject, hstrlen, hstrlen, httl, httl, hvals, hvals, incr, incr, incrBy, incrBy, incrByFloat, incrByFloat, info, info, jsonArrAppend, jsonArrAppend, jsonArrAppendWithEscape, jsonArrIndex, jsonArrIndex, jsonArrIndexWithEscape, jsonArrInsert, jsonArrInsert, jsonArrInsertWithEscape, jsonArrLen, jsonArrLen, jsonArrLen, jsonArrPop, jsonArrPop, jsonArrPop, jsonArrPop, jsonArrPop, jsonArrPop, jsonArrPop, jsonArrPop, jsonArrTrim, jsonArrTrim, jsonClear, jsonClear, jsonClear, jsonDebugMemory, jsonDebugMemory, jsonDebugMemory, jsonDel, jsonDel, jsonDel, jsonGet, jsonGet, jsonGet, jsonGet, jsonGet, jsonGetAsPlainString, jsonMerge, jsonMerge, jsonMGet, jsonMGet, jsonNumIncrBy, jsonNumIncrBy, jsonObjKeys, jsonObjKeys, jsonObjKeys, jsonObjLen, jsonObjLen, jsonObjLen, jsonSet, jsonSet, jsonSet, jsonSet, jsonSetWithEscape, jsonSetWithEscape, jsonSetWithPlainString, jsonStrAppend, jsonStrAppend, jsonStrAppend, jsonStrLen, jsonStrLen, jsonStrLen, jsonToggle, jsonToggle, jsonType, jsonType, jsonType, keys, keys, lcs, lcs, lindex, lindex, linsert, linsert, llen, llen, lmove, lmove, lmpop, lmpop, lmpop, lmpop, lpop, lpop, lpop, lpop, lpos, lpos, lpos, lpos, lpos, lpos, lpush, lpush, lpushx, lpushx, lrange, lrange, lrem, lrem, lset, lset, ltrim, ltrim, memoryUsage, memoryUsage, memoryUsage, memoryUsage, mget, mget, migrate, migrate, migrate, migrate, mset, mset, msetex, msetex, msetnx, msetnx, multi, objectEncoding, objectEncoding, objectFreq, objectFreq, objectIdletime, objectIdletime, objectRefcount, objectRefcount, persist, persist, pexpire, pexpire, pexpire, pexpire, pexpireAt, pexpireAt, pexpireAt, pexpireAt, pexpireTime, pexpireTime, pfadd, pfadd, pfcount, pfcount, pfcount, pfcount, pfmerge, pfmerge, ping, psetex, psetex, psubscribe, psubscribe, pttl, pttl, publish, publish, randomBinaryKey, randomKey, rename, rename, renamenx, renamenx, restore, restore, restore, restore, rpop, rpop, rpop, rpop, rpoplpush, rpoplpush, rpush, rpush, rpushx, rpushx, sadd, sadd, scan, scan, scan, scan, scan, scan, scanIteration, scanIteration, scard, scard, scriptExists, scriptExists, scriptExists, scriptExists, scriptExists, scriptFlush, scriptFlush, scriptFlush, scriptFlush, scriptFlush, scriptKill, scriptKill, scriptKill, scriptLoad, scriptLoad, scriptLoad, sdiff, sdiff, sdiffstore, sdiffstore, sendBlockingCommand, sendBlockingCommand, sendBlockingCommand, sendBlockingCommand, sendCommand, sendCommand, sendCommand, sendCommand, sendCommand, set, set, set, set, setbit, setbit, setBroadcastAndRoundRobinConfig, setDefaultSearchDialect, setex, setex, setGet, setGet, setGet, setGet, setJsonObjectMapper, setKeyArgumentPreProcessor, setnx, setnx, setProtocol, setrange, setrange, sinter, sinter, sintercard, sintercard, sintercard, sintercard, sinterstore, sinterstore, sismember, sismember, slowlogReset, smembers, smembers, smismember, smismember, smove, smove, sort, sort, sort, sort, sort, sort, sort, sort, sortReadonly, sortReadonly, spop, spop, spop, spop, srandmember, srandmember, srandmember, srandmember, srem, srem, sscan, sscan, strlen, strlen, subscribe, subscribe, substr, substr, sunion, sunion, sunionstore, sunionstore, tdigestAdd, tdigestByRank, tdigestByRevRank, tdigestCDF, tdigestCreate, tdigestCreate, tdigestInfo, tdigestMax, tdigestMerge, tdigestMerge, tdigestMin, tdigestQuantile, tdigestRank, tdigestReset, tdigestRevRank, tdigestTrimmedMean, topkAdd, topkIncrBy, topkInfo, topkList, topkListWithCount, topkQuery, topkReserve, topkReserve, touch, touch, touch, touch, tsAdd, tsAdd, tsAdd, tsAdd, tsAlter, tsCreate, tsCreate, tsCreateRule, tsCreateRule, tsDecrBy, tsDecrBy, tsDecrBy, tsDel, tsDeleteRule, tsGet, tsGet, tsIncrBy, tsIncrBy, tsIncrBy, tsInfo, tsInfoDebug, tsMAdd, tsMGet, tsMRange, tsMRange, tsMRevRange, tsMRevRange, tsQueryIndex, tsRange, tsRange, tsRevRange, tsRevRange, ttl, ttl, type, type, unlink, unlink, unlink, unlink, vadd, vadd, vadd, vadd, vadd, vadd, vaddFP32, vaddFP32, vaddFP32, vaddFP32, vaddFP32, vaddFP32, vcard, vcard, vdim, vdim, vemb, vemb, vembRaw, vembRaw, vgetattr, vgetattr, vinfo, vlinks, vlinks, vlinksWithScores, vlinksWithScores, vrandmember, vrandmember, vrandmember, vrandmember, vrem, vrem, vsetattr, vsetattr, vsim, vsim, vsim, vsim, vsimByElement, vsimByElement, vsimByElement, vsimByElement, vsimByElementWithScores, vsimByElementWithScores, vsimByElementWithScoresAndAttribs, vsimByElementWithScoresAndAttribs, vsimWithScores, vsimWithScores, vsimWithScoresAndAttribs, vsimWithScoresAndAttribs, waitAOF, waitAOF, waitReplicas, waitReplicas, xack, xack, xackdel, xackdel, xackdel, xackdel, xadd, xadd, xadd, xautoclaim, xautoclaim, xautoclaimJustId, xautoclaimJustId, xcfgset, xcfgset, xclaim, xclaim, xclaimJustId, xclaimJustId, xdel, xdel, xdelex, xdelex, xdelex, xdelex, xgroupCreate, xgroupCreate, xgroupCreateConsumer, xgroupCreateConsumer, xgroupDelConsumer, xgroupDelConsumer, xgroupDestroy, xgroupDestroy, xgroupSetID, xgroupSetID, xinfoConsumers, xinfoConsumers, xinfoConsumers2, xinfoGroups, xinfoGroups, xinfoStream, xinfoStream, xinfoStreamFull, xinfoStreamFull, xinfoStreamFull, xinfoStreamFull, xlen, xlen, xpending, xpending, xpending, xpending, xrange, xrange, xrange, xrange, xrange, xrange, xread, xread, xreadAsMap, xreadBinary, xreadBinaryAsMap, xreadGroup, xreadGroup, xreadGroupAsMap, xreadGroupBinary, xreadGroupBinaryAsMap, xrevrange, xrevrange, xrevrange, xrevrange, xrevrange, xrevrange, xtrim, xtrim, xtrim, xtrim, zadd, zadd, zadd, zadd, zadd, zadd, zadd, zadd, zaddIncr, zaddIncr, zcard, zcard, zcount, zcount, zcount, zcount, zdiff, zdiff, zdiffstore, zdiffStore, zdiffstore, zdiffStore, zdiffWithScores, zdiffWithScores, zincrby, zincrby, zincrby, zincrby, zinter, zinter, zintercard, zintercard, zintercard, zintercard, zinterstore, zinterstore, zinterstore, zinterstore, zinterWithScores, zinterWithScores, zlexcount, zlexcount, zmpop, zmpop, zmpop, zmpop, zmscore, zmscore, zpopmax, zpopmax, zpopmax, zpopmax, zpopmin, zpopmin, zpopmin, zpopmin, zrandmember, zrandmember, zrandmember, zrandmember, zrandmemberWithScores, zrandmemberWithScores, zrange, zrange, zrange, zrange, zrangeByLex, zrangeByLex, zrangeByLex, zrangeByLex, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangestore, zrangestore, zrangeWithScores, zrangeWithScores, zrangeWithScores, zrangeWithScores, zrank, zrank, zrankWithScore, zrankWithScore, zrem, zrem, zremrangeByLex, zremrangeByLex, zremrangeByRank, zremrangeByRank, zremrangeByScore, zremrangeByScore, zremrangeByScore, zremrangeByScore, zrevrange, zrevrange, zrevrangeByLex, zrevrangeByLex, zrevrangeByLex, zrevrangeByLex, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeWithScores, zrevrangeWithScores, zrevrank, zrevrank, zrevrankWithScore, zrevrankWithScore, zscan, zscan, zscore, zscore, zunion, zunion, zunionstore, zunionstore, zunionstore, zunionstore, zunionWithScores, zunionWithScoresclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waithscan, hscanNoValuessscanzscanxaddhscan, hscanNoValuessscanzscanxaddftAlter, ftAlter, ftCreate, ftCreate, ftCreate, ftSearchjsonMGet, jsonSetLegacy, jsonSetLegacyjsonMGet, jsonSet, jsonSet, jsonSetWithEscape, jsonSetWithEscapecmsIncrBytopkIncrBypublic static final java.lang.String INIT_NO_ERROR_PROPERTY
public static final int DEFAULT_TIMEOUT
public static final int DEFAULT_MAX_ATTEMPTS
public JedisCluster(HostAndPort node)
Here, the default timeout of 2000 ms is being used with 5 maximum attempts.
node - Node to first connect to.public JedisCluster(HostAndPort node, int timeout)
Here, the default timeout of 2000 ms is being used with 5 maximum attempts.
node - Node to first connect to.timeout - connection and socket timeout in milliseconds.public JedisCluster(HostAndPort node, int timeout, int maxAttempts)
node - Node to first connect to.timeout - connection and socket timeout in milliseconds.maxAttempts - maximum attempts for executing a command.public JedisCluster(HostAndPort node, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(HostAndPort node, int timeout, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(HostAndPort node, int timeout, int maxAttempts, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(HostAndPort node, int connectionTimeout, int soTimeout, int maxAttempts, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(HostAndPort node, int connectionTimeout, int soTimeout, int maxAttempts, java.lang.String password, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(HostAndPort node, int connectionTimeout, int soTimeout, int maxAttempts, java.lang.String password, java.lang.String clientName, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(HostAndPort node, int connectionTimeout, int soTimeout, int maxAttempts, java.lang.String user, java.lang.String password, java.lang.String clientName, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(HostAndPort node, int connectionTimeout, int soTimeout, int maxAttempts, java.lang.String password, java.lang.String clientName, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig, boolean ssl)
public JedisCluster(HostAndPort node, int connectionTimeout, int soTimeout, int maxAttempts, java.lang.String user, java.lang.String password, java.lang.String clientName, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig, boolean ssl)
public JedisCluster(HostAndPort node, JedisClientConfig clientConfig, int maxAttempts, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(java.util.Set<HostAndPort> nodes)
Here, the default timeout of 2000 ms is being used with 5 maximum attempts.
nodes - Nodes to connect to.public JedisCluster(java.util.Set<HostAndPort> nodes, int timeout)
Here, the default timeout of 2000 ms is being used with 5 maximum attempts.
nodes - Nodes to connect to.timeout - connection and socket timeout in milliseconds.public JedisCluster(java.util.Set<HostAndPort> nodes, int timeout, int maxAttempts)
nodes - Nodes to connect to.timeout - connection and socket timeout in milliseconds.maxAttempts - maximum attempts for executing a command.public JedisCluster(java.util.Set<HostAndPort> nodes, java.lang.String user, java.lang.String password)
public JedisCluster(java.util.Set<HostAndPort> nodes, java.lang.String user, java.lang.String password, HostAndPortMapper hostAndPortMap)
public JedisCluster(java.util.Set<HostAndPort> nodes, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(java.util.Set<HostAndPort> nodes, int timeout, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(java.util.Set<HostAndPort> clusterNodes, int timeout, int maxAttempts, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(java.util.Set<HostAndPort> clusterNodes, int connectionTimeout, int soTimeout, int maxAttempts, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(java.util.Set<HostAndPort> clusterNodes, int connectionTimeout, int soTimeout, int maxAttempts, java.lang.String password, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(java.util.Set<HostAndPort> clusterNodes, int connectionTimeout, int soTimeout, int maxAttempts, java.lang.String password, java.lang.String clientName, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(java.util.Set<HostAndPort> clusterNodes, int connectionTimeout, int soTimeout, int maxAttempts, java.lang.String user, java.lang.String password, java.lang.String clientName, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(java.util.Set<HostAndPort> clusterNodes, int connectionTimeout, int soTimeout, int infiniteSoTimeout, int maxAttempts, java.lang.String user, java.lang.String password, java.lang.String clientName, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(java.util.Set<HostAndPort> clusterNodes, int connectionTimeout, int soTimeout, int maxAttempts, java.lang.String password, java.lang.String clientName, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig, boolean ssl)
public JedisCluster(java.util.Set<HostAndPort> clusterNodes, int connectionTimeout, int soTimeout, int maxAttempts, java.lang.String user, java.lang.String password, java.lang.String clientName, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig, boolean ssl)
public JedisCluster(java.util.Set<HostAndPort> clusterNodes, JedisClientConfig clientConfig)
public JedisCluster(java.util.Set<HostAndPort> clusterNodes, JedisClientConfig clientConfig, int maxAttempts)
public JedisCluster(java.util.Set<HostAndPort> clusterNodes, JedisClientConfig clientConfig, int maxAttempts, java.time.Duration maxTotalRetriesDuration)
JedisClientConfig instance.DefaultJedisClientConfig.builder() builder pattern to customize your configuration, including socket timeouts,
username and passwords as well as SSL related parameters.clusterNodes - Nodes to connect to.clientConfig - Client configuration parameters.maxAttempts - maximum attempts for executing a command.maxTotalRetriesDuration - Maximum time used for reconnecting.public JedisCluster(java.util.Set<HostAndPort> clusterNodes, JedisClientConfig clientConfig, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(java.util.Set<HostAndPort> clusterNodes, JedisClientConfig clientConfig, int maxAttempts, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(java.util.Set<HostAndPort> clusterNodes, JedisClientConfig clientConfig, int maxAttempts, java.time.Duration maxTotalRetriesDuration, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
public JedisCluster(java.util.Set<HostAndPort> clusterNodes, JedisClientConfig clientConfig, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig, java.time.Duration topologyRefreshPeriod, int maxAttempts, java.time.Duration maxTotalRetriesDuration)
public JedisCluster(ClusterConnectionProvider provider, int maxAttempts, java.time.Duration maxTotalRetriesDuration)
@Experimental public JedisCluster(java.util.Set<HostAndPort> hnp, JedisClientConfig jedisClientConfig, CacheConfig cacheConfig)
@Experimental public JedisCluster(java.util.Set<HostAndPort> clusterNodes, JedisClientConfig clientConfig, Cache clientSideCache)
@Experimental public JedisCluster(java.util.Set<HostAndPort> clusterNodes, JedisClientConfig clientConfig, Cache clientSideCache, int maxAttempts, java.time.Duration maxTotalRetriesDuration)
@Experimental public JedisCluster(java.util.Set<HostAndPort> clusterNodes, JedisClientConfig clientConfig, Cache clientSideCache, int maxAttempts, java.time.Duration maxTotalRetriesDuration, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
@Experimental public JedisCluster(java.util.Set<HostAndPort> clusterNodes, JedisClientConfig clientConfig, Cache clientSideCache, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
@Experimental public JedisCluster(java.util.Set<HostAndPort> clusterNodes, JedisClientConfig clientConfig, Cache clientSideCache, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig, java.time.Duration topologyRefreshPeriod, int maxAttempts, java.time.Duration maxTotalRetriesDuration)
public static JedisCluster.Builder builder()
JedisCluster.Builder instancepublic java.util.Map<java.lang.String,ConnectionPool> getClusterNodes()
Map).public Connection getConnectionFromSlot(int slot)
slot - the slot to retrieve the connection for.close() of this connection must be called after use.public long spublish(java.lang.String channel,
java.lang.String message)
public long spublish(byte[] channel,
byte[] message)
public void ssubscribe(JedisShardedPubSub jedisPubSub, java.lang.String... channels)
public void ssubscribe(BinaryJedisShardedPubSub jedisPubSub, byte[]... channels)
public ClusterPipeline pipelined()
Pipelining allows batching multiple commands for more efficient execution by reducing network round-trips. In a cluster environment, commands are routed to the appropriate nodes based on key hash slots.
If the pipeline spans multiple nodes, a dedicated ExecutorService is
created internally to execute requests in parallel and shutdown when the pipeline
is synced.
pipelined in class UnifiedJedisClusterPipeline instancepipelined(ExecutorService)public ClusterPipeline pipelined(java.util.concurrent.ExecutorService executorService)
Pipelining allows batching multiple commands for more efficient execution by reducing network round-trips. In a cluster environment, commands are routed to the appropriate nodes based on key hash slots.
If the pipeline spans multiple nodes, the provided ExecutorService is
used to execute requests in parallel. The caller is responsible for managing
the lifecycle of this executor (creation, shutdown, etc.).
If null is provided, a dedicated executor is created and managed
internally, similar to pipelined().
executorService - the executor to use for multi-node execution, or nullClusterPipeline instancepublic AbstractTransaction transaction(boolean doMulti)
transaction in class UnifiedJedisdoMulti - paramjava.lang.UnsupportedOperationExceptionpublic final <T> T executeCommandToReplica(CommandObject<T> commandObject)
Copyright © 2026. All rights reserved.