使用HttpClient實(shí)現(xiàn)文件上傳

package com.pinyougou.httpclient.login;

import org.apache.commons.httpclient.Cookie;
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.NameValuePair;
import org.apache.commons.httpclient.cookie.CookiePolicy;
import org.apache.commons.httpclient.methods.GetMethod;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.http.HttpEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.mime.MultipartEntityBuilder;
import org.apache.http.entity.mime.content.FileBody;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.util.EntityUtils;

import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;

/**
 * Created by xiaohuihui on 2018-05-12
 */


public static void main(String[] args) {
    String respStr = null;

    // 1. 登錄pinyougou,同時(shí)存入cookie
//  HttpClient httpClient = getCookie("http://localhost:9102/login");
    TestHttpClient testHttpClient = new TestHttpClient();
    CloseableHttpClient httpClient = null;
    try {
        httpClient = testHttpClient.testLogin();
    } catch (Exception e) {
        e.printStackTrace();
    }

    // 2. 使用HttpClient完成文件上傳
//        String afterLoginUrl = "http://localhost:9102/itemCat/findByParentId.do?parentId=1";
//        afterLogin(httpClient, afterLoginUrl);

    // 3. 使用HttpClient完成文件上傳
    String uploadUrl = "http://localhost:9102/upload.do";
    HttpPost httpPost = new HttpPost(uploadUrl);
    FileBody fileBody = new FileBody(new File("C:/Users/Administrator/Desktop/timg.jpg"));
    MultipartEntityBuilder multipartEntityBuilder = MultipartEntityBuilder.create();
    multipartEntityBuilder.addPart("file",fileBody);

    // 設(shè)置其他參數(shù)
    List<NameValuePair> nvps = new ArrayList<NameValuePair>();
    nvps.add(new NameValuePair("Accept","application/json, text/plain, */*"));
    nvps.add(new NameValuePair("Accept-Encoding","gzip, deflate, br"));
    nvps.add(new NameValuePair("Accept-Language","zh-CN,zh;q=0.9"));
    nvps.add(new NameValuePair("Connection","keep-alive"));
    nvps.add(new NameValuePair("Content-Length","28700"));
    nvps.add(new NameValuePair("Content-Type","multipart/form-data; boundary=----WebKitFormBoundarypaEfQmIQBbUrkI0c"));
    nvps.add(new NameValuePair("Host","localhost:9102"));
    nvps.add(new NameValuePair("Origin","http://localhost:9102"));
    nvps.add(new NameValuePair("Referer","http://localhost:9102/admin/goods_edit.html"));
    nvps.add(new NameValuePair("User-Agent","Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/65.0.3325.146 Safari/537.36"));

    HttpEntity reqEntity  = multipartEntityBuilder.build();
    httpPost.setEntity(reqEntity);

    try {
        CloseableHttpResponse response = httpClient.execute(httpPost);
        System.out.println("上傳之后返回的狀態(tài)碼:"+response.getStatusLine().getStatusCode());
        try {
            HttpEntity resEntity = response.getEntity();
            respStr = getRespString(resEntity);
            EntityUtils.consume(reqEntity);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
          response.close();
        }
    } catch (IOException e) {
        e.printStackTrace();
    }

    System.out.println("resp=" + respStr);


}


/**
 * 將返回結(jié)果轉(zhuǎn)化為String
 *
 * @param entity
 * @return
 * @throws Exception
 */
private static String getRespString(HttpEntity entity) throws Exception {
    if (entity == null) {
        return null;
    }
    InputStream is = entity.getContent();
    StringBuffer strBuf = new StringBuffer();
    byte[] buffer = new byte[4096];
    int r = 0;
    while ((r = is.read(buffer)) > 0) {
        strBuf.append(new String(buffer, 0, r, "UTF-8"));
    }
    return strBuf.toString();
}

/**
 * 登陸后檢測(cè)
 *
 * @param httpClient
 * @param afterLoginUrl
 */
private static void afterLogin(HttpClient httpClient, String afterLoginUrl) {
    // 進(jìn)行登錄后的操作
    GetMethod getMethod = new GetMethod(afterLoginUrl);
    try {
        httpClient.executeMethod(getMethod);
        // 打印出返回?cái)?shù)據(jù)，檢驗(yàn)一下是否成功
        String responseText = getMethod.getResponseBodyAsString();
        System.out.println(responseText);

    } catch (IOException e) {
        e.printStackTrace();
    }
}


/**
 * 使用HttpClient進(jìn)行登錄同時(shí)返回帶有cookie信息的HttpClient對(duì)象
 * @param loginUrl
 * @return
 */
