`
dylan0514sina.cn
  • 浏览: 92331 次
  • 性别: Icon_minigender_1
  • 来自: 杭州
社区版块
存档分类
最新评论

消息写

 
阅读更多
   处理流程
   正如JDK规范中指出一个Channel任意时刻只能执行单个线程的写操作。单个Nioworker可以顺序处理多个socketChannel的写操作,单个SocketChannel上的多次写操作会事先放入到写请求队列;结果由Nioworker调度执行。当Channel被调度时正常情况下消息队列会被出列处理之至为空;如果中途Channel内核缓冲区已满,未写入数据将保留在内存中则下次Channel被调度时优先处理上次剩余数据之后出列可能的消息。
   而且一旦内核缓存区满并尝试n次写之后失败,将挂起写操作之后该channel的写入全部保存在消息队里中,等待下一次调度。其实挂起写操作时,selectKey可能修改为支持OP_WRITE,下次select()被唤醒时解挂。在此之前客户端发起的写全部被保存到消息队列中;以下是单个channel的写操作流程。

  写消息逻辑大部分在如下方法中 
  //AbstractNioWorker
   protected void write0(AbstractNioChannel<?> channel) 
  

   写操作数据结构
  之前所有的消息事件中包含消息数据,而这种数据类型由SocketSendBufferPool强制规定;由此可见消息数据必须是ChannelBuffer或FileRegion类型。acquire()方法将所需类型经过处理转变为SendBuffer。它的实现包括
     处理FileRegion的FileSendBuffer
    处理ChannelBuffer的UnpooledSendBuffer,GatheringSendBuffer
    处理ChannelBuffer的PooledSendBuffer
第1,2种类型比较简单,只是一个简单的代理;重点是第3种类型。单个nioworker中多个Channel会可能会使用多块DirectBuffer;关于DirectBuffer在读消息中详细说明过。
如果写入信息块ChannelBuffer小于等于1024,将返回PooledSendBuffer。当每个Channel消息队列正常处理完,则会立即释放引用计数器。不然PooledSendBuffer会占用,一般来讲接下来的轮询会处理完,直到同段的最后一个处理完,才标志该内存段的为PooledHeader ,假如有一个Channel总是无法写入则占用的内存段不会被释放,这也是“内存泄露”。
  SendBuffer acquire(Object message) {
        if (message instanceof ChannelBuffer) {
            return acquire((ChannelBuffer) message);
        }
        if (message instanceof FileRegion) {
            return acquire((FileRegion) message);
        }

        throw new IllegalArgumentException(
                "unsupported message type: " + message.getClass());
    }
  //SendBuffer
   interface SendBuffer {
        boolean finished();
        long writtenBytes();
        long totalBytes();

        long transferTo(WritableByteChannel ch) throws IOException;
        long transferTo(DatagramChannel ch, SocketAddress raddr) throws IOException;

        void release();
    }
   //PooledSendBuffer
     final class PooledSendBuffer extends UnpooledSendBuffer {

        private final Preallocation parent;

        PooledSendBuffer(Preallocation parent, ByteBuffer buffer) {
            super(buffer);
            this.parent = parent;
        }

        @Override
        public void release() {
            final Preallocation parent = this.parent;
            if (-- parent.refCnt == 0) {
                parent.buffer.clear();
                if (parent != current) {
                    poolHead = new PreallocationRef(parent, poolHead);
                }
            }
        }
    }

  PooledHead始终指向可用的链表头,详细的操作流程及描述如下图

0
0
分享到:
评论

相关推荐

    MQ消息读写

    MQ消息读写

    gen_msg自动从xml生成消息读写代码

    gen_msg自动从xml生成消息读写代码

    JavaScript写信息自动匹配类似的消息

    JavaScript写信息自动匹配类似的消息写信息自动匹配类似的消息写信息自动匹配类似的消息写信息自动匹配类似的消息写信息自动匹配类似的消息写信息自动匹配类似的消息写信息自动匹配类似的消息写信息自动匹配类似的...

    手写RocketMq详细操作手册

    RocketMq操作手册:针对入门初中级别。 消息队列 RocketMQ 是阿里巴巴集团基于高可用...制,所有主题的消息存储基于顺序读写,极大提高消息写性能,同时为了兼顾消息消费与消息查找,引入消息消费队列文件与索引文件

    LINUX的消息函数的分析

    Linux采用消息队列的方式来实现消息传递。System V的消息队列(message queues)是进程之间互相发送消息的一种异步(asynchronously)方式,在这种情形...当一个新的消息写到队列的时候,这个进程会被唤醒,继续运行。

    vc++2005写消息日志、读写ini文件

    vc++2005写消息日志、读写ini文件。 查看了一些资料,写的一个小程序。

    MQ消息测试工具 可直接向MQ写消息

    MQ消息测试工具 可直接向MQ写消息 用于MQ消息接收程序的测试

    漂亮的消息提示框 消息提示组件 Javascript写的

    函数改变了1.0版需要对确定和取消按钮分别写回调函数及不支持关闭事件的缺陷, 11、完全的封装,对外只暴露一个ymPrompt变量,有效防止与使用者程序变量的冲突。 12、程序(js)与样式(css)的完全分离,取消了1.0中...

    基于自写消息平台垃圾短信监管项目的质量管理案例.pptx

    这是一个对自写消息平台垃圾监管项目中质量管理进行分析的软件项目管理案例,可用于软件项目管理课上展示。

    易语言源码易语言截获写注册表消息源码.rar

    易语言源码易语言截获写注册表消息源码.rar 易语言源码易语言截获写注册表消息源码.rar 易语言源码易语言截获写注册表消息源码.rar 易语言源码易语言截获写注册表消息源码.rar 易语言源码易语言截获写注册表消息...

    Python-一个由python写简单和容易使用的消息队列

    一个由python写简单和容易使用的消息队列

    Window消息大全

    大家都知道,Window是基于消息驱动的,经过本人的整理,把window消息所有常用的消息写成一个word文档,供大家参考

    Go-Go写的消息中心服务

    Go写的消息中心服务

    易语言截获写注册表消息源码

    易语言截获写注册表消息源码。@易语言入门教程。

    c#写的UDP接收和发送消息

    用c#编写的UDP接收消息和发送消息一个小DEMO。

    QT 自己写一个消息弹窗源码

    这个资源,是配合此前自己写过的一篇博客“QT 写一个属于自己的消息弹窗MessageBox”所建立的,里面是一个自己写的消息弹窗源码和资源文件,博客里会从头介绍如何自己写一个消息弹窗,有兴趣去朋友可以关注一下!...

    C#写的QQ自动发消息.rar

    ////发送消息,因为QQ屏蔽了 WM_SETTEXT, WM_PASTE 命令,所有采用 EM_REPLACESEL 来实现 NativeMethods.SendMessage(hwndRichEdit, NativeMethods.EM_REPLACESEL, IntPtr.Zero, msg); ////给发送按钮发 鼠标...

    如何写好电视消息最终.ppt

    如何写好电视消息最终.ppt

    kafka客户端

    1/kafka是一个分布式的消息缓存系统 2/kafka集群中的服务器都叫做broker 3/kafka有两类客户端,一类叫producer(消息生产者),一类叫做consumer(消息消费者),客户端和broker服务器之间采用tcp协议连接 4/kafka中...

    全民K歌歌房后台架构与优化.pdf

    该架构包括消息写服务、消息读服务、长轮询服务和普通消息列表存储等多个组件。 三、歌房架构 歌房是全民K歌歌房的一个核心组件,旨在提供一个安全、稳定的在线歌房服务。为了实现这个功能,全民K歌歌房采用了一个...

Global site tag (gtag.js) - Google Analytics