springboot使用自定义的线程池完成多线程执行网络请求，返回数据后，统一返回给前段

定义自定义线程池配置类

创建一个ThreadPoolConfig类，用于配置自定义线程池的参数。

java">import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
@Configuration
public class ThreadPoolConfig {@Beanpublic ExecutorService customThreadPool() {// 核心线程数为5int corePoolSize = 5;// 最大线程数为10int maximumPoolSize = 10;// 线程空闲存活时间为60秒long keepAliveTime = 60;// 时间单位为秒TimeUnit unit = TimeUnit.SECONDS;// 使用有界阻塞队列，容量为100LinkedBlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>(100);return new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);}
}

这个配置类使用@Configuration注解标记，表明它是一个配置类。@Bean注解用于定义一个由 Spring 管理的ExecutorService类型的 Bean，也就是自定义的线程池。这里创建了一个ThreadPoolExecutor对象，设置了核心线程数、最大线程数、线程空闲存活时间、队列容量等参数。

创建网络请求服务类

定义一个NetworkRequestService类，用于执行网络请求。自己找工具类

java">import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
@Service
public class NetworkRequestService {private final RestTemplate restTemplate = new RestTemplate();public String makeNetworkRequest(String url) {ResponseEntity<String> response = restTemplate.getForEntity(url, String.class);return response.getBody();}
}

编写控制器类来处理多线程网络请求并返回结果给前端

创建一个MultiThreadRequestController类。

java">import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Future;
@RestController
public class MultiThreadRequestController {@Autowiredprivate NetworkRequestService networkRequestService;@Autowiredprivate ExecutorService customThreadPool;@GetMapping("/multi-request")public List<String> multiThreadRequests() throws InterruptedException, ExecutionException {// 定义要请求的URL列表List<String> urls = List.of("https://example1.com", "https://example2.com", "https://example3.com");List<Future<String>> futures = new ArrayList<>();for (String url : urls) {// 提交任务到自定义线程池Future<String> future = customThreadPool.submit(() -> networkRequestService.makeNetworkRequest(url));futures.add(future);}List<String> results = new ArrayList<>();for (Future<String> future : futures) {// 获取每个任务的结果results.add(future.get());}return results;}
}

这个类是一个 Spring REST 控制器，使用@RestController注解标记。它通过@Autowired注入了NetworkRequestService和自定义的ExecutorService。multiThreadRequests方法是一个处理 HTTP GET 请求的端点。它首先定义了一个要请求的URL列表，然后循环将每个网络请求任务提交到自定义线程池，将返回的Future对象保存到futures列表中。接着，它遍历futures列表，通过future.get()方法获取每个任务的结果，将结果保存到results列表中，最后返回results列表给前端。