如何使用 Netty 连接到 docker.sock？

Question

我有一个使用 Spring WebFlux 的 Reactive Springboot 应用程序。我正在尝试连接到我的 /var/run/docker.sock Unix Domain Socket 来查询一些信息。

从我的终端，我可以使用以下命令获取所有正在运行的容器。

curl --unix-socket /var/run/docker.sock http:/v1.40/containers/json

我正在遵循 Project Reactor 指南，在此处找到为 Unix 域套接字创建 HttpClient

我的测试代码如下。

return client.get()
        .uri("/containers/json")
        .responseContent()
        .asString()
        .collectList()
        .flatMapMany(new Function<List<String>, Publisher<? extends Container>>() {
            @Override
            public Publisher<? extends Container> apply(List<String> strings) {
                return Flux.empty();
            }
        });

HttpClient 就是这样创建的。

private HttpClient getOperationsClient(OperationsProperties properties) {
    return HttpClient.create()
            .remoteAddress(() -> new DomainSocketAddress("/var/run/docker.sock"));
}

提出请求时，我收到以下错误。

io.netty.channel.AbstractChannel$AnnotatedConnectException: connect(..) failed: Invalid argument: /var/run/docker.sock

深入研究一下错误，错误来自 io.netty.channel.unix.Socket.java 中的以下行（第 230 行）

res = connectDomainSocket(fd, unixDomainSocketAddress.path().getBytes(CharsetUtil.UTF_8));

res正在获得 -22 的值，这在堆栈跟踪中转换为“无效参数”。我已验证我的用户是正确的，并且对 /var/run/docker.sock 具有适当的“rw”权限（我的用户在 docker 组中）。

我究竟做错了什么？

我尝试改变周围的路径。我尝试了 的套接字地址unix:///var/run/docker.sock，结果是Address family not supported by protocol. 我还尝试将 DomainSocket URI 更改为不存在的内容，例如/var/run/test.sock也会导致-22 Invalid Argument.

我添加了 jvm 参数-Djava.net.preferIPv4Stack=true。它仍然不起作用，但似乎原来的 -22 错误已经消失。我现在面临-97 Address family not supported by protocol: /var/run/docker.sock

Answer 1

好吧，事实证明 Unix 域支持仅在快照 1.0.0-RC2 中可用。配置 spring 以使用 2.4.0-SNAPSHOT 在支持的 io.projectreactor 模块中传递地拉入，该模块具有 Unix Domain Socket 支持。它现在按预期工作。