private static HttpClient getCookie(String loginUrl) {

//        String loginUrl = "http://localhost:9102/login";

    HttpClient httpClient = new HttpClient();
    // 使用post方式進(jìn)行登錄
    PostMethod postMethod = new PostMethod(loginUrl);
    // 設(shè)置登錄信息
    NameValuePair[] data = {
            new NameValuePair("username", "wangyi"), new NameValuePair("password", "123456"),
            new NameValuePair("m1", "2")
    };

    postMethod.setRequestBody(data);

    // 設(shè)置 HttpClient 接收 Cookie,用與瀏覽器一樣的策略
    httpClient.getParams().setCookiePolicy(CookiePolicy.BROWSER_COMPATIBILITY);
    try {
        httpClient.executeMethod(postMethod);
    } catch (IOException e) {
        e.printStackTrace();
    }
    // 獲得登陸后的 Cookie
    Cookie[] cookies = httpClient.getState().getCookies();
    StringBuffer tmpcookies = new StringBuffer();
    for (Cookie c : cookies) {
        tmpcookies.append(c.toString() + ";");
    }

    return httpClient;
}

}

HttpClient4.x可以自帶維持會(huì)話功能，只要使用同一個(gè)HttpClient且未關(guān)閉連接，則可以使用相同會(huì)話來(lái)訪問(wèn)其他要求登錄驗(yàn)證的服務(wù)（見TestLogin()方法中的“執(zhí)行g(shù)et請(qǐng)求”部分）。
如果需要使用HttpClient池，并且想要做到一次登錄的會(huì)話供多個(gè)HttpClient連接使用，就需要自己保存會(huì)話信息。因?yàn)榭蛻舳说臅?huì)話信息是保存在cookie中的（JSESSIONID），所以只需要將登錄成功返回的cookie復(fù)制到各個(gè)HttpClient使用即可。
使用Cookie的方法有兩種，可以自己使用CookieStore來(lái)保存（見TestCookieStore()方法），也可以通過(guò)HttpClientContext上下文來(lái)維持（見TestContext()方法）。
附帶HttpClient4.3示例代碼 http://www.myexception.cn/program/1459749.html 。

package com.pinyougou.httpclient.login;

import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;

import org.apache.http.HeaderIterator;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.ParseException;
import org.apache.http.client.CookieStore;
import org.apache.http.client.config.CookieSpecs;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.protocol.HttpClientContext;
import org.apache.http.config.Registry;
import org.apache.http.config.RegistryBuilder;
import org.apache.http.cookie.CookieSpecProvider;
import org.apache.http.impl.client.BasicCookieStore;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.cookie.BasicClientCookie;
import org.apache.http.impl.cookie.BestMatchSpecFactory;
import org.apache.http.impl.cookie.BrowserCompatSpecFactory;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
import org.junit.Test;

/**
 * Created by xiaohuihui on 2018-05-12
 */
