Java中使用代理发送指定请求http,https(get,post等)
发送HTTP请求
public static String HttpProxy(String url, String param, String proxy,
int port) {
HttpURLConnection httpConn = null;
PrintWriter out = null;
OutputStreamWriter out1 = null;
BufferedReader in = null;
String result = "";
BufferedReader reader = null;
try {
URL urlClient = new URL(url);
System.out.println("请求的URL========:" + urlClient);
// 创建代理
Proxy proxy1 = new Proxy(Type.HTTP, new InetSocketAddress(proxy,
port));
// 设置代理
httpConn = (HttpURLConnection) urlClient.openConnection(proxy1);
//如果正向代理设置用户名和密码,需对header进行设置
// String headerkey = "Proxy-Authorization";
// String headerValue = "Basic "+Base64.getBase64("5gc:5gc");
String headerValue = "Basic NWdjOjVnYw==";
// httpConn.setRequestProperty(headerkey, headerValue);
// 设置通用的请求属性
httpConn.setRequestProperty("accept", "*/*");
httpConn.setRequestProperty("connection", "Keep-Alive");
// httpConn.setRequestProperty("user-agent",
// "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
// 发送POST请求必须设置如下两行
httpConn.setDoOutput(true);
httpConn.setDoInput(true);
// 获取URLConnection对象对应的输出流
//使请求报文不中文乱码
out1 = new OutputStreamWriter(httpConn.getOutputStream(), "utf-8");
out1.write(param);
// 发送请求参数
// out.print(param);
// flush输出流的缓冲
out1.flush();
// 定义BufferedReader输入流来读取URL的响应
// in = new BufferedReader(
// new InputStreamReader(httpConn.getInputStream()));
//使返回的报文不中文乱码
in = new BufferedReader(new InputStreamReader(httpConn.getInputStream(), "utf-8"));
String line;
while ((line = in.readLine()) != null) {
result += line;
}
// 断开连接
httpConn.disconnect();
System.out.println("====result====" + result);
System.out.println("返回结果:" + httpConn.getResponseMessage());
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (reader != null) {
reader.close();
}
} catch (IOException e) {
e.printStackTrace();
}
try {
if (in != null) {
in.close();
}
} catch (IOException e) {
e.printStackTrace();
}
try {
if (out1 != null) {
out1.close();
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
return result;
}
发送HTTPS请求
public static String HttpsProxy(String url, String param, String proxy, int port,String accessToken,String method) {
HttpsURLConnection httpsConn = null;
PrintWriter out = null;
BufferedReader in = null;
String result = "";
BufferedReader reader = null;
try {
URL urlClient = new URL(url);
System.out.println("请求的URL========:" + urlClient);
SSLContext sc = SSLContext.getInstance("SSL");
// 指定信任https
sc.init(null, new TrustManager[] { new TrustAnyTrustManager() }, new java.security.SecureRandom());
//创建代理虽然是https也是Type.HTTP
Proxy proxy1=new Proxy(Proxy.Type.HTTP, new InetSocketAddress(proxy, port));
//设置代理
httpsConn = (HttpsURLConnection) urlClient.openConnection(proxy1);
httpsConn.setSSLSocketFactory(sc.getSocketFactory());
httpsConn.setHostnameVerifier(new TrustAnyHostnameVerifier());
// 设置通用的请求属性
httpsConn.setRequestMethod(method);
httpsConn.setRequestProperty("accept", "*/*");
httpsConn.setRequestProperty("connection", "Keep-Alive");
httpsConn.setRequestProperty("Content-Type", "application/json");
if (accessToken!=null&&!accessToken.equals("")){
httpsConn.setRequestProperty("accessToken", accessToken);
}
// httpsConn.setRequestProperty("user-agent",
// "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
// 发送POST请求必须设置如下两行
httpsConn.setDoOutput(true);
httpsConn.setDoInput(true);
//发送GET请求将两行*中的代码注释掉即可
//************************************************************
// 获取URLConnection对象对应的输出流
out = new PrintWriter(httpsConn.getOutputStream());
// 发送请求参数
out.print(param);
System.out.println("====param===="+param);
// flush输出流的缓冲
out.flush();
//************************************************************
// 定义BufferedReader输入流来读取URL的响应
in = new BufferedReader(
new InputStreamReader(httpsConn.getInputStream()));
String line;
while ((line = in.readLine()) != null) {
result += line;
}
// 断开连接
httpsConn.disconnect();
LOGGER.info("====result===="+result);
LOGGER.info("返回结果:" + httpsConn.getResponseMessage());
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (reader != null) {
reader.close();
}
} catch (IOException e) {
}
try {
if (in != null) {
in.close();
}
} catch (IOException e) {
e.printStackTrace();
}
if (out != null) {
out.close();
}
}
return result;
}
以上是主要访问方法,下面是用到的工具类
private static class TrustAnyTrustManager implements X509TrustManager {
public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {
}
public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {
}
public X509Certificate[] getAcceptedIssuers() {
return new X509Certificate[] {};
}
}
private static class TrustAnyHostnameVerifier implements HostnameVerifier {
public boolean verify(String hostname, SSLSession session) {
return true;
}
}