Java HttpClientとは？使い方を解説【2026年版】

import java.net.http.HttpClient;

// HttpClientのインスタンスを生成
HttpClient client = HttpClient.newHttpClient();

import java.net.http.HttpClient;
import java.time.Duration;

// ビルダーを使ってHttpClientを生成
HttpClient client = HttpClient.newBuilder()
        .version(HttpClient.Version.HTTP_2) // 使用するHTTPバージョンを指定
        .connectTimeout(Duration.ofSeconds(10)) // 接続タイムアウトを10秒に設定
        .build();

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;

public class GetExample {
    public static void main(String[] args) throws Exception {
        // 1. HttpClientのインスタンスを作成
        HttpClient client = HttpClient.newHttpClient();

        // 2. HttpRequestを作成 (GETリクエスト)
        HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create("https://api.github.com/users/google"))
                .header("Accept", "application/vnd.github.v3+json")
                .GET() // GETメソッドを指定
                .build();

        // 3. リクエストを送信し、レスポンスを受信
        // BodyHandlers.ofString()はレスポンスボディを文字列として受け取る
        HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());

        // レスポンスの情報を出力
        System.out.println("Status Code: " + response.statusCode());
        System.out.println("Response Body: " + response.body());
    }
}

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;

public class PostExample {
    public static void main(String[] args) throws Exception {
        // 送信するJSONデータ
        String json = "{\"name\":\"Taro Yamada\", \"job\":\"Developer\"}";

        // 1. HttpClientインスタンスを作成
        HttpClient client = HttpClient.newHttpClient();

        // 2. HttpRequestを作成 (POSTリクエスト)
        HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create("https://httpbin.org/post"))
                .header("Content-Type", "application/json") // 送信するデータの種類を指定
                .POST(HttpRequest.BodyPublishers.ofString(json)) // POSTメソッドとリクエストボディを指定
                .build();

        // 3. リクエストを送信し、レスポンスを受信
        HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());

        // レスポンスの情報を出力
        System.out.println("Status Code: " + response.statusCode());
        System.out.println("Response Body: " + response.body());
    }
}

import java.net.http.HttpClient;
import java.time.Duration;

// 接続タイムアウトを10秒に設定
HttpClient client = HttpClient.newBuilder()
        .connectTimeout(Duration.ofSeconds(10))
        .build();

HttpRequest request = HttpRequest.newBuilder()
        .uri(URI.create("https://example.com"))
        .timeout(Duration.ofSeconds(5)) // このリクエスト単体のレスポンス待ち上限
        .GET()
        .build();

import java.net.URI;
import java.net.http.HttpRequest;

// 複数のヘッダーを追加する例
HttpRequest request = HttpRequest.newBuilder()
        .uri(URI.create("https://example.com"))
        .header("X-API-KEY", "your_api_key_here") // カスタムヘッダー
        .header("Accept", "application/json")   // Acceptヘッダー
        .build();

import java.net.http.HttpClient;

// リダイレクトポリシーを設定
HttpClient client = HttpClient.newBuilder()
        .followRedirects(HttpClient.Redirect.ALWAYS) // 常にリダイレクトに追従する
        .build();

// 他のポリシー
// HttpClient.Redirect.NEVER  - リダイレクトに追従しない
// HttpClient.Redirect.NORMAL - デフォルトの動作（同一プロトコルなど安全な場合のみ）

import java.net.InetSocketAddress;
import java.net.ProxySelector;
import java.net.http.HttpClient;

// プロキシサーバーを明示的に指定
HttpClient client = HttpClient.newBuilder()
        .proxy(ProxySelector.of(new InetSocketAddress("proxy.example.com", 8080)))
        .build();

import java.net.CookieManager;
import java.net.CookiePolicy;
import java.net.http.HttpClient;

// Cookieを自動保持するHttpClientを生成
CookieManager cookieManager = new CookieManager();
cookieManager.setCookiePolicy(CookiePolicy.ACCEPT_ALL);

HttpClient client = HttpClient.newBuilder()
        .cookieHandler(cookieManager)
        .build();

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.util.concurrent.CompletableFuture;

public class AsyncExample {
    public static void main(String[] args) throws Exception {
        HttpClient client = HttpClient.newHttpClient();
        HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create("https://api.github.com/"))
                .build();

        // 非同期でリクエストを送信
        CompletableFuture<HttpResponse<String>> future = 
            client.sendAsync(request, HttpResponse.BodyHandlers.ofString());

