public interface RedisConnection extends RedisCommands, AutoCloseable
RedisStringCommands.BitOperation, RedisStringCommands.SetOption
RedisListCommands.Position
RedisZSetCommands.Aggregate, RedisZSetCommands.Limit, RedisZSetCommands.Range, RedisZSetCommands.Tuple, RedisZSetCommands.Weights, RedisZSetCommands.ZAddArgs
RedisServerCommands.MigrateOption, RedisServerCommands.ShutdownOption
RedisStreamCommands.XAddOptions, RedisStreamCommands.XClaimOptions, RedisStreamCommands.XPendingOptions
RedisGeoCommands.DistanceUnit, RedisGeoCommands.GeoLocation<T>, RedisGeoCommands.GeoRadiusCommandArgs
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes (or quits) the connection.
|
List<Object> |
closePipeline()
Executes the commands in the pipeline and returns their result.
|
default RedisGeoCommands |
geoCommands()
Get
RedisGeoCommands . |
Object |
getNativeConnection()
Returns the native connection (the underlying library/driver object).
|
RedisSentinelConnection |
getSentinelConnection() |
default RedisHashCommands |
hashCommands()
Get
RedisHashCommands . |
default RedisHyperLogLogCommands |
hyperLogLogCommands()
|
boolean |
isClosed()
Indicates whether the underlying connection is closed or not.
|
boolean |
isPipelined()
Indicates whether the connection is currently pipelined or not.
|
boolean |
isQueueing()
Indicates whether the connection is in "queue"(or "MULTI") mode or not.
|
default RedisKeyCommands |
keyCommands()
Get
RedisKeyCommands . |
default RedisListCommands |
listCommands()
Get
RedisListCommands . |
void |
openPipeline()
Activates the pipeline mode for this connection.
|
default RedisScriptingCommands |
scriptingCommands()
|
default RedisServerCommands |
serverCommands()
Get
RedisServerCommands . |
default RedisSetCommands |
setCommands()
Get
RedisSetCommands . |
default RedisStreamCommands |
streamCommands()
Get
RedisStreamCommands . |
default RedisStringCommands |
stringCommands()
Get
RedisStringCommands . |
default RedisZSetCommands |
zSetCommands()
Get
RedisZSetCommands . |
execute
del, dump, encodingOf, exists, exists, expire, expireAt, idletime, keys, move, persist, pExpire, pExpireAt, pTtl, pTtl, randomKey, refcount, rename, renameNX, restore, restore, scan, sort, sort, touch, ttl, ttl, type, unlink
append, bitCount, bitCount, bitField, bitOp, bitPos, bitPos, decr, decrBy, get, getBit, getRange, getSet, incr, incrBy, incrBy, mGet, mSet, mSetNX, pSetEx, set, set, setBit, setEx, setNX, setRange, strLen
bLPop, bRPop, bRPopLPush, lIndex, lInsert, lLen, lPop, lPos, lPos, lPush, lPushX, lRange, lRem, lSet, lTrim, rPop, rPopLPush, rPush, rPushX
sAdd, sCard, sDiff, sDiffStore, sInter, sInterStore, sIsMember, sMembers, sMove, sPop, sPop, sRandMember, sRandMember, sRem, sScan, sUnion, sUnionStore
zAdd, zAdd, zAdd, zAdd, zCard, zCount, zCount, zIncrBy, zInterStore, zInterStore, zInterStore, zLexCount, zRange, zRangeByLex, zRangeByLex, zRangeByLex, zRangeByScore, zRangeByScore, zRangeByScore, zRangeByScore, zRangeByScore, zRangeByScore, zRangeByScoreWithScores, zRangeByScoreWithScores, zRangeByScoreWithScores, zRangeByScoreWithScores, zRangeWithScores, zRank, zRem, zRemRange, zRemRangeByLex, zRemRangeByScore, zRemRangeByScore, zRevRange, zRevRangeByLex, zRevRangeByLex, zRevRangeByLex, zRevRangeByScore, zRevRangeByScore, zRevRangeByScore, zRevRangeByScore, zRevRangeByScoreWithScores, zRevRangeByScoreWithScores, zRevRangeByScoreWithScores, zRevRangeByScoreWithScores, zRevRangeWithScores, zRevRank, zScan, zScore, zUnionStore, zUnionStore, zUnionStore
hDel, hExists, hGet, hGetAll, hIncrBy, hIncrBy, hKeys, hLen, hMGet, hMSet, hScan, hSet, hSetNX, hStrLen, hVals
discard, exec, multi, unwatch, watch
getSubscription, isSubscribed, pSubscribe, publish, subscribe
echo, ping, select
bgReWriteAof, bgSave, bgWriteAof, dbSize, flushAll, flushDb, getClientList, getClientName, getConfig, info, info, killClient, lastSave, migrate, migrate, resetConfigStats, rewriteConfig, save, setClientName, setConfig, shutdown, shutdown, slaveOf, slaveOfNoOne, time, time
xAck, xAck, xAdd, xAdd, xAdd, xClaim, xClaim, xClaimJustId, xDel, xDel, xGroupCreate, xGroupCreate, xGroupDelConsumer, xGroupDelConsumer, xGroupDestroy, xInfo, xInfoConsumers, xInfoGroups, xLen, xPending, xPending, xPending, xPending, xPending, xPending, xPending, xRange, xRange, xRead, xRead, xReadGroup, xReadGroup, xRevRange, xRevRange, xTrim, xTrim
eval, evalSha, evalSha, scriptExists, scriptFlush, scriptKill, scriptLoad
geoAdd, geoAdd, geoAdd, geoAdd, geoDist, geoDist, geoHash, geoPos, geoRadius, geoRadius, geoRadiusByMember, geoRadiusByMember, geoRadiusByMember, geoRemove
pfAdd, pfCount, pfMerge
default RedisGeoCommands geoCommands()
RedisGeoCommands
.default RedisHashCommands hashCommands()
RedisHashCommands
.default RedisHyperLogLogCommands hyperLogLogCommands()
default RedisKeyCommands keyCommands()
RedisKeyCommands
.default RedisListCommands listCommands()
RedisListCommands
.default RedisSetCommands setCommands()
RedisSetCommands
.default RedisScriptingCommands scriptingCommands()
default RedisServerCommands serverCommands()
RedisServerCommands
.default RedisStreamCommands streamCommands()
RedisStreamCommands
.default RedisStringCommands stringCommands()
RedisStringCommands
.default RedisZSetCommands zSetCommands()
RedisZSetCommands
.void close() throws DataAccessException
close
in interface AutoCloseable
DataAccessException
boolean isClosed()
Object getNativeConnection()
boolean isQueueing()
boolean isPipelined()
openPipeline()
,
isQueueing()
void openPipeline()
closePipeline()
. Calling this method when the connection is already pipelined has no effect.
Pipelining is used for issuing commands without requesting the response right away but rather at the end of the
batch. While somewhat similar to MULTI, pipelining does not guarantee atomicity - it only tries to improve
performance when issuing a lot of commands (such as in batching scenarios).
Note:
Consider doing some performance testing before using this feature since in many cases the performance benefits are minimal yet the impact on usage are not.RedisTxCommands.multi()
List<Object> closePipeline() throws RedisPipelineException
RedisPipelineException
- if the pipeline contains any incorrect/invalid statementsRedisSentinelConnection getSentinelConnection()
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.