netty客户端线程给多大比较合理 ?
对于这个疑问的由来可以看我的两一篇博客:netty客户端断线重连实现及问题思考
netty中一个NioEventLoopGroup
默认创建的线程数是cpu核心数 * 2 ,这些线程都是用于io操作,那么对于客户端应用程序来说真的需要这么多io线程么?
实际上netty在创建一个Channel
对象后只会从NioEventLoopGroup
中选择一个NioEventLoop
来绑定,只有创建多个Channel
才会依次选择下一个NioEventLoop
,也就是说一个Channel
只会对应一个NioEventLoop
,而NioEventLoop
可以绑定多个Channel
。
- 对于客户端来说,如果只是连接的一个server节点,那么只要设置1条线程即可。即使出现了断线重连,在连接断开之后,之前的
Channel
会从NioEventLoop
移除。重连之后,仍然只会在仅有的一个NioEventLoop
注册一个新的Channel
。 - 如果客户端同时如下方式多次调用
io.netty.bootstrap.Bootstrap#connect(String inetHost, int inetPort)
连接多个Server节点,那么线程可以设置大一点,但不要超过2*c,而且只要出现断线重连,同样不能保证每个NioEventLoop
都会绑定一个客户端Channel
。public boolean connect() { try { ChannelFuture channelFuture1 = bootstrap.connect("127.0.0.1", 8088); ChannelFuture channelFuture2 = bootstrap.connect("127.0.0.1", 8088); ChannelFuture channelFuture3 = bootstrap.connect("127.0.0.1", 8088); } catch (Exception e) { exceptionHandler(e); } clientChannel.close(); return false; } ```
- 如果netty客户端线程数设置大于1有什么影响么?
明显的异常肯定是不会有的,但是照成资源浪费,首先会创建多个NioEventLoop
对象,但是这些对于的NioEventLoop
是处于非运行状态。一旦出现断线重连,那么重新连接时,下一个NioEventLoop
则会被选中,并启动线程一直处于runnable
状态。而上一个NioEventLoop
也是一直处于runnable
状态,由于上一个Channel已经被close,所以会造成每次select结果都是空的,没有意义的空轮询。
如下则是netty客户端使用默认线程数,4次断线重连后一共创建的5条NioEventLoop线程,但是实际上只有第5条线程在执行读写操作。
- 如果客户端存在耗时的业务逻辑,应该单独使用业务线程池,避免在netty的io线程中执行耗时逻辑处理。