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

WsSession.sendCloseMessage介绍

暂无

代码示例

代码示例来源：origin: codefollower/Tomcat-Research

/**
 * Called when a close message is received. Should only ever happen once.
 * Also called after a protocol error when the ProtocolHandler needs to
 * force the closing of the connection.
 */
public void onClose(CloseReason closeReason) {
  synchronized (stateLock) {
    if (state == State.OPEN) {
      sendCloseMessage(closeReason);
      fireEndpointOnClose(closeReason);
      state = State.CLOSED;
    }
    // Close the socket
    wsRemoteEndpoint.close();
  }
}

代码示例来源：origin: codefollower/Tomcat-Research

/**
 * WebSocket 1.0. Section 2.1.5.
 * Need internal close method as spec requires that the local endpoint
 * receives a 1006 on timeout.
 */
private void doClose(CloseReason closeReasonMessage,
    CloseReason closeReasonLocal) {
  // Double-checked locking. OK because state is volatile
  if (state != State.OPEN) {
    return;
  }
  synchronized (stateLock) {
    if (state != State.OPEN) {
      return;
    }
    state = State.CLOSING;
    sendCloseMessage(closeReasonMessage);
    fireEndpointOnClose(closeReasonLocal);
    state = State.CLOSED;
  }
  IOException ioe = new IOException(sm.getString("wsSession.messageFailed"));
  SendResult sr = new SendResult(ioe);
  for (FutureToSendHandler f2sh : futures.keySet()) {
    f2sh.onResult(sr);
  }
}

代码示例来源：origin: org.jboss.web/jbossweb

/**
 * Called when a close message is received. Should only ever happen once.
 * Also called after a protocol error when the ProtocolHandler needs to
 * force the closing of the connection.
 */
public void onClose(CloseReason closeReason) {
  synchronized (stateLock) {
    if (state == State.OPEN) {
      try {
        wsRemoteEndpoint.setBatchingAllowed(false);
      } catch (IOException e) {
        WebsocketsLogger.ROOT_LOGGER.flushOnCloseFailed(e);
        fireEndpointOnError(e);
      }
      if (!Constants.RELAXED_CLOSE_EVENT) {
        sendCloseMessage(closeReason);
        fireEndpointOnClose(closeReason);
      } else {
        fireEndpointOnClose(closeReason);
        sendCloseMessage(closeReason);
      }
      state = State.CLOSED;
    }
    // Close the socket
    wsRemoteEndpoint.close();
  }
}

代码示例来源：origin: org.jboss.web/jbossweb

sendCloseMessage(closeReasonMessage);
  fireEndpointOnClose(closeReasonLocal);
} else {
  fireEndpointOnClose(closeReasonLocal);
  sendCloseMessage(closeReasonMessage);

代码示例来源：origin: org.apache.tomcat/tomcat7-websocket

/**
 * Called when a close message is received. Should only ever happen once.
 * Also called after a protocol error when the ProtocolHandler needs to
 * force the closing of the connection.
 */
public void onClose(CloseReason closeReason) {
  synchronized (stateLock) {
    if (state != State.CLOSED) {
      try {
        wsRemoteEndpoint.setBatchingAllowed(false);
      } catch (IOException e) {
        log.warn(sm.getString("wsSession.flushFailOnClose"), e);
        fireEndpointOnError(e);
      }
      if (state == State.OPEN) {
        state = State.OUTPUT_CLOSED;
        sendCloseMessage(closeReason);
        fireEndpointOnClose(closeReason);
      }
      state = State.CLOSED;
      // Close the socket
      wsRemoteEndpoint.close();
    }
  }
}

代码示例来源：origin: org.apache.tomcat.embed/tomcat-embed-websocket

/**
 * Called when a close message is received. Should only ever happen once.
 * Also called after a protocol error when the ProtocolHandler needs to
 * force the closing of the connection.
 *
 * @param closeReason The reason contained within the received close
 *                    message.
 */
public void onClose(CloseReason closeReason) {
  synchronized (stateLock) {
    if (state != State.CLOSED) {
      try {
        wsRemoteEndpoint.setBatchingAllowed(false);
      } catch (IOException e) {
        log.warn(sm.getString("wsSession.flushFailOnClose"), e);
        fireEndpointOnError(e);
      }
      if (state == State.OPEN) {
        state = State.OUTPUT_CLOSED;
        sendCloseMessage(closeReason);
        fireEndpointOnClose(closeReason);
      }
      state = State.CLOSED;
      // Close the socket
      wsRemoteEndpoint.close();
    }
  }
}

代码示例来源：origin: org.apache.tomcat.embed/tomcat-embed-websocket

sendCloseMessage(closeReasonMessage);
fireEndpointOnClose(closeReasonLocal);

代码示例来源：origin: org.apache.tomcat/tomcat-websocket

/**
 * Called when a close message is received. Should only ever happen once.
 * Also called after a protocol error when the ProtocolHandler needs to
 * force the closing of the connection.
 *
 * @param closeReason The reason contained within the received close
 *                    message.
 */
public void onClose(CloseReason closeReason) {
  synchronized (stateLock) {
    if (state != State.CLOSED) {
      try {
        wsRemoteEndpoint.setBatchingAllowed(false);
      } catch (IOException e) {
        log.warn(sm.getString("wsSession.flushFailOnClose"), e);
        fireEndpointOnError(e);
      }
      if (state == State.OPEN) {
        state = State.OUTPUT_CLOSED;
        sendCloseMessage(closeReason);
        fireEndpointOnClose(closeReason);
      }
      state = State.CLOSED;
      // Close the socket
      wsRemoteEndpoint.close();
    }
  }
}

代码示例来源：origin: org.apache.tomcat/tomcat7-websocket

sendCloseMessage(closeReasonMessage);
fireEndpointOnClose(closeReasonLocal);

代码示例来源：origin: org.apache.tomcat/tomcat-websocket

sendCloseMessage(closeReasonMessage);
fireEndpointOnClose(closeReasonLocal);