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

WebSocket.sendCloseFrame介绍

[英]Send a empty close frame.
[中]发送一个空的闭合帧。

代码示例

代码示例来源：origin: AsyncHttpClient/async-http-client

@Test(timeOut = 60000, expectedExceptions = ExecutionException.class)
public void sendPingMessageExpectFailure() throws Exception {
 try (AsyncHttpClient c = asyncHttpClient()) {
  CountDownLatch closeLatch = new CountDownLatch(1);
  WebSocket websocket = getWebSocket(c, closeLatch);
  websocket.sendCloseFrame();
  closeLatch.await(1, TimeUnit.SECONDS);
  websocket.sendPingFrame("PING".getBytes()).get(10, TimeUnit.SECONDS);
 }
}

代码示例来源：origin: AsyncHttpClient/async-http-client

@Test(timeOut = 60000, expectedExceptions = ExecutionException.class)
public void streamBytesExpectFailure() throws Exception {
 try (AsyncHttpClient c = asyncHttpClient()) {
  CountDownLatch closeLatch = new CountDownLatch(1);
  WebSocket websocket = getWebSocket(c, closeLatch);
  websocket.sendCloseFrame();
  closeLatch.await(1, TimeUnit.SECONDS);
  websocket.sendBinaryFrame("STREAM".getBytes(), true, 0).get(1, TimeUnit.SECONDS);
 }
}

代码示例来源：origin: AsyncHttpClient/async-http-client

@Test(timeOut = 60000, expectedExceptions = ExecutionException.class)
public void sendByteMessageExpectFailure() throws Exception {
 try (AsyncHttpClient c = asyncHttpClient()) {
  CountDownLatch closeLatch = new CountDownLatch(1);
  WebSocket websocket = getWebSocket(c, closeLatch);
  websocket.sendCloseFrame();
  closeLatch.await(1, TimeUnit.SECONDS);
  websocket.sendBinaryFrame("BYTES".getBytes()).get(10, TimeUnit.SECONDS);
 }
}

代码示例来源：origin: AsyncHttpClient/async-http-client

@Test(timeOut = 60000, expectedExceptions = ExecutionException.class)
public void sendPongMessageExpectFailure() throws Exception {
 try (AsyncHttpClient c = asyncHttpClient()) {
  CountDownLatch closeLatch = new CountDownLatch(1);
  WebSocket websocket = getWebSocket(c, closeLatch);
  websocket.sendCloseFrame();
  closeLatch.await(1, TimeUnit.SECONDS);
  websocket.sendPongFrame("PONG".getBytes()).get(1, TimeUnit.SECONDS);
 }
}

代码示例来源：origin: AsyncHttpClient/async-http-client

@Test(expectedExceptions = ExecutionException.class)
public void streamTextExpectFailure() throws Exception {
 try (AsyncHttpClient c = asyncHttpClient()) {
  CountDownLatch closeLatch = new CountDownLatch(1);
  WebSocket websocket = getWebSocket(c, closeLatch);
  websocket.sendCloseFrame();
  closeLatch.await(1, TimeUnit.SECONDS);
  websocket.sendTextFrame("STREAM", true, 0).get(1, TimeUnit.SECONDS);
 }
}

代码示例来源：origin: AsyncHttpClient/async-http-client

@Test(timeOut = 60000, expectedExceptions = ExecutionException.class)
public void sendTextMessageExpectFailure() throws Exception {
 try (AsyncHttpClient c = asyncHttpClient()) {
  CountDownLatch closeLatch = new CountDownLatch(1);
  WebSocket websocket = getWebSocket(c, closeLatch);
  websocket.sendCloseFrame();
  closeLatch.await(1, TimeUnit.SECONDS);
  websocket.sendTextFrame("TEXT").get(10, TimeUnit.SECONDS);
 }
}

代码示例来源：origin: AsyncHttpClient/async-http-client

@Test(timeOut = 60000)
public void onCloseWithCode() throws Exception {
 try (AsyncHttpClient c = asyncHttpClient()) {
  final CountDownLatch latch = new CountDownLatch(1);
  final AtomicReference<String> text = new AtomicReference<>("");
  WebSocket websocket = c.prepareGet(getTargetUrl()).execute(new WebSocketUpgradeHandler.Builder().addWebSocketListener(new Listener(latch, text)).build()).get();
  websocket.sendCloseFrame();
  latch.await();
  assertTrue(text.get().startsWith("1000"), "Expected a 1000 code but got " + text.get());
 }
}

代码示例来源：origin: AsyncHttpClient/async-http-client

@Test(timeOut = 60000)
public void onClose() throws Exception {
 try (AsyncHttpClient c = asyncHttpClient()) {
  final CountDownLatch latch = new CountDownLatch(1);
  final AtomicReference<String> text = new AtomicReference<>("");
  WebSocket websocket = c.prepareGet(getTargetUrl()).execute(new WebSocketUpgradeHandler.Builder().addWebSocketListener(new WebSocketListener() {
   @Override
   public void onOpen(WebSocket websocket) {
   }
   @Override
   public void onClose(WebSocket websocket, int code, String reason) {
    text.set("OnClose");
    latch.countDown();
   }
   @Override
   public void onError(Throwable t) {
    t.printStackTrace();
    latch.countDown();
   }
  }).build()).get();
  websocket.sendCloseFrame();
  latch.await();
  assertEquals(text.get(), "OnClose");
 }
}

代码示例来源：origin: AsyncHttpClient/async-http-client

@Test(timeOut = 60000)
public void testRedirectToWSResource() throws Exception {
 try (AsyncHttpClient c = asyncHttpClient(config().setFollowRedirect(true))) {
  final CountDownLatch latch = new CountDownLatch(1);
  final AtomicReference<String> text = new AtomicReference<>("");
  WebSocket websocket = c.prepareGet(getRedirectURL()).execute(new WebSocketUpgradeHandler.Builder().addWebSocketListener(new WebSocketListener() {
   @Override
   public void onOpen(WebSocket websocket) {
    text.set("OnOpen");
    latch.countDown();
   }
   @Override
   public void onClose(WebSocket websocket, int code, String reason) {
   }
   @Override
   public void onError(Throwable t) {
    t.printStackTrace();
    latch.countDown();
   }
  }).build()).get();
  latch.await();
  assertEquals(text.get(), "OnOpen");
  websocket.sendCloseFrame();
 }
}

代码示例来源：origin: org.apache.camel/camel-ahc-ws

@Override
protected void doStop() throws Exception {
  if (websocket != null && websocket.isOpen()) {
    if (LOG.isDebugEnabled()) {
      LOG.debug("Disconnecting from {}", getHttpUri().toASCIIString());
    }
    websocket.removeWebSocketListener(listener);
    websocket.sendCloseFrame();
    websocket = null;
  }
  super.doStop();
}

代码示例来源：origin: allbegray/slack-api

public void close() {
  logger.info("Slack RTM closing...");
  stop = true;
  if (webSocket != null && webSocket.isOpen()) {
    webSocket.sendCloseFrame();
  }
  if (asyncHttpClient != null && !asyncHttpClient.isClosed()) {
    try {
      asyncHttpClient.close();
    } catch (IOException e) {
      // ignore
    }
  }
  logger.info("Slack RTM closed.");
}