クラス JedisClusterConnection
java.lang.ObjectSE
org.springframework.data.redis.connection.jedis.JedisClusterConnection
- 実装済みのインターフェース一覧:
AutoCloseableSE、DefaultedRedisClusterConnection、DefaultedRedisConnection、RedisClusterCommands、RedisClusterCommandsProvider、RedisClusterConnection、RedisClusterServerCommands、RedisCommands、RedisCommandsProvider、RedisConnection、RedisConnectionCommands、RedisGeoCommands、RedisHashCommands、RedisHyperLogLogCommands、RedisKeyCommands、RedisListCommands、RedisPubSubCommands、RedisScriptingCommands、RedisServerCommands、RedisSetCommands、RedisStreamCommands、RedisStringCommands、RedisTxCommands、RedisZSetCommands
JedisCluster の上に RedisClusterConnection 実装。可能な場合はネイティブ
JedisCluster API を使用し、必要に応じて Jedis を使用して直接ノード通信にフォールバックします。このクラスはスレッドセーフではないため、インスタンスをスレッド間で共有しないでください。
- 導入:
- 1.7
- 作成者:
- Christoph Strobl, Mark Paluch, Ninad Divadkar, Tao Chen, Chen Guanqun, Pavel Khokhlov, Liming Deng, John Blum
ネストされたクラスの概要
ネストされたクラス修飾子と型クラス説明protected static interfaceprotected static classstatic classClusterTopologyProviderのジェダイ固有の実装。protected static interfaceインターフェース org.springframework.data.redis.connection.RedisClusterCommands から継承されたネストクラス / インターフェース
RedisClusterCommands.AddSlotsインターフェース org.springframework.data.redis.connection.RedisGeoCommands から継承されたネストクラス / インターフェース
RedisGeoCommands.DistanceUnit, RedisGeoCommands.GeoCommandArgs, RedisGeoCommands.GeoLocation<T>, RedisGeoCommands.GeoRadiusCommandArgs, RedisGeoCommands.GeoSearchCommandArgs, RedisGeoCommands.GeoSearchStoreCommandArgsインターフェース org.springframework.data.redis.connection.RedisListCommands から継承されたネストクラス / インターフェース
RedisListCommands.Direction, RedisListCommands.Positionインターフェース org.springframework.data.redis.connection.RedisServerCommands から継承されたネストクラス / インターフェース
RedisServerCommands.FlushOption, RedisServerCommands.MigrateOption, RedisServerCommands.ShutdownOptionインターフェース org.springframework.data.redis.connection.RedisStreamCommands から継承されたネストクラス / インターフェース
RedisStreamCommands.XAddOptions, RedisStreamCommands.XClaimOptions, RedisStreamCommands.XPendingOptionsインターフェース org.springframework.data.redis.connection.RedisStringCommands から継承されたネストクラス / インターフェース
RedisStringCommands.BitOperation, RedisStringCommands.SetOptionインターフェース org.springframework.data.redis.connection.RedisZSetCommands から継承されたネストクラス / インターフェース
RedisZSetCommands.Limit, RedisZSetCommands.Range, RedisZSetCommands.ZAddArgsコンストラクター概要
コンストラクターコンストラクター説明JedisClusterConnection(redis.clients.jedis.JedisCluster cluster) JedisClusterを介したネイティブ接続を利用して新しいJedisClusterConnectionを作成します。JedisClusterConnection(redis.clients.jedis.JedisCluster cluster, ClusterCommandExecutor executor) 指定されたClusterCommandExecutorを介してクラスター全体でコマンドを実行するJedisClusterを介したネイティブ接続を利用して、新しいJedisClusterConnectionを作成します。JedisClusterConnection(redis.clients.jedis.JedisCluster cluster, ClusterCommandExecutor executor, ClusterTopologyProvider topologyProvider) 指定されたClusterCommandExecutorを介してクラスター全体でコマンドを実行し、指定されたClusterTopologyProviderを使用して、JedisClusterを介したネイティブ接続を利用して新しいJedisClusterConnectionを作成します。方法の概要
修飾子と型メソッド説明voidclose()接続を閉じるか終了します。パイプラインでコマンドを実行し、その結果を返します。voidclusterAddSlots(RedisClusterNode node, int... slots) 指定されたRedisClusterNodeにスロットを割り当てます。voidclusterAddSlots(RedisClusterNode node, RedisClusterNode.SlotRange range) 指定されたRedisClusterNodeにRedisClusterNode.SlotRange.getSlotsArray()を割り当てます。RedisGeoCommandsを取得します。clusterCountKeysInSlot(int slot) 1 つのスロットに割り当てられたキーの数を数えます。voidclusterDeleteSlots(RedisClusterNode node, int... slots) RedisClusterNodeからスロットを取り外します。void指定されたRedisClusterNodeからRedisClusterNode.SlotRange.getSlotsArray()を削除します。void指定されたノードをクラスターから削除します。クラスター情報を取得します。ListSE<byte[]>clusterGetKeysInSlot(int slot, IntegerSE count) スロットによって提供されるキーを取得します。マスターとそれに接続されたレプリカに関する情報を取得します。clusterGetNodeForKey(byte[] key) 与えられたキーを提供するRedisClusterNodeを見つけます。clusterGetNodeForSlot(int slot) 指定されたスロットにサービスを提供しているRedisClusterNodeを見つけます。ID、ホスト、ポート、スロットなどのクラスターノード情報を取得します。clusterGetReplicas(RedisClusterNode master) 特定のマスターノードの接続されたレプリカに関する情報を取得します。clusterGetSlotForKey(byte[] key) 特定のkeyのスロットを見つけます。voidclusterMeet(RedisClusterNode node) 指定されたノードをクラスターに追加します。voidclusterReplicate(RedisClusterNode master, RedisClusterNode replica) 指定されたマスターにレプリカを割り当てます。voidclusterSetSlot(RedisClusterNode node, int slot, RedisClusterCommands.AddSlots mode) commands()RedisCommandsを取得します。protected DataAccessExceptionvoiddiscard()RedisTxCommands.multi()の後に発行されたすべてのコマンドを破棄します。byte[]echo(byte[] message) サーバーラウンドトリップを介してmessageを返します。exec()RedisTxCommands.multi()で開始されたトランザクションでキューに入れられたすべてのコマンドを実行します。指定された Redis コマンドと指定された引数のネイティブまたは生の実行。<T> Texecute(StringSE command, byte[] key, CollectionSE<byte[]> args) 追加される可能性のある引数が提供されたkeyに対して、指定されたコマンドを実行します。<T> ListSE<T>execute(StringSE command, CollectionSE<byte[]> keys, CollectionSE<byte[]> args) 提供されたkeysの各キーに対して指定されたコマンドを実行し、呼び出しごとにすべてのargsを追加します。RedisGeoCommandsを取得します。protected redis.clients.jedis.JedisClusterprotected ClusterCommandExecutorredis.clients.jedis.JedisClusterネイティブ接続(基になるライブラリ / ドライバオブジェクト)を返します。この接続の現在のサブスクリプションを返します。接続がサブスクライブされていない場合は null を返します。protected ClusterTopologyProviderRedisHashCommandsを取得します。RedisHyperLogLogCommandsを取得します。booleanisClosed()基になる接続が閉じているかどうかを示します。boolean接続が現在パイプライン化されているかどうかを示します。boolean接続が「キュー」(または「マルチ」)モードであるかどうかを示します。boolean現在の接続が(少なくとも 1 つのチャネルに)サブスクライブされているかどうかを示します。RedisKeyCommandsを取得します。SetSE<byte[]>keys(RedisClusterNode node, byte[] pattern) RedisListCommandsを取得します。voidmulti()トランザクションブロックの開始をマークします。voidこの接続のパイプラインモードをアクティブにします。ping()接続のテスト。ping(RedisClusterNode node) voidpSubscribe(MessageListener listener, byte[]... patterns) 指定されたパターンに一致するすべてのチャネルへの接続をサブスクライブします。publish(byte[] channel, byte[] message) 指定されたメッセージを指定されたチャネルに公開します。byte[]randomKey(RedisClusterNode node) voidredis.confファイルを書き換えます。Cursor<byte[]>scan(RedisClusterNode node, ScanOptions options) Cursorを使用して、キーを繰り返し処理します。RedisScriptingCommandsを取得します。voidselect(int dbIndex) 正のdbIndexが指定された DB を選択します。RedisServerCommandsを取得します。RedisSetCommandsを取得します。RedisStreamCommandsを取得します。RedisStringCommandsを取得します。voidsubscribe(MessageListener listener, byte[]... channels) 指定されたチャネルへの接続をサブスクライブします。voidunwatch()以前のすべてのRedisTxCommands.watch(byte[]...)キーをフラッシュします。voidwatch(byte[]... keys) RedisTxCommands.multi()で開始されたトランザクション中の変更について、指定されたkeysを監視します。RedisZSetCommandsを取得します。クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース org.springframework.data.redis.connection.DefaultedRedisClusterConnection から継承されたメソッド
bgReWriteAof, bgSave, dbSize, flushAll, flushAll, flushDb, flushDb, getClientList, getConfig, info, info, lastSave, resetConfigStats, rewriteConfig, save, setConfig, shutdown, time, timeインターフェース org.springframework.data.redis.connection.DefaultedRedisConnection から継承されたメソッド
append, applyHashFieldExpiration, bgReWriteAof, bgSave, bitCount, bitCount, bitField, bitOp, bitPos, bLMove, bLPop, bRPop, bRPopLPush, bZPopMax, bZPopMin, copy, dbSize, decr, decrBy, del, dump, encodingOf, eval, evalSha, evalSha, exists, exists, expire, expire, expireAt, expireAt, flushAll, flushAll, flushDb, flushDb, geoAdd, geoAdd, geoAdd, geoDist, geoDist, geoHash, geoPos, geoRadius, geoRadius, geoRadiusByMember, geoRadiusByMember, geoRemove, geoSearch, geoSearchStore, get, getBit, getClientList, getClientName, getConfig, getDel, getEx, getRange, getSet, hDel, hExists, hExpire, hExpire, hExpireAt, hExpireAt, hGet, hGetAll, hIncrBy, hIncrBy, hKeys, hLen, hMGet, hMSet, hPersist, hpExpire, hpExpire, hpExpireAt, hpExpireAt, hpTtl, hRandField, hRandField, hRandFieldWithValues, hRandFieldWithValues, hScan, hSet, hSetNX, hStrLen, hTtl, hTtl, hVals, idletime, incr, incrBy, incrBy, info, info, keys, killClient, lastSave, lIndex, lInsert, lLen, lMove, lPop, lPop, lPos, lPush, lPushX, lRange, lRem, lSet, lTrim, mGet, migrate, migrate, move, mSet, mSetNX, persist, pExpire, pExpire, pExpireAt, pExpireAt, pfAdd, pfCount, pfMerge, pSetEx, pTtl, pTtl, randomKey, refcount, rename, renameNX, replicaOf, replicaOfNoOne, resetConfigStats, restore, rPop, rPop, rPopLPush, rPush, rPushX, sAdd, save, scan, sCard, scriptExists, scriptFlush, scriptKill, scriptLoad, sDiff, sDiffStore, set, set, setBit, setClientName, setConfig, setEx, setGet, setNX, setRange, shutdown, shutdown, sInter, sInterStore, sIsMember, sMembers, sMIsMember, sMove, sort, sort, sPop, sPop, sRandMember, sRandMember, sRem, sScan, strLen, sUnion, sUnionStore, time, time, touch, ttl, ttl, type, unlink, xAck, xAdd, xClaim, xClaimJustId, xDel, xGroupCreate, xGroupCreate, xGroupDelConsumer, xGroupDestroy, xInfo, xInfoConsumers, xInfoGroups, xLen, xPending, xPending, xRange, xRange, xRead, xRead, xReadGroup, xReadGroup, xRevRange, xRevRange, xTrim, xTrim, zAdd, zAdd, zCard, zCount, zCount, zDiff, zDiffStore, zDiffWithScores, zIncrBy, zInter, zInterStore, zInterStore, zInterStore, zInterWithScores, zInterWithScores, zInterWithScores, zLexCount, zMScore, zPopMax, zPopMax, zPopMin, zPopMin, zRandMember, zRandMember, zRandMemberWithScore, zRandMemberWithScore, zRange, zRangeByLex, zRangeByScore, zRangeByScore, zRangeByScore, zRangeByScoreWithScores, zRangeStoreByLex, zRangeStoreByScore, zRangeStoreRevByLex, zRangeStoreRevByScore, zRangeWithScores, zRank, zRem, zRemRange, zRemRangeByLex, zRemRangeByScore, zRemRangeByScore, zRevRange, zRevRangeByLex, zRevRangeByScore, zRevRangeByScoreWithScores, zRevRangeWithScores, zRevRank, zScan, zScore, zUnion, zUnionStore, zUnionStore, zUnionStore, zUnionWithScores, zUnionWithScores, zUnionWithScoresインターフェース org.springframework.data.redis.connection.RedisGeoCommands から継承されたメソッド
geoAdd, geoRadiusByMemberインターフェース org.springframework.data.redis.connection.RedisHashCommands から継承されたメソッド
applyHashFieldExpiration, hExpire, hpExpireインターフェース org.springframework.data.redis.connection.RedisKeyCommands から継承されたメソッド
applyExpiration, expire, expireAt, pExpire, pExpireAt, restore, scanインターフェース org.springframework.data.redis.connection.RedisListCommands から継承されたメソッド
lPosインターフェース org.springframework.data.redis.connection.RedisStreamCommands から継承されたメソッド
xAck, xAdd, xAdd, xClaim, xDel, xGroupDelConsumer, xPending, xPending, xPending, xPending, xPendingインターフェース org.springframework.data.redis.connection.RedisStringCommands から継承されたメソッド
bitPosインターフェース org.springframework.data.redis.connection.RedisZSetCommands から継承されたメソッド
zAdd, zAdd, zRangeByLex, zRangeByLex, zRangeByScore, zRangeByScore, zRangeByScore, zRangeByScoreWithScores, zRangeByScoreWithScores, zRangeByScoreWithScores, zRangeStoreByLex, zRangeStoreByScore, zRangeStoreRevByLex, zRangeStoreRevByScore, zRevRangeByLex, zRevRangeByLex, zRevRangeByScore, zRevRangeByScore, zRevRangeByScore, zRevRangeByScoreWithScores, zRevRangeByScoreWithScores, zRevRangeByScoreWithScores
コンストラクターの詳細
JedisClusterConnection
public JedisClusterConnection(redis.clients.jedis.JedisCluster cluster) JedisClusterを介したネイティブ接続を利用して新しいJedisClusterConnectionを作成します。- パラメーター:
cluster- null であってはなりません。
JedisClusterConnection
public JedisClusterConnection(redis.clients.jedis.JedisCluster cluster, ClusterCommandExecutor executor) 指定されたClusterCommandExecutorを介してクラスター全体でコマンドを実行するJedisClusterを介したネイティブ接続を利用して、新しいJedisClusterConnectionを作成します。デフォルトでJedisClusterConnection.JedisClusterTopologyProviderを使用します。- パラメーター:
cluster- null であってはなりません。executor- null であってはなりません。
JedisClusterConnection
public JedisClusterConnection(redis.clients.jedis.JedisCluster cluster, ClusterCommandExecutor executor, ClusterTopologyProvider topologyProvider) 指定されたClusterCommandExecutorを介してクラスター全体でコマンドを実行し、指定されたClusterTopologyProviderを使用して、JedisClusterを介したネイティブ接続を利用して新しいJedisClusterConnectionを作成します。- パラメーター:
cluster- null であってはなりません。executor- null であってはなりません。topologyProvider- null であってはなりません。- 導入:
- 2.2
方法の詳細
execute
インターフェースからコピーされた説明:RedisCommands指定された Redis コマンドと指定された引数のネイティブまたは生の実行。コマンドは、できる限り解釈を少なくしてそのまま実行されます。引数や結果の処理は呼び出し側の責任になります。
- 次で指定:
- インターフェース
RedisCommands内のexecute - パラメーター:
command- RediscommandSE を実行します。null であってはなりません。args- オプションのコマンド引数の配列。空の場合もあります。- 戻り値:
- 実行結果。null の場合もあります。
execute
インターフェースからコピーされた説明:RedisClusterConnection与えられたkeyに対して指定されたコマンドを実行し、引数を追加する可能性があります。
RedisCommands.execute(String, byte[]...)以外のこのメソッドは、コマンドをkeyサービングマスターノードにディスパッチします。// SET foo bar EX 10 NX execute("SET", "foo".getBytes(), asBinaryList("bar", "EX", 10, "NX"))- 次で指定:
- インターフェース
RedisClusterConnection内のexecute - パラメーター:
command- null であってはなりません。key- null であってはなりません。args- null であってはなりません。- 戻り値:
- 基礎となる Redis ドライバーによって提供されるコマンド結果。null にすることができます。
execute
@Nullable public <T> ListSE<T> execute(StringSE command, CollectionSE<byte[]> keys, CollectionSE<byte[]> args) 呼び出しごとにすべてのargsを追加して、指定されたkeysの各キーに対して指定されたコマンドを実行します。
execute(String, byte[]...)以外のこのメソッドは、コマンドをkeyサービングマスターノードにディスパッチし、keyを最初のコマンド引数としてcommandに追加します。keysは、単一キーコマンド用に同じスロットを共有する必要はありません。argsでキーを運ぶマルチキーコマンドは、keyと同じスロットを共有する必要があります。// SET foo bar EX 10 NX execute("SET", "foo".getBytes(), asBinaryList("bar", "EX", 10, "NX"))- パラメーター:
command- null であってはなりません。keys- null であってはなりません。args- null であってはなりません。- 戻り値:
- 基礎となる Redis ドライバーによって提供されるコマンド結果。null にすることができます。
- 導入:
- 2.1
commands
インターフェースからコピーされた説明:RedisCommandsProviderRedisCommandsを取得します。- 次で指定:
- インターフェース
RedisCommandsProvider内のcommands - 戻り値:
- 決して null にはなりません。
clusterCommands
インターフェースからコピーされた説明:RedisClusterCommandsProviderRedisGeoCommandsを取得します。- 次で指定:
- インターフェース
RedisClusterCommandsProvider内のclusterCommands - 戻り値:
- 決して null にはなりません。
geoCommands
インターフェースからコピーされた説明:RedisCommandsProviderRedisGeoCommandsを取得します。- 次で指定:
- インターフェース
RedisCommandsProvider内のgeoCommands - 戻り値:
- 決して null にはなりません。
hashCommands
インターフェースからコピーされた説明:RedisCommandsProviderRedisHashCommandsを取得します。- 次で指定:
- インターフェース
RedisCommandsProvider内のhashCommands - 戻り値:
- 決して null にはなりません。
hyperLogLogCommands
インターフェースからコピーされた説明:RedisCommandsProviderRedisHyperLogLogCommandsを取得します。- 次で指定:
- インターフェース
RedisCommandsProvider内のhyperLogLogCommands - 戻り値:
- 決して null にはなりません。
keyCommands
インターフェースからコピーされた説明:RedisCommandsProviderRedisKeyCommandsを取得します。- 次で指定:
- インターフェース
RedisCommandsProvider内のkeyCommands - 戻り値:
- 決して null にはなりません。
listCommands
インターフェースからコピーされた説明:RedisCommandsProviderRedisListCommandsを取得します。- 次で指定:
- インターフェース
RedisCommandsProvider内のlistCommands - 戻り値:
- 決して null にはなりません。
setCommands
インターフェースからコピーされた説明:RedisCommandsProviderRedisSetCommandsを取得します。- 次で指定:
- インターフェース
RedisCommandsProvider内のsetCommands - 戻り値:
- 決して null にはなりません。
serverCommands
インターフェースからコピーされた説明:RedisCommandsProviderRedisServerCommandsを取得します。- 次で指定:
- インターフェース
RedisClusterCommandsProvider内のserverCommands - 次で指定:
- インターフェース
RedisCommandsProvider内のserverCommands - 戻り値:
- 決して null にはなりません。
streamCommands
インターフェースからコピーされた説明:RedisCommandsProviderRedisStreamCommandsを取得します。- 次で指定:
- インターフェース
RedisCommandsProvider内のstreamCommands - 戻り値:
- 決して null にはなりません。
stringCommands
インターフェースからコピーされた説明:RedisCommandsProviderRedisStringCommandsを取得します。- 次で指定:
- インターフェース
RedisCommandsProvider内のstringCommands - 戻り値:
- 決して null にはなりません。
zSetCommands
インターフェースからコピーされた説明:RedisCommandsProviderRedisZSetCommandsを取得します。- 次で指定:
- インターフェース
RedisCommandsProvider内のzSetCommands - 戻り値:
- 決して null にはなりません。
scriptingCommands
インターフェースからコピーされた説明:RedisCommandsProviderRedisScriptingCommandsを取得します。- 次で指定:
- インターフェース
RedisCommandsProvider内のscriptingCommands - 戻り値:
- 決して null にはなりません。
keys
- 次で指定:
- インターフェース
RedisClusterConnection内のkeys - パラメーター:
node- null であってはなりません。pattern- null であってはなりません。- 戻り値:
- パイプライン / トランザクションで使用される場合は null。
- 関連事項:
scan
インターフェースからコピーされた説明:RedisClusterConnectionCursorを使用して、キーを繰り返し処理します。- 次で指定:
- インターフェース
RedisClusterConnection内のscan - パラメーター:
node- null であってはなりません。options- null であってはなりません。- 戻り値:
- 決して null にはなりません。
- 関連事項:
randomKey
- 次で指定:
- インターフェース
RedisClusterConnection内のrandomKey - パラメーター:
node- null であってはなりません。- 戻り値:
- ノードにキーが保存されていない場合、またはパイプライン / トランザクションで使用されている場合は null。
- 関連事項:
multi
public void multi()インターフェースからコピーされた説明:RedisTxCommandsトランザクションブロックの開始をマークします。
コマンドはキューに入れられ、RedisTxCommands.exec()を呼び出すことによって実行するか、RedisTxCommands.discard()を使用してロールバックすることができます。- 次で指定:
- インターフェース
RedisTxCommands内のmulti - 関連事項:
exec
インターフェースからコピーされた説明:RedisTxCommandsRedisTxCommands.multi()で開始されたトランザクションでキューに入れられたすべてのコマンドを実行します。
RedisTxCommands.watch(byte[]...)と一緒に使用する場合、監視対象のキーのいずれかが変更されていると、操作は失敗します。- 次で指定:
- インターフェース
RedisTxCommands内のexec - 戻り値:
- 実行された各コマンドに対する応答のリスト。
- 関連事項:
discard
public void discard()インターフェースからコピーされた説明:RedisTxCommandsRedisTxCommands.multi()の後に発行されたすべてのコマンドを破棄します。- 次で指定:
- インターフェース
RedisTxCommands内のdiscard - 関連事項:
watch
public void watch(byte[]... keys) インターフェースからコピーされた説明:RedisTxCommandsRedisTxCommands.multi()で開始されたトランザクション中の変更について、指定されたkeysを監視します。- 次で指定:
- インターフェース
RedisTxCommands内のwatch - パラメーター:
keys- null であってはなりません。- 関連事項:
unwatch
public void unwatch()インターフェースからコピーされた説明:RedisTxCommands以前のすべてのRedisTxCommands.watch(byte[]...)キーをフラッシュします。- 次で指定:
- インターフェース
RedisTxCommands内のunwatch - 関連事項:
isSubscribed
public boolean isSubscribed()インターフェースからコピーされた説明:RedisPubSubCommands現在の接続が(少なくとも 1 つのチャネルに)サブスクライブされているかどうかを示します。- 次で指定:
- インターフェース
RedisPubSubCommands内のisSubscribed - 戻り値:
- 接続がサブスクライブされている場合は true、それ以外の場合は false
getSubscription
インターフェースからコピーされた説明:RedisPubSubCommandsこの接続の現在のサブスクリプションを返します。接続がサブスクライブされていない場合は null を返します。- 次で指定:
- インターフェース
RedisPubSubCommands内のgetSubscription - 戻り値:
- 現在のサブスクリプション。使用可能なサブスクリプションがない場合は null。
publish
インターフェースからコピーされた説明:RedisPubSubCommands指定されたメッセージを指定されたチャネルに公開します。- 次で指定:
- インターフェース
RedisPubSubCommands内のpublish - パラメーター:
channel- 公開するチャネル。null であってはなりません。message- 公開するメッセージ。null であってはなりません。- 戻り値:
- メッセージを受信したクライアントの数、またはパイプライン / トランザクションで使用されたときに null。
- 関連事項:
subscribe
インターフェースからコピーされた説明:RedisPubSubCommands指定されたチャネルへの接続をサブスクライブします。サブスクライブすると、接続はリスニングモードになり、他のチャネルにサブスクライブするか、サブスクライブを解除することしかできません。接続がサブスクライブ解除されるまで、他のコマンドは受け入れられません。この操作はブロックされており、現在のスレッドはすぐに新しいメッセージの待機を開始することに注意してください。
- 次で指定:
- インターフェース
RedisPubSubCommands内のsubscribe - パラメーター:
listener- メッセージリスナー。null であってはなりません。channels- チャネル名は null であってはなりません。- 関連事項:
pSubscribe
インターフェースからコピーされた説明:RedisPubSubCommands指定されたパターンに一致するすべてのチャネルへの接続をサブスクライブします。サブスクライブすると、接続はリスニングモードになり、他のチャネルにサブスクライブするか、サブスクライブを解除することしかできません。接続がサブスクライブ解除されるまで、他のコマンドは受け入れられません。この操作はブロックされており、現在のスレッドはすぐに新しいメッセージの待機を開始することに注意してください。
- 次で指定:
- インターフェース
RedisPubSubCommands内のpSubscribe - パラメーター:
listener- メッセージリスナー。null であってはなりません。patterns- チャネル名パターン。null であってはなりません。- 関連事項:
select
public void select(int dbIndex) インターフェースからコピーされた説明:RedisConnectionCommands正のdbIndexが指定された DB を選択します。- 次で指定:
- インターフェース
RedisConnectionCommands内のselect - パラメーター:
dbIndex- データベースインデックス。- 関連事項:
echo
public byte[] echo(byte[] message) インターフェースからコピーされた説明:RedisConnectionCommandsサーバーラウンドトリップを介してmessageを返します。- 次で指定:
- インターフェース
RedisConnectionCommands内のecho - パラメーター:
message- エコーするメッセージ。- 戻り値:
- メッセージまたはパイプライン / トランザクションで使用される場合は null。
- 関連事項:
ping
インターフェースからコピーされた説明:RedisConnectionCommands接続のテスト。- 次で指定:
- インターフェース
RedisConnectionCommands内のping - 戻り値:
- サーバーレスポンスメッセージ - 通常は PONG。パイプライン / トランザクションで使用される場合は null。
- 関連事項:
ping
- 次で指定:
- インターフェース
RedisClusterConnection内のping - パラメーター:
node- null であってはなりません。- 戻り値:
- パイプライン / トランザクションで使用される場合は null。
- 関連事項:
clusterSetSlot
- 次で指定:
- インターフェース
RedisClusterCommands内のclusterSetSlot - パラメーター:
node- null であってはなりません。mode- null であってはなりません。- 関連事項:
clusterGetKeysInSlot
インターフェースからコピーされた説明:RedisClusterCommandsスロットによって提供されるキーを取得します。- 次で指定:
- インターフェース
RedisClusterCommands内のclusterGetKeysInSlot count- null であってはなりません。- 戻り値:
- 関連事項:
clusterAddSlots
インターフェースからコピーされた説明:RedisClusterCommands指定されたRedisClusterNodeにスロットを割り当てます。- 次で指定:
- インターフェース
RedisClusterCommands内のclusterAddSlots - パラメーター:
node- null であってはなりません。- 関連事項:
clusterAddSlots
インターフェースからコピーされた説明:RedisClusterCommands指定されたRedisClusterNodeにRedisClusterNode.SlotRange.getSlotsArray()を割り当てます。- 次で指定:
- インターフェース
RedisClusterCommands内のclusterAddSlots - パラメーター:
node- null であってはなりません。range- null であってはなりません。- 関連事項:
clusterCountKeysInSlot
インターフェースからコピーされた説明:RedisClusterCommands1 つのスロットに割り当てられたキーの数を数えます。- 次で指定:
- インターフェース
RedisClusterCommands内のclusterCountKeysInSlot - 戻り値:
- 関連事項:
clusterDeleteSlots
インターフェースからコピーされた説明:RedisClusterCommandsRedisClusterNodeからスロットを取り外します。- 次で指定:
- インターフェース
RedisClusterCommands内のclusterDeleteSlots - パラメーター:
node- null であってはなりません。- 関連事項:
clusterDeleteSlotsInRange
インターフェースからコピーされた説明:RedisClusterCommands指定されたRedisClusterNodeからRedisClusterNode.SlotRange.getSlotsArray()を削除します。- 次で指定:
- インターフェース
RedisClusterCommands内のclusterDeleteSlotsInRange - パラメーター:
node- null であってはなりません。range- null であってはなりません。- 関連事項:
clusterForget
インターフェースからコピーされた説明:RedisClusterCommands指定されたノードをクラスターから削除します。- 次で指定:
- インターフェース
RedisClusterCommands内のclusterForget - パラメーター:
node- null であってはなりません。- 関連事項:
clusterMeet
インターフェースからコピーされた説明:RedisClusterCommands指定されたノードをクラスターに追加します。- 次で指定:
- インターフェース
RedisClusterCommands内のclusterMeet - パラメーター:
node-hostおよびRedisNode.getPort()を含む必要があり、null であってはなりません。- 関連事項:
clusterReplicate
インターフェースからコピーされた説明:RedisClusterCommands指定されたマスターにレプリカを割り当てます。- 次で指定:
- インターフェース
RedisClusterCommands内のclusterReplicate - パラメーター:
master- null であってはなりません。replica- null であってはなりません。- 関連事項:
clusterGetSlotForKey
インターフェースからコピーされた説明:RedisClusterCommands特定のkeyのスロットを見つけます。- 次で指定:
- インターフェース
RedisClusterCommands内のclusterGetSlotForKey - パラメーター:
key- null であってはなりません。- 戻り値:
- 関連事項:
clusterGetNodeForKey
インターフェースからコピーされた説明:RedisClusterCommands与えられたキーを提供するRedisClusterNodeを見つけます。- 次で指定:
- インターフェース
RedisClusterCommands内のclusterGetNodeForKey - パラメーター:
key- null であってはなりません。- 戻り値:
clusterGetNodeForSlot
インターフェースからコピーされた説明:RedisClusterCommands指定されたスロットにサービスを提供しているRedisClusterNodeを見つけます。- 次で指定:
- インターフェース
RedisClusterCommands内のclusterGetNodeForSlot - 戻り値:
clusterGetNodes
インターフェースからコピーされた説明:RedisClusterCommandsID、ホスト、ポート、スロットなどのクラスターノード情報を取得します。- 次で指定:
- インターフェース
RedisClusterCommands内のclusterGetNodes - 戻り値:
- 決して null にはなりません。
- 関連事項:
clusterGetReplicas
インターフェースからコピーされた説明:RedisClusterCommands特定のマスターノードの接続されたレプリカに関する情報を取得します。- 次で指定:
- インターフェース
RedisClusterCommands内のclusterGetReplicas - パラメーター:
master- null であってはなりません。- 戻り値:
- 決して null にはなりません。
- 関連事項:
clusterGetMasterReplicaMap
インターフェースからコピーされた説明:RedisClusterCommandsマスターとそれに接続されたレプリカに関する情報を取得します。- 次で指定:
- インターフェース
RedisClusterCommands内のclusterGetMasterReplicaMap - 戻り値:
- 決して null にはなりません。
- 関連事項:
clusterGetClusterInfo
インターフェースからコピーされた説明:RedisClusterCommandsクラスター情報を取得します。- 次で指定:
- インターフェース
RedisClusterCommands内のclusterGetClusterInfo - 戻り値:
- 関連事項:
convertJedisAccessException
close
インターフェースからコピーされた説明:RedisConnection接続を閉じるか終了します。- 次で指定:
- インターフェース
AutoCloseableSE内のclose - 次で指定:
- インターフェース
RedisConnection内のclose - 例外:
DataAccessException-RedisConnectionを閉じることができなかった場合。
isClosed
public boolean isClosed()インターフェースからコピーされた説明:RedisConnection基になる接続が閉じているかどうかを示します。- 次で指定:
- インターフェース
RedisConnection内のisClosed - 戻り値:
- 接続が閉じている場合は true、それ以外の場合は false。
getNativeConnection
public redis.clients.jedis.JedisCluster getNativeConnection()インターフェースからコピーされた説明:RedisConnectionネイティブ接続(基になるライブラリ / ドライバオブジェクト)を返します。- 次で指定:
- インターフェース
RedisConnection内のgetNativeConnection - 戻り値:
- 基になるネイティブオブジェクト
isQueueing
public boolean isQueueing()インターフェースからコピーされた説明:RedisConnection接続が「キュー」(または「マルチ」)モードであるかどうかを示します。キューイングする場合、EXEC または DISCARD コマンドが発行されるまで、すべてのコマンドが延期されます。キューイングでは結果が返されないため、接続はデータと対話するすべての操作で NULL を返します。- 次で指定:
- インターフェース
RedisConnection内のisQueueing - 戻り値:
- 接続がキュー / マルチモードの場合は true、それ以外の場合は false
isPipelined
public boolean isPipelined()インターフェースからコピーされた説明:RedisConnection接続が現在パイプライン化されているかどうかを示します。- 次で指定:
- インターフェース
RedisConnection内のisPipelined - 戻り値:
- 接続がパイプライン化されている場合は true、それ以外の場合は false
- 関連事項:
openPipeline
public void openPipeline()インターフェースからコピーされた説明:RedisConnectionこの接続のパイプラインモードをアクティブにします。パイプライン化されると、すべてのコマンドは null を返します(レスポンスはRedisConnection.closePipeline()を介して最後に読み取られます。接続がすでにパイプライン化されているときにこのメソッドを呼び出しても効果はありません。パイプライン化は、レスポンスをすぐにリクエストせずにコマンドを発行するために使用されます。バッチ。MULTI にいくらか似ていますが、パイプラインはアトミック性を保証しません。多くのコマンドを発行するとき(バッチシナリオなど)にのみパフォーマンスを向上させようとします。注:
多くの場合、パフォーマンスのメリットは最小限ですが、使用への影響は少ないため、この機能を使用する前にパフォーマンステストを行うことを検討してください。- 次で指定:
- インターフェース
RedisConnection内のopenPipeline - 関連事項:
closePipeline
インターフェースからコピーされた説明:RedisConnectionパイプラインでコマンドを実行し、その結果を返します。接続がパイプライン化されていない場合、空のコレクションが返されます。- 次で指定:
- インターフェース
RedisConnection内のclosePipeline - 戻り値:
- 実行されたコマンドの結果。
- 例外:
RedisPipelineException- パイプラインに不正 / 無効なステートメントが含まれている場合
getSentinelConnection
- 次で指定:
- インターフェース
RedisConnection内のgetSentinelConnection - 戻り値:
- Redis Sentinel 使用時は
RedisSentinelConnection。
rewriteConfig
public void rewriteConfig()インターフェースからコピーされた説明:RedisServerCommandsredis.confファイルを書き換えます。- 次で指定:
- インターフェース
DefaultedRedisConnection内のrewriteConfig - 次で指定:
- インターフェース
RedisServerCommands内のrewriteConfig - 関連事項:
getCluster
protected redis.clients.jedis.JedisCluster getCluster()getClusterCommandExecutor
getTopologyProvider