咨询热线:13960087636 联系人:李雨洪 地址:贵州省松桃苗族自治县盘信中街
netty搭建Tcp服务器实践
来源:ag官方网站 发布时间:2019-11-25 点击量:286
在netty基本组件介绍中,我们大致了解了netty的一些基本组件,今天我们来搭建一个基于netty的Tcp服务端程序,通过代码来了解和熟悉这些组件的功能和使用方法。
首先我们自己创建一个Server类,命名为TCPServer
第一步初始化ServerBootstrap,ServerBootstrap是netty中的一个服务器引导类,对ServerBootstrap的实例化就是创建netty服务器的入口
public class TCPServer { private Logger log = LoggerFactory.getLogger(getClass()); //端口号 private int port=5080; //服务器运行状态 private volatile boolean isRunning = false; //处理Accept连接事件的线程,这里线程数设置为1即可,netty处理链接事件默认为单线程,过度设置反而浪费cpu资源 private final EventLoopGroup bossGroup = new NioEventLoopGroup(1); //处理hadnler的工作线程,其实也就是处理IO读写 。线程数据默认为 CPU 核心数乘以2 private final EventLoopGroup workerGroup = new NioEventLoopGroup(); public void init() throws Exception{ //创建ServerBootstrap实例 ServerBootstrap serverBootstrap=new ServerBootstrap(); //初始化ServerBootstrap的线程模型 serverBootstrap.group(workerGroup,workerGroup);// //设置将要被实例化的ServerChannel类 serverBootstrap.channel(NioServerSocketChannel.class);// //在ServerChannelInitializer中初始化ChannelPipeline责任链,并添加到serverBootstrap中 serverBootstrap.childHandler(new ServerChannelInitializer()); //标识当服务器请求处理线程全满时,用于临时存放已完成三次握手的请求的队列的最大长度 serverBootstrap.option(ChannelOption.SO_BACKLOG, 1024); // 是否启用心跳保活机机制 serverBootstrap.childOption(ChannelOption.SO_KEEPALIVE, true); //绑定端口后,开启监听 ChannelFuture channelFuture = serverBootstrap.bind(port).sync(); if(channelFuture.isSuccess()){ System.out.println("TCP服务启动 成功---------------"); } } /** * 服务启动 */ public synchronized void startServer() { try { this.init(); }catch(Exception ex) { } } /** * 服务关闭 */ public synchronized void stopServer() { if (!this.isRunning) { throw new IllegalStateException(this.getName() + " 未启动 ."); } this.isRunning = false; try { Future<?> future = this.workerGroup.shutdownGracefully().await(); if (!future.isSuccess()) { log.error("workerGroup 无法正常停止:{}", future.cause()); } future = this.bossGroup.shutdownGracefully().await(); if (!future.isSuccess()) { log.error("bossGroup 无法正常停止:{}", future.cause()); } } catch (InterruptedException e) { e.printStackTrace(); } this.log.info("TCP服务已经停止..."); } private String getName() { return "TCP-Server"; }}
上面的代码中主要使用到的ServerBootstrap类的方法有以下这些:
group :设置SeverBootstrap要用到的EventLoopGroup,也就是定义netty服务的线程模型,处理Acceptor链接的主"线程池"以及用于I/O工作的从"线程池";
channel:设置将要被实例化的SeverChannel类;
option :指定要应用到新创建SeverChannel的ChannelConfig的ChannelOption.其实也就是服务本身的一些配置;
chidOption:子channel的ChannelConfig的ChannelOption。也就是与客户端建立的连接的一些配置;
childHandler:设置将被添加到已被接收的子Channel的ChannelPipeline中的ChannelHandler,其实就是让你在里面定义处理连接收发数据,需要哪些ChannelHandler按什么顺序去处理;
第二步接下来我们实现ServerChannelInitializer类,这个类继承实现自netty的ChannelInitializer抽象类,这个类的作用就是对channel(连接)的ChannelPipeline进行初始化工作,说白了就是你要把处理数据的方法添加到这个任务链中去,netty才知道每一步拿着socket连接和数据去做什么。
@ChannelHandler.Sharablepublic class ServerChannelInitializer extends ChannelInitializer<SocketChannel> { static final EventExecutorGroup group = new DefaultEventExecutorGroup(2); public ServerChannelInitializer() throws InterruptedException { } @Override protected void initChannel(SocketChannel socketChannel) throws Exception { ChannelPipeline pipeline = socketChannel.pipeline(); //IdleStateHandler心跳机制,如果超时触发Handle中userEventTrigger()方法 pipeline.addLast("idleStateHandler", new IdleStateHandler(15, 0, 0, TimeUnit.MINUTES)); // netty基于分割符的自带解码器,根据提供的分隔符解析报文,这里是0x7e;1024表示单条消息的最大长度,解码器在查找分隔符的时候,达到该长度还没找到的话会抛异常// pipeline.addLast(// new DelimiterBasedFrameDecoder(1024, Unpooled.copiedBuffer(new byte[] { 0x7e }),// Unpooled.copiedBuffer(new byte[] { 0x7e }))); //自定义编解码器 pipeline.addLast( new MessagePacketDecoder(), new MessagePacketEncoder() ); //自定义Hadler pipeline.addLast("handler",new TCPServerHandler()); //自定义Hander,可用于处理耗时操作,不阻塞IO处理线程 pipeline.addLast(group,"BussinessHandler",new BussinessHandler()); }}
这里我们注意下
pipeline.addLast(group,"BussinessHandler",new BussinessHandler());
在这里我们可以把一些比较耗时的操作(如存储、入库)等操作放在BussinessHandler中进行,因为我们为它单独分配了EventExecutorGroup 线程池执行,所以说即使这里发生阻塞,也不会影响TCPServerHandler中数据的接收。
最后就是各个部分的具体实现
解码器的实现:
public class MessagePacketDecoder extends ByteToMessageDecoder{ public MessagePacketDecoder() throws Exception { } @Override protected void decode(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out) throws Exception { try { if (buffer.readableBytes() > 0) { // 待处理的消息包 byte[] bytesReady = new byte[buffer.readableBytes()]; buffer.readBytes(bytesReady); //这之间可以进行报文的解析处理 out.add(bytesReady ); } }finally { } }}
编码器的实现
public class MessagePacketEncoder extends MessageToByteEncoder<Object>{ public MessagePacketEncoder() { } @Override protected void encode(ChannelHandlerContext ctx, Object msg, ByteBuf out) throws Exception { try { //在这之前可以实现编码工作。 out.writeBytes((byte[])msg); }finally { } }}
TCPServerHandler的实现
public class TCPServerHandler extends ChannelInboundHandlerAdapter { public TCPServerHandler() { } @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { //拿到传过来的msg数据,开始处理 } //检测到空闲连接,触发 @Override public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception { //这里可做一些断开连接的处理 }}
BussinessHandler的实现与TCPServerHandler基本类似,它可以处理一些相对比较耗时的操作,我们这里就不实现了。
通过以上的代码我们可以看到,一个基于netty的TCP服务的搭建基本就是三大块:
1、对引导服务器类ServerBootstrap的初始化;
2、对ChannelPipeline的定义,也就是把多个ChannelHandler组成一条任务链;
3、对 ChannelHandler的具体实现,其中可以有编解码器,可以有对收发数据的业务处理逻辑;
以上代码只是在基于netty框架搭建一个最基本的TCP服务,其中包含了一些netty基本的特性和功能,当然这只是netty运用的一个简单的介绍,如有不正确的地方还望指出与海涵。
相关产品
-
赛前巴萨竞技主管罗伯托在场边接受采访时表示:“佩德罗说他想离开。虽然我们希望他留下,但这可能是他在巴萨的最后一场比赛,3000万欧元的要价不会降低。”不出意外,佩德罗的下家将是英超曼联,从目前的情况来看,这笔交易已经无限接近完成。
-
尚玉龙表示,2018年,青海将探索“旗舰店+微商+加盟店”商品营销新模式,引导青海产品“走出去”,提升青海特色产品市场竞争力。同时加大电商扶贫力度,不断提升贫困人口利用电商就业创业能力,带动贫困人口增收脱贫。(完)
-
《斯诺登》电影讲述斯诺登如何加入CIA,如何成为CIA情报分析人员,如何最终决定将CIA机密公之于众的过程。在早前公布的预告中,我们可以看到斯诺登把储存了“棱镜计划”机密文件的SD数据卡带出国安局的片段,他把SD卡隐藏在自己的魔方里,以逃过戒备森严的安检。这一片段也是整部影片中备受期待的看点之一。
-
对林少钢来说,他因儿子而学习遥控模型飞机,继而认识许多志同道合的朋友,互相交换“遥控”心得,彼此交流人生经历。在空旷场地“驾”飞机,看见飞机在天空忽高忽低,自由自在地飞行,让人乐在其中。
-
实际上,对于App账号可注销一事,2013年9月1日起施行的《电信和互联网用户个人信息保护规定》提出,电信业务经营者、互联网信息服务提供者在用户终止使用电信服务或者互联网信息服务后,应当停止对用户个人信息的收集和使用,并为用户提供注销号码或者账号的服务。
-
意见稿规定,金融机构应在各项风险可控的范围内选择互联网机构,并对互联网机构的资质负责。具体来看,互联网机构注册资本应不低于3000万元人民币,且必须为实缴货币资本,同时应具备熟悉黄金业务的工作人员。
-
2009年,奥迪在法兰克福国际车展发布了首款名为“e-tron”的概念车。这款概念车采用的是4台轮毂电机驱动4个车轮的复杂技术,再次让业界惊叹不已。奥迪用这样一部前瞻、精密的“纯电动四驱超跑”展示了强大的技术开发能力。
-
记者18日在台北打开电视机,发现岛内对军演相当关注。有媒体派出记者到军演外围“现场直击”,详细介绍演习细节,并点名演习就是“警告‘台独’”。这两天恰逢台当局领导人蔡英文“出访”,当局有关部门表面上一副成竹在胸的样子,用“例行性”军演来安抚民众。至于赖清德,却开始神隐不言。
热点资讯
- 贵州:乡村“微旅游”吸引都市客2019-11-25
- 奋斗成就幸福为奋斗者点赞2019-11-25
- 香脆可口,金华酥饼梅干菜肉酥饼40个12.9元/80个22.8元2019-11-25
- 电影《孙悟空》宣布孙悟空化身为铁人2019-11-25
- 物种日历丨方头、小眼、短腿,藏狐是狐属动物中辨识度最高的一种2019-11-25
- Linuxugo权限2019-11-25
- 中国最贵的山一上山就花了500元,黄山超过泰山的年收入是52亿元。2019-11-25
- 研究机构:苹果A12处理器成本30美元,较A11高出9%2019-11-25