Главная / I/O / Клиенты WebSocket с java.net.http
I/O Средний

Клиенты WebSocket с java.net.http

Используйте стандартный асинхронный клиент WebSocket вместо добавления сторонней зависимости.

HTTP I/O Async Programming
Сравнение кода
✕ Third-party library 
WebSocketClient client =
    new WebSocketClient(serverUri) {
        @Override
        public void onMessage(String message) {
            handle(message);
        }
    };
client.connect();
✓ Java 11+ 
HttpClient.newHttpClient()
    .newWebSocketBuilder()
    .buildAsync(serverUri,
        new WebSocket.Listener() {
            @Override
            public CompletionStage<?> onText(
                    WebSocket socket,
                    CharSequence data,
                    boolean last) {
                handle(data.toString());
                return WebSocket.Listener.super
                    .onText(socket, data, last);
            }
        });
Заметили проблему в этом коде? Сообщите нам.
Почему современный подход лучше
📦

Без дополнительной зависимости

Клиент WebSocket входит в состав JDK.

🧵

Асинхронный API

Установление соединения и обработка сообщений компонуются с CompletionStage.

🔗

Общий стек HTTP

Для прокси, TLS и исполнителя используются стандартные средства JDK.

Старый подход
Сторонний клиент WebSocket
Современный подход
java.net.http.WebSocket
Начиная с JDK
11
Сложность
Средний
Поддержка JDK
Клиенты WebSocket с java.net.http
Доступно

Широко доступно начиная с JDK 11 (сентябрь 2018)

Как это работает

Пакет java.net.http включает асинхронный клиент WebSocket, интегрированный со стандартным HTTP-клиентом. Соединения устанавливаются с помощью CompletableFuture, обратные вызовы слушателя поддерживают неблокирующую обработку сообщений через CompletionStage, а клиент использует стандартные настройки прокси, TLS и исполнителя из JDK.

Связанная документация
WebSocket ↗ HTTP Client (JEP 321) ↗
Доказательство
Посмотреть исходник доказательства ↗
Похожие шаблоны
I/O Начинающий

Modern HTTP client

Java 8
URL url = new URL("https://api.com/data");
HttpURLConnection con =
    (HttpURLConnection) url.openConnection();
con.setRequestMethod("GET");
BufferedReader in = new BufferedReader(
    new InputStreamReader(con.getInputStream()));
// read lines, close streams...
Java 11+
var client = HttpClient.newHttpClient();
var request = HttpRequest.newBuilder()
    .uri(URI.create("https://api.com/data"))
    .build();
var response = client.send(
    request, BodyHandlers.ofString());
String body = response.body();
Наведите, чтобы увидеть современный ➜
JDK 11+ →
Concurrency Средний

CompletableFuture chaining

Pre-Java 8
Future<String> future =
    executor.submit(this::fetchData);
String data = future.get(); // blocks
String result = transform(data);
Java 8+
CompletableFuture.supplyAsync(
    this::fetchData
)
.thenApply(this::transform)
.thenAccept(IO::println);
Наведите, чтобы увидеть современный ➜
JDK 8+ →
Concurrency Средний

Concurrent HTTP with virtual threads

Java 8
ExecutorService pool =
    Executors.newFixedThreadPool(10);
List<Future<String>> futures =
    urls.stream()
    .map(u -> pool.submit(
        () -> fetchUrl(u)))
    .toList();
// manual shutdown, blocking get()
Java 21+
try (var exec = Executors
    .newVirtualThreadPerTaskExecutor()) {
    var results = urls.stream()
        .map(u -> exec.submit(
            () -> client.send(req(u),
                ofString()).body()))
        .toList().stream()
        .map(Future::join).toList();
}
Наведите, чтобы увидеть современный ➜
JDK 21+ →