public class TestHttpClient {
// 創(chuàng)建CookieStore實(shí)例
static CookieStore cookieStore = null;
static HttpClientContext context = null;
String loginUrl = "http://localhost:9102/login";
String testUrl = "http://localhost:9102/itemCat/findByParentId.do?parentId=1";
String loginErrorUrl = "http://localhost:9102/login";

public CloseableHttpClient testLogin() throws Exception {
    System.out.println("----testLogin");

    // // 創(chuàng)建HttpClientBuilder
    // HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();
    // // HttpClient
    // CloseableHttpClient client = httpClientBuilder.build();
    // 直接創(chuàng)建client
    CloseableHttpClient client = HttpClients.createDefault();

    HttpPost httpPost = new HttpPost(loginUrl);
    Map parameterMap = new HashMap();
    parameterMap.put("username", "wangyi");
    parameterMap.put("password", "123456");
    UrlEncodedFormEntity postEntity = new UrlEncodedFormEntity(
            getParam(parameterMap), "UTF-8");
    httpPost.setEntity(postEntity);
    System.out.println("request line:" + httpPost.getRequestLine());
    try {
        // 執(zhí)行post請(qǐng)求
        HttpResponse httpResponse = client.execute(httpPost);
        String location = httpResponse.getFirstHeader("Location")
                .getValue();
        if (location != null && location.startsWith(loginErrorUrl)) {
            System.out.println("----loginError");
        }
        printResponse(httpResponse);

        // 執(zhí)行g(shù)et請(qǐng)求
        System.out.println("----the same client");
        HttpGet httpGet = new HttpGet(testUrl);
        System.out.println("request line:" + httpGet.getRequestLine());
        HttpResponse httpResponse1 = client.execute(httpGet);
        printResponse(httpResponse1);


        // cookie store
        setCookieStore(httpResponse);
        // context
        setContext();
        return client;

    } catch (IOException e) {
        e.printStackTrace();
        throw new RuntimeException(e);
    }
//        finally {
//            try {
//                // 關(guān)閉流并釋放資源
//                client.close();
//            } catch (IOException e) {
//                e.printStackTrace();
//            }
//        }
}

@Test
public void testContext() throws Exception {
    System.out.println("----testContext");
    // 使用context方式
    CloseableHttpClient client = HttpClients.createDefault();
    HttpGet httpGet = new HttpGet(testUrl);
    System.out.println("request line:" + httpGet.getRequestLine());
    try {
        // 執(zhí)行g(shù)et請(qǐng)求
        HttpResponse httpResponse = client.execute(httpGet, context);
        printResponse(httpResponse);
        System.out.println("context cookies:"
                + context.getCookieStore().getCookies());
        printResponse(httpResponse);
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        try {
            // 關(guān)閉流并釋放資源
            client.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

@Test
public void testCookieStore() throws Exception {
    System.out.println("----testCookieStore");
    // 使用cookieStore方式
    CloseableHttpClient client = HttpClients.custom()
            .setDefaultCookieStore(cookieStore).build();
    HttpGet httpGet = new HttpGet(testUrl);
    System.out.println("request line:" + httpGet.getRequestLine());
    try {
        // 執(zhí)行g(shù)et請(qǐng)求
        HttpResponse httpResponse = client.execute(httpGet);
        System.out.println("cookie store:" + cookieStore.getCookies());
        printResponse(httpResponse);
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        try {
            // 關(guān)閉流并釋放資源
            client.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

public static void printResponse(HttpResponse httpResponse)
        throws ParseException, IOException {
    // 獲取響應(yīng)消息實(shí)體
    HttpEntity entity = httpResponse.getEntity();
    // 響應(yīng)狀態(tài)
    System.out.println("status:" + httpResponse.getStatusLine());
    System.out.println("headers:");
    HeaderIterator iterator = httpResponse.headerIterator();
    while (iterator.hasNext()) {
        System.out.println("\t" + iterator.next());
    }
    // 判斷響應(yīng)實(shí)體是否為空
    if (entity != null) {
        String responseString = EntityUtils.toString(entity);
        System.out.println("response length:" + responseString.length());
        System.out.println("response content:"
                + responseString.replace("\r\n", ""));
    }
}

public static void setContext() {
    System.out.println("----setContext");
    context = HttpClientContext.create();
    Registry<CookieSpecProvider> registry = RegistryBuilder
            .<CookieSpecProvider>create()
            .register(CookieSpecs.BEST_MATCH, new BestMatchSpecFactory())
            .register(CookieSpecs.BROWSER_COMPATIBILITY,
                    new BrowserCompatSpecFactory()).build();
    context.setCookieSpecRegistry(registry);
    context.setCookieStore(cookieStore);
}

public static void setCookieStore(HttpResponse httpResponse) {
    System.out.println("----setCookieStore");
    cookieStore = new BasicCookieStore();
    // JSESSIONID
    String setCookie = httpResponse.getFirstHeader("Set-Cookie")
            .getValue();
    String JSESSIONID = setCookie.substring("JSESSIONID=".length(),
            setCookie.indexOf(";"));
    System.out.println("JSESSIONID:" + JSESSIONID);
    // 新建一個(gè)Cookie
    BasicClientCookie cookie = new BasicClientCookie("JSESSIONID",
            JSESSIONID);
    cookie.setVersion(0);
    cookie.setDomain("127.0.0.1");
    cookie.setPath("/CwlProClient");
    // cookie.setAttribute(ClientCookie.VERSION_ATTR, "0");
    // cookie.setAttribute(ClientCookie.DOMAIN_ATTR, "127.0.0.1");
    // cookie.setAttribute(ClientCookie.PORT_ATTR, "8080");
    // cookie.setAttribute(ClientCookie.PATH_ATTR, "/CwlProWeb");
    cookieStore.addCookie(cookie);
}

public static List<NameValuePair> getParam(Map parameterMap) {
    List<NameValuePair> param = new ArrayList<NameValuePair>();
    Iterator it = parameterMap.entrySet().iterator();
    while (it.hasNext()) {
        Entry parmEntry = (Entry) it.next();
        param.add(new BasicNameValuePair((String) parmEntry.getKey(),
                (String) parmEntry.getValue()));
    }
    return param;
}


}
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡(jiǎn)書系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容