Dubbo-聊聊通信模块设计( 三 ) _生活百科

对于HeapChannelBuffer的具体的工厂的实现是HeapChannelBufferFactory，该工厂是一个单例模式，HeapChannelBufferFactory通过ChannelBuffers工具类创建固定容量的HeapChannelBuffer，此外也可以通过拷贝的形式创建HeapChannelBuffer 。
    @Override    public ChannelBufferFactory factory() {        return HeapChannelBufferFactory.getInstance();    }

DynamicChannelBufferDynamicChannelBuffer可以理解为一个扩展类，也就是对装饰者模式，就是对ChannelBuffer的增加强，增加动态扩容的能力，关于该类默认的实现HeapChannelBufferFactory ，我可以通过指定HeapChannelBufferFactory为对应的实现添加动态扩容的能力。
    //具体的ChannelBufferFactory的实现    private final ChannelBufferFactory factory;    //需要扩容的buffer    private ChannelBuffer buffer;    public DynamicChannelBuffer(int estimatedLength) {        //默认实现        this(estimatedLength, HeapChannelBufferFactory.getInstance());    }    //指定具体的实现    public DynamicChannelBuffer(int estimatedLength, ChannelBufferFactory factory) {        if (estimatedLength < 0) {            throw new IllegalArgumentException("estimatedLength: " + estimatedLength);        }        if (factory == null) {            throw new NullPointerException("factory");        }        this.factory = factory;        buffer = factory.getBuffer(estimatedLength);    }关于如何实现ChannelBuffer的动态扩容，看懂Java ArryList扩容的，我相信一定能理解，也就是我们要控制写入时候的判断写入的空间是否足够就可以了。DynamicChannelBuffer通过ensureWritableBytes方法来实现扩容，我们来看下他是如何做的:
    @Override    public void ensureWritableBytes(int minWritableBytes) {        //如果写入字节数小于等于可写的字节数        if (minWritableBytes <= writableBytes()) {            return;        }        //新增容量        int newCapacity;        //缓存区字节数为0        if (capacity() == 0) {            //设置为1            newCapacity = 1;        } else {            //新增容量为缓冲区字节数            newCapacity = capacity();        }        //最小新增容量 = 当前写入字节数的索引+最小写入的字节数        int minNewCapacity = writerIndex() + minWritableBytes;        //如果新增容量小于最小新增容量        while (newCapacity < minNewCapacity) {            //新增容量左移1位，加倍            newCapacity <<= 1;        }        //通过工厂类创建该容量        ChannelBuffer newBuffer = factory().getBuffer(newCapacity);        //从buffer中读取数据到newBuffer中        newBuffer.writeBytes(buffer, 0, writerIndex());        //替换原来的缓存区        buffer = newBuffer;    }

Dubbo-聊聊通信模块设计( 三 )

推荐阅读

教你如何使用迅雷离线下载[新发布]

在“再见阿郎”中的刘金虎怎么又是金鹏？

如何通过女人面相看婚姻哪些面相的女人婚姻好

梦见和当官的同学在一起商人梦见当官的同学

皮蛋是生的还是熟的怎么判断皮蛋是生的还是熟的

梦见水里有黑鱼在游

一斤几克重，一斤等于多少千克

我们好像在哪见过歌词我们好像在哪见过歌词歌谱

商业承兑汇票是什么意思商业承兑汇票的理解

煤炭公司起名大全免费煤炭行业起名大全

天麻能泡白酒吗天麻可以和虫草花一起煲汤吗

etc不抬杆可以倒回吗 etc不抬杆可以倒回会被扣分吗

节日由来英语节日由来

瑜伽入门动作图解瑜伽入门动作图解上

五岳奇险天下第一山是哪座山天下第一山是哪座山

孕妇梦见和别人吵架孕妇梦见别人挣了很多钱

喝番茄汁有什么好处番茄汁的好处有哪些

忙碌了多少天辛苦了多少年是啥歌快去听一下吧

关于洛阳昊远机械设备有限公司简述洛阳昊远机械设备有限公司

“八岐之术”是什么？