Skip to content

Commit

Permalink
Api
Browse files Browse the repository at this point in the history
  • Loading branch information
@WindRunnerMax
WindRunnerMax committed Mar 28, 2020
1 parent 2611979 commit 9cf6e50
Show file tree
Hide file tree
Showing 5 changed files with 296 additions and 343 deletions.
281 changes: 132 additions & 149 deletions Java/Http.java
View file
Original file line number Diff line number Diff line change
@@ -1,162 +1,145 @@
package com.czy.sw;
package com.sw;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.nio.charset.StandardCharsets;
import java.util.Map;
import java.util.Map.Entry;

/**
* @author Czy
* @time Jul 6, 2019
* @detail Http请求类
*/
* @author Czy
* @time Jul 6, 2019
* @detail Http请求类
*/

public class Http {

public static String httpRequest(String url,Map<String, String> param,String method,Map<String, String> headers) {
String paramDipose = ParamHandle(param);
if (method.equalsIgnoreCase("GET")) {
return doGet(url + paramDipose, headers);
}else {
return doPost(url, paramDipose, headers);
}
}

private static String ParamHandle(Map<String, String> params) {
StringBuilder urlParam = new StringBuilder("?");;
for (Entry<String,String> param : params.entrySet()) {
urlParam.append(param.getKey() + "=" + param.getValue() + "&");
}
return urlParam.toString();
}

private static String doGet(String httpurl,Map<String, String> headers) {
HttpURLConnection connection = null;
InputStream is = null;
BufferedReader br = null;
String result = null;// 返回结果字符串
try {
// 创建远程url连接对象
URL url = new URL(httpurl);
// 通过远程url连接对象打开一个连接，强转成httpURLConnection类
connection = (HttpURLConnection) url.openConnection();
// 设置连接方式：get
connection.setRequestMethod("GET");
// 设置连接主机服务器的超时时间：15000毫秒
connection.setConnectTimeout(15000);
// 设置读取远程返回的数据时间：60000毫秒
connection.setReadTimeout(60000);
for (Entry<String,String> header : headers.entrySet()) {
connection.setRequestProperty(header.getKey(), header.getValue());
}
// 发送请求
connection.connect();
// 通过connection连接，获取输入流
if (connection.getResponseCode() == 200) {
is = connection.getInputStream();
// 封装输入流is，并指定字符集
br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
// 存放数据
StringBuffer sbf = new StringBuffer();
String temp = null;
while ((temp = br.readLine()) != null) {
sbf.append(temp);
sbf.append("\r\n");
}
result = sbf.toString();
}
} catch (MalformedURLException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} finally {
// 关闭资源
if (null != br) {
try {
br.close();
} catch (IOException e) {
e.printStackTrace();
}
}
if (null != is) {
try {
is.close();
} catch (IOException e) {
e.printStackTrace();
}
}
connection.disconnect();// 关闭远程连接
}

return result;
}

private static String doPost(String httpUrl, String param,Map<String, String> headers) {

HttpURLConnection connection = null;
InputStream is = null;
OutputStream os = null;
BufferedReader br = null;
String result = null;
try {
URL url = new URL(httpUrl);
connection = (HttpURLConnection) url.openConnection();
connection.setRequestMethod("POST");
connection.setConnectTimeout(15000);
connection.setReadTimeout(60000);
connection.setDoOutput(true);
connection.setDoInput(true);
for (Entry<String,String> header : headers.entrySet()) {
connection.setRequestProperty(header.getKey(), header.getValue());
}
connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
os = connection.getOutputStream();
os.write(param.getBytes());
if (connection.getResponseCode() == 200) {
is = connection.getInputStream();
br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
StringBuffer sbf = new StringBuffer();
String temp = null;
while ((temp = br.readLine()) != null) {
sbf.append(temp);
sbf.append("\r\n");
}
result = sbf.toString();
}
} catch (MalformedURLException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} finally {
if (null != br) {
try {
br.close();
} catch (IOException e) {
e.printStackTrace();
}
}
if (null != os) {
try {
os.close();
} catch (IOException e) {
e.printStackTrace();
}
}
if (null != is) {
try {
is.close();
} catch (IOException e) {
e.printStackTrace();
}
}
connection.disconnect();
}
return result;
}


public static String httpRequest(String url, Map<String, String> param, String method, Map<String, String> headers) {
String paramDipose = pramHandle(param);
if (method.equalsIgnoreCase("GET")) {
return doGet(url + paramDipose, headers);
} else {
return doPost(url, paramDipose, headers);
}
}

private static String pramHandle(Map<String, String> params) {
StringBuilder urlParam = new StringBuilder("?");
;
for (Entry<String, String> param : params.entrySet()) {
urlParam.append(param.getKey() + "=" + param.getValue() + "&");
}
return urlParam.toString();
}

private static String doGet(String httpurl, Map<String, String> headers) {
HttpURLConnection connection = null;
String result = null;// 返回结果字符串
try {
// 创建远程url连接对象
URL url = new URL(httpurl);
// 通过远程url连接对象打开一个连接，强转成httpURLConnection类
connection = (HttpURLConnection) url.openConnection();
// 设置连接方式：get
connection.setRequestMethod("GET");
// 设置连接主机服务器的超时时间：15000毫秒
connection.setConnectTimeout(15000);
// 设置读取远程返回的数据时间：60000毫秒
connection.setReadTimeout(60000);
for (Entry<String, String> header : headers.entrySet()) {
connection.setRequestProperty(header.getKey(), header.getValue());
}
// 发送请求
connection.connect();
// 通过connection连接，获取输入流
if (connection.getResponseCode() == 200) result = getResult(connection);
} catch (Exception e) {
System.out.println(e.toString());
}
return result;
}

private static String doPost(String httpUrl, String param, Map<String, String> headers) {
HttpURLConnection connection = null;
OutputStream os = null;
String result = null;
try {
URL url = new URL(httpUrl);
connection = (HttpURLConnection) url.openConnection();
connection.setRequestMethod("POST");
connection.setConnectTimeout(15000);
connection.setReadTimeout(60000);
connection.setDoOutput(true);
connection.setDoInput(true);
for (Entry<String, String> header : headers.entrySet()) {
connection.setRequestProperty(header.getKey(), header.getValue());
}
connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
os = connection.getOutputStream();
os.write(param.getBytes());
if (connection.getResponseCode() == 200) result = getResult(connection);
} catch (Exception e) {
System.out.println(e.toString());
} finally {
if (null != os) {
try {
os.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
return result;
}

private static String getResult(HttpURLConnection connection){
InputStream is = null;
BufferedReader br = null;
StringBuilder sb = new StringBuilder();
try {
is = connection.getInputStream();
br = new BufferedReader(new InputStreamReader(is, StandardCharsets.UTF_8));

String temp = "";
while ((temp = br.readLine()) != null) {
sb.append(temp);
}
}catch (Exception e){
e.printStackTrace();
}finally {
closeConn(br,is,connection);

}
return sb.toString();
}

private static void closeConn(BufferedReader br,InputStream is,HttpURLConnection connection){
if (null != br) {
try {
br.close();
} catch (IOException e) {
e.printStackTrace();
}
}
if (null != is) {
try {
is.close();
} catch (IOException e) {
e.printStackTrace();
}
}
if(connection!=null){
connection.disconnect();

}
}

}



Loading

0 comments on commit 9cf6e50

Please sign in to comment.