设为首页收藏本站
开启辅助访问

在路上

 找回密码
 立即注册
在路上 › 站点首页 ›学习 › 查看内容

HttpClient4.3.x使用-基础篇

2016-8-29 13:14| 发布者: zhangjf| 查看: 810| 评论: 0

摘要: 1、关闭流和responseCloseableHttpClient httpclient = HttpClients.createDefault();HttpGet httpget = new HttpGet(http://localhost/);CloseableHttpResponse response = httpclient.execute(httpget);try { H ...
1、关闭流和response
  1. CloseableHttpClient httpclient = HttpClients.createDefault();
  2. HttpGet httpget = new HttpGet("http://localhost/");
  3. CloseableHttpResponse response = httpclient.execute(httpget);
  4. try {
  5. HttpEntity entity = response.getEntity();
  6. if (entity != null) {
  7. InputStream instream = entity.getContent();
  8. try {
  9. // do something useful
  10. } finally {
  11. instream.close();
  12. }
  13. }
  14. } finally {
  15. response.close();
  16. }
复制代码

The difference between closing the content stream and closing the response is that the former will
attempt to keep the underlying connection alive by consuming the entity content while the latter
immediately shuts down and discards the connection.

关闭InputStream和关闭response的区别在于：关闭InputStream会通过消费实体内容与底层保持连接，而关闭response则会立即停止和丢弃连接。

  1. class HttpResponseProxy implements CloseableHttpResponse {
  2. private final HttpResponse original;
  3. private final ConnectionHolder connHolder;
  4. public HttpResponseProxy(final HttpResponse original, final ConnectionHolder connHolder) {
  5. this.original = original;
  6. this.connHolder = connHolder;
  7. ResponseEntityProxy.enchance(original, connHolder);
  8. }
  9. public void close() throws IOException {
  10. if (this.connHolder != null) {
  11. this.connHolder.abortConnection();
  12. }
  13. }
复制代码

丢弃的代码：

  1. public void abortConnection() {
  2. synchronized (this.managedConn) {
  3. if (this.released) {
  4. return;
  5. }
  6. this.released = true;
  7. try {
  8. this.managedConn.shutdown();
  9. log.debug("Connection discarded");
  10. } catch (final IOException ex) {
  11. if (this.log.isDebugEnabled()) {
  12. this.log.debug(ex.getMessage(), ex);
  13. }
  14. } finally {
  15. this.manager.releaseConnection(
  16. this.managedConn, null, 0, TimeUnit.MILLISECONDS);
  17. }
  18. }
  19. }
复制代码
2、读取Entity

如果是使用EntityUtils#consume(HttpEntity)这个方法，它会自动去关闭inputStream

如果不需要读取全部的实体，则可以直接关闭response，来终止InputSteam的读取（关闭response会自动关闭InputStream）。

  1. CloseableHttpClient httpclient = HttpClients.createDefault();
  2. HttpGet httpget = new HttpGet("http://localhost/");
  3. CloseableHttpResponse response = httpclient.execute(httpget);
  4. try {
  5. HttpEntity entity = response.getEntity();
  6. if (entity != null) {
  7. InputStream instream = entity.getContent();
  8. int byteOne = instream.read();
  9. int byteTwo = instream.read();
  10. // Do not need the rest
  11. }
  12. } finally {
  13. response.close();
  14. }
复制代码

不推荐使用EntityUtils的toString方法，如果需要的话，最好自己判断长度：

  1. CloseableHttpClient httpclient = HttpClients.createDefault();
  2. HttpGet httpget = new HttpGet("http://localhost/");
  3. CloseableHttpResponse response = httpclient.execute(httpget);
  4. try {
  5. HttpEntity entity = response.getEntity();
  6. if (entity != null) {
  7. long len = entity.getContentLength();
  8. if (len != -1 && len < 2048) {
  9. System.out.println(EntityUtils.toString(entity));
  10. } else {
  11. // Stream content out
  12. }
  13. }
  14. } finally {
  15. response.close();
  16. }
复制代码

因为toString方法默认最大的长度是Integer.MAX_VALUE，这个有点危险，会导致缓冲区溢出。

  1. /**
  2. * Get the entity content as a String, using the provided default character set
  3. * if none is found in the entity.
  4. * If defaultCharset is null, the default "ISO-8859-1" is used.
  5. *
  6. * @param entity must not be null
  7. * @param defaultCharset character set to be applied if none found in the entity
  8. * @return the entity content as a String. May be null if
  9. * {[url=home.php?mod=space&uid=17823]@LINK[/url] HttpEntity#getContent()} is null.
  10. * @throws ParseException if header elements cannot be parsed
  11. * @throws IllegalArgumentException if entity is null or if content length > Integer.MAX_VALUE
  12. * @throws IOException if an error occurs reading the input stream
  13. * @throws UnsupportedCharsetException Thrown when the named charset is not available in
  14. * this instance of the Java virtual machine
  15. */
  16. public static String toString(
  17. final HttpEntity entity, final Charset defaultCharset) throws IOException, ParseException {
  18. Args.notNull(entity, "Entity");
  19. final InputStream instream = entity.getContent();
  20. if (instream == null) {
  21. return null;
  22. }
  23. try {
  24. Args.check(entity.getContentLength() <= Integer.MAX_VALUE,
  25. "HTTP entity too large to be buffered in memory");
  26. int i = (int)entity.getContentLength();
  27. if (i < 0) {
  28. i = 4096;
  29. }
  30. Charset charset = null;
  31. try {
  32. final ContentType contentType = ContentType.get(entity);
  33. if (contentType != null) {
  34. charset = contentType.getCharset();
  35. }
  36. } catch (final UnsupportedCharsetException ex) {
  37. throw new UnsupportedEncodingException(ex.getMessage());
  38. }
  39. if (charset == null) {
  40. charset = defaultCharset;
  41. }
  42. if (charset == null) {
  43. charset = HTTP.DEF_CONTENT_CHARSET;
  44. }
  45. final Reader reader = new InputStreamReader(instream, charset);
  46. final CharArrayBuffer buffer = new CharArrayBuffer(i);
  47. final char[] tmp = new char[1024];
  48. int l;
  49. while((l = reader.read(tmp)) != -1) {
  50. buffer.append(tmp, 0, l);
  51. }
  52. return buffer.toString();
  53. } finally {
  54. instream.close();
  55. }
  56. }
复制代码

如果entity需要反复使用的话，最好使用缓存起来：

  1. CloseableHttpResponse response = <...>
  2. HttpEntity entity = response.getEntity();
  3. if (entity != null) {
  4. entity = new BufferedHttpEntity(entity);
  5. }
复制代码
3、写Entity

主要有四种：StringEntity, ByteArrayEntity, InputStreamEntity,和FileEntity

  1. File file = new File("somefile.txt");
  2. FileEntity entity = new FileEntity(file,
  3. ContentType.create("text/plain", "UTF-8"));
  4. HttpPost httppost = new HttpPost("http://localhost/action.do");
  5. httppost.setEntity(entity);
复制代码

注意：InputStreamEnity只能读取一次。

表单：

  1. List<NameValuePair> formparams = new ArrayList<NameValuePair>();
  2. formparams.add(new BasicNameValuePair("param1", "value1"));
  3. formparams.add(new BasicNameValuePair("param2", "value2"));
  4. UrlEncodedFormEntity entity = new UrlEncodedFormEntity(formparams, Consts.UTF_8);
  5. HttpPost httppost = new HttpPost("http://localhost/handler.do");
  6. httppost.setEntity(entity);
复制代码

它会自动对参数进行URL编码。
param1=value1¶m2=value2

4、处理Response

最直接的方式是使用ResponseHandler，它不需要去自己管理连接和资源释放，HttpClient会自动去保证连接被释放不论是否发生异常。

  1. CloseableHttpClient httpclient = HttpClients.createDefault();
  2. HttpGet httpget = new HttpGet("http://localhost/json");
  3. ResponseHandler<MyJsonObject> rh = new ResponseHandler<MyJsonObject>() {
  4. @Override
  5. public JsonObject handleResponse(
  6. final HttpResponse response) throws IOException {
  7. StatusLine statusLine = response.getStatusLine();
  8. HttpEntity entity = response.getEntity();
  9. if (statusLine.getStatusCode() >= 300) {
  10. throw new HttpResponseException(
  11. statusLine.getStatusCode(),
  12. statusLine.getReasonPhrase());
  13. }
  14. if (entity == null) {
  15. throw new ClientProtocolException("Response contains no content");
  16. }
  17. Gson gson = new GsonBuilder().create();
  18. ContentType contentType = ContentType.getOrDefault(entity);
  19. Charset charset = contentType.getCharset();
  20. Reader reader = new InputStreamReader(entity.getContent(), charset);
  21. return gson.fromJson(reader, MyJsonObject.class);
  22. }
  23. };
  24. MyJsonObject myjson = client.execute(httpget, rh);
复制代码
5、自定义HttpClient
  1. ConnectionKeepAliveStrategy keepAliveStrat = new DefaultConnectionKeepAliveStrategy() {
  2. @Override
  3. public long getKeepAliveDuration(
  4. HttpResponse response,
  5. HttpContext context) {
  6. long keepAlive = super.getKeepAliveDuration(response, context);
  7. if (keepAlive == -1) {
  8. // Keep connections alive 5 seconds if a keep-alive value
  9. // has not be explicitly set by the server
  10. keepAlive = 5000;
  11. }
  12. return keepAlive;
  13. }
  14. };
  15. CloseableHttpClient httpclient = HttpClients.custom()
  16. .setKeepAliveStrategy(keepAliveStrat)
  17. .build();
复制代码
6、HttpContext

Http是请求响应式的，本是无状态的，不过web应用通常需要在几个连续的请求之间保持联系，因此可以使用这个来传递变量，注意这个不是线程安全的，建议每个线程使用一个。

  1. CloseableHttpClient httpclient = HttpClients.createDefault();
  2. RequestConfig requestConfig = RequestConfig.custom()
  3. .setSocketTimeout(1000)
  4. .setConnectTimeout(1000)
  5. .build();
  6. HttpGet httpget1 = new HttpGet("http://localhost/1");
  7. httpget1.setConfig(requestConfig);
  8. CloseableHttpResponse response1 = httpclient.execute(httpget1, context);
  9. try {
  10. HttpEntity entity1 = response1.getEntity();
  11. } finally {
  12. response1.close();
  13. }
  14. HttpGet httpget2 = new HttpGet("http://localhost/2");
  15. CloseableHttpResponse response2 = httpclient.execute(httpget2, context);
  16. try {
  17. HttpEntity entity2 = response2.getEntity();
  18. } finally {
  19. response2.close();
  20. }
复制代码

两次请求，通过context共享配置。

7、重试机制
  1. HttpRequestRetryHandler myRetryHandler = new HttpRequestRetryHandler() {
  2. public boolean retryRequest(
  3. IOException exception,
  4. int executionCount,
  5. HttpContext context) {
  6. if (executionCount >= 5) {
  7. // Do not retry if over max retry count
  8. return false;
  9. }
  10. if (exception instanceof InterruptedIOException) {
  11. // Timeout
  12. return false;
  13. }
  14. if (exception instanceof UnknownHostException) {
  15. // Unknown host
  16. return false;
  17. }
  18. if (exception instanceof ConnectTimeoutException) {
  19. // Connection refused
  20. return false;
  21. }
  22. if (exception instanceof SSLException) {
  23. // SSL handshake exception
  24. return false;
  25. }
  26. HttpClientContext clientContext = HttpClientContext.adapt(context);
  27. HttpRequest request = clientContext.getRequest();
  28. boolean idempotent = !(request instanceof HttpEntityEnclosingRequest);
  29. if (idempotent) {
  30. // Retry if the request is considered idempotent
  31. return true;
  32. }
  33. return false;
  34. }
  35. };
  36. CloseableHttpClient httpclient = HttpClients.custom()
  37. .setRetryHandler(myRetryHandler)
  38. .build();
复制代码

如果是幂等的操作，则可以重试。

8、终止请求

在一些情况下，由于目标服务器的高负载或客户端有很多活动的请求，那么 HTTP 请求执行会在预期的时间框内而失败。这时，就可能不得不过早地中止请求，解除封锁在 I/O 执行中的线程封锁。被 HttpClient 执行的 HTTP 请求可以在执行的任意阶段通过调用HttpUriRequest#abort()方法而中止。这个方法是线程安全的，而且可以从任意线程中调用。当一个 HTTP 请求被中止时，它的执行线程就封锁在 I/O 操作中了，而且保证通过抛出 InterruptedIOException 异常来解锁。

9、协议拦截器

协议拦截器可以使用 HTTP 内容来为一个或多个连续的请求存储一个处理状态。 协议拦截器必须实现为线程安全的。和 Servlet 相似，协议拦截器不应该使用实例变量，除非访问的那些变量是同步的。

  1. CloseableHttpClient httpclient = HttpClients.custom()
  2. .addInterceptorLast(new HttpRequestInterceptor() {
  3. public void process(
  4. final HttpRequest request,
  5. final HttpContext context) throws HttpException, IOException {
  6. AtomicInteger count = (AtomicInteger) context.getAttribute("count");
  7. request.addHeader("Count", Integer.toString(count.getAndIncrement()));
  8. }
  9. })
  10. .build();
  11. AtomicInteger count = new AtomicInteger(1);
  12. HttpClientContext localContext = HttpClientContext.create();
  13. localContext.setAttribute("count", count);
  14. HttpGet httpget = new HttpGet("http://localhost/");
  15. for (int i = 0; i < 10; i++) {
  16. CloseableHttpResponse response = httpclient.execute(httpget, localContext);
  17. try {
  18. HttpEntity entity = response.getEntity();
  19. } finally {
  20. response.close();
  21. }
  22. }
复制代码
10、重定向处理

HttpClient会自动处理重定向，当然也可以自己自定义策略。

  1. LaxRedirectStrategy redirectStrategy = new LaxRedirectStrategy();
  2. CloseableHttpClient httpclient = HttpClients.custom()
  3. .setRedirectStrategy(redirectStrategy)
  4. .build();
复制代码

resolve可以用来构建绝对路径：

  1. CloseableHttpClient httpclient = HttpClients.createDefault();
  2. HttpClientContext context = HttpClientContext.create();
  3. HttpGet httpget = new HttpGet("http://localhost:8080/");
  4. CloseableHttpResponse response = httpclient.execute(httpget, context);
  5. try {
  6. HttpHost target = context.getTargetHost();
  7. List<URI> redirectLocations = context.getRedirectLocations();
  8. URI location = URIUtils.resolve(httpget.getURI(), target, redirectLocations);
  9. System.out.println("Final HTTP location: " + location.toASCIIString());
  10. // Expected to be an absolute URI
  11. } finally {
  12. response.close();
  13. }
复制代码
收藏 邀请
上一篇：基于BP神经网络的人脸识别下一篇：Apple APNS http2 Provider 开发 使用 okHttp

最新评论

相关分类

小黑屋|在路上 ( 蜀ICP备15035742号-1 )  

;

GMT+8, 2025-7-6 21:40

Copyright 2015-2025 djqfx

返回顶部