GRPC Java - 防止内存泄漏

Question

我试图阻止 GRPC 每个通道使用多个线程。为此，我使用以下代码设置了一个单线程执行器：

for (int i = 0; i < 3 * numFaults + 1; i++) {
            //One thread for each channel
            ManagedChannel channel = NettyChannelBuilder
                    .forAddress(host, port + i + 1)
                    .usePlaintext()
                    .executor(Executors.newSingleThreadExecutor())
                    .build();

然后我为每个通道创建一个异步存根。

但是，这似乎不起作用，因为我的程序中仍然产生太多线程，最终内存不足。

我应该将执行程序传递给存根吗？或者有什么根本性的错误。

提前致谢

Answer 1

额外产生的线程可能是 EventLoop 线程（默认情况下它最多可以创建 # 个核心线程）。在 NettyChannelBuilder 中有一个提供 EventLoopGroup 的选项。要使用此 API，您还需要设置 ChannelType。 EventLoopGroup 和 Channel 类型来自 netty 如果您有兴趣，请参阅链接的 javadoc 了解更多详细信息。

如果在 linux 上，你可以使用 Epoll，否则使用 NIO 是当前的 gRPC 行为。下面的例子是使用 NIO。 所有网络事件都发生在事件循环线程上，因此使用较少的线程会显着影响整体性能（取决于通道的使用方式）。也可以考虑使用directExecutor，为EventLoopGroup分配更多线程。

NioEventLoopGroup sharedEventLoopGroup = new NioEventLoopGroup(numThread);
ManagedChannel channel = NettyChannelBuilder
    .forAddress(host, port + i + 1)
    .usePlaintext()
    .channelType(NioSocketChannel.class)
    .eventLoopGroup(sharedEventLoopGroup)
    .executor(Executors.newSingleThreadExecutor())
    .build();