前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Netty整理(三) 顶

Netty整理(三) 顶

作者头像
算法之名
发布2019-10-09 15:37:42
4480
发布2019-10-09 15:37:42
举报
文章被收录于专栏:算法之名算法之名

Netty整理(二)

ByteBuf:是数据容器(字节容器)

代码语言:txt
复制
    JDK ByteBuffer
代码语言:txt
复制
         共用读写索引,每次读写操作都需要Flip()
代码语言:txt
复制
         扩容麻烦,而且扩容后容易造成浪费 关于ByteBuffer的使用方法可以参考[序列化和反序列化的三种方法 ](https://my.oschina.net/u/3768341/blog/1815513),里面有Netty 3的ChannelBuffer,因为现在Netty 3用的比较少,当作参考就好。
代码语言:txt
复制
    Netty ByteBuf
代码语言:txt
复制
         读写使用不同的索引,所以操作便捷
代码语言:txt
复制
         自动扩容,使用便捷

我们现在来看一下ByteBuf的源码。

代码语言:javascript
复制
public abstract class ByteBuf implements ReferenceCounted, Comparable<ByteBuf>

我们可以看到ByteBuf是一个抽象类,它里面几乎大部分都是抽象方法。

继承ByteBuf的是一个AbstractByteBuf的抽象类,而读写索引的属性就在该类中。

代码语言:javascript
复制
public abstract class AbstractByteBuf extends ByteBuf
代码语言:javascript
复制
int readerIndex;  //读索引
int writerIndex;  //写索引
private int markedReaderIndex;  //标记当前读索引的位置
private int markedWriterIndex;  //标记当前写索引的位置
private int maxCapacity;  //最大容量

而支持自动扩容的部分可以由ensureWritable追踪看到

代码语言:javascript
复制
@Override
public ByteBuf ensureWritable(int minWritableBytes) {
    if (minWritableBytes < 0) {
        throw new IllegalArgumentException(String.format(
                "minWritableBytes: %d (expected: >= 0)", minWritableBytes));
    }
    ensureWritable0(minWritableBytes);
    return this;
}

final void ensureWritable0(int minWritableBytes) {
    ensureAccessible();
    if (minWritableBytes <= writableBytes()) {
        return;
    }

    if (minWritableBytes > maxCapacity - writerIndex) {
        throw new IndexOutOfBoundsException(String.format(
                "writerIndex(%d) + minWritableBytes(%d) exceeds maxCapacity(%d): %s",
                writerIndex, minWritableBytes, maxCapacity, this));
    }

    // Normalize the current capacity to the power of 2.
    int newCapacity = alloc().calculateNewCapacity(writerIndex + minWritableBytes, maxCapacity);

    // Adjust to the new capacity.
    capacity(newCapacity);
}

在AbstractByteBufAllocator中

代码语言:javascript
复制
static final int CALCULATE_THRESHOLD = 1048576 * 4; // 4 MiB page
代码语言:javascript
复制
/**
 * 计算新容量
 */
@Override
public int calculateNewCapacity(int minNewCapacity, int maxCapacity) {
    if (minNewCapacity < 0) {
        throw new IllegalArgumentException("minNewCapacity: " + minNewCapacity + " (expected: 0+)");
    }
    if (minNewCapacity > maxCapacity) {
        throw new IllegalArgumentException(String.format(
                "minNewCapacity: %d (expected: not greater than maxCapacity(%d)",
                minNewCapacity, maxCapacity));
    }
    final int threshold = CALCULATE_THRESHOLD; // 4 MiB page

    if (minNewCapacity == threshold) {
        return threshold;
    }

    // If over threshold, do not double but just increase by threshold.
    if (minNewCapacity > threshold) {
        int newCapacity = minNewCapacity / threshold * threshold;
        if (newCapacity > maxCapacity - threshold) {
            newCapacity = maxCapacity;
        } else {
            newCapacity += threshold;
        }
        return newCapacity;
    }

    // Not over threshold. Double up to 4 MiB, starting from 64.
    int newCapacity = 64;
    while (newCapacity < minNewCapacity) {
        newCapacity <<= 1;
    }

    return Math.min(newCapacity, maxCapacity);
}

这个newCapacity就是扩容的新容量,所以我们一般不需要担心ByteBuf容量不够的问题。

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
文件存储
文件存储(Cloud File Storage,CFS)为您提供安全可靠、可扩展的共享文件存储服务。文件存储可与腾讯云服务器、容器服务、批量计算等服务搭配使用,为多个计算节点提供容量和性能可弹性扩展的高性能共享存储。腾讯云文件存储的管理界面简单、易使用,可实现对现有应用的无缝集成;按实际用量付费,为您节约成本,简化 IT 运维工作。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档