技术标签: java netty实战 后端 tcp/ip 开发语言
哈喽!大家好,我是【Bug 终结者】 ,【CSDN新星创作者】,阿里云技术博主,51CTO人气博主,INfoQ写作专家
一位上进心十足,拥有极强学习力的【Java领域博主】
【Bug 终结者】博客的领域是【面向后端技术】的学习,未来会持续更新更多的【后端技术】以及【学习心得】。 偶尔会分享些前端基础知识,会更新实战项目,面向企业级开发应用!
如果有对【后端技术】、【前端领域】感兴趣的【小可爱】,欢迎关注【Bug 终结者】
️️️ 感谢各位大可爱小可爱! ️️️
学习Netty需要了解BIO、NIO、AIO,具体可参考
官网介绍
Netty is an asynchronous event-driven network application framework
for rapid development of maintainable high performance protocol servers & clients.
Netty 是 一个异步事件驱动的网络应用程序框架
,用于快速开发可维护的高性能协议服务器和客户端。
Netty 是一个 NIO 客户端服务器框架,可以快速轻松地开发协议服务器和客户端等网络应用程序。它极大地简化和流线了网络编程,例如 TCP 和 UDP 套接字服务器。
“快速和简单”并不意味着生成的应用程序会受到可维护性或性能问题的影响。Netty 是经过精心设计的,它借鉴了许多协议(如 FTP、SMTP、HTTP 以及各种基于二进制和基于文本的遗留协议)的实现经验。因此,Netty 成功地找到了一种方法,可以在不妥协的情况下实现易于开发、性能、稳定性和灵活性。
Netty在NIO的基础上进行了封装,比NIO强大,Netty使用很广泛,用的企业多,所以需要去学习,Netty支持高并发,在高并发的情况下具有良好的吞吐量,是网络通讯的首选框架
Netty对JDK自带的NIO的API进行了封装,解决了上述问题
Netty模型图
Netty在互联网领域、大数据分布式计算领域、游戏行业、通信行业等获得了广泛的应用,一些业界著名的开源组件也基于Netty的NIO框架构建 (文章尾有详细介绍)。 2.Netty的特点 高并发 Netty是一款基于NIO(Nonblocking IO,非阻塞 IO)开发的网络通信框架,对比于BIO(Blocking IO,阻塞IO),他的并发性能得到了很大提高 。
工作原理示意图-简单版
Netty主要基于主从Reactor多线程模型,做了一定的改进,其中主从Reactor多线程有多个Reactor
对上图说明
Netty主要基于主从Reactor多线程模型,做了一定的改进,其中主从Reactor多线程模型有多个Reactor
对上图的说明
Netty服务器在6666端口监听,客户端发送消息给服务器 “Hello,服务器”
服务器可以回复消息给客户端 “hello 客户端”
NettyServer
服务器,监听6666端口
package com.wanshi.netty.simple;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
public class NettyServer {
public static void main(String[] args) throws Exception {
// 创建BossGroup 和 WorkerGroup
//说明
//1.创建2个线程组,分别是boosGroup和workerGroup
//2.boosGroup只是处理连接请求,真正的与客户端业务处理,会交给workerGroup完成
//3.两个都是无限循环
//4. boosGroup 和 workerGroup 含有的子线程(NioEventLoop)的个数
// 默认实际 CPU核数*2
EventLoopGroup boosGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
//创建服务器端的启动的对象,配置参数
ServerBootstrap bootstrap = new ServerBootstrap();
//使用链式编程来进行设置
bootstrap.group(boosGroup, workerGroup) // 设置两个线程组
.channel(NioServerSocketChannel.class) //使用NioServerSocketChannel作为服务器的通道实现
.option(ChannelOption.SO_BACKLOG, 128) // 设置线程队列等待连接个数
.childOption(ChannelOption.SO_KEEPALIVE, true) // 设置保持活动连接状态
.childHandler(new ChannelInitializer<SocketChannel>() {
// 创建一个通道初始化对象(匿名对象)
//给pipeline 设置处理器
@Override
protected void initChannel(SocketChannel socketChannel) throws Exception {
//可以使用一个集合管理SocketChannel,再推送消息时,可以将业务加入到各个channel对应的NioEventLoop的taskQueue
//或者 scheduleTaskQueue
System.out.println("客户 SocketChannel:" + socketChannel.hashCode());
socketChannel.pipeline().addLast(new NettyServerHandler());
}
}); //给我们的workerGroup的某一个EventLoop的对应的管道设置处理器
System.out.println("服务器 is ready...");
//绑定一个端口并且同步,生成了一个ChannelFuture对象
//启动服务器并绑定端口
ChannelFuture channelFuture = bootstrap.bind(6668).sync();
channelFuture.addListener(new ChannelFutureListener() {
@Override
public void operationComplete(ChannelFuture future) throws Exception {
if (channelFuture.isSuccess()) {
System.out.println("监听端口 6668 成功");
} else {
System.out.println("监听端口 6668 失败");
}
}
});
//对关闭通道进行监听
channelFuture.channel().closeFuture().sync();
} catch (Exception e) {
e.printStackTrace();
} finally {
//优雅关闭
boosGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}
}
NettyServerHandler
服务器处理器,处理客户端发送的消息并输出到控制台,并向服务端发送消息
package com.wanshi.netty.simple;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.util.CharsetUtil;
import java.util.concurrent.TimeUnit;
/**
* 自定义一个Handler,需要继承netty规定好的某个HandlerAdapter
* 这时我们自定义的handler才能称为一个handler
*/
public class NettyServerHandler extends ChannelInboundHandlerAdapter {
//读取数据事件(这里我们可以读取客户端发送的消息)
/**
* 1.ChannelHandlerContext ctx: 上下文对象,含有 管道pipeline,通道channel,地址
* 2.Object msg:就是客户端发送的数据,默认Object
* @param ctx
* @param msg
* @throws Exception
*/
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
System.out.println("server ctx =" + ctx);
//将 msg 转成一个ByteBuf
// ByteBuf buf = (ByteBuf) msg;
// System.out.println("客户端发送消息是:" + buf.toString(CharsetUtil.UTF_8));
// System.out.println("客户端地址:" + ctx.channel().remoteAddress());
//自定义普通任务队列,将耗时长的任务加入队列,定义到NioEventLoop --> taskQueue
ctx.channel().eventLoop().execute(new Runnable() {
@Override
public void run() {
try {
Thread.currentThread().sleep(10 * 1000);
ctx.writeAndFlush(Unpooled.copiedBuffer("hello,客户端:喵2~", CharsetUtil.UTF_8));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
ctx.channel().eventLoop().execute(new Runnable() {
@Override
public void run() {
try {
Thread.currentThread().sleep(20 * 1000);
ctx.writeAndFlush(Unpooled.copiedBuffer("hello,客户端:喵3~", CharsetUtil.UTF_8));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
//用户自定义定时任务 --》 该任务是提交到 scheduleQueue中
ctx.channel().eventLoop().schedule(new Runnable() {
@Override
public void run() {
try {
Thread.currentThread().sleep(5 * 1000);
ctx.writeAndFlush(Unpooled.copiedBuffer("hello,客户端:喵4~", CharsetUtil.UTF_8));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}, 5, TimeUnit.SECONDS);
System.out.println("go ~");
}
/**
* 数据读取完毕
* @param ctx
* @throws Exception
*/
@Override
public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
//writeAndFlush 是 write+flush
//将数据写入到缓存,并刷新
//一般讲,需要对发送的数据进行编码
ctx.writeAndFlush(Unpooled.copiedBuffer("hello,客户端:喵1~", CharsetUtil.UTF_8));
}
//处理异常,一般是需要关闭通道
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
ctx.close();
}
}
NettyClient
客户端,用于连接服务器
package com.wanshi.netty.simple;
import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;
public class NettyClient {
public static void main(String[] args) throws Exception {
//客户端需要一个事件循环组
EventLoopGroup eventExecutors = new NioEventLoopGroup();
try {
//创建一个客户端启动对象
//客户端使用的不是ServerGroup 而是Bootstrap
Bootstrap bootstrap = new Bootstrap();
//设置相关参数
bootstrap.group(eventExecutors) //设置线程组
.channel(NioSocketChannel.class) //设置客户端通道的实现类(反射)
.handler(new ChannelInitializer<SocketChannel>() {
@Override
protected void initChannel(SocketChannel socketChannel) throws Exception {
socketChannel.pipeline().addLast(new NettyClientHandler()); //加入自己的处理器
}
});
System.out.println("客户端 is ok...");
//启动客户端去连接服务器端, netty异步模型ChannelFuture
ChannelFuture channelFuture = bootstrap.connect("127.0.0.1", 6668).sync();
//给关闭通道进行监听
channelFuture.channel().closeFuture().sync();
} finally {
//优雅关闭线程池
eventExecutors.shutdownGracefully();
}
}
}
NettyClientHandler
客户端处理器,处理服务器发送的消息输出到控制台,并向服务器发送消息
package com.wanshi.netty.simple;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.util.CharsetUtil;
public class NettyClientHandler extends ChannelInboundHandlerAdapter {
/**
* 当通道就绪就会触发该方法
* @param ctx
* @throws Exception
*/
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
System.out.println("client " + ctx);
ctx.writeAndFlush(Unpooled.copiedBuffer("hello,服务端Server:喵~", CharsetUtil.UTF_8));
}
/**
* 当通道有读取事件时,会触发
* @param ctx
* @param msg
* @throws Exception
*/
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
//将msg转成buf
ByteBuf buf = (ByteBuf) msg;
System.out.println("服务器回复的消息:" + buf.toString(CharsetUtil.UTF_8));
System.out.println("服务器的地址:" + ctx.channel().remoteAddress());
}
// 当通道发生异常时执行此方法
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
cause.printStackTrace();
ctx.close();
}
}
如何免费使用阿里云服务器?【一篇文章教会你,真香】
如何使用Git SVN工具 – TortoiseGit(小乌龟)将本地项目上传至GitEE?【超详细教程】
前后端分离系列 – SpringBoot + Spring Security + Vue 实现用户认证 SpringSecurity如此简单
Postman测试工具调试接口详细教程【向后端发送Json数据并接收返回的Json结果】
Java面向对象 — 吃货联盟订餐系统(完整版)
以上就是【Bug 终结者】对Netty入门简单的理解,小编认为Java中支持三种网络编程IO模型,BIO、NIO、AIO,Netty对NIO又做了一层封装,本文我们已大致了解Netty到底是什么,Netty入门案例还需多敲,多练,方可掌握,通过本文能加固你对Netty的理解
如果这篇【文章】有帮助到你,希望可以给【Bug 终结者】点个赞,创作不易,如果有对【后端技术】、【前端领域】感兴趣的小可爱,也欢迎关注️️️ 【Bug 终结者】️️️,我将会给你带来巨大的【收获与惊喜】!
文章浏览阅读705次。背景介绍由于EasyNVR的受众越来越多,时常会遇到很多类似的问题咨询,之前虽然有写过很多的博文进行技术的或者使用问题的解答,随着客户询问的增多,我发现,要想让客户了解问题和解决问题,往往引导和给一个思路比直接给与支持和回答更有效果。今天我们就来解决Windows重启EasyNVR服务出现进程意外终止问题。Windows重启EasyNVR服务出现进程意外终止问题Windows..._大华流媒体服务器端口
文章浏览阅读1.3w次。前面一篇文章提到了两个Netfilter上的新玩意儿,其中之一就是bpf match模块,另一个nftables的ball还没有放出来,即使放出来了,它的吸引力也没有bpf match大,毕竟伯克利的东西不可小觑啊!虽然nftables也是借用了BPF的思想,但是能看得出的仅在代码层面上,反之,bpf match模块却是iptables质的飞跃,综合状态机,JIT(及时编译技术),它可以在很短的时_bpf iptables
文章浏览阅读431次,点赞3次,收藏3次。知识点目录3.1 如何编写程序界面3.2 常用控件的使用方法* 3.2.1 TextView* 3.2.2 Button* 3.2.3 EditText* 3.2.4 ImageView* 3.2.5 ProgressBar* 3.2.6 AlertDialog* 3.2.7 ProgressDialog3.3 详解4中基本布局* 3.3.1 线性布局*..._通常调用view 的( )方法来获取到界面控件imageview 和 textview 的实例
文章浏览阅读550次。我们系统中目前设置的是jdbc.maxIdleTime=14400000 ,minIdle=2014400000/3600/1000=4小时我们的数据库目前设置为15分钟即断开。故客户端连接池设置时间短一点:10分钟,会回收连接直到20.剩下的20个连接即使一直空闲也不回收,符合连接池的意义。但是数据库会把这20个连接关闭。故依旧无法解决抛错或者超时的问题。只能查看druid的监控,查看峰值活..._mysql连接断开多久回收
文章浏览阅读3.3w次,点赞31次,收藏175次。微信小程序获取用户手机号码的教程,包括前端开发和后端开发,代码亲测可用,以及包括如何获取用户信息的最新方法_微信小程序获取手机号
文章浏览阅读163次,点赞3次,收藏3次。然后,定义烟花的形状,采用 turtle.Shape 的方式来定义,包括圆形和尾迹。接着,注册烟花的形状,采用 turtle.register_shape 的方式来注册。然后,定义烟花类 Firework,包括初始化位置、颜色、速度等属性,以及更新位置的方法 update。接着,创建烟花,将其添加到 fireworks 列表中。最后,进入动画循环,不断更新烟花的位置,直到所有烟花都绽放完毕。大家好,小编为大家解答python炫酷烟花表白源代码的问题。首先,设置窗口大小和标题,定义烟花的颜色和数量。
文章浏览阅读350次,点赞8次,收藏6次。欢迎大家转发,一起传播知识和正能量,帮助到更多人。期待大家提出宝贵改进建议,互相交流,收获更大。辛苦大家转发时注明出处(也是咱们公益编程交流群的入口网址),刘经纬老师共享知识相关文件下载地址为:https://liujingwei.cn。print("【执行】math.perm(3,1)")print("【执行】math.perm(3,2)")期待大家提出宝贵建议,互相交流,收获更大,助教:whs。【小白从小学Python、C、Java】【计算机等考+500强证书+考研】即从n个不同元素中取出k个。
文章浏览阅读1.7k次,点赞2次,收藏5次。vulnhub靶场,JANGOW: 1.0.1环境准备靶机下载地址:https://www.vulnhub.com/entry/jangow-101,754/攻击机:kali(192.168.109.128)靶机:JANGOW: 1.0.1(192.168.109.198)下载好靶机之后直接使用VMware Workstation Pro虚拟机导入环境,启动即可,将网段设置为NAT模式目标:提升为root权限获取root目录下的flag信息收集使用arp-scan确定目标靶机确定目标靶机_jangow: 1.0.1靶场
文章浏览阅读696次。https://blog.csdn.net/qq_28205153/article/details/55798628https://blog.csdn.net/Simple_Man_Just/article/details/69258923?utm_source=blogxgwz1 _电信座机aes-1解密
文章浏览阅读2k次。一、DNS系统(一)、DNS概述在日常生活中人们习惯使用域名访问服务器,但机器间互相只认IP地址,域名与IP地址之间是多对一的关系,一个Ip地址不一定只对应一个域名,且一个域名只可以对应一个Ip地址,它们之间的转换工作称为域名解析,域名解析需要由专门的域名解析服务器来完成,整个过程是自动进行的。(二)、DNS的定义DNS是”域名系统(Domain Name System)"的英文缩写。它作为将域名和IP地址相互映射的一个分布式数据库,能够使人更方便地访问互联网。DNS服务使用TCP和UDP的_本地域名服务器域名解析次数
文章浏览阅读4.4k次,点赞11次,收藏16次。终于等到了周末,在经历了一周的忙碌后,终于可以利用空闲写篇博客。其实,博主有一点困惑,困惑于这个世界早已“堆积”起人类难以想象的“大”数据,而我们又好像执着于去“造”一个又一个“差不多”的“内容管理系统”,从前我们说互联网的精神是开放和分享,可不知从什么时候起,我们亲手打造了一个又一个的“信息孤岛”。而为了打通这些“关节”,就不得不去造一张巨大无比的蜘蛛网,你说这就是互联网的本质,对此我表示无法反驳。我更关心的是这其中最脆弱的部分,即:一条数据怎么从A系统流转到B系统。可能你会想到API或者ETL这样的关键_mysql数据同步可以通过读取binlog某个位置开始的数据往后走么
文章浏览阅读3.1k次,点赞9次,收藏55次。介绍线性代数与数据科学的关系就像罗宾与蝙蝠侠。这位数据科学忠实的伙伴经常会被大家所忽视,但实际上,它是数据科学主要领域--包括计算机视觉(CV)与自然语言处理(NLP)等热门领域的强力支撑。数据开发者往往会因为数学太难而尝试避开这个主题。因为有很多现成的数据处理库可以帮助他们避开线性代数这个烦恼。这是极其错误的想法。线性代数是我们所熟知的所用强大机器学习算法的背后核心,同样是数据科学家..._线性代数在大数据技术的应用