类 Reactor2TcpClient<P>

字段详细资料

• REACTOR_TCP_CLIENT_TYPE

  public static final Class<reactor.io.net.impl.netty.tcp.NettyTcpClient> REACTOR_TCP_CLIENT_TYPE

构造器详细资料

• Reactor2TcpClient

  public Reactor2TcpClient​(String host,
                           int port,
                           reactor.io.codec.Codec<reactor.io.buffer.Buffer,​Message<P>,​Message<P>> codec)

  A constructor that creates a TcpClientSpec factory with a default SynchronousDispatcher, i.e. relying on Netty threads. The number of Netty threads can be tweaked with the reactor.tcp.ioThreadCount System property. The network I/O threads will be shared amongst the active clients.

  参数:

  host - the host to connect to

  port - the port to connect to

  codec - the codec to use for encoding and decoding the TCP stream

• Reactor2TcpClient

  public Reactor2TcpClient​(reactor.fn.Supplier<InetSocketAddress> addressSupplier,
                           reactor.io.codec.Codec<reactor.io.buffer.Buffer,​Message<P>,​Message<P>> codec)

  A variant of Reactor2TcpClient(String, int, Codec) that takes a supplier of any number of addresses instead of just one host and port. This can be used to reconnect to a different address after the current host becomes unavailable.

  参数:

  addressSupplier - supplier of addresses to use for connecting

  codec - the codec to use for encoding and decoding the TCP stream

  从以下版本开始:

  4.3.15

• Reactor2TcpClient

  public Reactor2TcpClient​(reactor.io.net.NetStreams.TcpClientFactory<Message<P>,​Message<P>> tcpClientSpecFactory)

  A constructor with a pre-configured Spec.TcpClientSpecFunction factory. This might be used to add SSL or specific network parameters to the generated client configuration.

  NOTE: if the client is configured with a thread-creating dispatcher, you are responsible for cleaning them, e.g. via Resource.shutdown().

  参数:

  tcpClientSpecFactory - the TcpClientSpec Function to use for each client creation

方法详细资料

• initEventLoopGroup

  public static io.netty.channel.nio.NioEventLoopGroup initEventLoopGroup()

• connect

  public ListenableFuture<Void> connect​(TcpConnectionHandler<P> connectionHandler)

  从接口复制的说明: TcpOperations
  Open a new connection.

  指定者:

  connect 在接口中 TcpOperations<P>

  参数:

  connectionHandler - a handler to manage the connection

  返回:

  a ListenableFuture that can be used to determine when and if the connection is successfully established

• connect

  public ListenableFuture<Void> connect​(TcpConnectionHandler<P> connectionHandler,
                                        ReconnectStrategy strategy)

  从接口复制的说明: TcpOperations
  Open a new connection and a strategy for reconnecting if the connection fails.

  指定者:

  connect 在接口中 TcpOperations<P>

  参数:

  connectionHandler - a handler to manage the connection

  strategy - a strategy for reconnecting

  返回:

  a ListenableFuture that can be used to determine when and if the initial connection is successfully established

• shutdown

  public ListenableFuture<Void> shutdown()

  从接口复制的说明: TcpOperations
  Shut down and close any open connections.

  指定者:

  shutdown 在接口中 TcpOperations<P>

  返回:

  a ListenableFuture that can be used to determine when and if the connection is successfully closed