JAVA альтернатива для CURLOPT_INTERFACE - PullRequest
Новая
       37

JAVA альтернатива для CURLOPT_INTERFACE

0 голосов
/ 22 апреля 2020

У меня на сервере запущено приложение Java, которое отправляет запрос на внешние серверы.

Мой сервер имеет 5 разных IP-адресов.

как мне сделать каждый запрос с одним другим IP-адресом?

Например, я хочу отправить первый запрос с 192.168.1.2 и отправить второй запрос с 192.168.1.3 и т. д.

В PHP Я достиг этой цели с помощью этого кода 

curl_setopt_array($curl , array(CURLOPT_INTERFACE => 'IpAddress'));

Я искал Unirest и OKHttp, но не смог найти хороших решений по этому поводу

1 Ответ

0 голосов
/ 22 апреля 2020

Я только что решил эту проблему с созданием пользовательского SocketFactory 

    public abstract class MySocketFactory
{
    private static javax.net.SocketFactory theFactory;

    protected MySocketFactory() { /* NOTHING */ }


    /**
     * Returns a copy of the environment's default socket factory.
     *
     * @return the default <code>SocketFactory</code>
     */
    public static javax.net.SocketFactory getDefault(String localIP) throws UnknownHostException {
        synchronized (javax.net.SocketFactory.class) {
            if (theFactory == null) {
                theFactory = new DefaultSocketFactory(InetAddress.getByName(localIP));
            }
            else app.l("theFactory is not null");
        }

        return theFactory;
    }


    public static void setDefault(javax.net.SocketFactory factory) {
        synchronized (javax.net.SocketFactory.class) {
            theFactory = factory;
        }
    }


    public Socket createSocket() throws IOException {

        UnsupportedOperationException uop = new
                UnsupportedOperationException();
        SocketException se =  new SocketException(
                "Unconnected sockets not implemented");
        se.initCause(uop);
        throw se;
    }
    public abstract Socket createSocket(String host, int port)
            throws IOException, UnknownHostException;


    public abstract Socket
    createSocket(String host, int port, InetAddress localHost, int localPort)
            throws IOException, UnknownHostException;


    public abstract Socket createSocket(InetAddress host, int port)
            throws IOException;


    public abstract Socket
    createSocket(InetAddress address, int port,
                 InetAddress localAddress, int localPort)
            throws IOException;
}


class DefaultSocketFactory extends javax.net.SocketFactory {
    InetAddress localIP;
    public DefaultSocketFactory(InetAddress localIP) {
        this.localIP = localIP;
    }
    public Socket createSocket() throws IOException {
        ServerSocket s = new ServerSocket(0);
        //get an empty port
        System.out.println("local port: " + s.getLocalPort());
        //close the listener to re open the port
        s.close();
        int finalPort = s.getLocalPort() ;
        SocketChannel channel = SocketChannel.open();
        channel.socket().bind(new InetSocketAddress(localIP, finalPort));
        return channel.socket();

    }

    public Socket createSocket(String host, int port)
            throws IOException {
        return new Socket(host, port);
    }

    public Socket createSocket(InetAddress address, int port)
            throws IOException
    {
        return new Socket(address, port);
    }

    public Socket createSocket(String host, int port,
                               InetAddress clientAddress, int clientPort)
            throws IOException
    {
        return new Socket(host, port, localIP, clientPort);
    }

    public Socket createSocket(InetAddress address, int port,
                               InetAddress clientAddress, int clientPort)
            throws IOException
    {
        return new Socket(address, port, localIP, clientPort);
    }
}

Я попытался связать локальный IP-адрес в createSocket(), тогда я просто использовал MySocketFactory в OKHttp

OkHttpClient.Builder httpClient = new OkHttpClient.Builder();
SocketFactory socketFactory = 
MySocketFactory.getDefault("192.168.1.2");
httpClient.socketFactory(socketFactory);
...