P - 送受信メッセージのペイロードの型 public class ReactorNettyTcpClient<P> extends ObjectSE implements TcpOperations<P>
TcpOperations の実装。| コンストラクターと説明 |
|---|
ReactorNettyTcpClient(FunctionSE<reactor.netty.tcp.TcpClient,reactor.netty.tcp.TcpClient> clientConfigurer, ReactorNettyCodec<P> codec)TcpClient と基礎となるリソースのライフサイクルを引き続き管理するが、Function<TcpClient, TcpClient> を介してクライアントの他のプロパティを直接構成できる ReactorNettyTcpClient(String, int, ReactorNettyCodec) のバリアント。 |
ReactorNettyTcpClient(StringSE host, int port, ReactorNettyCodec<P> codec) 接続に使用するホストとポートを持つ単純なコンストラクター。 |
ReactorNettyTcpClient(reactor.netty.tcp.TcpClient tcpClient, ReactorNettyCodec<P> codec) ライフサイクルが外部で管理されることが期待される、外部で作成された TcpClient インスタンスを持つコンストラクター。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
ListenableFuture<VoidSE> | connect(TcpConnectionHandler<P> handler) 新しい接続を開きます。 |
ListenableFuture<VoidSE> | connect(TcpConnectionHandler<P> handler, ReconnectStrategy strategy) 新しい接続を開き、接続が失敗した場合の再接続方法を示します。 |
protected reactor.netty.tcp.TcpClient | extendTcpClient(reactor.netty.tcp.TcpClient tcpClient, TcpConnectionHandler<P> handler) 特定の TcpConnectionHandler の TcpClient を初期化する機会を提供します。これにより、さらに情報を公開する StompTcpConnectionHandler などのサブインターフェースが実装される場合があります。 |
Log | getLogger() 現在設定されているロガーを返します。 |
void | setLogger(Log logger) クラス名に基づいたロガーよりも使用する代替ロガーを設定します。 |
ListenableFuture<VoidSE> | shutdown() 開いている接続をシャットダウンして閉じます。 |
StringSE | toString() |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEpublic ReactorNettyTcpClient(StringSE host, int port, ReactorNettyCodec<P> codec)
このコンストラクターは、TcpClient および ConnectionProvider、LoopResources、ChannelGroup などの基盤となるリソースのライフサイクルを管理します。
TcpClient の初期化とライフサイクルを完全に制御するには、ReactorNettyTcpClient(TcpClient, ReactorNettyCodec) を使用します。
host - 接続するホスト port - 接続するポート codec - 入力 / 出力バイトストリームをエンコードおよびデコードするため StompReactorNettyCodecpublic ReactorNettyTcpClient(FunctionSE<reactor.netty.tcp.TcpClient,reactor.netty.tcp.TcpClient> clientConfigurer, ReactorNettyCodec<P> codec)
TcpClient と基礎となるリソースのライフサイクルを引き続き管理するが、Function<TcpClient, TcpClient> を介してクライアントの他のプロパティを直接構成できる ReactorNettyTcpClient(String, int, ReactorNettyCodec) のバリアント。clientConfigurer - コンフィギュレーター機能 codec - 入力 / 出力バイトストリームをエンコードおよびデコードするため StompReactorNettyCodecpublic ReactorNettyTcpClient(reactor.netty.tcp.TcpClient tcpClient,
ReactorNettyCodec<P> codec)TcpClient インスタンスを持つコンストラクター。tcpClient - 使用する TcpClient インスタンス codec - 入力 / 出力バイトストリームをエンコードおよびデコードするため StompReactorNettyCodecpublic void setLogger(Log logger)
logger - 使用するロガー public Log getLogger()
public ListenableFuture<VoidSE> connect(TcpConnectionHandler<P> handler)
TcpOperationsTcpOperations<P> の connect handler - 接続を管理するためのハンドラー protected reactor.netty.tcp.TcpClient extendTcpClient(reactor.netty.tcp.TcpClient tcpClient,
TcpConnectionHandler<P> handler)TcpConnectionHandler の TcpClient を初期化する機会を提供します。これにより、さらに情報を公開する StompTcpConnectionHandler などのサブインターフェースが実装される場合があります。tcpClient - 候補 TcpClienthandler - TCP 接続のハンドラー public ListenableFuture<VoidSE> connect(TcpConnectionHandler<P> handler, ReconnectStrategy strategy)
TcpOperationsTcpOperations<P> の connect handler - 接続を管理するためのハンドラー strategy - 再接続するための戦略 public ListenableFuture<VoidSE> shutdown()
TcpOperationsTcpOperations<P> の shutdown public StringSE toString()
ObjectSE の toStringSE