[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_11":-5},"routes/user.$name.replies",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":16},"replies",[34],"user",{"_20":21,"_13":14,"_22":23,"_24":25,"_26":27,"_28":29,"_30":16,"_31":16,"_32":33},"loginname","lenel","page",1,"limit",50,"total","id","47","avatar_url","http://www.gravatar.com/avatar/d24a0763ae28e6537c5d9a5511723b0a?s=48","githubUsername","","create_at","2011-04-22 16:20:09","score",10,"topic_count","reply_count","is_star",false,{"_20":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":33,"_46":33,"_31":47,"_48":49,"_26":50,"_51":52},"120","author_id","38","tab","content","

什么是Comet

\r\n
Comet, 据IBM这篇文章介绍,是基于HTTP长连接的“服务器推”技术. 和AJAX类似, 这是一种改善WEB用户体验的通讯技术. 其实早在CGI盛行的时代, 有种叫做\"Server-Push\"的技术, 和Comet本质是一回事, 都是基于长连接来实现. Server-Push更具体, 强调使用multipart/x-mixed-replace的Conent-Type技巧, 使得服务器能替换浏览器的内容. Comet包含面更广泛, 只要是有长连接和HTTP chunked的实现, 都算作其中. 这篇文章详细介绍了Comet的各种形态,值得一读.\r\n
\r\n
Comet虽然能让浏览器达到及时的响应, 但是由于基于长连接实现, 服务器成本很高. 最近这种技术之所以火起来, 主要还是牛人们探索到了各种降低服务器成本的方法. 这个叫amix的家伙对此有较多的研究.\r\n

什么是NodeJs

\r\n
nodejs号称Evented I/O for V8 JavaScript, 是基于V8的一款神器, 让我们可以使用javascript轻松进行服务器端编程.\r\n

最简单的Comet原型

\r\n
我用一下午的时间, 使用nodejs搞了一个简单的不能再简单的Comet原型. 在这个demo里面, 我假定使用iframe实现Comet, 但是忽略了iframe的父窗口和客户端js库, 只考虑服务器如何将HTTP chunked push到客户端.\r\n
\r\n
我定义了一种Comet资源: http://{host}/{pathname}?[{query_string}] . 其中{pathname}直接当作客户端id来使用(在程序里面它被叫做resid). {query_string}用来做消息内容. 这样, 原型就简化成了两种操作:\r\n

HTTP GET : http://{host}/{pathname} 用来模拟iframe长连接, 不断接收到新数据.

HTTP PUT : http://{host}/{pathname}?{query_string} 用来模拟业务操作, 直接将{query_string}当作数据投递到上面的长连接里面.

\r\n

具体实现

\r\n
好, 主角登场, 用nodejs实现最简单的Comet:\r\n

global.messages = {\r\n
\t//'resid':[]\r\n
};\r\n
\r\n
var char500 = (function(){ var i=0; var arr = []; for(i=0; i<500; i++) { arr.push( ' ' ); } return arr.join(''); })();\r\n
\r\n
var http_method_funs = {\r\n
\t'GET': function(resid, data, request, response) {\r\n
\t\tif(global.messages[resid] == undefined) {\r\n
\t\t\tglobal.messages[resid] = [];\r\n
\t\t}\r\n
\r\n
\t\tresponse.writeHead(200, {'content-type': 'text/plain'});\r\n
\r\n
\t\tvar interval = setInterval(myoutput, 500 );\r\n
\t\tresponse.connection.on('end', function(){\r\n
\t\t\t\tconsole.log(\"GET\\t\" + resid + \"\\tclosed\");\r\n
\t\t\t\tclearInterval(interval);\r\n
\t\t\t\t});\r\n
\r\n
\t\tmyoutput();\r\n
\r\n
\t\tfunction myoutput(){\r\n
\r\n
\t\t\tvar msgs = global.messages[resid];\r\n
\t\t\tif(msgs.length){\r\n
\t\t\t\tvar str = msgs.join(\"\\n\\n\\n\") + \"\\n\\n\\n\";\r\n
\t\t\t\tstr = (str.length < 500 ) ? ( str + char500 ) : str; //for MTU\r\n
\t\t\t\tresponse.write(str);\r\n
\t\t\t\tglobal.messages[resid] = [];\r\n
\t\t\t}\r\n
\r\n
\t\t}\r\n
\t},\r\n
\r\n
\t'PUT': function(resid, data , request, response) {\r\n
\t\tif(global.messages[resid] == undefined) {\r\n
\t\t\tglobal.messages[resid] = [];\r\n
\t\t}\r\n
\r\n
\t\tglobal.messages[resid].push(data);\r\n
\t\tconsole.log(global.messages);\r\n
\r\n
\t\tresponse.writeHead(200, {'content-type': 'text/plain'});\r\n
\t\tresponse.end( 'ok\\n');\r\n
\t},\r\n
};\r\n
//method function \r\n
\r\n
require('http').createServer(function (request, response) {\r\n
\r\n
\t\tvar urlinfo = require('url').parse(request.url);\r\n
\t\tvar resid = urlinfo['pathname'];\r\n
\t\tvar data = (urlinfo['query']) ? urlinfo['query'] : 0 ;\r\n
\t\tvar method = request.method;\r\n
\r\n
\t\tconsole.log(method + \"\\t\" + resid );\r\n
\r\n
\t\tif(typeof http_method_funs[method] == 'function') {\r\n
\t\t\thttp_method_funs[method].call(null, resid, data, request, response);\r\n
\t\t}\r\n
\t\telse {\r\n
\t\t\tresponse.writeHead(400);\r\n
\t\t\tresponse.end(\"unsupport method\\n\");\r\n
\t\t}\r\n
\r\n
\t\t}).listen(18124);\r\n
console.log('server running at http://127.0.0.1:18124/');

\r\n

测试方法

\r\n
上面的代码保存到文件, 我们在第一个终端启动这个服务:\r\n

shell> node hello.js

\r\n
我们在第二个终端模拟iframe的数据流. 输入命令, 观察收到的数据:\r\n

telnet 127.0.0.1 18124\r\n
GET /mymessages HTTP/1.1\r\n
\r\n
HTTP/1.1 200 OK\r\n
content-type: text/plain\r\n
Connection: keep-alive\r\n
Transfer-Encoding: chunked

\r\n
我们在第三个终端输入curl -X PUT命令, 模拟发送两条消息:\r\n

shell> curl -X PUT \"http://127.0.0.1:18124/mymessages?a=1&b=2&c=3\"\r\n
ok\r\n
shell> curl -X PUT \"http://127.0.0.1:18124/mymessages?a=4&b=5&c=6\"\r\n
ok

\r\n
观察第二个终端, 会发现已经收到两条HTTP chunked. (为了避免测试数据小于MTU, 我实际上多输出了一些空格,但这里省去了.)\r\n

202\r\n
a=1&b=2&c=3\r\n
\r\n
202\r\n
a=4&b=5&c=6

\r\n

总结

\r\n
在这个原型中, 我省掉了Comet iframe方案内无关紧要的东西, 只用HTTP PUT/GET来演示一个最简单的原型. 用NodeJs轻松搭建了它.\r\n
\r\n
可以看到, 用javascript event的风格写服务器, 简直是明白如话, 散文那样自然.\r\n
我用global.messages对象来存储消息, key是resid(上面说的客户端id), value是个array, 里面存储客户端收到的messages.\r\n
我为GET/PUT两种操作分别实现了两个函数.\r\n
PUT函数, 收到请求就将query_string当作message存到对应resid的array中, 然后断开HTTP连接.\r\n
GET函数, 收到请求就启动一个定时器, 轮询global.messages里面自己的消息队列(array). 如果遇到数据则在HTTP response输出http chunked. HTTP连接不主动关闭, 但如果被异常关闭则清除定时器对象.\r\n
\r\n
就这么一个简单功能, 如果用C和select来开发, 那么一个全局的客户端句柄队列是免不了要实现的, 当io事件到来时, 如何恢复之前中断的上下文,进行正确的io操作, 也是一件头疼的事情.\r\n
而我们看这个实现里面的myoutput定时器函数. 由于局部变量resid,response在函数的定义时环境内, 所以函数被执行时, 很自然就使用这些上下文信息. 相比来说, C的实现里面专门为此设计一个客户端句柄队列就太突兀了.\r\n
\r\n
javascript通过函数式和闭包, 轻而易举的完成了一个非阻塞服务器. 如果说libevent是通过库来实现了事件的封装, 那么nodejs所宣称的\"Evented I/O for V8 JavaScript\", 则是借语言本身的优雅特性获得自然的收获.\r\n
\r\n
----我是分割线----\r\n
大家好, 今天我刚参加了NodeParty, 有幸认识了许多大侠, 收获良多(不幸的是迟到了).\r\n
早就听说过nodejs, 但这次是第一次拿它做个原型, 分享给大家, 期待共同进步.\r\n
我的blog: http://www.dulao5.com/ , gmail 和 twitter id: dulao5 .","title","使用nodejs搭建最简单的comet原型","last_reply_at","2011-11-16 09:07:16","good","top",5,"visit_count",16639,"2011-04-16 16:09:23","author",{"_13":53,"_22":54},"duzhigang","http://www.gravatar.com/avatar/864eaff251427ff19791105794ba59cc?s=48"]