HttpClient以form-data形式发送请求

忘是亡心i 2022-09-06 01:18 211阅读 0赞

import org.apache.commons.lang3.StringUtils;
    import org.apache.http.HttpEntity;
    import org.apache.http.HttpResponse;
    import org.apache.http.client.methods.HttpPost;
    import org.apache.http.entity.ContentType;
    import org.apache.http.entity.mime.MultipartEntityBuilder;
    import org.apache.http.impl.client.CloseableHttpClient;
    import org.apache.http.impl.client.HttpClients;
    import org.apache.http.util.EntityUtils;
    
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.IOException;
    import java.nio.charset.Charset;
    import java.util.ArrayList;
    import java.util.List;
    
    
    @Slf4j
    public class Req { 
        public static void main(String[] args) throws IOException { 
            String url = "https://helloworld.com/api/upload";
            String bodyData = "uuid=666&filename=xxx&A=1&data=GDwUFRZCRAJYBFhdVF49WQdBXEUQBQpZAFEBRk";
    
            HttpPost httpPost = new HttpPost(url);
    
            CloseableHttpClient client = HttpClients.createDefault();
            MultipartEntityBuilder builder = MultipartEntityBuilder.create();
    
            // 标记哪些字段是文件
            List<String> fileField = new ArrayList<>();
    
            if (!fileField.isEmpty() && StringUtils.isNotBlank(bodyData)) { 
                String[] params = bodyData.split("&");
                for (String param : params) { 
                    String[] kv = param.split("=");
                    for (String field : fileField) { 
                        if (kv[0].equals(field)) { 
                            File file = new File(kv[1]);
                            // 添加文件
                            builder.addBinaryBody(
                                    kv[0],
                                    new FileInputStream(file),
                                    ContentType.APPLICATION_OCTET_STREAM,
                                    file.getName()
                            );
                            break;
                        }
                    }
                    // 添加非文件
                    builder.addTextBody(kv[0], kv[1], ContentType.MULTIPART_FORM_DATA);
                }
            } else if (StringUtils.isNotBlank(bodyData)) { 
                String[] params = bodyData.split("&");
                for (String param : params) { 
                    String[] kv = param.split("=");
                    builder.addTextBody(kv[0], kv[1], ContentType.MULTIPART_FORM_DATA);
                }
            }
            HttpEntity multipart = builder.build();
    
            HttpResponse resp = null;
            String respContent = null;
            try { 
                httpPost.setEntity(multipart);
                // biu
                resp = client.execute(httpPost);
    
                if (resp.getStatusLine().getStatusCode() == 302) { 
                    HttpEntity entity = resp.getEntity();
                    respContent = EntityUtils.toString(entity, "UTF-8");
                    logger.info("302 resp" + respContent);
                }
            } catch (Exception e) { 
                logger.error(e.getMessage());
            }
    
            logger.info("resp status code: \t" + resp.getStatusLine().getStatusCode());
            logger.info("resp: \t" + EntityUtils.toString(resp.getEntity(), StandardCharsets.UTF_8));
        }
    }