基于Netty的JT/T 809

基于Netty的JT/T 809

1.写在前面

九月初接到任务，负责开发xx区交通局接收车辆定位数据模块。当时对于socket的了解并不是太多，过往的工作和学习中对这一块也没有太过涉猎，吃了知识面过窄的亏。

pm给的时间也不是很长，当时就感觉要原地螺旋上天。资深的程序猿能在短时间内将一项新技能掌握个七七八八并迅速运行到项目中，完美掌控bug出现率。很明显我离这个境界差的不是一点点啊。所以面对是选择原生socket还是通信框架进行开发的时候，我只能选择直接上网google+度娘试图抓住几根救命稻草。

感谢这个信息爆炸的时代，弊端暂且不谈，互联网带给我们的好处还是大大的。

不知道是哪位大佬以前接过这样的任务，并无私地将半成品的代码发到网上供后来者参考，虽然漏洞也有但似乎已经足够了啊，喝水不忘挖井人，还是要感谢这位大佬奉献的精神，不然绩效被扣完就要吃土了啊！

佚名大佬选择的框架是netty，当时就着代码和几篇netty从入门到入土的博客直接开始啃，超硬

2.开始搞

public class JTServer implements Runnable{private static Logger LOG = Logger(JTServer.class);private static Properties prop = new PropFileManagerImpl().load("socketParam.properties");@Overridepublic void run() {ChannelFactory factory = new wCachedThreadPool(),wCachedThreadPool());ServerBootstrap bootstrap = new ServerBootstrap(factory);bootstrap.setPipelineFactory(new ChannelPipelineFactory() {public ChannelPipeline getPipeline() {ChannelPipeline pipeline = Channels.pipeline();pipeline.addLast("loging", new LoggingHandler(InternalLogLevel.INFO));pipeline.addLast("decoder", new Decoder());pipeline.addLast("encoder", new Encoder());pipeline.addLast("busiHandler", new BusiHandler());return pipeline;}});bootstrap.setOption("pNoDelay", true);bootstrap.setOption("child.keepAlive", true);bootstrap.bind(new InetSocketAddress(Integer.Property("mastersocket.port"))));System.out.println("Netty服务启动！！！");}}

public class NettyServerStart implements ServletContextListener{@Overridepublic void contextInitialized(ServletContextEvent arg0){new Thread(new JTServer()).start();	}@Overridepublic void contextDestroyed(ServletContextEvent arg0){// }
}

2.1 服务端初建立

服务类直接继承了Runnable接口，我的处理是：通过启动tomcat的时候，初始化自定义的继承ServletContextListener的类，在contextInitialized()方法中启动netty服务类，并在l中配置监听器监听tomcat的启动和销毁。至于什么tomcat热部署的时候会提示netty已经绑定当前的接口的异常不必理会，这种情况发生个鬼啊

那么这个服务启动类做了啥？

1. ChannelFactory配置bossExecutor和workerExecutor，装进ServerBootstrap实例中<