类 ReactorNettyWebSocketClient

构造器详细资料

• ReactorNettyWebSocketClient

  public ReactorNettyWebSocketClient()

  Default constructor.

• ReactorNettyWebSocketClient

  public ReactorNettyWebSocketClient​(reactor.netty.http.client.HttpClient httpClient)

  Constructor that accepts an existing HttpClient builder.

  从以下版本开始:

  5.1

方法详细资料

• getHttpClient

  public reactor.netty.http.client.HttpClient getHttpClient()

  Return the configured HttpClient.

• setMaxFramePayloadLength

  public void setMaxFramePayloadLength​(int maxFramePayloadLength)

  Configure the maximum allowable frame payload length. Setting this value to your application's requirement may reduce denial of service attacks using long data frames.

  Corresponds to the argument with the same name in the constructor of WebSocketServerHandshakerFactory in Netty.

  By default set to 65536 (64K).

  参数:

  maxFramePayloadLength - the max length for frames.

  从以下版本开始:

  5.2

• getMaxFramePayloadLength

  public int getMaxFramePayloadLength()

  Return the configured maxFramePayloadLength.

  从以下版本开始:

  5.2

• setHandlePing

  public void setHandlePing​(boolean handlePing)

  Configure whether to let ping frames through to be handled by the WebSocketHandler given to the execute method. By default, Reactor Netty automatically replies with pong frames in response to pings. This is useful in a proxy for allowing ping and pong frames through.

  By default this is set to false in which case ping frames are handled automatically by Reactor Netty. If set to true, ping frames will be passed through to the WebSocketHandler.

  参数:

  handlePing - whether to let Ping frames through for handling

  从以下版本开始:

  5.2.4

• getHandlePing

  public boolean getHandlePing()

  Return the configured setHandlePing(boolean).

  从以下版本开始:

  5.2.4

• execute

  public reactor.core.publisher.Mono<Void> execute​(URI url,
                                                   WebSocketHandler handler)

  从接口复制的说明: WebSocketClient
  Execute a handshake request to the given url and handle the resulting WebSocket session with the given handler.

  指定者:

  execute 在接口中 WebSocketClient

  参数:

  url - the handshake url

  handler - the handler of the WebSocket session

  返回:

  completion Mono<Void> to indicate the outcome of the WebSocket session handling.

• execute

  public reactor.core.publisher.Mono<Void> execute​(URI url,
                                                   HttpHeaders requestHeaders,
                                                   WebSocketHandler handler)

  从接口复制的说明: WebSocketClient
  A variant of WebSocketClient.execute(URI, WebSocketHandler) with custom headers.

  指定者:

  execute 在接口中 WebSocketClient

  参数:

  url - the handshake url

  requestHeaders - custom headers for the handshake request

  handler - the handler of the WebSocket session

  返回:

  completion Mono<Void> to indicate the outcome of the WebSocket session handling.