ホーム / I/O / java.net.httpによるWebSocketクライアント
I/O 中級

java.net.httpによるWebSocketクライアント

サードパーティ依存関係を追加する代わりに、標準の非同期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サポート
java.net.httpによるWebSocketクライアント
利用可能

JDK 11（2018年9月）以降、広く利用可能

仕組み

java.net.httpパッケージには、標準HTTPクライアントと統合された非同期WebSocketクライアントが含まれています。接続はCompletableFutureで確立され、リスナーコールバックはCompletionStageによるノンブロッキングのメッセージ処理をサポートし、クライアントはJDK標準のプロキシ、TLS、エグゼキュータ設定を共有します。

関連ドキュメント
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+ →