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

WebSocket.sendText介绍

暂无

代码示例

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

@Override
  public boolean send(String item) {
    webSocket.sendText(item);
    return !webSocket.isClosed();
  }
};

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

this.webSocket.openAndNotify(netSocket -> {
    connected.set(true);
    webSocket.sendText(message, exceptionConsumer);
  }, exceptionConsumer);
} else {
  webSocket.sendText(message);

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

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

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

@Test
public void testNewOpenWaitWebSocketNewServerStuff() {
  connect();
  server.setWebSocketOnOpenConsumer(webSocket -> webSocket.setTextMessageConsumer(message -> {
    if (message.equals("What do you want on your cheeseburger?")) {
      webSocket.sendText("Bacon");
      requestReceived.set(true);
    } else {
      puts("Websocket message", message);
    }
  }));
  run();
  final WebSocket webSocket = client.createWebSocket("/services/cheeseburger");
  webSocket.setTextMessageConsumer(message -> {
    if (message.equals("Bacon")) {
      responseReceived.set(true);
    }
  });
  webSocket.openAndWait();
  webSocket.sendText("What do you want on your cheeseburger?");
  client.flush();
  validate();
  stop();
}

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

@Test
public void testNewOpenWaitWebSocket() {
  connect();
  server.setWebSocketMessageConsumer(webSocketMessage -> {
    puts(webSocketMessage.address(), webSocketMessage.body());
    if (webSocketMessage.getMessage().equals("What do you want on your cheeseburger?")) {
      webSocketMessage.getSender().sendText("Bacon");
      requestReceived.set(true);
    } else {
      puts("Websocket message", webSocketMessage.getMessage());
    }
  });
  run();
  final WebSocket webSocket = client.createWebSocket("/services/cheeseburger");
  webSocket.setTextMessageConsumer(message -> {
    if (message.equals("Bacon")) {
      responseReceived.set(true);
    }
  });
  webSocket.openAndWait();
  webSocket.sendText("What do you want on your cheeseburger?");
  client.flush();
  validate();
  stop();
}

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

@Test
public void testTextQueue() throws Exception {
  final int port = PortUtils.findOpenPortStartAt(4000);
  final HttpServer httpServer = HttpServerBuilder.httpServerBuilder().setPort(port).build();
  final AtomicReference<Object> bodyRef = new AtomicReference<>();
  httpServer.setWebSocketMessageConsumer(webSocketMessage -> {
    bodyRef.set(webSocketMessage.body());
    webSocketMessage.getSender().sendText("world");
  });
  httpServer.startServerAndWait();
  final HttpClient httpClient = HttpClientBuilder.httpClientBuilder().setPort(port).buildAndStart();
  final WebSocket webSocket = httpClient.createWebSocket("/foo");
  final WebSocketTextQueue queue = new WebSocketTextQueue(webSocket);
  webSocket.openAndWait();
  webSocket.sendText("hello");
  String message = queue.receiveQueue().pollWait();
  assertEquals("world", message);
  assertEquals("hello", bodyRef.get().toString());
}

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

public static void main(String... args) {
    final HttpClient httpClient = httpClientBuilder().setAutoFlush(true).setPort(9999).build();

    httpClient.startClient();

    final WebSocket webSocket = httpClient.createWebSocket("/hello");

    webSocket.setTextMessageConsumer(message ->
        puts("\n\n\n", message, "\n\n")
    );

    webSocket.openAndWait();

    webSocket.sendText("Hello");

    Sys.sleep(100000);
  }
}

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

@Test
public void testTextQueueWithBatchSize() throws Exception {
  final int port = PortUtils.findOpenPortStartAt(4000);
  final HttpServer httpServer = HttpServerBuilder.httpServerBuilder().setPort(port).build();
  final AtomicReference<Object> bodyRef = new AtomicReference<>();
  httpServer.setWebSocketMessageConsumer(webSocketMessage -> {
    bodyRef.set(webSocketMessage.body());
    webSocketMessage.getSender().sendText("world");
  });
  httpServer.startServerAndWait();
  final HttpClient httpClient = HttpClientBuilder.httpClientBuilder().setPort(port).buildAndStart();
  final WebSocket webSocket = httpClient.createWebSocket("/foo");
  final WebSocketTextQueue queue = new WebSocketTextQueue(webSocket, 100, 100, TimeUnit.MILLISECONDS);
  webSocket.openAndWait();
  webSocket.sendText("hello");
  String message = queue.receiveQueue().pollWait();
  assertEquals("world", message);
  assertEquals("hello", bodyRef.get().toString());
}

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

@Override
  public boolean send(String item) {
    webSocket.sendText(item);
    return !webSocket.isClosed();
  }
};

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

@Test
public void testWebSocket() {
  connect();
  server.setWebSocketMessageConsumer(webSocketMessage -> {
    puts(webSocketMessage.address(), webSocketMessage.body());
    if (webSocketMessage.getMessage().equals("What do you want on your cheeseburger?")) {
      webSocketMessage.getSender().sendText("Bacon");
      requestReceived.set(true);
    } else {
      puts("Websocket message", webSocketMessage.getMessage());
    }
  });
  run();
  final WebSocket webSocket = client.createWebSocket("/services/cheeseburger");
  webSocket.setTextMessageConsumer(message -> {
    if (message.equals("Bacon")) {
      responseReceived.set(true);
    }
  });
  webSocket.setOpenConsumer(
      aVoid -> {
        webSocket.sendText("What do you want on your cheeseburger?");
      }
  );
  webSocket.open(e -> {
  });
  client.flush();
  validate();
  stop();
}

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

message -> {
  if (webSocket.isOpen()) {
    webSocket.sendText(message);

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

this.webSocket.openAndNotify(netSocket -> {
    connected.set(true);
    webSocket.sendText(message, exceptionConsumer);
  }, exceptionConsumer);
} else {
  webSocket.sendText(message);

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

webSocket.sendText(message);
} else {
  connected.set(false);

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

message -> {
  if (webSocket.isOpen()) {
    webSocket.sendText(message);

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

message -> {
  if (webSocket.isOpen()) {
    webSocket.sendText(message);