什么Netty?
创新互联公司是少有的成都网站制作、做网站、营销型企业网站、小程序开发、手机APP,开发、制作、设计、卖链接、推广优化一站式服务网络公司,从2013年成立,坚持透明化,价格低,无套路经营理念。让网页惊喜每一位访客多年来深受用户好评Netty是由JBOSS提供的一个java开源框架。Netty提供异步的、事件驱动的网络应用程序框架和工具,用以快速开发高性能、高可靠性的网络服务器和客户端程序。
也就是说,Netty 是一个基于NIO的客户、服务器端编程框架,使用Netty 可以确保你快速和简单的开发出一个网络应用,例如实现了某种协议的客户,服务端应用。Netty相当简化和流线化了网络应用的编程开发过程,例如,TCP和UDP的socket服务开发。
我们下面编写四个类
1.用于接收数据的服务器端Socket
2.用于接收客户端的消息,用于接收和反馈客户端发出的消息类ServertHandler
3.用于发送数据的服务器端Client
4.用于发送数据和接收服务器端发出的数据处理类ClientHandler
Socket.java
import io.netty.bootstrap.ServerBootstrap; import io.netty.buffer.ByteBuf; import io.netty.buffer.Unpooled; import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelInitializer; import io.netty.channel.ChannelOption; import io.netty.channel.EventLoopGroup; import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.socket.SocketChannel; import io.netty.channel.socket.nio.NioServerSocketChannel; import io.netty.handler.codec.DelimiterBasedFrameDecoder; import io.netty.handler.codec.string.StringDecoder; public class Server { public static void main(String[] args) throws InterruptedException { //1.第一个线程组是用于接收Client端连接的 EventLoopGroup bossGroup = new NioEventLoopGroup(); //2.第二个线程组是用于实际的业务处理的 EventLoopGroup workerGroup = new NioEventLoopGroup(); ServerBootstrap b = new ServerBootstrap(); b.group(bossGroup, workerGroup);//绑定两个线程池 b.channel(NioServerSocketChannel.class);//指定NIO的模式,如果是客户端就是NioSocketChannel b.option(ChannelOption.SO_BACKLOG, 1024);//TCP的缓冲区设置 b.option(ChannelOption.SO_SNDBUF, 32*1024);//设置发送缓冲的大小 b.option(ChannelOption.SO_RCVBUF, 32*1024);//设置接收缓冲区大小 b.option(ChannelOption.SO_KEEPALIVE, true);//保持连续 b.childHandler(new ChannelInitializer<SocketChannel>() { @Override protected void initChannel(SocketChannel sc) throws Exception { ByteBuf buf = Unpooled.copiedBuffer("$_".getBytes());//拆包粘包定义结束字符串(第一种解决方案) sc.pipeline().addLast(new DelimiterBasedFrameDecoder(1024,buf));//在管道中加入结束字符串 // sc.pipeline().addLast(new FixedLengthFrameDecoder(200));第二种定长 sc.pipeline().addLast(new StringDecoder());//定义接收类型为字符串把ByteBuf转成String sc.pipeline().addLast(new ServertHandler());//在这里配置具体数据接收方法的处理 } }); ChannelFuture future = b.bind(8765).sync();//绑定端口 future.channel().closeFuture().sync();//等待关闭(程序阻塞在这里等待客户端请求) bossGroup.shutdownGracefully();//关闭线程 workerGroup.shutdownGracefully();//关闭线程 } }
当前题目:Netty学习教程之基础使用篇-创新互联
网页URL:https://www.cdcxhl.com/article30/idgpo.html
成都网站建设公司_创新互联,为您提供软件开发、面包屑导航、品牌网站建设、网站营销、网站排名、企业网站制作
声明:本网站发布的内容(图片、视频和文字)以用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服。电话:028-86922220;邮箱:631063699@qq.com。内容未经允许不得转载,或转载时需注明来源: 创新互联