如何用Java多线程处理网络请求

在Java中，使用多线程处理网络请求是一种常见的做法，它可以提高程序的性能和响应速度。以下是一个简单的示例，展示了如何使用Java多线程处理网络请求：

1. 首先，导入所需的库：

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

2. 创建一个实现Runnable接口的类，该类将处理网络请求：

class HttpRequestTask implements Runnable {
    private String url;

    public HttpRequestTask(String url) {
        this.url = url;
    }

    @Override
    public void run() {
        try {
            URL obj = new URL(url);
            HttpURLConnection connection = (HttpURLConnection) obj.openConnection();
            connection.setRequestMethod("GET");

            int responseCode = connection.getResponseCode();
            System.out.println("Response Code for " + url + ": " + 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 for " + url + ": " + response.toString());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

3. 在主类中，创建一个线程池，并为每个网络请求提交一个任务：

public class MultiThreadedHttpRequests {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(5); // 创建一个固定大小的线程池

        // 添加网络请求任务到线程池
        executorService.submit(new HttpRequestTask("https://api.example.com/data1"));
        executorService.submit(new HttpRequestTask("https://api.example.com/data2"));
        executorService.submit(new HttpRequestTask("https://api.example.com/data3"));
        executorService.submit(new HttpRequestTask("https://api.example.com/data4"));
        executorService.submit(new HttpRequestTask("https://api.example.com/data5"));

        // 关闭线程池
        executorService.shutdown();
    }
}

这个示例中，我们创建了一个固定大小的线程池，用于处理5个网络请求。每个请求都在一个单独的线程中执行，这样可以并行处理多个请求，提高程序的性能。当所有任务完成后，线程池会被关闭。