zoukankan      html  css  js  c++  java
  • java Http原生 Get 和Post 支持代理认证

    import java.io.BufferedReader;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.io.PrintWriter;
    import java.net.Authenticator;
    import java.net.InetSocketAddress;
    import java.net.PasswordAuthentication;
    import java.net.Proxy;
    import java.net.URL;
    import java.net.URLConnection;
    
    public class HttpUtil {
        /**
         * 
         * @param urlString 请求url
         * @param res 返回结果
         * @param timeOut 超时时间(min)
         * @param useProxy 是否使用代理
         * @return
         * @throws Exception
         */
        public static  String sendGet(String urlString, String res, String timeOut, boolean useProxy) throws Exception {
            URL url = new URL(urlString);
            URLConnection uc = null;
            //判断是否用代理
            if(useProxy){
                //使用代理
                InetSocketAddress isa = new InetSocketAddress(PropertiesUtil.properties.getProperty("proxy_host"), Integer.parseInt(PropertiesUtil.properties.getProperty("proxy_port")));
                Proxy proxy = new Proxy(Proxy.Type.HTTP, isa);
                Authenticator.setDefault(new MyAuthenticator(PropertiesUtil.properties.getProperty("proxy_user"), PropertiesUtil.properties.getProperty("proxy_password")));
                uc = url.openConnection(proxy);
            }else{
                //不用代理
                uc = url.openConnection();
            }
            uc.setRequestProperty("Content-Type", "text/plain; charset=utf-8");
            uc.setReadTimeout(60 * 1000 * Integer.parseInt(timeOut));
            uc.setDoOutput(true);
            uc.setDoInput(true);
            InputStream is = uc.getInputStream();
            int c;
            StringBuffer sf = new StringBuffer();
            while ((c = is.read()) != -1) {
                sf.append((char) c);
            }
            byte[] b2 = sf.toString().getBytes("ISO8859_1");
            String ss = new String(b2, "UTF-8");
            res = ss;
            is.close();
            return res;
        }
        
         public static String sendPost(String urlString, String param, String res, String timeOut, boolean useProxy) throws Exception {
            PrintWriter out = null;
            BufferedReader in = null;
            URLConnection conn = null;
            String result = "";
            URL realUrl = new URL(urlString);
            //判断是否用代理
              if(useProxy){
                  //使用代理
                  InetSocketAddress isa = new InetSocketAddress(PropertiesUtil.properties.getProperty("proxy_host"), Integer.parseInt(PropertiesUtil.properties.getProperty("proxy_port")));
                  Proxy proxy = new Proxy(Proxy.Type.HTTP, isa);
                  Authenticator.setDefault(new MyAuthenticator(PropertiesUtil.properties.getProperty("proxy_user"), PropertiesUtil.properties.getProperty("proxy_password")));
                  conn = realUrl.openConnection(proxy);
              }else{
                  // 打开和URL之间的连接
                  conn = realUrl.openConnection();
              }
            // 设置通用的请求属性
            conn.setRequestProperty("accept", "*/*");
            conn.setRequestProperty("connection", "Keep-Alive");
            conn.setRequestProperty("Content-Type", "text/plain; charset=utf-8");
            conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
            // 发送POST请求必须设置如下两行
            conn.setDoOutput(true);
            conn.setDoInput(true);
            // 获取URLConnection对象对应的输出流
            out = new PrintWriter(conn.getOutputStream());
            // 发送请求参数
            out.print(param);
            // flush输出流的缓冲
            out.flush();
            // 定义BufferedReader输入流来读取URL的响应
            in = new BufferedReader(new InputStreamReader(conn.getInputStream()));
            String line;
            while ((line = in.readLine()) != null) {
                result += line;
            }
            //使用finally块来关闭输出流、输入流
            if(out!=null){
                out.close();
            }
            if(in!=null){
                in.close();
            }
            return result;
        } 
        
        public static class MyAuthenticator extends Authenticator {
            private String user = "";
            private String password = "";
    
            public MyAuthenticator(String user, String password) {
                this.user = user;
                this.password = password;
            }
    
            protected PasswordAuthentication getPasswordAuthentication() {
                return new PasswordAuthentication(user, password.toCharArray());
            }
        }
    
        public static void main(String[] args) throws Exception {
    //        System.out.println(HttpUtil.sendGet("http://www.baidu.com", "", "5", true));
            System.out.println(HttpUtil.sendPost("http://www.baidu.com","","", "5", true));
        }
    }
  • 相关阅读:
    ExpandoObject与DynamicObject的使用
    ManualResetEvent 线程通信
    CancellationTokenSource 取消任务
    SQL Server 每日一题--老二解析
    说说 C# 8 using 新特性
    SQL Server 每日一题--老二
    C#中的坑--浮点类型
    开胃菜解析
    开胃菜
    快速入门 Arrow 日期处理库
  • 原文地址:https://www.cnblogs.com/sprinng/p/5757507.html
Copyright © 2011-2022 走看看