package com.hx.util;
|
|
import java.io.BufferedReader;
|
import java.io.InputStream;
|
import java.io.InputStreamReader;
|
import java.io.OutputStream;
|
import java.io.OutputStreamWriter;
|
import java.net.HttpURLConnection;
|
import java.net.URL;
|
import java.net.URLEncoder;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
|
public class RequestMethod {
|
|
/**
|
* 发送Post请求
|
* @param path 请求路径
|
* @param params 请求参数
|
* @param encoding 编码
|
* @return 服务器端内容
|
*/
|
public static String sendPOSTRequest(String path, Map<String, String> params, String encoding) throws Exception{
|
StringBuilder data = new StringBuilder();
|
if(params!=null && !params.isEmpty()){
|
for(Map.Entry<String, String> entry : params.entrySet()){
|
data.append(entry.getKey()).append("=");
|
data.append(URLEncoder.encode(entry.getValue(), encoding));
|
data.append("&");
|
}
|
data.deleteCharAt(data.length() - 1);
|
}
|
byte[] entity = data.toString().getBytes();//生成实体数据
|
HttpURLConnection conn = (HttpURLConnection) new URL(path).openConnection();
|
conn.setConnectTimeout(5000);
|
conn.setRequestMethod("POST");
|
conn.setDoOutput(true);//允许对外输出数据
|
conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
|
conn.setRequestProperty("Content-Length", String.valueOf(entity.length));
|
OutputStream outStream = conn.getOutputStream();
|
outStream.write(entity);
|
if(conn.getResponseCode() == 200){
|
return StreamUtils.InputStreamTOString(conn.getInputStream()) ;
|
}
|
return null;
|
}
|
|
/**
|
* 发送Post请求
|
* @param path 请求路径
|
* @param content 发送内容
|
* @param encoding 编码
|
* @return 服务器端内容
|
*/
|
public static String sendPOSTRequest(String path, String content, String encoding){
|
//byte[] entity = content.toString().getBytes();//生成实体数据
|
try{
|
HttpURLConnection conn = (HttpURLConnection) new URL(path).openConnection();
|
conn.setConnectTimeout(5000);
|
conn.setRequestMethod("POST");
|
conn.setDoOutput(true);//允许对外输出数据
|
conn.setDoInput(true);
|
conn.setUseCaches(false);
|
conn.setRequestProperty("Charset", "utf-8");
|
conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
|
//conn.setRequestProperty("Content-Length", String.valueOf(entity.length));
|
OutputStreamWriter outStream = new OutputStreamWriter(conn.getOutputStream(),"UTF-8");
|
outStream.write(content);
|
outStream.flush();
|
if(conn.getResponseCode() == 200){
|
return StreamUtils.InputStreamTOString(conn.getInputStream());
|
}
|
}catch(Exception e){
|
e.printStackTrace();
|
}
|
return null;
|
}
|
|
/**
|
* 发送Post请求
|
* @param path 请求路径
|
* @param entity 发送内容
|
* @param encoding 编码
|
* @return 服务器端内容
|
*/
|
public static String sendPOSTRequest(String path, byte[] entity, String encoding) throws Exception{
|
System.out.println("entity:" + entity.length);
|
HttpURLConnection conn = (HttpURLConnection) new URL(path).openConnection();
|
conn.setConnectTimeout(5000);
|
conn.setRequestMethod("POST");
|
conn.setDoOutput(true);//允许对外输出数据
|
conn.setRequestProperty("Content-Type", "application/octet-stream");
|
conn.setRequestProperty("Accept", "application/octet-stream");
|
conn.setRequestProperty("Content-Length", String.valueOf(entity.length));
|
OutputStream outStream = conn.getOutputStream();
|
outStream.write(entity);
|
if(conn.getResponseCode() == 200){
|
return StreamUtils.InputStreamTOString(conn.getInputStream());
|
}
|
return null;
|
}
|
|
/**
|
* 发送GET请求
|
* @param path 请求路径
|
* @param params 请求参数
|
* @return 服务器端内容
|
*/
|
public static String sendGETRequest(String path, Map<String, String> params, String ecoding) throws Exception{
|
// http://192.168.1.100:8080/web/ManageServlet?title=xxx&timelength=90
|
StringBuilder url = new StringBuilder(path);
|
if(params!=null){
|
url.append("?");
|
for(Map.Entry<String, String> entry : params.entrySet()){
|
url.append(entry.getKey()).append("=");
|
url.append(URLEncoder.encode(entry.getValue(), ecoding));
|
url.append("&");
|
}
|
url.deleteCharAt(url.length() - 1);
|
}
|
HttpURLConnection conn = (HttpURLConnection)new URL(url.toString()).openConnection();
|
conn.setConnectTimeout(5000);
|
conn.setRequestMethod("GET");
|
if(conn.getResponseCode() == 200){
|
return StreamUtils.InputStreamTOString(conn.getInputStream()) ;
|
}
|
return null;
|
}
|
|
|
|
public static String msg(InputStream in) throws Exception{
|
BufferedReader br = new BufferedReader(new InputStreamReader(in));
|
String line;
|
List<String> lines = new ArrayList<String>();
|
while((line = br.readLine())!=null){
|
lines.add(line);
|
}
|
if(lines.size()>0){
|
String f = lines.get(0);
|
if(f.indexOf("200")!=-1){
|
String e = lines.get(lines.size()-1);
|
return e;
|
}else{
|
return null;
|
}
|
}else{
|
return null;
|
}
|
}
|
}
|
