ngx-push模块详解.docx

ngx-push-stream模块源码学习（一）——序言一、概述??? 与传统的request-response的web应用模式不同，comet是一种长连接（long-held）的应用模式，从而允许服务端主动向客户端推送数据。 ??? 主流的comet技术主要有以下两个分支： 分类描述streaming客户端和服务器端保持一种长连接long polling客户端与服务器端建立连接后，以轮询方式等待服务器端数据或事件。收到服务端数据或连接超时后，断开连接并迅速再次建立连接??? ngx-push-stream模块是ngx的一个第三方扩展模块，可以同时支持stream和long polling两种comet技术，基于该模块可以较容易使用nginx server push。 ??? 二、模型??? 一种典型的模型如图所示： ??? 基于ngx+ngx-push-stream模块可以实现在nginx服务器上扩展出两类终端：一种用于发布，一种用于订阅。订阅者以stream或long polling的方式向nginx channel请求数据；同时，发布者可可将信息以post的方式发送到nginx channel。ngx-push-stream模块则完成二者之间的信息缓存和中转。 三、总体流程??? 简单来讲，整个发布订阅过程完成两项工作： 向服务器推送MSG，服务端暂存MSG 服务器端向订阅者推送MSG ??? 为了完成上面两项工作，通道（channel）应运而生。它是发布者和订阅者之间的桥梁。发布者将MSG以post的形式发送到某个通道上，订阅者则以GET的方式从channle获取MSG。由此channel的重要性可见一斑。 ???? 通道的发布者一侧，支持http POST（发布信息）、DELETE（删除channel）和GET（获取channel信息）三种请求；订阅者一侧则只接受GET请求以获取必威体育精装版MSG。具体来讲，发布者一侧主要完成以下三种功能： 获取channle信息 ??? 订阅者数目、缓存信息数目、已发送信息数目等等。。 删除channel ??? 清空缓存的信息、通知所有的订阅者、释放channel 发布信息 ??? 将信息发布到channel上，并向订阅者中转 nginx-push-stream模块源码学习（二）——模块初始化?本文重点介绍push stream模块的构成，至于nginx如何启动、维护该模块不会详细阐述，以后有时间会做详细阐述。?一、模块定义?1.1.? 模块配置???????? 通用nginx模块的配置struct有三种，分别是main，server和location。本模块会涉及到main和location两个域的配置。名称分别为：ngx_http_push_stream_main_conf_t和ngx_http_push_stream_loc_conf_t.???????? 具体模块配置请参考nginx官网：/HttpPushStreamModule?1.2.? 模块指令?? 模块的指令是定义在一个叫做ngx_command_t的静态数组中的，或用于在nginx配置文件中设定模块的相关参数或处理相应请求，先简单来说下ngx_command_t的定义：?C代码??struct?ngx_command_t?{??????ngx_str_t?????????????name;//指令名称??????ngx_uint_t????????????type;//指令类型——该指令可用于ngx?conf的哪个域——main？server？location？??????/*命令所对应的处理函数指针，参数???????????@指向结构体?ngx_conf_t?的指针,?这个结构体里包含需要传递给指令的参数；???????????@指向结构体?ngx_command_t?的指针；???????????@指向模块自定义配置结构体的指针?????*/??????char???????????????*(*set)(ngx_conf_t?*cf,?ngx_command_t?*cmd,?void?*conf);??????ngx_uint_t????????????conf;//指定参数存储区域（main？server？loc？）??????ngx_uint_t????????????offset;//指定数据保存位置??????void?????????????????*post;//指向模块在读配置的时候需要的一些零碎变量??};??比如：?C代码??{?ngx_string(push_stream_publisher),??????NGX_HTTP_LOC_CONF|NGX_CONF_NOARGS|NGX_CONF_