记在运用DotNetty的一次关于通道的调试经历

2019-07-21  本文已影响0人  杨凯本尊

本人博客原文链接

起因

最近由于工作需要通信功能,我就上午搜搜大厂都在用用什么通信框架,在java领域netty是相当火的一个通信框架,于是我就在github上找到了C#版本额netty框架---DotNetty。

DotNetty

DotNetty是微软的Azure团队,使用C#实现的Netty的版本发布。不但使用了C#和.Net平台的技术特点,并且保留了Netty原来绝大部分的编程接口。让我们在使用时,完全可以依照Netty官方的教程来学习和使用DotNetty应用程序。DotNetty拥有一个强大的后台,所以我感觉这个C#版的Netty框架也会火起来的。

第一个应用

DotNetty带着Netty的诸多光环,还有一个强大的“爹”,于是说干就干,开始写了一个TCP连接的Listener程序,代码如下:

ProtocolV1ServiceFrameHandler frameHandler = new ProtocolV1ServiceFrameHandler();
          frameHandler.ProtocolMsgReceivedChanged += FrameDecoder_ProtocolMsgReceivedChanged;
          BYHXTcpIdleHandler tcpIdleHandler = new BYHXTcpIdleHandler(0, 0, 5);
          tcpIdleHandler.LostConnectionChanged += TcpIdleHandler_LostConnectionChanged;
          group = new MultithreadEventLoopGroup();
          return new ServerBootstrap()
             .Group(group)
             .Channel<TcpServerSocketChannel>()
             .Option(ChannelOption.TcpNodelay, true)
             .Option(ChannelOption.SoKeepalive,true)
             .Option(ChannelOption.SoBacklog,100)
             .ChildHandler(new ActionChannelInitializer<ISocketChannel>(channel =>
             {
                 IChannelPipeline pipeline = channel.Pipeline;
                 pipeline.AddLast("Idle", tcpIdleHandler);
                 pipeline.AddLast("framing-enc", new LengthFieldPrepender(2));
                 pipeline.AddLast("en", new ProtocolV1FrameEncoder());
                 pipeline.AddLast("framing-dec", new LengthFieldBasedFrameDecoder(int.MaxValue, 0, 2, 0, 2));
                 pipeline.AddLast("dn", new ProtocolV1FrameDecoder());
                 pipeline.AddLast("handler", frameHandler);
             }));

上面的代码看起来没有任何问题,于是我就找了一个TCP客户端模拟器,可以连接没有问题,我又打开了一个TCP客户端,问题出现了,我通过cmd(netstat -an)命令行工具看到我第二次打开的连接是TIME_WAIT,之后打开的连接都是这个状态,我百思不得其解,于是我打印了netty的log,添加如下代码:

InternalLoggerFactory.DefaultFactory.AddProvider(new ConsoleLoggerProvider((s, level) => true, false));

通过Console窗口看到的log发现第二个之后的连接****ProtocolV1ServiceFrameHandler****通道处理器初始化失败了,我对比了事例发现在实例化通道处理器的又唯一的区别,如下:

   pipeline.AddLast("handler", new ProtocolV1ServiceFrameHandler());

这,,,有区别吗?不明白。忽然,我记得我查看ChannelHandlerAdapter可用的重载方法是看到一个可重载的属性IsSharable,表示通道是否可以共享,于是我把这个字段设置为true。OK!!!可以了。

总结

虽然这次调试通过了,但是一个通道那两中声明方式的差异性,或者说Netty框架处理的差异性,有何区别,我目前不得而知!我一直坚信,不刨根问底的程序员不是好的程序员,我还坚信,源码面前了无秘密。因此,我接下来会对netty的通道机制做一次深入的源码级别的刨析......

上一篇下一篇

猜你喜欢

热点阅读