本文共 1054 字,大约阅读时间需要 3 分钟。
netty日常开发中一些重要事项分析
在netty中有两种发送消息的方式,可以直接写到Channel中,也可以写到与ChannelHandler所关联的那个ChannelHandlerContext中。对于前一种方式来说,消息会从ChannelPipeline的末尾开始流动,对于后一种方式来说,消息将从ChannelPipeline中的下一个ChannelHandler开始流动。因此:
对于oin阻塞方式的I/O操作,我们可以使用和nio异步非阻塞相同的api模型,只需要修改相关的接口实现,之所以能够同时解决两种情况,是因为netty底层使用异常捕获(SocketTimeoutException)来让同步的oio(阻塞I/O)操作在下一次EventLoop继续来处理,而对于异步nio基本不会出现该异常
考虑以下情况,netty正常接收客户端的请求,同时将请求发送到另一台netty服务端,在这里只是起到一个中转的作用。也许我们会这样考虑,当做服务端的时候来启动相应的ServerBootstrap,而当做客户端来转发到另一个netty服务端的时候,启动相应的Bootstrap来处理。但是我们有一种更加优雅的处理方式,在channelActive的handle回调方法中将当前的eventLoop绑定到该Bootstrap上,因为作为客户端一个线程就可以处理,公用当前的eventLoop相应的线程来处理可以让性能达到最佳。以下是伪代码:
public void channelActive(ChannelHandlerContext ctx){ Bootstrap bootstrap = ... bootstrap.channel(NioSocketChannel.class).handler( bootstrap.group(ctx.channel().eventLoop()); bootstrap.connect()...)}
转载地址:http://jhrgi.baihongyu.com/