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

技术  /  管理员 发布于 8年前   290

 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;   } } 

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