HttpClient4.5 简单入门实例(一)

一、所需要的jar包

httpclient-4.5.jar

httpcore-4.4.1.jar

httpmime-4.5.jar
二、实例

package com.gblfy.test;import java.io.File;  
import java.io.IOException;  
import java.net.URL;  
import java.util.ArrayList;  
import java.util.List;  
import java.util.Map;  import org.apache.http.HttpEntity;  
import org.apache.http.NameValuePair;  
import org.apache.http.client.config.RequestConfig;  
import org.apache.http.client.entity.UrlEncodedFormEntity;  
import org.apache.http.client.methods.CloseableHttpResponse;  
import org.apache.http.client.methods.HttpGet;  
import org.apache.http.client.methods.HttpPost;  
import org.apache.http.conn.ssl.DefaultHostnameVerifier;  
import org.apache.http.conn.util.PublicSuffixMatcher;  
import org.apache.http.conn.util.PublicSuffixMatcherLoader;  
import org.apache.http.entity.ContentType;  
import org.apache.http.entity.StringEntity;  
import org.apache.http.entity.mime.MultipartEntityBuilder;  
import org.apache.http.entity.mime.content.FileBody;  
import org.apache.http.entity.mime.content.StringBody;  
import org.apache.http.impl.client.CloseableHttpClient;  
import org.apache.http.impl.client.HttpClients;  
import org.apache.http.message.BasicNameValuePair;  
import org.apache.http.util.EntityUtils;  public class HttpClientUtil {  private RequestConfig requestConfig = RequestConfig.custom()  .setSocketTimeout(15000)  .setConnectTimeout(15000)  .setConnectionRequestTimeout(15000)  .build();  private static HttpClientUtil instance = null;  private HttpClientUtil(){}  public static HttpClientUtil getInstance(){  if (instance == null) {  instance = new HttpClientUtil();  }  return instance;  }  /** * 发送 post请求 * @param httpUrl 地址 */  public String sendHttpPost(String httpUrl) {  HttpPost httpPost = new HttpPost(httpUrl);// 创建httpPost    return sendHttpPost(httpPost);  }  /** * 发送 post请求 * @param httpUrl 地址 * @param params 参数(格式:key1=value1&key2=value2) */  public String sendHttpPost(String httpUrl, String params) {  HttpPost httpPost = new HttpPost(httpUrl);// 创建httpPost    try {  //设置参数  StringEntity stringEntity = new StringEntity(params, "UTF-8");  stringEntity.setContentType("application/x-www-form-urlencoded");  httpPost.setEntity(stringEntity);  } catch (Exception e) {  e.printStackTrace();  }  return sendHttpPost(httpPost);  }  /** * 发送 post请求 * @param httpUrl 地址 * @param maps 参数 */  public String sendHttpPost(String httpUrl, Map<String, String> maps) {  HttpPost httpPost = new HttpPost(httpUrl);// 创建httpPost    // 创建参数队列    List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();  for (String key : maps.keySet()) {  nameValuePairs.add(new BasicNameValuePair(key, maps.get(key)));  }  try {  httpPost.setEntity(new UrlEncodedFormEntity(nameValuePairs, "UTF-8"));  } catch (Exception e) {  e.printStackTrace();  }  return sendHttpPost(httpPost);  }  /** * 发送 post请求（带文件） * @param httpUrl 地址 * @param maps 参数 * @param fileLists 附件 */  public String sendHttpPost(String httpUrl, Map<String, String> maps, List<File> fileLists) {  HttpPost httpPost = new HttpPost(httpUrl);// 创建httpPost    MultipartEntityBuilder meBuilder = MultipartEntityBuilder.create();  for (String key : maps.keySet()) {  meBuilder.addPart(key, new StringBody(maps.get(key), ContentType.TEXT_PLAIN));  }  for(File file : fileLists) {  FileBody fileBody = new FileBody(file);  meBuilder.addPart("files", fileBody);  }  HttpEntity reqEntity = meBuilder.build();  httpPost.setEntity(reqEntity);  return sendHttpPost(httpPost);  }  /** * 发送Post请求 * @param httpPost * @return */  private String sendHttpPost(HttpPost httpPost) {  CloseableHttpClient httpClient = null;  CloseableHttpResponse response = null;  HttpEntity entity = null;  String responseContent = null;  try {  // 创建默认的httpClient实例.  httpClient = HttpClients.createDefault();  httpPost.setConfig(requestConfig);  // 执行请求  response = httpClient.execute(httpPost);  entity = response.getEntity();  responseContent = EntityUtils.toString(entity, "UTF-8");  } catch (Exception e) {  e.printStackTrace();  } finally {  try {  // 关闭连接,释放资源  if (response != null) {  response.close();  }  if (httpClient != null) {  httpClient.close();  }  } catch (IOException e) {  e.printStackTrace();  }  }  return responseContent;  }  /** * 发送 get请求 * @param httpUrl */  public String sendHttpGet(String httpUrl) {  HttpGet httpGet = new HttpGet(httpUrl);// 创建get请求  return sendHttpGet(httpGet);  }  /** * 发送 get请求Https * @param httpUrl */  public String sendHttpsGet(String httpUrl) {  HttpGet httpGet = new HttpGet(httpUrl);// 创建get请求  return sendHttpsGet(httpGet);  }  /** * 发送Get请求 * @param httpPost * @return */  private String sendHttpGet(HttpGet httpGet) {  CloseableHttpClient httpClient = null;  CloseableHttpResponse response = null;  HttpEntity entity = null;  String responseContent = null;  try {  // 创建默认的httpClient实例.  httpClient = HttpClients.createDefault();  httpGet.setConfig(requestConfig);  // 执行请求  response = httpClient.execute(httpGet);  entity = response.getEntity();  responseContent = EntityUtils.toString(entity, "UTF-8");  } catch (Exception e) {  e.printStackTrace();  } finally {  try {  // 关闭连接,释放资源  if (response != null) {  response.close();  }  if (httpClient != null) {  httpClient.close();  }  } catch (IOException e) {  e.printStackTrace();  }  }  return responseContent;  }  /** * 发送Get请求Https * @param httpPost * @return */  private String sendHttpsGet(HttpGet httpGet) {  CloseableHttpClient httpClient = null;  CloseableHttpResponse response = null;  HttpEntity entity = null;  String responseContent = null;  try {  // 创建默认的httpClient实例.  PublicSuffixMatcher publicSuffixMatcher = PublicSuffixMatcherLoader.load(new URL(httpGet.getURI().toString()));  DefaultHostnameVerifier hostnameVerifier = new DefaultHostnameVerifier(publicSuffixMatcher);  httpClient = HttpClients.custom().setSSLHostnameVerifier(hostnameVerifier).build();  httpGet.setConfig(requestConfig);  // 执行请求  response = httpClient.execute(httpGet);  entity = response.getEntity();  responseContent = EntityUtils.toString(entity, "UTF-8");  } catch (Exception e) {  e.printStackTrace();  } finally {  try {  // 关闭连接,释放资源  if (response != null) {  response.close();  }  if (httpClient != null) {  httpClient.close();  }  } catch (IOException e) {  e.printStackTrace();  }  }  return responseContent;  }  
}

客户端代码：

package com.gblfy.test;import java.io.File;  
import java.util.ArrayList;  
import java.util.HashMap;  
import java.util.List;  
import java.util.Map;  import org.junit.Test;  public class HttpClientUtilTest {  @Test  public void testSendHttpPost1() {  String responseContent = HttpClientUtil.getInstance()  .sendHttpPost("http://localhost:8081/gblfy/test/send?username=test01&password=123456");  System.out.println("reponse content:" + responseContent);  }  @Test  public void testSendHttpPost2() {  String responseContent = HttpClientUtil.getInstance()  .sendHttpPost("http://localhost:8081/gblfy/test/send", "username=test01&password=123456");  System.out.println("reponse content:" + responseContent);  }  @Test  public void testSendHttpPost3() {  Map<String, String> maps = new HashMap<String, String>();  maps.put("username", "test01");  maps.put("password", "123456");  String responseContent = HttpClientUtil.getInstance()  .sendHttpPost("http://localhost:8081/gblfy/test/send", maps);  System.out.println("reponse content:" + responseContent);  }  @Test  public void testSendHttpPost4() {  Map<String, String> maps = new HashMap<String, String>();  maps.put("username", "test01");  maps.put("password", "123456");  List<File> fileLists = new ArrayList<File>();  fileLists.add(new File("D://test//httpclient//1.png"));  fileLists.add(new File("D://test//httpclient//1.txt"));  String responseContent = HttpClientUtil.getInstance()  .sendHttpPost("http://localhost:8081/gblfy/test/sendpost/file", maps, fileLists);  System.out.println("reponse content:" + responseContent);  }  @Test  public void testSendHttpGet() {  String responseContent = HttpClientUtil.getInstance()  .sendHttpGet("http://localhost:8081/gblfy/test/send?username=test01&password=123456");  System.out.println("reponse content:" + responseContent);  }  @Test  public void testSendHttpsGet() {  String responseContent = HttpClientUtil.getInstance()  .sendHttpsGet("https://www.baidu.com");  System.out.println("reponse content:" + responseContent);  }  }

服务端代码：

package com.gblfy.web;import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.util.HashMap;
import java.util.Map;import javax.servlet.http.HttpServletRequest;import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.stereotype.Controller;@Controller
public class Controller {@RequestMapping(value = "/test/send")  @ResponseBody  public Map<String, String> sendPost(HttpServletRequest request) {  Map<String, String> maps = new HashMap<String, String>();  String username = request.getParameter("username");  String password = request.getParameter("password");  maps.put("username", username);  maps.put("password", password);  return maps;  }  @RequestMapping(value = "/test/sendpost/file",method=RequestMethod.POST)  @ResponseBody  public Map<String, String> sendPostFile(@RequestParam("files") MultipartFile [] files,HttpServletRequest request) {  Map<String, String> maps = new HashMap<String, String>();  String username = request.getParameter("username");  String password = request.getParameter("password");  maps.put("username", username);  maps.put("password", password);  try {  for(MultipartFile file : files){  String fileName = file.getOriginalFilename();  fileName = new String(fileName.getBytes(),"UTF-8");  InputStream is = file.getInputStream();  if (fileName != null && !("".equals(fileName))) {  File directory = new File("D://test//httpclient//file");  if (!directory.exists()) {  directory.mkdirs();  }  String filePath = ("D://test//httpclient//file") + File.separator + fileName;  FileOutputStream fos = new FileOutputStream(filePath);  byte[] buffer = new byte[1024];  while (is.read(buffer) > 0) {  fos.write(buffer, 0, buffer.length);  }  fos.flush();  fos.close();  maps.put("file--"+fileName, "uploadSuccess");  }  }  } catch (Exception e) {  e.printStackTrace();  }  return maps;  }  
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/520926.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Nacos 计划发布v0.2版本，进一步融合Dubbo和SpringCloud生态

Nacos 计划发布v0.2版本，进一步融合Dubbo和SpringCloud生态

在近期的Aliware Open Source 成都站的活动上&#xff0c;阿里巴巴高级工程师邢学超&#xff08;于怀&#xff09;分享了Nacos v0.2的规划和进度&#xff0c;并对Nacos v0.3的控制台进行了预览。Nacos v0.2将进一步融入Duboo和Spring Cloud生态&#xff0c;帮助开发者更好的在微…
阅读更多...
你还在疯狂加班打码？兄dei，不如跟我学做超融合吧！

你还在疯狂加班打码？兄dei，不如跟我学做超融合吧！

纵观过去十年&#xff0c;媒体、娱乐、交通、银行、保险、医疗、旅游、物流等行业&#xff0c;无一不打上了数字化的烙印。据统计&#xff0c;一百多年前&#xff0c;公司的平均寿命是67年&#xff1b;而在当今的数字化时代&#xff0c;则锐减至15年。 除此之外&#xff0c;更有…
阅读更多...
apache禁止多目录运行php文件下载,Nginx Apache下如何禁止指定目录运行PHP脚本

apache禁止多目录运行php文件下载,Nginx Apache下如何禁止指定目录运行PHP脚本

网站程序的上传目录通常是不需要PHP执行权限&#xff0c;通过限制目录的PHP执行权限可以提网站的安全性&#xff0c;减少被攻击的机率。下面和大家一起分享下如何在Apache和Nginx禁止上传目录里PHP的执行权限。Apache下禁止指定目录运行PHP脚本在虚拟主机配置文件中增加php_fla…
阅读更多...
python加载模型包占用内存多大_如何保持Keras模型加载到内存中并在需要时使用它？ - python...

python加载模型包占用内存多大_如何保持Keras模型加载到内存中并在需要时使用它？ - python...

我正在阅读Keras blog讲解如何使用Flask创建简单的图像分类器Restful API。我想知道如何在不使用python的其他Web框架中实现加载模型的相同方法。在下面的代码中&#xff0c;将在服务器启动之前将模型加载到内存中&#xff0c;直到服务器处于活动状态&#xff0c;它才会运行&am…
阅读更多...
你只差这两步 | 将Sentinel 控制台应用于生产环境

你只差这两步 | 将Sentinel 控制台应用于生产环境

这是围绕 Sentinel 的使用场景、技术对比和实现、开发者实践等维度推出的系列文章的第四篇。 第一篇回顾&#xff1a; Dubbo 的流量防卫兵 | Sentinel如何通过限流实现服务的高可用性 - 传送门 第二篇回顾&#xff1a; RocketMQ 的保险丝| Sentinel 如何通过匀速请求和冷启动…
阅读更多...
win10日常操作

win10日常操作

C:\Windows\System32\drivers\etc
阅读更多...
eclipse分级,分级列表显示 - bieshixuan的个人博客 - OSCHINA - 中文开源技术交流社区...

eclipse分级,分级列表显示 - bieshixuan的个人博客 - OSCHINA - 中文开源技术交流社区...

这是个效果图设计思想是&#xff0c;使用左右两个tableview分别展示NSArray * _allArr;NSMutableArray * _rightArr;UITableView * _leftTableView;UITableView * _rightTableView;初始化_arr [{"全部":[ "棉花", "小麦", "水稻", &q…
阅读更多...
python如何实时捕捉cmd显示_如何从Python脚本中捕获Python解释器和/或CMD.EXE的输出？ -问答-阿里云开发者社区-阿里云...

python如何实时捕捉cmd显示_如何从Python脚本中捕获Python解释器和/或CMD.EXE的输出？ -问答-阿里云开发者社区-阿里云...

如果您正在谈论python解释器或CMD.exe&#xff0c;它是您脚本的“父”&#xff0c;那么不可能。在每个类似POSIX的系统中(现在你正在运行Windows&#xff0c;看起来可能有一些我不知道的怪癖&#xff0c;YMMV)每个进程都有三个流&#xff0c;标准输入&#xff0c;标准输出和标准…
阅读更多...
分布式消息规范 OpenMessaging 1.0.0-preview 发布

分布式消息规范 OpenMessaging 1.0.0-preview 发布

OpenMessaging 是由阿里巴巴牵头发起&#xff0c;由 Yahoo、滴滴、Streamlio、微众银行、Datapipeline 等公司共同发起创建的分布式消息规范&#xff0c;其目标在于打造厂商中立&#xff0c;面向 Cloud Native &#xff0c;同时对流计算以及大数据生态友好的下一代分布式消息标…
阅读更多...
腾讯云重磅发布系列自研产品，自研服务器星星海为云而生

腾讯云重磅发布系列自研产品，自研服务器星星海为云而生

今日在腾讯全球数字生态大会成都峰会上&#xff0c;腾讯云重磅发布系列自研产品&#xff0c;包括腾讯自研第四代数据中心T-block产品家族、第一款真正为云而生的自研服务器“星星海”等基础产品&#xff0c;结合现场发布的弹性容器服务、无服务器等自研产品&#xff0c;腾讯云正…
阅读更多...
wsimport将wsdl生成java 调用时碰到的一个问题Could not initialize Service

wsimport将wsdl生成java 调用时碰到的一个问题Could not initialize Service

在一个采用了XFire作为WebService框架Web项目中&#xff0c;添加由JDK1.6 wsimport命令生成的一个WebService客户端调用&#xff0c;在客户端调用时出现了如下问题 log4j:WARN No appenders could be found for logger (org.codehaus.xfire.jaxws.Provider). log4j:WARN Pleas…
阅读更多...
服务化改造实践（二）| Dubbo + Kubernetes

服务化改造实践（二）| Dubbo + Kubernetes

“没有最好的技术&#xff0c;只有最合适的技术。”我想这句话也同样适用于微服务领域&#xff0c;没有最好的服务框架&#xff0c;只有最适合自己的服务改造。在Dubbo的未来规划中&#xff0c;除了保持自身技术上的领先性&#xff0c;关注性能&#xff0c;大流量&#xff0c;大…
阅读更多...
电子技术基础数字部分第六版_大部分数字图书馆技术特点与应用分析

电子技术基础数字部分第六版_大部分数字图书馆技术特点与应用分析

数字图书馆是一个开放式的硬件和软件的集成平台&#xff0c;通过对技术和产品的集成&#xff0c;把当前大量的各种文献载体数字化&#xff0c;将它们组织起来在网上服务。从理论上讲&#xff0c;数字图书馆是一种引入管理和应用数字化技术的方法&#xff0c;它的主要特点有&…
阅读更多...
java hashmap读,java – ConcurrentHashmap – 读取和删除

java hashmap读,java – ConcurrentHashmap – 读取和删除

你是对的.如果这个Map可以被多个线程修改,那么对chm.get(key)的第一次调用可能会返回一个非null值,而第二次调用将返回null(由于从Map完成的Map中删除了键)另一个线程),因此chm.get(key).doSomething()将抛出一个NullPointerException.您可以使用局部变量来存储chm.get(key)的结…
阅读更多...
腾讯云与智慧产业总裁汤道生：产业互联网是一场“持久战”

腾讯云与智慧产业总裁汤道生：产业互联网是一场“持久战”

“产业互联网是一场‘持久战’&#xff0c;腾讯希望和合作伙伴一起参与转型&#xff0c;让每一个产业都变身为智慧产业&#xff0c;实现数字化、网络化和智能化。”10月29日&#xff0c;在腾讯全球数字生态大会成都峰会上&#xff0c;腾讯公司高级执行副总裁、云与智慧产业事业…
阅读更多...
NLP领域中更有效的迁移学习方法

NLP领域中更有效的迁移学习方法

在深度学习领域&#xff0c;迁移学习&#xff08;transfer learning&#xff09;是应用比较广的方法之一。该方法允许我们构建模型时候不光能够借鉴一些其它科研人员的设计的模型&#xff0c;还可以借用类似结构的模型参数&#xff0c;有些类似于站在巨人的肩膀上进行深入开发。…
阅读更多...
使用wsimport将wsdl生成java

使用wsimport将wsdl生成java

使用管理员打开cmd wsimport -encoding utf-8 -keep -s D:\temp -p com.lamcy.webService -verbose http://服务地址?wsdl -encoding : 指定编码格式 -keep&#xff1a;是否生成java源文件 -d&#xff1a;指定.class文件的输出目录 -s&#xff1a;指定.java文件的输出目录…
阅读更多...
使用python创建自己的第一个神经网络模型吧！

使用python创建自己的第一个神经网络模型吧！

神经网络&#xff08;NN&#xff09;&#xff0c;也被称为人工神经网络&#xff08;ANN&#xff09;&#xff0c;是机器学习领域中学习算法的子集&#xff0c;大体上借鉴了生物神经网络的概念。目前&#xff0c;神经网络在计算机视觉、自然语言处理等领域应用广泛。德国资深机器…
阅读更多...
数据 正则化 python_python3.6怎么单独正则化/标准化DataFrame中的指定列数据

数据 正则化 python_python3.6怎么单独正则化/标准化DataFrame中的指定列数据

问 题问题&#xff1a;读入一个excel表后&#xff0c;想要正则化(标准化)其中的某一列数据&#xff0c;还试过单独正则化后&#xff0c;再把两个DataFrame拼接的&#xff0c;用过insert和cancat&#xff0c;append这些&#xff0c;但是因为索引对不上号&#xff0c;不能直接拼到…
阅读更多...
百度现场面试：JVM+算法+Redis+数据库！(三面）｜ CSDN博文精选

百度现场面试：JVM+算法+Redis+数据库！(三面）｜ CSDN博文精选

戳蓝字“CSDN云计算”关注我们哦&#xff01;作者 | 中琦2513转自 &#xff5c; CSDN博客责编 | 阿秃百度一面&#xff08;现场&#xff09;自我介绍Java中的多态为什么要同时重写hashcode和equalsHashmap的原理Hashmap如何变线程安全&#xff0c;每种方式的优缺点垃圾回收机制…
阅读更多...
最新文章

Copyright @ 2022~2023