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

Question

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

Answer 1

2017-01-04 更新：

这在 Spring Framework 的 5.0.0.M4 版本中已通过此补丁得到纠正。

原答案：

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

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。