インターフェース ReactiveRedisConnection
- すべてのスーパーインターフェース:
AutoCloseableSE,CloseableSE
- すべての既知のサブインターフェース:
ReactiveRedisClusterConnection
リアクティブコマンド実行のエントリポイントを宣言するリアクティブインフラストラクチャを使用した Redis 接続。
ReactiveRedisConnection は通常、ステートフルオブジェクトによって実装されます。ステートフルオブジェクトは、不要になったときに closed である必要があります。
コマンドは、key、value などのプレーンな引数を渡すことによって実行するか、コマンドストリーム内にラップすることができます。ストリーミングコマンドの実行は、特定の ReactiveRedisConnection.Command の Publisher を受け入れます。コマンドは、放出時に実行されます。
引数は、ByteBufferSE 引数を使用することでバイナリセーフです。ByteBufferSE は、ReactiveRedisConnection の呼び出しまたは実行中に消費されると予想されます。メソッドパラメーターとして使用される ByteBufferSE は、呼び出し後に変更しないでください。
- 導入:
- 2.0
- 作成者:
- Christoph Strobl, Mark Paluch
- 関連事項:
ネストされたクラスのサマリー
ネストされたクラス修飾子と型インターフェース説明static classキーがない場合のByteBufferSE レスポンスのReactiveRedisConnection.CommandResponse実装。static classBooleanSE レスポンスのReactiveRedisConnection.CommandResponse実装。static classstatic interfaceリアクティブインフラストラクチャで実行される Redis コマンドのベースインターフェース。static classコマンドレスポンスの基本クラス。static classキーバインド操作用のReactiveRedisConnection.Command。static classstatic classListSE レスポンスのReactiveRedisConnection.CommandResponse実装。static classnumericSE レスポンスのReactiveRedisConnection.CommandResponse実装。static classメソッドのサマリー
修飾子と型メソッド説明default voidclose()reactor.core.publisher.Mono<VoidSE>接続を非同期的に閉じ、関連するリソースを解放します。ReactiveHashCommandsを取得します。ReactiveHyperLogLogCommandsを取得します。ReactiveKeyCommandsを取得します。ReactiveListCommandsを取得します。reactor.core.publisher.Mono<StringSE>ping()接続のテスト。ReactivePubSubCommandsを取得します。ReactiveScriptingCommandsを取得します。ReactiveServerCommandsを取得します。ReactiveSetCommandsを取得します。ReactiveStreamCommandsを取得します。ReactiveStringCommandsを取得します。ReactiveZSetCommandsを取得します。
メソッドの詳細
close
default void close()- 次で指定:
- インターフェース
AutoCloseableSEのclose - 次で指定:
- インターフェース
CloseableSEのclose
closeLater
reactor.core.publisher.Mono<VoidSE> closeLater()接続を非同期的に閉じ、関連するリソースを解放します。- 戻り値:
- 完了したら、
Monoシグナリング。
keyCommands
ReactiveKeyCommands keyCommands()ReactiveKeyCommandsを取得します。- 戻り値:
- 決して null にはなりません。
stringCommands
ReactiveStringCommands stringCommands()ReactiveStringCommandsを取得します。- 戻り値:
- 決して null にはなりません。
numberCommands
ReactiveNumberCommands numberCommands()- 戻り値:
- 決して null にはなりません。
listCommands
ReactiveListCommands listCommands()ReactiveListCommandsを取得します。- 戻り値:
- 決して null にはなりません。
setCommands
ReactiveSetCommands setCommands()ReactiveSetCommandsを取得します。- 戻り値:
- 決して null にはなりません。
zSetCommands
ReactiveZSetCommands zSetCommands()ReactiveZSetCommandsを取得します。- 戻り値:
- 決して null にはなりません。
hashCommands
ReactiveHashCommands hashCommands()ReactiveHashCommandsを取得します。- 戻り値:
- 決して null にはなりません。
geoCommands
ReactiveGeoCommands geoCommands()- 戻り値:
- 決して null にはなりません。
hyperLogLogCommands
ReactiveHyperLogLogCommands hyperLogLogCommands()ReactiveHyperLogLogCommandsを取得します。- 戻り値:
- 決して null にはなりません。
pubSubCommands
ReactivePubSubCommands pubSubCommands()ReactivePubSubCommandsを取得します。- 戻り値:
- 決して null にはなりません。
- 導入:
- 2.1
scriptingCommands
ReactiveScriptingCommands scriptingCommands()ReactiveScriptingCommandsを取得します。- 戻り値:
- 決して null にはなりません。
serverCommands
ReactiveServerCommands serverCommands()ReactiveServerCommandsを取得します。- 戻り値:
- 決して null にはなりません。
streamCommands
ReactiveStreamCommands streamCommands()ReactiveStreamCommandsを取得します。- 戻り値:
- 決して null にはなりません。
- 導入:
- 2.2
ping
reactor.core.publisher.Mono<StringSE> ping()接続のテスト。- 戻り値:
Mono折り返しサーバーレスポンスメッセージ - 通常は PONG。- 関連事項: