1、Netty 是怎么创建服务端Channel的呢？ 我们在使用ServerBootstrap.bind(端口)方法时，最终调用其父类AbstractBootstrap中的doBind方法，相关源码如下： private ChannelFuture doBind(final SocketAddress localAddress) { //初始化和注册 final ChannelFuture regFuture = initAndRegister(); ..... 我们继续跟进initAndRegister()这个方…
传统同步阻塞I/O（BIO） 在NIO之前编写服务器使用的是同步阻塞I/O（Blocking I/O）。下面是一个典型的线程池客服端服务器示例代码，这段代码在连接数急剧上升的情况下，这个服务器代码就会不好使了，因为serverSocket.accept()，以及IO的read()，write()方法都是同步阻塞的，虽然通过线程池，避免频繁创建线程开销，但是该系统过于依赖线程，一个是线程的创建和销毁很耗时，再者线程的切换开销很大，尤其是在高并发的情况下系统压力不堪设想。 BIO线程池客服端服务器示例代码 /** * …
什么是Netty Netty是一个基于Java NIO的编写客服端服务器的框架，是一个异步事件框架。 官网https://netty.io/ 为什么选择Netty 由于JAVA NIO编写服务器的过程过于复杂且不易掌控，所以我们选择Netty框架进行开发。 具有很高的的性能。 且比NIO更容易编码和维护。 实践者众多，Elastic Search，dubbo,Akka,grpc等等 社区很成熟。 Netty的常用组件 EventLoopGroup 相当于Reactor线程组,常用NioEventLoopGroup …
WebSocket与Http、Socket的区别和联系 WebSocket同HTTP一样也是应用层的协议，但是它是一种双向通信协议，是建立在TCP之上的。 WebSocket与HTTP的关系 相同点 都是一样基于TCP的，都是可靠性传输协议。 都是应用层协议。 不同点 WebSocket是双向通信协议，模拟Socket协议，可以双向发送或接受信息。HTTP是单向的。 WebSocket是需要握手进行建立连接的。 联系 WebSocket在建立握手时，数据是通过HTTP传输的。但是建立之后，在真正传输时候是不需要HT…
1、介绍 Linux 的内核将所有外部设备都看做一个文件来操作（一切皆文件），对一个文件的读写操作会调用内核提供的系统命令，返回一个file descriptor（fd，文件描述符）。而对一个socket的读写也会有响应的描述符，称为socket fd（socket文件描述符），描述符就是一个数字，指向内核中的一个结构体（文件路径，数据区等一些属性）。 根据UNIX网络编程对I/O模型的分类，UNIX提供了5种I/O模型。 1.1、阻塞I/O模型 最常用的I/O模型，默认情况下，所有…
1、BIO编程 1.1、传统的BIO编程 网络编程的基本模型是C/S模型，即两个进程间的通信。 服务端提供IP和监听端口，客户端通过连接操作想服务端监听的地址发起连接请求，通过三次握手连接，如果连接成功建立，双方就可以通过套接字进行通信。 传统的同步阻塞模型开发中，ServerSocket负责绑定IP地址，启动监听端口；Socket负责发起连接操作。连接成功后，双方通过输入和输出流进行同步阻塞式通信。 简单的描述一下BIO的服务端通信模型：采用BIO通信模型的服务端，通常由…
（原） 第一篇，从一个最简单的例子开始 1、netty是干什么，怎么用，这里不作介绍，先从一个例子来了解它， netty 5.0以上的版本被废弃了，以下例子从4.1.10.Final版本开始。 2、一共3个类 1> TestServer 用于启动服务，这里有二个EventLoopGroup,bossGroup和workerGroup，bossGroup接收来自客户端的请求，然后将这些请求再转交给workerGroup处理。 2> TestServerInitializer 服务端初始化，用于收集客户端数…
(原) 第二篇，客户端与服务端互发消息 与第一篇的例子类似，这里服务端需要三个类，客户端也需要三个类。 服务端关键代码如下：MyServer与上一个例子中的TestServer 差多，这里只列举不同的地方。 通过MyServerHandler能看到，服务端收到消息后会向客户端发送一个UUID。 客户端代码如下： 这里能看到与服务端最明显的区别就是只有一个EventLoopGroup，用于连接类是bootstrap，不是serverBootStrap。 通过MyClientHandler可以看到，当连接成功以…
(原) 第三篇，客户端与服务端通信 以下例子逻辑： 如果客户端连上服务端，服务端控制台就显示，XXX个客户端地址连接上线。 第一个客户端连接成功后，客户端控制台不显示信息，再有其它客户端再连接上线，则其它客户端显示：【服务器】 - XXX 已加入 当客户端发送一条消息给服务端，其它客户端控制台都能收到此消息【服务端】 - xxx msg，同时自己也会收到一条消息，【服务端】 - 【自己】 msg 服务端ChannelInitializer和SimpleChannelInboundHandler实现为： 这里的cha…
(原) 第四篇，客户端与服务端心跳 心跳事件有三种，读空闲，写空闲，读写空闲，定义在了IdleState枚举类中，分别为READER_IDLE，WRITER_IDLE，ALL_IDLE 服务端： main方法与之前的例子差不多，只不过多了加了一个日志，其中,handler是用于处理bossGroup的handler，而childHandler是用于处理workerGroup的handler。 这里IdleStateHandler接收三个参数，分别是读超时时间，写超时时间，读写超时时间 这个handler继承…
COPYRIGHT © 2022 zhizhesoft. ALL RIGHTS RESERVED.