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

WebSocket.setBinaryMessageConsumer介绍

暂无

代码示例

代码示例来源：origin: advantageous/qbit

@Test
public void testBinary() throws Exception {
  final int port = PortUtils.findOpenPortStartAt(4001);
  final HttpServer httpServer = HttpServerBuilder.httpServerBuilder().setPort(port).build();
  final AtomicReference<Object> bodyRef = new AtomicReference<>();
  final AtomicReference<byte[]> messageRef = new AtomicReference<>();
  final CountDownLatch countDownLatch = new CountDownLatch(2);
  httpServer.setWebSocketMessageConsumer(webSocketMessage -> {
    bodyRef.set(webSocketMessage.body());
    webSocketMessage.getSender().sendBytes("world".getBytes());
    countDownLatch.countDown();
  });
  httpServer.startServerAndWait();
  final HttpClient httpClient = HttpClientBuilder.httpClientBuilder().setPort(port).buildAndStart();
  final WebSocket webSocket = httpClient.createWebSocket("/foo");
  webSocket.setBinaryMessageConsumer(message -> {
    messageRef.set(message);
    countDownLatch.countDown();
  });
  webSocket.openAndWait();
  webSocket.sendBinary("hello".getBytes());
  countDownLatch.await(5, TimeUnit.SECONDS);
  assertEquals("world", new String(messageRef.get(), StandardCharsets.UTF_8));
  assertEquals("hello", new String(((byte[]) bodyRef.get()), StandardCharsets.UTF_8));
}

代码示例来源：origin: advantageous/qbit

webSocket.setBinaryMessageConsumer(webSocketMessageIn -> {

代码示例来源：origin: com.github.advantageous/qbit-core

webSocket.setBinaryMessageConsumer(webSocketMessageIn -> {

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

webSocket.setBinaryMessageConsumer(webSocketMessageIn -> {