spring - 如何配置 reactor-netty 以使用 SSL？

Question

我正在尝试熟悉 Spring 的 Project Reactor (https://projectreactor.io/) 并构建了一个小型应用程序以通过 SSL 对另一个服务进行 REST 调用。我找不到任何方法来配置 org.springframework.web.client.reactive.WebClient 以通过 SSL 发出请求。似乎没有关于此的文档。我正在使用 reactor-core 3.0.0.RC1 和 reactor-netty 0.5.0.M3，以及 Spring Framework 5.0.0.M1。有谁知道如何配置 reactor-netty 以支持 SSL？

Answer 1

2017-01-04 更新:

这已在 Spring Framework 的 5.0.0.M4 版本中通过 this patch 得到纠正.

原答案:

我发现解决方案是创建一个支持 SSL 的新 ClientHttpConnector 实现。

public class ReactorClientHttpsAwareConnector implements ClientHttpConnector {

    @Override
    public Mono<ClientHttpResponse> connect(HttpMethod method, URI uri,
                                            Function<? super ClientHttpRequest, Mono<Void>> requestCallback) {

        return reactor.ipc.netty.http.HttpClient.create()
                                                .request(io.netty.handler.codec.http.HttpMethod.valueOf(method.name()),
                                                    uri.toString(),
                                                    httpClientRequest -> requestCallback
                                                        .apply(new ReactorClientHttpRequest(method, uri, httpClientRequest)))
                                                .cast(HttpInbound.class)
                                                .otherwise(HttpException.class, exc -> Mono.just(exc.getChannel()))
                                                .map(ReactorClientHttpResponse::new);
    }
}

HttpClient.create() 是使客户端支持 SSL 所必需的。