本文整理了Java中io.undertow.websockets.spi.WebSocketHttpExchange.endExchange()方法的一些代码示例，展示了WebSocketHttpExchange.endExchange()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。WebSocketHttpExchange.endExchange()方法的具体详情如下：
包路径：io.undertow.websockets.spi.WebSocketHttpExchange
类名称：WebSocketHttpExchange
方法名：endExchange

WebSocketHttpExchange.endExchange介绍

[英]End the exchange normally. If this is a blocking exchange this may be a noop, and the exchange will actually end when the call stack returns
[中]正常结束交换。如果这是一个阻塞交换，那么这可能是一个noop，当调用堆栈返回时，交换实际上将结束

代码示例

代码示例来源：origin: wildfly/wildfly

protected void upgradeChannel(final WebSocketHttpExchange exchange, final byte[] data) {
  if (data.length > 0) {
    writePayload(exchange, ByteBuffer.wrap(data));
  } else {
    exchange.endExchange();
  }
}

代码示例来源：origin: wildfly/wildfly

protected void handshakeInternal(final WebSocketHttpExchange exchange) {
  String origin = exchange.getRequestHeader(Headers.SEC_WEB_SOCKET_ORIGIN_STRING);
  if (origin != null) {
    exchange.setResponseHeader(Headers.SEC_WEB_SOCKET_ORIGIN_STRING, origin);
  }
  selectSubprotocol(exchange);
  selectExtensions(exchange);
  exchange.setResponseHeader(Headers.SEC_WEB_SOCKET_LOCATION_STRING, getWebSocketLocation(exchange));
  final String key = exchange.getRequestHeader(Headers.SEC_WEB_SOCKET_KEY_STRING);
  try {
    final String solution = solve(key);
    exchange.setResponseHeader(Headers.SEC_WEB_SOCKET_ACCEPT_STRING, solution);
    performUpgrade(exchange);
  } catch (NoSuchAlgorithmException e) {
    IoUtils.safeClose(exchange);
    exchange.endExchange();
    return;
  }
}

代码示例来源：origin: wildfly/wildfly

@Override
protected void handshakeInternal(final WebSocketHttpExchange exchange) {
  String origin = exchange.getRequestHeader(Headers.ORIGIN_STRING);
  if (origin != null) {
    exchange.setResponseHeader(Headers.ORIGIN_STRING, origin);
  }
  selectSubprotocol(exchange);
  selectExtensions(exchange);
  exchange.setResponseHeader(Headers.SEC_WEB_SOCKET_LOCATION_STRING, getWebSocketLocation(exchange));
  final String key = exchange.getRequestHeader(Headers.SEC_WEB_SOCKET_KEY_STRING);
  try {
    final String solution = solve(key);
    exchange.setResponseHeader(Headers.SEC_WEB_SOCKET_ACCEPT_STRING, solution);
    performUpgrade(exchange);
  } catch (NoSuchAlgorithmException e) {
    IoUtils.safeClose(exchange);
    exchange.endExchange();
    return;
  }
}

代码示例来源：origin: io.undertow/undertow-core

protected void upgradeChannel(final WebSocketHttpExchange exchange, final byte[] data) {
  if (data.length > 0) {
    writePayload(exchange, ByteBuffer.wrap(data));
  } else {
    exchange.endExchange();
  }
}

代码示例来源：origin: org.jboss.eap/wildfly-client-all

protected void upgradeChannel(final WebSocketHttpExchange exchange, final byte[] data) {
  if (data.length > 0) {
    writePayload(exchange, ByteBuffer.wrap(data));
  } else {
    exchange.endExchange();
  }
}

代码示例来源：origin: io.undertow/undertow-core

@Override
protected void handshakeInternal(final WebSocketHttpExchange exchange) {
  String origin = exchange.getRequestHeader(Headers.ORIGIN_STRING);
  if (origin != null) {
    exchange.setResponseHeader(Headers.ORIGIN_STRING, origin);
  }
  selectSubprotocol(exchange);
  selectExtensions(exchange);
  exchange.setResponseHeader(Headers.SEC_WEB_SOCKET_LOCATION_STRING, getWebSocketLocation(exchange));
  final String key = exchange.getRequestHeader(Headers.SEC_WEB_SOCKET_KEY_STRING);
  try {
    final String solution = solve(key);
    exchange.setResponseHeader(Headers.SEC_WEB_SOCKET_ACCEPT_STRING, solution);
    performUpgrade(exchange);
  } catch (NoSuchAlgorithmException e) {
    IoUtils.safeClose(exchange);
    exchange.endExchange();
    return;
  }
}

代码示例来源：origin: io.undertow/undertow-core

protected void handshakeInternal(final WebSocketHttpExchange exchange) {
  String origin = exchange.getRequestHeader(Headers.SEC_WEB_SOCKET_ORIGIN_STRING);
  if (origin != null) {
    exchange.setResponseHeader(Headers.SEC_WEB_SOCKET_ORIGIN_STRING, origin);
  }
  selectSubprotocol(exchange);
  selectExtensions(exchange);
  exchange.setResponseHeader(Headers.SEC_WEB_SOCKET_LOCATION_STRING, getWebSocketLocation(exchange));
  final String key = exchange.getRequestHeader(Headers.SEC_WEB_SOCKET_KEY_STRING);
  try {
    final String solution = solve(key);
    exchange.setResponseHeader(Headers.SEC_WEB_SOCKET_ACCEPT_STRING, solution);
    performUpgrade(exchange);
  } catch (NoSuchAlgorithmException e) {
    IoUtils.safeClose(exchange);
    exchange.endExchange();
    return;
  }
}

代码示例来源：origin: org.jboss.eap/wildfly-client-all

protected void handshakeInternal(final WebSocketHttpExchange exchange) {
  String origin = exchange.getRequestHeader(Headers.SEC_WEB_SOCKET_ORIGIN_STRING);
  if (origin != null) {
    exchange.setResponseHeader(Headers.SEC_WEB_SOCKET_ORIGIN_STRING, origin);
  }
  selectSubprotocol(exchange);
  selectExtensions(exchange);
  exchange.setResponseHeader(Headers.SEC_WEB_SOCKET_LOCATION_STRING, getWebSocketLocation(exchange));
  final String key = exchange.getRequestHeader(Headers.SEC_WEB_SOCKET_KEY_STRING);
  try {
    final String solution = solve(key);
    exchange.setResponseHeader(Headers.SEC_WEB_SOCKET_ACCEPT_STRING, solution);
    performUpgrade(exchange);
  } catch (NoSuchAlgorithmException e) {
    IoUtils.safeClose(exchange);
    exchange.endExchange();
    return;
  }
}

代码示例来源：origin: org.jboss.eap/wildfly-client-all

@Override
protected void handshakeInternal(final WebSocketHttpExchange exchange) {
  String origin = exchange.getRequestHeader(Headers.ORIGIN_STRING);
  if (origin != null) {
    exchange.setResponseHeader(Headers.ORIGIN_STRING, origin);
  }
  selectSubprotocol(exchange);
  selectExtensions(exchange);
  exchange.setResponseHeader(Headers.SEC_WEB_SOCKET_LOCATION_STRING, getWebSocketLocation(exchange));
  final String key = exchange.getRequestHeader(Headers.SEC_WEB_SOCKET_KEY_STRING);
  try {
    final String solution = solve(key);
    exchange.setResponseHeader(Headers.SEC_WEB_SOCKET_ACCEPT_STRING, solution);
    performUpgrade(exchange);
  } catch (NoSuchAlgorithmException e) {
    IoUtils.safeClose(exchange);
    exchange.endExchange();
    return;
  }
}