HttpClient Post 二进制/字节流/byte[]实例代码


             HttpClient Post 二进制/字节流/byte[]实例代码

HttpClient 3.x







public class HttpHelper { 

  String m_url; 

  HttpClient m_HttpClient; 

 

  public HttpHelper(String url) { 

    m_url = url; 

    m_HttpClient = new HttpClient(); 

  } 

 

  public byte[] post(byte[] bytes, String contentType) throws IOException { 

    PostMethod method = new PostMethod(m_url); 

 

    if ((contentType != null) && (contentType.length() > 0)) 

      method.setRequestHeader("Content-type" , contentType); 

    method.setRequestEntity(new ByteArrayRequestEntity(bytes)); 

    int HttpCode = m_HttpClient.executeMethod(method); 

    if (HttpCode != HttpStatus.SC_OK) 

      throw new IOException("Invalid HttpStatus: " + HttpCode); 

    InputStream respStream = method.getResponseBodyAsStream(); 

    int respBodySize = respStream.available(); 

    if (respBodySize <= 0) 

      throw new IOException("Invalid respBodySize: " + respBodySize); 

    byte[] respBuffer = new byte[respBodySize]; 

    if (respStream.read(respBuffer) != respBodySize) 

      throw new IOException("Read respBody Error"); 

    return respBuffer; 

  } 

 

  public String postXml(String str) throws IOException { 

    byte[] reqBuffer = str.getBytes(Charset.forName("UTF-8")); 

    byte[] respBuffer = post(reqBuffer, "application/xml; charset=UTF-8"); 

    String resp = new String(respBuffer, Charset.forName("UTF-8")); 

    return resp; 

  } 

} 





HttpClient 4.x







public class HttpHelper { 

  CloseableHttpClient m_HttpClient; 

 

  public HttpHelper() { 

    m_HttpClient = HttpClients.createDefault(); 

  } 

 

  // send bytes and recv bytes 

  public byte[] post(String url, byte[] bytes, String contentType) throws IOException { 

    HttpPost httpPost = new HttpPost(url); 

    httpPost.setEntity(new ByteArrayEntity(bytes)); 

    if (contentType != null) 

      httpPost.setHeader("Content-type", contentType); 

    CloseableHttpResponse httpResponse = m_HttpClient.execute(httpPost); 

    try { 

      HttpEntity entityResponse = httpResponse.getEntity(); 

      int contentLength = (int) entityResponse.getContentLength(); 

      if (contentLength <= 0) 

        throw new IOException("No response"); 

      byte[] respBuffer = new byte[contentLength]; 

      if (entityResponse.getContent().read(respBuffer) != respBuffer.length) 

        throw new IOException("Read response buffer error"); 

      return respBuffer; 

    } finally { 

      httpResponse.close(); 

    } 

  } 

 

  public byte[] post(String url, byte[] bytes) throws IOException { 

    return post(url, bytes, null); 

  } 

 

  public String postXml(String url, String str) throws IOException { 

    byte[] reqBuffer = str.getBytes(Charset.forName("UTF-8")); 

    byte[] respBuffer = post(url, reqBuffer, "application/xml; charset=UTF-8"); 

    String resp = new String(respBuffer, Charset.forName("UTF-8")); 

    return resp; 

  } 

} 





 感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！