绑定CXF Client源IP地址

Question

我有一个连接到 Web 服务的 CXF 客户端。此客户端安装在同一网络中具有两个 IP 地址（例如 172.16.1.101 和 172.16.1.102）的计算机中。

如何将 CXF 客户端配置为使用特定的源 IP 地址，以便服务器看到来自该特定 IP 地址而不是其他 IP 地址的请求？

如果我可以访问 Socket，我会执行以下操作：

Socket s = new Socket(); 
s.bind(new InetSocketAddress("172.16.1.102", 0));  //this Ip address is the one I need to specify
s.connect(new InetSocketAddress("google.com", 80));

是否可以配置 CXF 创建的 Sockets 以便我可以指定源 IP 地址？

编辑：我需要指定源 IP 地址，因为在客户端和 Web 服务器之间有一个防火墙，其中一个 IP 地址具有规则（来自另一个 IP 地址的连接被阻止）。

Answer 1

CXF 客户端使用java.net.URLConnection 连接到服务。可以通过这种方式配置 URLConnection 选择本地 IP 地址（见How can I specify the local address on a java.net.URLConnection?）

URL url = new URL(yourUrlHere);
Proxy proxy = new Proxy(Proxy.Type.DIRECT, 
    new InetSocketAddress( 
        InetAddress.getByAddress(
            new byte[]{your, ip, interface, here}), yourTcpPortHere));
URLConnection conn = url.openConnection(proxy);

我检查了工件 cxf-rt-rs-client 和 cxf-rt-transports-http 的代码以了解 CXF 如何创建连接。在ProxyFactory 中是用于创建UrlConnection 所需的Proxy 对象的代码

private Proxy createProxy(final HTTPClientPolicy policy) {
    return new Proxy(Proxy.Type.valueOf(policy.getProxyServerType().toString()),
                     new InetSocketAddress(policy.getProxyServer(),
                                           policy.getProxyServerPort()));
}

如您所见，没有办法配置IP地址，所以问题的答案恐怕是不能用CXF配置源IP地址

但是，我认为修改源代码以允许设置源IP地址并不难

HTTPClientPolicy

将以下代码添加到org.apache.cxf.transports.http.configuration.HTTPClientPolicycxf-rt-transports-http

public class HTTPClientPolicy {
    protected byte[] sourceIPAddress;
    protected int port;

    public boolean isSetSourceIPAddress(){
        return (this.sourceIPAddress != null);
    }

代理工厂

将以下代码修改为org.apache.cxf.transport.http.ProxyFactorycxf-rt-transports-http

 //added || policy.isSetSourceIPAddress()
 //getProxy() calls finally to createProxy
 public Proxy createProxy(HTTPClientPolicy policy, URI currentUrl) {
    if (policy != null) {
        // Maybe the user has provided some proxy information
        if (policy.isSetProxyServer() || policy.isSetSourceIPAddress())
            && !StringUtils.isEmpty(policy.getProxyServer())) {
            return getProxy(policy, currentUrl.getHost());
        } else {
            // There is a policy but no Proxy configuration,
            // fallback on the system proxy configuration
            return getSystemProxy(currentUrl.getHost());
        }
    } else {
        // Use system proxy configuration
        return getSystemProxy(currentUrl.getHost());
    }
}

//Added condition to set the source IP address (is set)
//Will work also with a proxy
private Proxy createProxy(final HTTPClientPolicy policy) {
    if (policy.isSetSourceIPAddress()){
        Proxy proxy = new Proxy(Proxy.Type.DIRECT, 
            new InetSocketAddress( 
                InetAddress.getByAddress(
                    policy.getSourceIPAddress(), policy.getPort()));
    } else {
        return new Proxy(Proxy.Type.valueOf(policy.getProxyServerType().toString()),
                     new InetSocketAddress(policy.getProxyServer(),
                                           policy.getProxyServerPort()));
    }                
}

用法

Client client = ClientProxy.getClient(service);
HTTPConduit http = (HTTPConduit) client.getConduit();
HTTPClientPolicy httpClientPolicy = new HTTPClientPolicy();
httpClientPolicy.setSourceIPAddress(new byte[]{your, ip, interface, here}));
httpClientPolicy.setPort(yourTcpPortHere);
http.setClient(httpClientPolicy);

Answer 2

自定义 URLStreamHandlerFactory 可以工作。

例子：

        ...
        URL.setURLStreamHandlerFactory(new URLStreamHandlerFactory() {
            @Override
            public URLStreamHandler createURLStreamHandler(String protocol) {
                if (protocol.equals("http")) {
                    return new HttpHandler();
                } else if (protocol.equals("https")) {
                    return new sun.net.www.protocol.https.Handler();
                }
                return null;
            }
        });
        ...

private class HttpHandler extends java.net.URLStreamHandler {

    protected int getDefaultPort() {
        return 80;
    }

    @Override
    protected URLConnection openConnection(URL u) throws IOException {
        return openConnection(u, (Proxy) null);
    }

    @Override
    protected URLConnection openConnection(URL u, Proxy p) throws IOException {
        return new HttpURLConnection(u, p) {

            @Override
            protected HttpClient getNewHttpClient(URL url, Proxy p, int connectTimeout)
                    throws IOException {
                return new HttpClient(url, (String) null, -1, true, connectTimeout) {

                    @Override
                    protected Socket createSocket() throws IOException {
                        Socket s = new Socket();

                        s.bind(new InetSocketAddress(InetAddress.getByName("1.2.3.4"),
                                0)); // yours IP here

                        return s;
                    }

                };
            }

            @Override
            protected HttpClient getNewHttpClient(URL url, Proxy p, int connectTimeout,
                    boolean useCache) throws IOException {
                return getNewHttpClient(url, p, connectTimeout);
            }

        };
    }
}

对于 HTTPS 也可以使用自定义 SSLSocketFactory

HttpsURLConnection.setDefaultSSLSocketFactory(...);

Answer 3

不确定我是否正确理解了您的问题，但我认为您不需要在客户端上专门设置 IP 地址以供服务器读取`

Message message = PhaseInterceptorChain.getCurrentMessage();
HttpServletRequest request = (HttpServletRequest)message.get(AbstractHTTPDestination.HTTP_REQUEST);
request.getRemoteAddr()

在服务器上添加此代码，它实际上可以从请求中找到 IP，您可以在服务器上对 IP 进行比较。让我知道这是否是您正在寻找的。​​p>

编辑：-----

嗯，我的理解是防火墙在消息中看不到 Header 或 Payload 中的 IP。它检查原始服务器的 IP。

如果我错了，请纠正我，但我觉得如果您将客户端部署在添加了防火墙规则的服务器上并调用服务器，它没有理由不工作。

让我知道你遇到了什么样的错误，比如堆栈跟踪或其他什么，我们可以看到发生了什么。