ChannelPipeline 提供了ChannelHandler 链的容器，并定义了用于在该链上传播入站和出站事件流的API。ChannelPipeline不是单独存在,它肯定会和Channel、ChannelHandler、ChannelHandlerContext关联在一起。 一、ChannelHandler 1、概述 如上图所示ChannelHandler下主要是两个子接口       ChannelInboundHandler(入站): 处理输入数据和Channel状态类型改变。             …

Netty提供的ByteBuf不同于JDK中NIO的ByteBuffer，ByteBuf是netty中数据传输的容器，是Netty自己实现的，作为NIO ByteBuffer的替代品，提供了更好的API供开发者使用。相较于NIO的ByteBuffer更具有卓越的功能性和灵活性。具体NIO的ByteBuffer如何实现请参考IO模型之NIO代码及其实践详解。 一、ByteBuf的API特点 ByteBuf提供读访问索引(readerIndex)和写访问索引(writerIndex)来控制字节数组。ByteBuf AP…

一、什么是粘包、半包 1、粘包半包场景重现 来做这么一个测试，在Netty客户端发送数据到Netty服务端，代码如下： public void channelActive(ChannelHandlerContext ctx) throws Exception { for (int i = 0; i < 500; i++) { ByteBuf outBuffer = Unpooled.copiedBuffer("hello netty server"+i, CharsetUtil.UTF_8); ctx.wri…

如果将消息看作是对于特定的应用程序具有具体含义的结构化的字节序列—它的数据。那么编码器是将消息转换为适合于传输的格式（最有可能的就是字节流）；而对应的解码器则是将网络字节流转换回应用程序的消息格式。 在了解Netty编解码之前,先了解Java的编解码: 编码（Encode）称为序列化， 它将对象序列化为字节数组，用于网络传输、数据持久化或者其它用途。 解码（Decode）称为反序列化，它把从网络、磁盘等读取的字节数组还原成原始对象（通常是原始对象的拷贝），以方便后续的业务逻辑操作。 java序列化对象只需要实现ja…

一、七层网络模型 OSI是Open System Interconnection的缩写，意为开放式系统互联。国际标准化组织（ISO）制定了OSI模型，该模型定义了不同计算机互联的标准，它是一个七层的、抽象的模型体。 1、物理层 并不是物理媒体本身，它只是开放系统中利用物理媒体实现物理连接的功能描述和执行连接的规程，建立、维护、断开物理连接，传输单位是比特(bit)。 物理层的媒体包括架空明线、平衡电缆、光纤、无线信道等。通信用的互连设备指DTE（Data Terminal Equipment）和DCE（Data C…

先附上GitHub地址：https://github.com/kosamino/netty-root/tree/master/ym-netty-rpc RPC的实现方式是本地通过远程代理对象调用远程服务。在互联网应用场景中，单体服务极度缺乏弹性伸缩能力，在大规模开发团队中也不便于开发管理。所以往往会把服务根据模块进行垂直拆分，也就是我们说的SOA服务化。服务拆分后系统跟系统直接的业务交互往往依赖于RPC框架进行通讯。 通常RPC的服务端会提供对应的接口jar包，客户端通过rpc框架功能拿到对应接口的代理实例，整个调…

Netty是业界最流行的nio框架之一，它具有功能强大、性能优异、可定制性和可扩展性的优点 Netty的优点： 1.API使用简单，开发入门门槛低。 2.功能十分强大，预置多种编码解码功能，支持多种主流协议。 3.可定制、可扩展能力强，可以通过其提供的ChannelHandler进行灵活的扩展。 4.性能优异，特别在综合性能上的优异性。 5.成熟，稳定，适用范围广。 6.可用于智能GSM/GPRS模块的通讯服务端开发，使用它进行MQTT协议的开发。 1、Netty结合Springboot快速开发框架搭建服务端程序：…

之前搭建了一个Springboot+Netty服务端的应用，既然有服务端，自然也有客户端的应用，现在搭建一个Springboot+Netty客户端的应用Demo程序，也是使用TCP工具来进行测试，最终将客户端和服务端作为一个具体的应用来测试。 1、新建Springboot的maven项目，pom.xml文件导入依赖包 <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> &l…

  UDP是一个无连接协议，应用范围很大，对于一些低功耗的设备可以使用UDP方式向云端推送消息信息，也可以在推送消息时收到从云端原路返回的消息，使用Netty+SpringBoot方式可以快速开发一套基于UDP协议的服务端程序。 1、 新建Springboot的maven项目，pom.xml文件导入依赖包 ​ <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <pr…

使用Netty+SpringBoot方式可以快速地开发一套基于UDP协议的服务端程序，同样的也可以开发客户端，一般使用UDP都是使用原生的方式，发送消息后就不管不问，也就是不需要确定消息是否收到，这里使用Netty创建的客户端和服务端倒是能够类似http协议那样请求数据，得到返回数据，实际上得到的就是服务端原路返回的数据。 1、这里也使用SpringBoot+Netty创建，pom.xml文件导入依赖包 ​ <properties> <project.build.sourceEncoding>…