java代码模拟http发起请求且用线程池Callable+Future

如果一个平台的前端调用另一个平台的后端接口，由于跨域问题，而那边的后端接口不开放安全控制不支持跨域，所以由后端用Java代码模拟http请求，代理发起请求获取数据，然后在组装返回给前端需要的数据结构即可。

这是利用java代码模拟的发起http请求，相当于伪代理

public class HttpRequest {
    /**
     * 向指定URL发送GET方法的请求
     * @param url 发送请求的URL
     * @param param 请求参数，请求参数是 name1=value1&name2=value2 的形式。
     * @return 远程资源的响应结果
     */
    public static String sendGet(String url, String param) {
        String result = "";
        BufferedReader in = null;
        try {
            String urlNameString = url + "?" + param;
            URL realUrl = new URL(urlNameString);
            // 打开和URL之间的连接
            URLConnection connection = realUrl.openConnection();
            // 设置通用的请求属性
            connection.setRequestProperty("accept", "*/*");
            connection.setRequestProperty("connection", "Keep-Alive");
            connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
            // 建立实际的连接
            connection.connect();
            // 获取所有响应头字段
            Map<String, List<String>> map = connection.getHeaderFields();
            // 遍历所有的响应头字段
            for (String key : map.keySet()) {
                log.info(key + "--->" + map.get(key));
            }
            // 定义 BufferedReader输入流来读取URL的响应
            in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
            String line;
            while ((line = in.readLine()) != null) {
                result += line;
            }
        } catch (IOException e) {
            log.info("Send GET request exception!",e);

        }finally {
            try {
                if (in != null) {
                    in.close();
                }
            } catch (Exception e) {
                log.info("The input stream closes an exception!",e);
            }
        }
        return result;
    }
}

这是Callable的实现

public class MyCallable implements Callable<String> {
    private String url;
    private String param;

    public MyCallable(String url,String param){
        this.url = url;
        this.param = param;
    }

    @Override
    public String call() throws Exception {
        String app = HttpRequest.sendGet(url,param);
        return app;
    }
}

这是具体的执行Controller代码

public class ApplicationController {
    @GetMapping(value = "/get")
    public PojoResult getApplicationName(){
        try {
            //发送 GET 请求
            String str = HttpRequest.sendGet("url", "param");
            List<Atorage> list = new ArrayList<>();
            JSONArray jsonArray = JSONObject.parseObject(str).getJSONArray("object");
            for (int i = 0; i < jsonArray.size(); i++) {
                JSONObject json = jsonArray.getJSONObject(i);
                Atorage atorage = new Atorage();
                //用这边取到的值作为下面的参数
                atorage.setId(json.getInteger("id"));
                atorage.setName(json.getString("name"));

                //省略构造数据结构的过程。。。。。。
            }

            // 创建一个线程池
            ExecutorService pool = new ThreadPoolExecutor(list.size(), list.size(),
                    0, TimeUnit.SECONDS,
                    new ArrayBlockingQueue<>(512),
                    new ThreadPoolExecutor.DiscardPolicy());

            // 创建多个有返回值的任务
            List<Future<String>> futures = new ArrayList<>();
            for (int i = 0; i < list.size(); i++) {
                Atorage atorage = list.get(i);
                List<ProductVO> productVOS = new ArrayList<>();
                Integer reginId = atorage.getId();
                String url = "https://www.baidu.com/";
                String param = reginId;

                Callable c = new MyCallable(url,param);
                // 执行任务并获取Future对象
                Future f = pool.submit(c);
                futures.add(f);
            }

            // 关闭线程池
            pool.shutdown();

            // 获取所有并发任务的运行结果
            for (Future<String> future : futures) {
                List<ProductVO> productVOS = new ArrayList<>();
                // 从Future对象上获取任务的返回值，并对返回的json数据进行操作
                String app = future.get();

                //直接操纵json对象，对于没有pojo类的情况
                JSONArray appArray = JSONObject.parseObject(app).getJSONObject("object").getJSONArray("dataList");

                //沈略封装参数的过程。。。。。。
       
            }
            return PojoResultUtil.success(appVOS);
        } catch (Exception e) {
            log.error("ApplicationController.getApplicationName Exception", e);
            return PojoResultUtil.fail(ResBookingMessageCode.SERVER_ERROR);
        }
    }
}