Java – HTTPリクエストのタイムアウトを設定する方法

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
public class App {
    public static void main(String[] args) {
        try {
            // URLを指定
            URL url = new URL("https://httpbin.org/get");
            HttpURLConnection connection = (HttpURLConnection) url.openConnection();
            
            // 接続タイムアウトを設定(ミリ秒単位)
            connection.setConnectTimeout(5000); // 5秒
            
            // 読み取りタイムアウトを設定(ミリ秒単位)
            connection.setReadTimeout(5000); // 5秒
            
            // リクエストメソッドをGETに設定
            connection.setRequestMethod("GET");
            
            // 接続を実行
            int responseCode = connection.getResponseCode();
            
            // レスポンスコードを表示
            System.out.println("レスポンスコード: " + responseCode);
            
            // レスポンスを読み取る
            BufferedReader in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
            String inputLine;
            StringBuilder response = new StringBuilder();
            
            while ((inputLine = in.readLine()) != null) {
                response.append(inputLine);
            }
            in.close();
            
            // レスポンス内容を表示
            System.out.println("レスポンス内容: " + response.toString());
            
        } catch (Exception e) {
            // エラーメッセージを表示
            System.out.println("エラー: " + e.getMessage());
        }
    }
}

レスポンスコード: 200
レスポンス内容: {
  "args": {},
  "headers": {
    "Accept": "*/*",
    "Host": "httpbin.org",
    "User-Agent": "Java/11.0.10",
    "X-Amzn-Trace-Id": "Root=1-60c72b2e-1c2e1e1e1e1e1e1e1e1e1e1e"
  },
  "origin": "xxx.xxx.xxx.xxx",
  "url": "https://httpbin.org/get"
}

import org.apache.http.HttpEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.util.EntityUtils;
public class App {
    public static void main(String[] args) {
        // タイムアウト設定
        RequestConfig requestConfig = RequestConfig.custom()
                .setConnectTimeout(5000) // 接続タイムアウトを5秒に設定
                .setSocketTimeout(5000)  // ソケットタイムアウトを5秒に設定
                .build();
        // HttpClientのインスタンスを作成
        try (CloseableHttpClient httpClient = HttpClients.custom()
                .setDefaultRequestConfig(requestConfig) // タイムアウト設定を適用
                .build()) {
            
            // GETリクエストを作成
            HttpGet httpGet = new HttpGet("https://httpbin.org/get");
            
            // リクエストを実行
            try (CloseableHttpResponse response = httpClient.execute(httpGet)) {
                // レスポンスを取得
                HttpEntity entity = response.getEntity();
                
                // レスポンス内容を表示
                if (entity != null) {
                    String result = EntityUtils.toString(entity);
                    System.out.println("レスポンス内容: " + result);
                }
            }
        } catch (Exception e) {
            // エラーメッセージを表示
            System.out.println("エラー: " + e.getMessage());
        }
    }
}

レスポンス内容: {
  "args": {},
  "headers": {
    "Accept": "*/*",
    "Host": "httpbin.org",
    "User-Agent": "Apache-HttpClient/4.5.13 (Java/11.0.10)",
    "X-Amzn-Trace-Id": "Root=1-60c72b2e-1c2e1e1e1e1e1e1e1e1e1e"
  },
  "origin": "xxx.xxx.xxx.xxx",
  "url": "https://httpbin.org/get"
}

import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import java.io.IOException;
public class App {
    public static void main(String[] args) {
        // OkHttpClientのインスタンスを作成
        OkHttpClient client = new OkHttpClient.Builder()
                .connectTimeout(5, java.util.concurrent.TimeUnit.SECONDS) // 接続タイムアウトを5秒に設定
                .readTimeout(5, java.util.concurrent.TimeUnit.SECONDS)    // 読み取りタイムアウトを5秒に設定
                .build();
        // GETリクエストを作成
        Request request = new Request.Builder()
                .url("https://httpbin.org/get")
                .build();
        // リクエストを実行
        try (Response response = client.newCall(request).execute()) {
            // レスポンス内容を表示
            if (response.body() != null) {
                System.out.println("レスポンス内容: " + response.body().string());
            }
        } catch (IOException e) {
            // エラーメッセージを表示
            System.out.println("エラー: " + e.getMessage());
        }
    }
}

import retrofit2.Retrofit;
import retrofit2.converter.gson.GsonConverterFactory;
import retrofit2.http.GET;
import retrofit2.Call;
import java.util.concurrent.TimeUnit;
public class App {
    public interface ApiService {
        @GET("get")
        Call<String> getData();
    }
    public static void main(String[] args) {
        // Retrofitのインスタンスを作成
        Retrofit retrofit = new Retrofit.Builder()
                .baseUrl("https://httpbin.org/")
                .addConverterFactory(GsonConverterFactory.create())
                .client(new OkHttpClient.Builder()
                        .connectTimeout(5, TimeUnit.SECONDS) // 接続タイムアウトを5秒に設定
                        .readTimeout(5, TimeUnit.SECONDS)    // 読み取りタイムアウトを5秒に設定
                        .build())
                .build();
        // APIサービスを作成
        ApiService apiService = retrofit.create(ApiService.class);
        // リクエストを実行
        Call<String> call = apiService.getData();
        call.enqueue(new retrofit2.Callback<String>() {
            @Override
            public void onResponse(Call<String> call, retrofit2.Response<String> response) {
                // レスポンス内容を表示
                System.out.println("レスポンス内容: " + response.body());
            }
            @Override
            public void onFailure(Call<String> call, Throwable t) {
                // エラーメッセージを表示
                System.out.println("エラー: " + t.getMessage());
            }
        });
    }
}