json
public static String sendRequest(String url, Object object) {
PrintWriter out = null;
BufferedReader in = null;
StringBuilder result = new StringBuilder();
try {
URL realUrl = new URL(url);
// 打开和URL之间的连接
URLConnection conn = realUrl.openConnection();
conn.setConnectTimeout(1000000);
// 设置通用的请求属性
/*conn.setRequestProperty("accept", "*");
conn.setRequestProperty("connection", "Keep-Alive");
conn.setRequestProperty("user-agent","Mozilla/4.0(compatible; MSIE 6.0; Windows NT 5.1;SV1)");*/
conn.setRequestProperty("Content-Type",
"application/json;charset=utf-8");
// 发送POST请求必须设置如下两行
conn.setDoOutput(true);
conn.setDoInput(true);
// 获取URLConnection对象对应的输出流
out = new PrintWriter(conn.getOutputStream());
// 发送请求参数
out.print(object);
// flush输出流的缓冲
out.flush();
// 定义BufferedReader输入流来读取URL的响应
in = new BufferedReader(new InputStreamReader(conn.getInputStream()));
String line;
while ((line = in.readLine()) != null) {
result.append(line);
}
} catch (Exception e) {
System.out.println("发送 POST 请求出现异常！" + e);
e.printStackTrace();
}
// 使用finally块来关闭输出流、输入流
finally {
try {
if (out != null) {
out.close();
}
if (in != null) {
in.close();
}
} catch (IOException ex) {
ex.printStackTrace();
}
}
return result.toString();
}
multipart form-data
通讯实现
package com.token;
import org.apache.http.NameValuePair;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
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;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
public class HttpClientUtil {
/**
* 日志对象
*/
private static final Logger LOGGER = LoggerFactory.getLogger(HttpClientUtil.class);
private HttpClientUtil(){
}
public static String doPost(String url, Map<String, String> param) {
// 创建Httpclient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
CloseableHttpResponse response = null;
String resultString = "";
try {
// 创建Http Post请求
HttpPost httpPost = new HttpPost(url);
// 创建参数列表
if (param != null) {
List<NameValuePair> paramList = new ArrayList<>();
for (String key : param.keySet()) {
paramList.add(new BasicNameValuePair(key, param.get(key)));
}
// 模拟表单
UrlEncodedFormEntity entity = new UrlEncodedFormEntity(paramList,"utf-8");
httpPost.setEntity(entity);
}
// 执行http请求
response = httpClient.execute(httpPost);
resultString = EntityUtils.toString(response.getEntity(), "utf-8");
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
response.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
return resultString;
}
}发起通讯
Map<String, String> paramMap = new HashMap();
paramMap.put("name","zhangsan");
paramMap.put("age","12");
String result = HttpClientUtil.doPost("http://127.0.0.1/api?", paramMap);
application/x-www-form-urlencoded
/**
* POST请求
*
* @param requestUrl 请求地址
* @param object 头信息
* @return
*/
public static String get(String requestUrl, Object object) {
HttpURLConnection connection = null;
InputStream is = null;
BufferedReader br = null;
String result = null;
try {
/** 创建远程url连接对象 */
URL url = new URL(requestUrl);
/** 通过远程url对象打开一个连接，强制转换为HttpUrlConnection类型 */
connection = (HttpURLConnection) url.openConnection();
/** 设置连接方式：GET */
connection.setRequestMethod("GET");
if(object!=null){
connection.setRequestProperty("token", object.toString());
}
/** 设置通用的请求属性 */
connection.setRequestProperty("accept", "*/*");
connection.setRequestProperty("connection", "Keep-Alive");
connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
// 设置传入参数的格式:请求参数应该是 name1=value1&name2=value2 的形式
connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
/** 发送GET方式请求，使用connet方法建立和远程资源之间的实际连接即可 */
connection.connect();
/** 请求成功：返回码为200 */
if (connection.getResponseCode() == 200) {
/** 通过connection连接，获取输入流 */
is = connection.getInputStream();
/** 封装输入流is，并指定字符集 */
br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
/** 存放数据 */
StringBuffer sbf = new StringBuffer();
String line = null;
while ((line = br.readLine()) != null) {
sbf.append(line);
sbf.append("\r\n");
}
result = sbf.toString();
}
} catch (Exception e) {
e.printStackTrace();
} finally {
/** 关闭资源 */
try {
if (null != br) {
br.close();
}
if (null != is) {
is.close();
}
} catch (Exception e) {
e.printStackTrace();
}
/** 关闭远程连接 */
// 断开连接，最好写上，disconnect是在底层tcp socket链接空闲时才切断。如果正在被其他线程使用就不切断。
// 固定多线程的话，如果不disconnect，链接会增多，直到收发不出信息。写上disconnect后正常一些
connection.disconnect();
}
return result;
}Map<String, String> paramMap = new HashMap<>();
paramMap.put("name","zhangsan");
paramMap.put("password","123456");
String result = HttpClientUtil.doPost("http://192.0.0.1/api/?", paramMap);