java用socks5实现内网和外网连接

心已赠人 2022-12-28 15:29 183阅读 0赞

**由于httpclient使用的是http协议，而socks5是tcp/ip层的代理，所以目前的httpclient还不支持对ss5代理的“开箱即用”。**

**可以通过一下代码来实现httpclient的ss5代理：注意这段代码的有一个非常重要的点是封装了一个FakeDnsResolver，这样写就可以将DNS解析交给SS5代理服务器去做，否则的话，程序会先去做域名解析，在内网机器无法访问  
外网DNS的时候就会报错**

package com.yeap.compiletest.jar_test;
    
    import java.io.IOException;
    importjava.net.InetAddress;
    importjava.net.InetSocketAddress;
    importjava.net.UnknownHostException;
    
    import org.apache.http.HttpEntity;
    import org.apache.http.HttpHost;
    import org.apache.http.client.ClientProtocolException;
    import org.apache.http.client.methods.CloseableHttpResponse;
    import org.apache.http.client.methods.HttpGet;
    import org.apache.http.client.protocol.HttpClientContext;
    import org.apache.http.config.Registry;
    import org.apache.http.config.RegistryBuilder;
    import org.apache.http.conn.DnsResolver;
    import org.apache.http.conn.socket.ConnectionSocketFactory;
    import org.apache.http.conn.socket.PlainConnectionSocketFactory;
    import org.apache.http.conn.ssl.SSLContexts;
    import org.apache.http.impl.client.CloseableHttpClient;
    import org.apache.http.impl.client.HttpClients;
    import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
    import org.apache.http.util.EntityUtils;
    
    public class App3 {
           
           public static void main(String[] args) throws ClientProtocolException, IOException {
                 
                 Registry<ConnectionSocketFactory> reg = RegistryBuilder.<ConnectionSocketFactory>create()
                         .register("http", new MyConnectionSocketFactory())
                         .register("https", new MySSLConnectionSocketFactory(SSLContexts.createSystemDefault()))
                         .build();
                 PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager(reg,new FakeDnsResolver());
                 CloseableHttpClient httpclient = HttpClients.custom()
                         .setConnectionManager(cm)
                         .build();
                 try {
                     InetSocketAddress socksaddr = new InetSocketAddress("10.1.68.102", 1080);
                     HttpClientContext context = HttpClientContext.create();
                     context.setAttribute("socks.address", socksaddr);
    
                     HttpHost target = new HttpHost("www.baidu.com", 443, "https");
                     HttpGet request = new HttpGet("/");
    
                     System.out.println("Executing request " + request + " to " + target + " via SOCKS proxy " + socksaddr);
                     CloseableHttpResponse response = httpclient.execute(target, request, context);
                     try {
                         System.out.println("----------------------------------------");
                         System.out.println(response.getStatusLine());
                         HttpEntity entity1 = response.getEntity();
                         //EntityUtils.consume(entity1);
                         System.out.println(EntityUtils.toString(entity1,"utf-8"));
                     } finally {
                         response.close();
                     }
                 } finally {
                     httpclient.close();
                 }
                 
                 
                 
           }
           
           static class FakeDnsResolver implements DnsResolver {
            @Override
            public InetAddress[] resolve(String host) throws UnknownHostException {
                // Return some fake DNS record for every request, we won't be using it
                return new InetAddress[] { InetAddress.getByAddress(new byte[] { 1, 1, 1, 1 }) };
            }
        }
    }

package com.yeap.compiletest.jar_test;
    
    import java.io.IOException;
    importjava.net.InetSocketAddress;
    importjava.net.Proxy;
    importjava.net.Socket;
    
    import javax.net.ssl.SSLContext;
    
    import org.apache.http.HttpHost;
    import org.apache.http.conn.socket.PlainConnectionSocketFactory;
    import org.apache.http.protocol.HttpContext;
    
    public class MyConnectionSocketFactory extends PlainConnectionSocketFactory  {
        @Override
        public Socket createSocket(final HttpContext context) throws IOException {
            InetSocketAddress socksaddr = (InetSocketAddress) context.getAttribute("socks.address");
            Proxy proxy = new Proxy(Proxy.Type.SOCKS, socksaddr);
            return new Socket(proxy);
        }
       
        @Override
        public Socket connectSocket(int connectTimeout, Socket socket, HttpHost host, InetSocketAddress remoteAddress,
                                    InetSocketAddress localAddress, HttpContext context) throws IOException {
            // Convert address to unresolved
            InetSocketAddress unresolvedRemote = InetSocketAddress
                    .createUnresolved(host.getHostName(), remoteAddress.getPort());
            return super.connectSocket(connectTimeout, socket, host, unresolvedRemote, localAddress, context);
        }
    
    }

package com.yeap.compiletest.jar_test;
    import java.io.IOException;
    import java.net.InetSocketAddress;
    import java.net.Proxy;
    import java.net.Socket;
    import javax.net.ssl.SSLContext;
    import org.apache.http.HttpHost;
    import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
    import org.apache.http.protocol.HttpContext;
    public class MySSLConnectionSocketFactory extends SSLConnectionSocketFactory {
        
        public MySSLConnectionSocketFactory(final SSLContext sslContext) {
            // You may need this verifier if target site's certificate is not secure
            super(sslContext, ALLOW_ALL_HOSTNAME_VERIFIER);
        }
        @Override
        public Socket createSocket(final HttpContext context) throws IOException {
            InetSocketAddress socksaddr = (InetSocketAddress) context.getAttribute("socks.address");
            Proxy proxy = new Proxy(Proxy.Type.SOCKS, socksaddr);
            return new Socket(proxy);
        }
        @Override
        public Socket connectSocket(int connectTimeout, Socket socket, HttpHost host, InetSocketAddress remoteAddress,
                                    InetSocketAddress localAddress, HttpContext context) throws IOException {
            // Convert address to unresolved
            InetSocketAddress unresolvedRemote = InetSocketAddress
                    .createUnresolved(host.getHostName(), remoteAddress.getPort());
            return super.connectSocket(connectTimeout, socket, host, unresolvedRemote, localAddress, context);
        }
        
        
    }