HttpClient post提交multipart/form-data数据实现文件上传

た入场券 2022-12-27 08:47 147阅读 0赞

**场景：前端提交multipart/form-data数据，由api服务A将请求转发到api服务B**

A服务工具类方法如下：

public static Map<String, String> sendMultipartFilePost( String url, MultipartFile multipartFile, String fileParName,
                                                            Map<String, Object> params, int timeout) {
            Map<String, String> resultMap = new HashMap<String, String>();
            CloseableHttpClient httpClient = HttpClients.createDefault();
            String result = "";
            try {
                HttpPost httpPost = new HttpPost(url);
                MultipartEntityBuilder builder = MultipartEntityBuilder.create();
                builder.setCharset(java.nio.charset.Charset.forName("UTF-8"));
                builder.setMode(HttpMultipartMode.BROWSER_COMPATIBLE);
                String fileName = null;
                fileName = multipartFile.getOriginalFilename();
                builder.addBinaryBody(fileParName, multipartFile.getInputStream(), ContentType.MULTIPART_FORM_DATA, fileName);// 文件流
                //解决中文乱码
                ContentType contentType = ContentType.create(HTTP.PLAIN_TEXT_TYPE, HTTP.UTF_8);
                for (Map.Entry<String, Object> entry : params.entrySet()) {
                    if(entry.getValue() == null)
                        continue;
                    // 类似浏览器表单提交，对应input的name和value
                    builder.addTextBody(entry.getKey(), entry.getValue().toString(), contentType);
                }
                HttpEntity entity = builder.build();
                httpPost.setEntity(entity);
                HttpResponse response = httpClient.execute(httpPost);// 执行提交
     
                // 设置连接超时时间
                RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(timeout)
                        .setConnectionRequestTimeout(timeout).setSocketTimeout(timeout).build();
                httpPost.setConfig(requestConfig);
     
                HttpEntity responseEntity = response.getEntity();
                resultMap.put("scode", String.valueOf(response.getStatusLine().getStatusCode()));
                resultMap.put("data", "");
                if (responseEntity != null) {
                    // 将响应内容转换为字符串
                    result = EntityUtils.toString(responseEntity, java.nio.charset.Charset.forName("UTF-8"));
                    resultMap.put("data", result);
                }
            } catch (Exception e) {
                resultMap.put("scode", "error");
                resultMap.put("data", "HTTP请求出现异常: " + e.getMessage());
     
                Writer w = new StringWriter();
                e.printStackTrace(new PrintWriter(w));
            } finally {
                try {
                    httpClient.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            return resultMap;
        }

控制层调用方法如下：两种方式根据前端传值方式自行选择

第一种：

public BaseResponse<Object> uploadFile(@RequestParam("file") MultipartFile file,
                                               HttpServletRequest request){
            BaseResponse<Object> result = new BaseResponse<Object>();
            try {
                String code = request.getParameter("code");
                String name = request.getParameter("name");
                String url = request.getParameter("url");
                url = nlpNerPath + url;
                Map<String, Object> data = new HashMap<>();
                data.put("code", code);
                data.put("name", name);
                Map<String, String> resultDataMap = HttpRequest.sendMultipartFilePost(url, file, "file", data, -1);
                if ("200".equals(resultDataMap.get("scode"))) {
                    result.code = 200;
                    result.setMsg("成功");
                }
            } catch (Exception e) {
                e.printStackTrace();
                result.code = 500;
                result.setMsg("服务器错误");
            }
            return result;
        }

第二种：

@RequestMapping(value = "/add", method = RequestMethod.POST)
    public @ResponseBody Map<String, Object> add(HttpServletRequest request) throws Exception {
        MultipartHttpServletRequest params = ((MultipartHttpServletRequest) request);
        Map<String, Object> data = new HashMap<>();
        data.put("code", params.getParameter("code"));
        data.put("name", params.getParameter("name"));
        Map<String, String> resultDataMap = HttpUtil.httpPostRequest2("转发API地址",params.getFiles("files"), "files", data, -1);
        if ("200".equals(resultDataMap.get("scode"))) {
            Map<String, Object> returnData = JsonUtil.reflect(MapUtil.getString(resultDataMap, "data"));
            super.setOutData(returnData);
            return returnData;
        }
    }

参考博客：[https://blog.csdn.net/u010826617/article/details/80236226][https_blog.csdn.net_u010826617_article_details_80236226]  多文件上传

[https://blog.csdn.net/lsqingfeng/article/details/90611686][https_blog.csdn.net_lsqingfeng_article_details_90611686]     单文件上传

[https://www.cnblogs.com/foxting/p/7895724.html][https_www.cnblogs.com_foxting_p_7895724.html]

[https_blog.csdn.net_u010826617_article_details_80236226]: https://blog.csdn.net/u010826617/article/details/80236226
[https_blog.csdn.net_lsqingfeng_article_details_90611686]: https://blog.csdn.net/lsqingfeng/article/details/90611686
[https_www.cnblogs.com_foxting_p_7895724.html]: https://www.cnblogs.com/foxting/p/7895724.html