什么Netty?
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();//关闭线程 } }
免责声明:
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
软考中级精品资料免费领
- 历年真题答案解析
- 备考技巧名师总结
- 高频考点精准押题
- 资料下载
- 历年真题
193.9 KB下载数265
191.63 KB下载数245
143.91 KB下载数1148
183.71 KB下载数642
644.84 KB下载数2756
相关文章
发现更多好内容- 如何判断 Java 数组中是否存在重复元素?(Java怎么判断数组是否有重复元素)
- Java 中魔法值究竟是什么含义?(java魔法值是什么意思)
- 在 Java 开发中,Javase 究竟扮演着怎样的角色?(Javase在Java开发中扮演什么角色)
- 在 Java 中如何实现 base64 到 blob 的转换?(Java中base64转blob怎么实现)
- Java 中 clazz 类创建的方式有哪些?(java clazz类创建的方式是什么)
- 如何正确使用 Java PersistenceContext 类?实例详解!(Java PersistenceContext类使用实例)
- Java 中 Quartz 框架究竟是什么?(java中quartz是什么框架)
- PHP数据类型转换对存储方式的影响
- Java House 有哪些具体的方法?(Java House的方法有哪些)
- Java 如何读取 txt 文件内容并进行处理?(java怎么读取txt文件内容并处理)
猜你喜欢
AI推送时光机Netty学习教程之基础使用篇
后端开发2023-05-31
CTF之PHP基础学习篇(一)
后端开发2023-10-02
socket.io学习教程之基础介绍(一)
后端开发2022-06-04
vuex学习进阶篇之getters的使用教程
后端开发2022-11-13
Netty学习教程之Netty与Marshalling结合发送对象
后端开发2023-05-31
Python基础学习教程:Python基础之基本数据类型(一)
后端开发2023-06-02
socket.io学习教程之深入学习篇(三)
后端开发2022-06-04
Python常用算法学习基础教程
后端开发2022-06-04
kotlin 官方学习教程之基础语法详解
后端开发2023-05-31
Java学习教程:Java基础——反射
后端开发2023-06-03
Python学习入门基础教程(lear
后端开发2023-01-31
Python学习入门基础教程(learn
后端开发2023-01-31
Discuz! 的防水墙使用教程(基础篇)
后端开发2022-06-12
socket.io学习教程之基本应用(二)
后端开发2022-06-04
Python基础学习之认识线程
后端开发2024-04-02
shell学习之编程基础知识
后端开发2024-04-02
python基础学习之 特征工程
后端开发2023-06-02
C#多线程学习之基础入门
后端开发2024-04-02
python 基础教程之Map使用方法
后端开发2022-06-04
android基础教程之context使用详解
后端开发2022-06-06
咦!没有更多了?去看看其它编程学习网 内容吧