当前位置: 首页 > article >正文

HttpClient发送MultipartFile多文件及多参数请求

1、环境准备:


        <dependency>
            <groupId>commons-httpclient</groupId>
            <artifactId>commons-httpclient</artifactId>
            <version>3.1</version>
        </dependency>
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpmime</artifactId>
            <version>4.5.3</version>
        </dependency>

2、Java中发送httpClient请求:

/**
     * HttpClient post multipart/form-data数据实现多文件上传
     * @param url
     * @param headers 头部参数
     * @param body body参数,json字符串
     * @param multipartFiles 文件列表
     * @param fileParName 接收的文件名
     * @return
     */
    public static String sendFilePost(String url, Map<String, String> headers, String body,List<MultipartFile> multipartFiles,String fileParName) {
        CloseableHttpClient httpclient = HttpClients.createDefault();
        HttpPost httppost = new HttpPost(url);
        MultipartEntityBuilder builder = MultipartEntityBuilder.create();
        builder.setMode(HttpMultipartMode.BROWSER_COMPATIBLE);
        builder.setCharset(java.nio.charset.Charset.forName("UTF-8"));
        //单个文件
        String fileName = null;
        MultipartFile multipartFile = null;
        for (int i = 0; i < multipartFiles.size(); i++) {
            //第一个参数为 相当于 Form表单提交的file框的name值 第二个参数就是我们要发送的InputStream对象了
            //第三个参数是文件名
            //3)
            multipartFile = multipartFiles.get(i);
            fileName = multipartFile.getOriginalFilename();
            InputStream inputStream = null;
            try {
                inputStream = multipartFile.getInputStream();
            } catch (IOException e) {
                e.printStackTrace();
            }
            builder.addBinaryBody(fileParName,inputStream, ContentType.MULTIPART_FORM_DATA, fileName);// 文件流
        }
        //4)构建请求参数 普通表单项
		/*	StringBody stringBody = new StringBody("12", ContentType.MULTIPART_FORM_DATA);
			builder.addPart("id", stringBody);*/
        //决中文乱码
        ContentType contentType = ContentType.create(HTTP.PLAIN_TEXT_TYPE, Consts.UTF_8);
        builder.addTextBody("paramStr", body, contentType);
        HttpEntity entity = builder.build();
        if (null!=headers&&headers.size()>0){
            for (Map.Entry<String, String> entry : headers.entrySet()) {
                httppost.addHeader(entry.getKey(),entry.getValue());
            }
        }
        httppost.setEntity(entity);
        CloseableHttpResponse response = null;
        try {
            response = httpclient.execute(httppost);
        } catch (IOException e) {
            logger.error("请求出错:" + url, e);
            return null;
        }
        String result = null;
        try {
            if(response!=null){
                HttpEntity httpEntity = response.getEntity();
                if (httpEntity != null && response.getStatusLine().getStatusCode()== HttpURLConnection.HTTP_OK) {// 判断请求状态
                    result = EntityUtils.toString(httpEntity);
                }
            }
        } catch (Exception e) {
            logger.error("请求出错:" + url, e);
        } finally {
            try {
                if(response!=null){
                    response.close();
                }
            } catch (IOException e) {
                logger.error("请求出错:" + url, e);
            }
        }
        logger.info("请求的URL:" + url + ", 返回结果:" + result);
        return result;
    }

3、后端服务restful接口接参:

    @Operation(summary = "获取附件")
    @PostMapping("/xxx")
    private void sendfilepost(@RequestParam(value = "file") List<MultipartFile> mulFiles,@RequestParam(value = "paramStr") String json){
        /**这里处理自己的逻辑*/
    }

4、模拟2中调用

/**将普通文件转成MultipartFile文件*/
public static MultipartFile getMultipartFile(File file) {
        FileItem item = new DiskFileItemFactory().createItem("file"
                , MediaType.MULTIPART_FORM_DATA_VALUE
                , true
                , file.getName());
        try (InputStream input = new FileInputStream(file);
             OutputStream os = item.getOutputStream()) {
            // 流转移
            IOUtils.copy(input, os);
        } catch (Exception e) {
            throw new IllegalArgumentException("Invalid file: " + e, e);
        }

        return new CommonsMultipartFile(item);
}


public static void main(String[] args) {
    String url = "请求的服务路径";
    File f = new File("D:\\test");
    File[] files = f.listFiles();
    List<MultipartFile> multiFiles = new ArrayList();
    for(File tempFile:files){
       MultipartFile cMultiFile = getMultipartFile(tempFile);
       multiFiles.add(cMultiFile);
    }
    String restr = sendFilePost(url, null, JSON.toJSONString(paramMap),multiFiles,"file");
}


http://www.kler.cn/news/136553.html

相关文章:

  • 解决运行jar错误: 缺少 JavaFX 运行时组件, 需要使用该组件来运行此应用程序
  • kafka 的高可用机制是什么?
  • Servlet(三)-------Cookie和session
  • 分享几个办公类常用的AI工具
  • Excel:vba实现生成随机数
  • 网站被浏览器提示“不安全”,如何快速解决
  • 担忧CentOS停服?KeyarchOS系统来支撑
  • 大模型LLM 在线量化;GPTQ\AWQ量化及推理
  • Windows 安装 Docker
  • PostgreSQL数据库结合内网穿透实现公网远程连接
  • 2023年中职“网络安全“—Linux系统渗透提权③
  • 如何快速将txt类型的日志文件转换为excel表格并进行数据分析报表统计图(如:饼图、折线图、柱状图)?
  • WPS或Excel查找A列中有B列没有的值
  • synchronized锁膨胀过程
  • 第四代智能井盖传感器,实时守护井盖位安全
  • IF:9.0+期刊被踢除,11月SCI/SSCI期刊目录已更新!
  • 上下文切换
  • 基于龙格-库塔算法优化概率神经网络PNN的分类预测 - 附代码
  • RESTful API 设计指南——为什么要用(上)
  • Ubuntu——卸载、安装CUDA
  • Linux编辑器-gcc/g++使用
  • C#的类型转换
  • 代码随想录算法训练营第六十天 | LeetCode 84. 柱状图中最大的矩形
  • Android13 新增 Stable AIDL接口
  • 海外服务器相较于国内服务器有何特点?亚马逊海外服务器为何零跑全球
  • 电池管理系统设计与实现