java - 使用 Apache Camel 的简单 HTTPS 代理服务器

Question

我正在尝试使用 Apache Camel 实现一个简单的 HTTP 代理服务。我的代码如下所示:

from("jetty:http://localhost:80?matchOnUriPrefix=true")
.recipientList(simple("jetty:${in.header.CamelHttpUrl}?bridgeEndpoint=true&throwExceptionOnFailure=false&disableStreamCache=true"));

本质上是this使用动态收件人列表来支持多个目的地。我还必须添加 disableStreamCache=true 位，否则我会得到路径重复的奇怪异常(比如 /index.html 会变成 /index.html/index.html).

不过，它似乎有效。但仅限于 HTTP 请求。当我尝试访问 HTTPS 站点时，我总是收到 404。

根据日志， jetty 组件似乎没有找到远程服务器。我不知道为什么。

01:36:37.495 [qtp85415531-22 - www.google.cz:443] DEBUG org.eclipse.jetty.server.Server - REQUEST www.google.cz:443 on AsyncHttpConnection@6964b063,g=HttpGenerator{s=0,h=-1,b=-1,c=-1},p=HttpParser{s=-5,l=17,c=0},r=1
01:36:37.495 [qtp85415531-22 - www.google.cz:443] DEBUG o.e.j.server.handler.ContextHandler - scope null||www.google.cz:443 @ o.e.j.s.ServletContextHandler{/,null}
01:36:37.495 [qtp85415531-22 - www.google.cz:443] DEBUG o.e.j.server.handler.ContextHandler - context=null||www.google.cz:443 @ o.e.j.s.ServletContextHandler{/,null}
01:36:37.495 [qtp85415531-22 - www.google.cz:443] DEBUG o.e.jetty.servlet.ServletHandler - servlet null||www.google.cz:443 -> null
01:36:37.495 [qtp85415531-22 - www.google.cz:443] DEBUG o.e.jetty.servlet.ServletHandler - chain=null
01:36:37.495 [qtp85415531-22 - www.google.cz:443] DEBUG o.e.jetty.servlet.ServletHandler - Not Found www.google.cz:443
01:36:37.495 [qtp85415531-22 - www.google.cz:443] DEBUG org.eclipse.jetty.server.Server - RESPONSE www.google.cz:443  200 handled=false

我应该怎么做才能启用此 HTTPS 支持？使用标准的 Camel 组件甚至有可能吗？

编辑:

我设法更新我的路由定义以不使用收件人列表。我不知道这是否会提高性能(是吗？)，但感觉更好。通过此操作，我还能够在不使用 disableStreamCache=true 时消除路径重复问题。

from("jetty:http://localhost:80?matchOnUriPrefix=true")
.to("http4:dummy?bridgeEndpoint=true&urlRewrite=#urlRewrite&throwExceptionOnFailure=false");

以及 URL 重写器实现:

UrlRewrite urlRewrite = new HttpServletUrlRewrite() {
    @Override
    public String rewrite(String url, String relativeUrl, Producer producer, HttpServletRequest request) throws Exception {
        return request.getRequestURL().toString();
    }

    @Override
    public String rewrite(String url, String relativeUrl, Producer producer) throws Exception {
        return null;
    }
};

编辑 2:

我可能应该提到我想拦截这些请求并读取/更改内容(实际上只是 HTTP header )。实际上，我想实现一个 MITM 代理。

编辑 3:

我尝试用 log 替换目标组件以查看请求是否通过:

from("jetty:http://localhost:80?matchOnUriPrefix=true")
.to("log:test")

消息在用​​作 HTTP 代理时被记录。当我用 jetty:https://localhost?matchOnUriPrefix=true 替换 URI 并尝试直接在浏览器中打开 https://localhost 时，它也会被记录下来。但是，当尝试将其用作 HTTPS 代理时，我无法将其记录下来。 Jetty 组件似乎不支持这种行为。是否正确？

我也尝试使用 Netty-http 组件得到类似的结果(路由跟踪器记录了 CONNECT 请求，但消息没有传递到 Log 组件)

Answer 1

关键是为 jetty 定义一个处理程序来处理 CONNECT 方法:

from("jetty:http://localhost:80?matchOnUriPrefix=true&handlers=#connectHandler")

在这种情况下，connectHandler 可以是 Jetty ConnectHandler(对于普通 HTTPS 代理)或自定义的(对于 MITM 代理):

class CustomConnectHandler extends ConnectHandler {
    @Override
    protected SocketChannel connect(HttpServletRequest request, String host, int port) throws IOException {
        SocketChannel channel = SocketChannel.open();
        channel.socket().setTcpNoDelay(true);
        channel.socket().connect(new InetSocketAddress("localhost", 443), getConnectTimeout());
        return channel;
    }
}

这个连接到本地主机上的端口 443 并在那里路由 SSL 数据。所以我们需要从那里定义另一条路线:

from("jetty:https://localhost:443?matchOnUriPrefix=true")

(我们可以保留两条单独的路线或稍后使用 SEDA 组件将它们连接起来)

要定义自定义 SSL 上下文参数( keystore 、信任库等)，我们可以在端点上使用 sslContextParametersRef 参数。

接下来，我们需要更改 URL。我们通过使用完整的 URL 填充 URI header 来实现这一点(默认情况下它只是相对路径):

.setHeader(Exchange.HTTP_URI, simple("${header.CamelHttpUrl}"))

我们还需要删除 PATH header ，因为 HTTP4 组件通过连接 URI 和 PATH header 来构建最终 URL:

.removeHeader(Exchange.HTTP_PATH)

最后，我们可以将消息转发给 HTTP4 组件。我们还应该设置 throwExceptionOnFailure=false 以将错误转发给客户端，并设置 httpClient.redirectsEnabled=false 以转发重定向(否则这可能会扰乱某些网站):

.to("http4:dummy?throwExceptionOnFailure=false&httpClient.redirectsEnabled=false");

我希望这对任何想使用 Camel 实现 HTTPS 代理并且像我一样苦苦挣扎的人有所帮助。