الرئيسية / 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.

🧵

واجهة برمجية غير متزامنة

يتكامل إنشاء الاتصال ومعالجة الرسائل مع 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+ →