        System.out.println("リクエストを送信しました。レスポンスを待っています...");

        // レスポンスが返ってきた後の処理を定義
        future.thenAccept(response -> {
            System.out.println("Status Code: " + response.statusCode());
            System.out.println("Response Body: " + response.body().substring(0, 80) + "...");
        });

        // 非同期処理の完了を待つ (サンプルコードのため)
        future.join();
    }
}

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.util.concurrent.CompletableFuture;

public class CompletableFutureChain {
    public static void main(String[] args) {
        HttpClient client = HttpClient.newHttpClient();
        HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create("https://api.github.com/users/google"))
                .build();

        CompletableFuture<Void> future = client.sendAsync(request, HttpResponse.BodyHandlers.ofString())
                .thenApply(HttpResponse::body) // HttpResponseからボディ(文字列)を抽出
                .thenApply(body -> { // ボディを加工 (ここでは大文字に変換)
                    System.out.println("ボディを大文字に変換します。");
                    return body.toUpperCase();
                })
                .thenAccept(processedBody -> { // 加工後のボディをコンソールに出力
                    System.out.println("処理結果:");
                    System.out.println(processedBody.substring(0, 100) + "...");
                })
                .exceptionally(e -> { // エラーハンドリング
                    System.err.println("エラーが発生しました: " + e.getMessage());
                    return null;
                });

        System.out.println("非同期処理のチェーンを定義しました。");
        
        // 処理の完了を待機
        future.join();
    }
}

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;

public class WeatherApiExample {
    public static void main(String[] args) throws Exception {
        // 東京の緯度経度を指定してAPIのURLを構築
        String apiUrl = "https://api.open-meteo.com/v1/forecast" +
                "?latitude=35.6895&longitude=139.6917¤t_weather=true";

        HttpClient client = HttpClient.newHttpClient();
        HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create(apiUrl))
                .GET()
                .build();

        HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());

        if (response.statusCode() == 200) {
            System.out.println("東京の現在の天気情報:");
            System.out.println(response.body());
        } else {
            System.out.println("天気情報の取得に失敗しました。Status Code: " + response.statusCode());
        }
    }
}

// CurrentWeather.java
// APIレスポンスの"current_weather"部分に対応するクラス
public class CurrentWeather {
    public double temperature;
    public double windspeed;
    public int weathercode;
}

import com.fasterxml.jackson.databind.ObjectMapper;
// (他のimport文は省略)

public class JsonParseExample {
    public static void main(String[] args) throws Exception {
        // (APIリクエスト部分は前の例と同じ)
        String apiUrl = "..."; // 天気APIのURL
        // ... request, responseの取得 ...
        HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());

        if (response.statusCode() == 200) {
            String responseBody = response.body();

            // JacksonのObjectMapperを生成
            ObjectMapper mapper = new ObjectMapper();

            // JSON文字列をパースしてJavaオブジェクトに変換
            // ここではレスポンス全体から"current_weather"ノードを抽出してパース
            CurrentWeather weather = mapper.readTree(responseBody)
                                            .get("current_weather")
                                            .traverse(mapper)
                                            .readValueAs(CurrentWeather.class);
            
            System.out.println("現在の気温: " + weather.temperature + "℃");
            System.out.println("現在の風速: " + weather.windspeed + " km/h");
            System.out.println("天気コード: " + weather.weathercode);
        }
    }
}

// アプリケーションで共有するHttpClientインスタンス
public class AppHttpClient {
    public static final HttpClient INSTANCE = HttpClient.newBuilder()
            .version(HttpClient.Version.HTTP_2)
            .connectTimeout(Duration.ofSeconds(10))
            .build();

    private AppHttpClient() {}
}

// 利用する側のコード
public class SomeService {
    public void doSomething() throws Exception {
        HttpRequest request = ...;
        // 共有インスタンスを使ってリクエストを送信
        HttpResponse<String> response = AppHttpClient.INSTANCE.send(request, HttpResponse.BodyHandlers.ofString());
    }
}

try {
    HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
    System.out.println(response.body());
} catch (IOException e) {
    // 通信エラー：リトライやフォールバック処理を検討
    System.err.println("通信に失敗しました: " + e.getMessage());
} catch (InterruptedException e) {
    // 割り込み：スレッドの割り込み状態を復元してから再スロー
    Thread.currentThread().interrupt();
    throw new RuntimeException("リクエストが中断されました", e);
}