NIO中的buffer很经典,但是也需要小心翼翼。比如,flip如果不用好,就可能出错。
netty中重新封装了buffer,于是ByteBuf出现了。
public interface ByteBuf extends ChannelBuf, Comparable<ByteBuf> {
public ByteBufAllocator alloc();
public byte[] array();
public int arrayOffset();
public int bytesBefore(byte);
public int bytesBefore(ByteBufIndexFinder);
public int bytesBefore(int, byte);
public int bytesBefore(int, ByteBufIndexFinder);
public int bytesBefore(int, int, byte);
public int bytesBefore(int, int, byteBufIndexFinder);
public int capacity();
public ByteBuf capacity(int);
public ByteBuf clear();
public int compareTo(ByteBuf);
public ByteBuf copy();
public ByteBuf copy(int, int);
public ByteBuf discardReadBytes();
public ByteBuf duplicate();
public ByteBuf ensureWritableBytes(int);
public ByteBuf ensureWritableBytes(int, boolean);
public boolean equals(Object);
...
}
实在是太多,不一一罗列。这里注意的是,readerIndex()和writerIndex()说明有两个指针,这样的话,在0和readerIndex()之间的数据就表示已经读过的,调用discardReadBytes()就可以删除这些数据,类似NIO中的compact
这样做的好处是减少不必要的拷贝。指针是个宝。
当然这里的ByteBuf也把ByteBuffer中该有的都不落下。同时看接口,ChannelBuf只是一个方法 type()返回表明是byte还是message数据。comparable大家都很熟悉了。
ByteBuf是个接口,她有两个子接口
CompositeByteBuf 和 UnsafeByteBuf
CompositeByteBuf 就是多个ByteBuf的组合。
UnsafeByteBuf则是增加了一些方法,可以操作NIO。
接下来有 AbstractByteBuf,ReplayingDecoderBuffer和SwappedByteBuf
当然这些都不怎么用,SwappedByteBuf直接把传入的ByteBuf的字节序弄反就是了。
ReplayingDecoderBuffer则是在terminate以后,才返回capacity,这样可以用于在接受数据时,如果数据接收齐全了,就使用terminate()函数。
在AbstractByteBuf的强大实现下,开始有很多的子类了。大家可以看看。
这里要说常用的。例如UnpooledHeapByteBuf和UnpooledDirectByteBuf
这两个类基本上就是ByteBuf的实现类,工具类UnpooledByteBufAllocator正是通过返回他们得到想要的ByteBuf实例。文档上建议我们使用Unpooled工具类来创建这些ByteBuf,例如 directBuffer() 或者 wrappedBuffer(byte[]),wrappedBuffer(ByteBuffer) 等。
UnpooledDirectByteBuf很有意思,请看
private static final Field CLEANER_FIELD;
static {
ByteBuffer direct = ByteBuffer.allocateDirect(1);
Field cleanerField;
try {
cleanerField = direct.getClass().getDeclaredField("cleaner");
cleanerField.setAccessible(true);
Cleaner cleaner = (Cleaner) cleanerField.get(direct);
cleaner.clean();
} catch (Throwable t) {
cleanerField = null;
}
CLEANER_FIELD = cleanerField;
}
这里正是NIO中一个头疼的问题,就是direct memory的回收。这里给出一个解决办法。通常我们都是使用了System.gc()去建议JVM回收。
下面是使用。
private static void freeDirect(ByteBuffer buffer) {
if (CLEANER_FIELD == null) {
// Doomed to wait for GC.
return;
}
Cleaner cleaner;
try {
cleaner = (Cleaner) CLEANER_FIELD.get(buffer);
cleaner.clean();
} catch (Throwable t) {
// Nothing we can do here.
}
}
netty4.0 buffer,使用了读写指针直接对byte进行封装。并没有在NIO的buffer上再次封装,对于NIO buffer,则是直接使用byte array包装。
分享到:
相关推荐
Netty4.0全部jar包.开发时候只需要倒入总的哪一个netty4.0.jar就行了 后缀为resources.jar的全部是源码。 简单的代码例子在netty-example-resources.jar里面。
在本文中,我们将深入探讨如何利用Netty 4.0实现文件分片上传、断点续传以及权限校验的功能。 **文件分片上传** 文件分片上传是为了处理大文件传输时,避免一次性加载整个文件到内存中,从而减少内存消耗和提高...
在本篇Netty4.0学习笔记中,我们将聚焦于如何在实际应用中混合使用`coder`和`handler`,这是Netty框架中非常关键的一部分,对于构建高性能、低延迟的网络应用程序至关重要。Netty是一个用Java编写的异步事件驱动的...
Netty4.0 是其一个重要版本,引入了诸多改进和新特性。 在 Netty4.0 中,主要知识点包括: 1. **ByteBuf**:Netty4.0 引入了 ByteBuf 作为缓冲区,替代了传统的 ByteBuffer。ByteBuf 提供了更高效的内存管理,支持...
`UnpooledByteBufAllocator` 是一个工具类,用于创建这些 `ByteBuf` 实例,通常推荐使用 `Unpooled` 工具类中的静态方法,如 `directBuffer()` 或 `wrappedBuffer()` 来创建和管理 `ByteBuf`。 总的来说,`ByteBuf`...
NIO socket开发,netty4.0工具包。
Springboot2.0.8集成 netty4 ,使用protobuf作为ping的数据交换,比json更加的小巧,占用数据量更小,可用于任何第三方应用做心跳监控。 已完成功能: - 客户端授权验证(基于protoBuff) - 心跳检测(基于protoBuff) ...
在这个“Netty4.0 http案例”中,我们将深入探讨如何利用Netty 4.0 实现HTTP服务,以及客户端如何通过HTTP请求与服务器进行交互,特别是在处理JSON格式的数据时。 首先,让我们了解HTTP协议。HTTP(超文本传输协议...
Netty 4.0.45提供了高度优化的NIO(非阻塞I/O)和EPOLL(用于Linux系统的高效I/O)实现,确保了在处理大量并发连接时的性能。 在Socket开发中,Netty的ChannelHandlerContext和EventLoopGroup等概念非常关键。...
在 Netty 4.0 中,引入了一系列重大改进和变化,旨在提高性能、可维护性和易用性。以下是这些变化的详细说明: 1. **工程结构的改变**: - 包名从 org.jboss.netty 更改为 io.netty,反映了项目的独立性。 - ...
Netty4.0.54英文版API文档,与官网中文档内容一致,方便用户在离线环境下,开发Netty
在本篇Netty4.0学习笔记系列之六中,我们将深入探讨Netty框架如何支持多种通讯协议,以及它在实现高效、灵活的网络通信中的关键特性。Netty是一个高性能、异步事件驱动的网络应用框架,适用于开发服务器和客户端的...
Netty 是一个高性能、异步事件驱动的网络应用程序框架,用于快速开发可维护的高性能协议服务器和客户端。这个压缩包包含的是Netty 4.0.0.CR3版本的相关资源,包括源码、示例以及API文档,对于学习和理解Netty的工作...
Netty4.0学习笔记系列之三是关于构建简单的HTTP服务的教程,这主要涉及网络编程、服务器开发以及Java NIO(非阻塞I/O)的相关知识。Netty是一个高性能、异步事件驱动的网络应用程序框架,它使得开发可伸缩且稳定的...
在本篇“Netty4.0学习笔记系列之五:自定义通讯协议”中,我们将深入探讨如何在Netty框架下构建和实现自己的通信协议。Netty是一个高性能、异步事件驱动的网络应用框架,广泛应用于Java领域的服务器开发,如网络游戏...
在本篇“Netty4.0学习笔记系列之二:Handler的执行顺序”中,我们将深入探讨Netty中的Handler处理链以及它们的执行流程。 首先,Netty 中的 ChannelHandler 是处理 I/O 事件或拦截 I/O 操作的核心组件。每个 ...
这个"Netty4.0 demo"压缩包包含了一些Netty 4.0版本的应用示例代码,可以帮助我们更好地理解和学习Netty的工作原理以及如何在实际项目中运用它。 1. **Netty简介** Netty 是由JBOSS组织开发的一个开源项目,最初...
Netty是由JBOSS提供的一个java开源框架。Netty提供异步的、事件驱动的网络应用程序框架和工具,用以快速开发高性能、高可靠性的网络服务器和客户端程序dsf。...netty, 4.0.28, Final, jar包, 含源码
在本文中,我们将深入探讨Netty 4.0的学习笔记,特别是关于Server与Client之间的通信机制。 首先,我们要理解Netty的核心概念——NIO(非阻塞I/O)。Netty基于Java NIO库构建,它提供了更高级别的API,简化了多路...
Netty官方4.0.42版jar包