Ana Sayfa / I/O / java.net.http ile WebSocket istemcileri
I/O Orta

java.net.http ile WebSocket istemcileri

Üçüncü taraf bağımlılığı eklemek yerine standart asenkron WebSocket istemcisini kullanın.

HTTP I/O Async Programming
Kod Karşılaştırması
✕ 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);
            }
        });
Bu kodda bir sorun mu gördünüz? Bize bildirin.
Modern yöntem neden daha iyi
📦

Ek bağımlılık yok

WebSocket istemcisi JDK ile birlikte gelir.

🧵

Asenkron API

Bağlantı ve mesaj işleme CompletionStage ile birleştirilebilir.

🔗

Paylaşılan HTTP yığını

Proxy, TLS ve executor yapılandırması standart JDK olanaklarını kullanır.

Eski Yaklaşım
Üçüncü taraf WebSocket istemcisi
Modern Yaklaşım
java.net.http.WebSocket
JDK'dan itibaren
11
Zorluk
Orta
JDK Desteği
java.net.http ile WebSocket istemcileri
Mevcut

JDK 11'den (Eylül 2018) itibaren geniş çapta kullanılabilir

Nasıl çalışır

java.net.http paketi, standart HTTP istemcisiyle tümleşik asenkron bir WebSocket istemcisi içerir. Bağlantılar CompletableFuture ile kurulur, listener callback'leri CompletionStage aracılığıyla bloklamayan mesaj işlemeyi destekler ve istemci JDK'nın standart proxy, TLS ve executor yapılandırmasını paylaşır.

İlgili Belgeler
WebSocket ↗ HTTP Client (JEP 321) ↗
Kanıt
Kanıt kaynağını görüntüle ↗
İlgili desenler
I/O Başlangıç

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();
Modernini görmek için üzerine gel ➜
JDK 11+ →
Concurrency Orta

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);
Modernini görmek için üzerine gel ➜
JDK 8+ →
Concurrency Orta

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();
}
Modernini görmek için üzerine gel ➜
JDK 21+ →