[{"_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":20},"replies",[35,36],"user",{"_21":22,"_13":14,"_23":24,"_25":14,"_26":27,"_28":29,"_30":31,"_32":20,"_33":34},"loginname","dragon2268","page",1,"limit",50,"total",2,"id","18043","avatar_url","https://avatars.githubusercontent.com/u/13462860?v=3","githubUsername","create_at","2015-07-23 06:18:09.243","score",10,"topic_count",0,"reply_count","is_star",false,{"_21":59,"_38":60,"_40":-5,"_42":61,"_44":62,"_46":63,"_48":49,"_50":34,"_32":64,"_52":65,"_26":66,"_55":67},{"_21":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":34,"_32":51,"_52":53,"_26":54,"_55":56},"10345","author_id","15297","tab","share","content","### socket.io实战\r\nnodejs mult process + nginx + redis + socket.io 实现c50K,目前正在优化app,希望能实现c100K.\r\n目前 c50K 非常稳定。c100K 下会有写 400 和 502 错误，以及个别进程 cpu 100%.\r\n\r\n**通过 v8 自带的 prof 监控的日志：**\r\n\r\n \tticks total nonlib name\r\n\t11453687 94.9% 0.0% /lib64/libc-2.12.so\r\n\t327343 2.7% 0.0% /usr/bin/node\r\n\t32393 0.3% 0.0% /lib64/libpthread-2.12.so\r\n\t1189 0.0% 0.0% 7fff269c3000-7fff269c4000\r\n 996 0.0% 0.0% /lib64/libm-2.12.so\r\n 947 0.0% 0.0% /usr/lib64/libstdc++.so.6.0.13\r\n 475 0.0% 0.0% /lib64/librt-2.12.so\r\n 391 0.0% 0.0% ffffffffff600000-ffffffffff601000\r\n 1 0.0% 0.0% /lib64/ld-2.12.so\r\n\r\n **JavaScript**\r\n \r\n \tticks total nonlib name\r\n \t34551 0.3% 13.9% LazyCompile: *exports._unrefActive timers.js:425\r\n \t 9061 0.1% 3.6% Stub: CompareStub_EQ\r\n \t6462 0.1% 2.6% LazyCompile: EventEmitter.emit events.js:53\r\n \t4519 0.0% 1.8% LazyCompile: EventEmitter.addListener events.js:126\r\n \t3929 0.0% 1.6% KeyedLoadIC: A keyed load IC from the snapshot\r\n \t3818 0.0% 1.5% LazyCompile: ~onread net.js:496\r\n \t3817 0.0% 1.5% LazyCompile: *remove _linklist.js:47\r\n \t3117 0.0% 1.3% LazyCompile: *append _linklist.js:63\r\n \t2857 0.0% 1.1% LazyCompile: *writeOrBuffer _stream_writable.js:200\r\n \t2653 0.0% 1.1% Builtin: A builtin from the snapshot {5}\r\n \t2590 0.0% 1.0% Stub: CEntryStub\r\n \t2242 0.0% 0.9% LazyCompile: *EventEmitter events.js:26\r\n \t2171 0.0% 0.9% LazyCompile: EventEmitter.removeListener events.js:191\r\n \t2047 0.0% 0.8% Builtin: A builtin from the snapshot\r\n \t1976 0.0% 0.8% Stub: FastNewClosureStub\r\n \t1971 0.0% 0.8% LazyCompile: *Url.parse url.js:105\r\n \t1824 0.0% 0.7% LazyCompile: *Buffer buffer.js:156\r\n \t1763 0.0% 0.7% Stub: CompareICStub {2}\r\n \t1710 0.0% 0.7% CallMegamorphic: args_count: 2\r\n \t1633 0.0% 0.7% LazyCompile: *Decode native uri.js:208\r\n \t1509 0.0% 0.6% LazyCompile: *Readable.read _stream_readable.js:252\r\n \t1491 0.0% 0.6% CallMegamorphic: args_count: 1\r\n \t1457 0.0% 0.6% LazyCompile: *_nextDomainTick node.js:493\r\n \t1444 0.0% 0.6% Stub: ToBooleanStub_UndefinedSpecObject\r\n \t1411 0.0% 0.6% Stub: InstanceofStub\r\n \t1410 0.0% 0.6% LazyCompile: ~OutgoingMessage.end http.js:915\r\n \t1339 0.0% 0.5% LazyCompile: _tickDomainCallback node.js:426\r\n\t。。。。。。。。。\r\n **C++**\r\n \r\n \tticks total nonlib name\r\n\r\n **GC**\r\n \r\n \tticks total nonlib name\r\n \t29804 0.2%\r\n\r\n**Bottom up (heavy) profile**\r\n\r\n \tNote: percentage shows a share of a particular caller in the total\r\n \tamount of its parent calls.\r\n \tCallers occupying less than 2.0% are not shown.\r\n\r\n **ticks parent name**\r\n \r\n 11453687 94.9% /lib64/libc-2.12.so\r\n\r\n 327343 2.7% /usr/bin/node\r\n 18923 5.8% LazyCompile: EventEmitter.addListener events.js:126\r\n 14701 77.7% LazyCompile: *Readable.on _stream_readable.js:688\r\n 4420 30.1% LazyCompile: *connectionListener http.js:1903\r\n 4121 93.2% LazyCompile: EventEmitter.emit events.js:53\r\n 4121 100.0% LazyCompile: *onconnection net.js:1163\r\n 200 4.5% LazyCompile: *onconnection net.js:1163\r\n 89 2.0% LazyCompile: ~EventEmitter.emit events.js:53\r\n 89 100.0% LazyCompile: *onconnection net.js:1163\r\n 3964 27.0% LazyCompile: *ServerResponse.assignSocket http.js:1108\r\n 3964 100.0% LazyCompile: ~parser.onIncoming http.js:2038\r\n 3812 96.2% LazyCompile: *parserOnHeadersComplete http.js:69\r\n 136 3.4% LazyCompile: ~parserOnHeadersComplete http.js:69\r\n 3287 22.4% LazyCompile: *EventEmitter.once events.js:169\r\n 1673 50.9% LazyCompile: *Duplex _stream_duplex.js:39\r\n 1656 99.0% LazyCompile: *Socket net.js:135\r\n 688 20.9% LazyCompile: ~onread net.js:496\r\n 542 16.5% LazyCompile: *onSocketEnd net.js:243\r\n 495 91.3% LazyCompile: EventEmitter.emit events.js:53\r\n 29 5.4% LazyCompile: *onread net.js:496\r\n 17 3.1% LazyCompile: ~EventEmitter.emit events.js:53\r\n 241 7.3% LazyCompile: *afterShutdown net.js:222\r\n 131 4.0% LazyCompile: *onread net.js:496\r\n 1220 8.3% LazyCompile: *Socket net.js:135\r\n 1217 99.8% LazyCompile: *onconnection net.js:1163\r\n\t\r\n### 高并发Nodejs参数调整\r\n\r\n**关闭v8 空时通知机制**\r\n\r\n --nouse-idle-notification\r\n\t\r\n**修改http.Agent**\r\n\r\n 官网说明：\r\n\tagent.maxSockets\r\n By default set to 5. Determines how many concurrent sockets the agent can have open per host.\r\n\t(为了http请求能复用connection连接，Nodejs在http.Agent创建了一个默认大小为5的连接池)\r\n\t修改后如下:\r\n\trequire(\"http\").globalAgent.maxSockets = Infinity;\r\n**修改--max-old-space-size**\r\n\r\n\t--max-old-space-size=2048（根据自己情况，可以调大,单位是M）\r\n\t说明：v8 在64位操作系统默认使用的max-old-space-size是1.7G,大家可以通过：node --v8-options 查看V8参数\r\n**使用PM2管理**\r\n\r\n\t例如：\r\n\t{\r\n \"apps\" : [\r\n {\r\n \"name\": \"comet-server-4000\",\r\n \"script\": \"server.js\",\r\n \"port\": 4000,\r\n \"args\": \"['-p4000','-t','plan']\",\r\n \"run-as-group\" : \"comet\",\r\n \"exec_mode\": \"cluster_mode\",\r\n \"node-args\": \"--nouse-idle-notification --gc_global --max-old-space-size=2048 --max-new-space-size=1024\"\r\n },\r\n {\r\n \"name\": \"comet-server-4001\",\r\n \"script\": \"server.js\",\r\n \"port\": 4001,\r\n \"run-as-group\": \"comet\",\r\n \"args\": \"['-p4001','-t','plan']\",\r\n \"exec_mode\": \"cluster_mode\",\r\n \"node-args\": \"--nouse-idle-notification --gc_global --max-old-space-size=2048 --max-new-space-size=10240\"\r\n }\r\n ]\r\n }\r\n\t\r\n**避免在socket.io实时推送项目中使用同步代码，推送项目应该是以中间件的身份出现的,只传输数据**\r\n\r\n### 高并发系统参数调整\r\n\r\n**以Linux为例子调整文件句柄数**\r\n\r\n 1. 查看liunx 最大文件句柄数\r\n cat /proc/sys/fs/file-max\r\n 2. 查看进程使用的文件句柄数\r\n ls /proc/pid/fd | wc -l\r\n 3. 查看进程句柄数限制\r\n cat /proc/pid/limits | grep “files”\r\n 4. 修改/etc/sysctl.conf 添加\r\n fs.file-max=1000000\r\n\r\n......时间原因待续","title","socket.io 高并发实战","last_reply_at","2017-05-31 09:32:27.909","good",true,"top",55,"visit_count",46616,"2014-12-18 11:29:15.609","author",{"_13":57,"_23":58},"hackeridear","https://avatars1.githubusercontent.com/u/3871455?v=4","1941","5432","我自己在用socket.io开发，对官方网站上的文档，进行简单的整理，然后自己写了一个简单的聊天程序。\r\n最最开始\r\n\r\n先安装socket.io:\r\n\r\n 1 npm install socket.io\r\n\r\n利用Node的搭建Http服务\r\n\r\n分为两个文件，服务端文件app.js和客户端index.html\r\n\r\n app.js\r\n 01 var app = require('http').createServer(handler)\r\n 02 , io = require('socket.io').listen(app)\r\n 03 , fs = require('fs')\r\n 04 \r\n 05 app.listen(80);\r\n 06 \r\n 07 function handler (req, res) {\r\n 08 fs.readFile(__dirname + '/index.html',\r\n 09 function (err, data) {\r\n 10 if (err) {\r\n 11 res.writeHead(500);\r\n 12 return res.end('Error loading index.html');\r\n 13 }\r\n 14 \r\n 15 res.writeHead(200);\r\n 16 res.end(data);\r\n 17 });\r\n 18 }\r\n 19 \r\n 20 io.sockets.on('connection', function (socket) {\r\n 21 socket.emit('news', { hello: 'world' });\r\n 22 socket.on('my other event', function (data) {\r\n 23 console.log(data);\r\n 24 });\r\n 25 });\r\n\r\n这里需要注意的是：\r\nrequire('socket.io').listen(app) 实际上这句就是讲socket的监听加入的app设置的http模块了\r\nio.sockets.on('connection',function()....)这里设置了在连接后进行的处理，代码示例中，主要包含两件事，一个是向前段发送news的事件，一个是监听my other event事件。\r\n\r\n index.html\r\n 1 \r\n 2 \r\n\r\n客户端一个引用了socket.io.js的javscript库\r\n还有就是连接服务器(通过io.connect('http://localhost'))\r\n之后在监听收到news的事件后，发送my other event事件\r\n\r\n\r\n利用Express3框架\r\n上面的例子只是使用nodejs建立了一个交互，也可以使用express2的web框架，具体app.js代码如下：\r\n\r\nv\r\n\r\n ar app = require('express')()\r\n , server = require('http').createServer(app)\r\n , io = require('socket.io').listen(server);\r\n \r\n server.listen(80);\r\n \r\n app.get('/', function (req, res) {\r\n res.sendfile(__dirname + '/index.html');\r\n });\r\n \r\n io.sockets.on('connection', function (socket) {\r\n socket.emit('news', { hello: 'world' });\r\n socket.on('my other event', function (data) {\r\n console.log(data);\r\n });\r\n });\r\n\r\n接收发送事件\r\nsocket.io允许用户自定义发送接收的事件。除了connect，message，disconnect三个事件外，用户可以自定义自己的事件\r\n\r\n // note, io.listen() will create a http server for you\r\n var io = require('socket.io').listen(80);\r\n \r\n io.sockets.on('connection', function (socket) {\r\n io.sockets.emit('this', { will: 'be received by everyone'});\r\n \r\n socket.on('private message', function (from, msg) {\r\n console.log('I received a private message by ', from, ' saying ', msg);\r\n });\r\n \r\n socket.on('disconnect', function () {\r\n io.sockets.emit('user disconnected');\r\n });\r\n });\r\n\r\n存储数据\r\n有的时候需要存储一些和客户端关联的数据在会话里，socket.io也是支持的，代码如下：\r\n\r\n var io = require('socket.io').listen(80);\r\n \r\n io.sockets.on('connection', function (socket) {\r\n socket.on('set nickname', function (name) {\r\n socket.set('nickname', name, function () {\r\n socket.emit('ready');\r\n });\r\n });\r\n \r\n socket.on('msg', function () {\r\n socket.get('nickname', function (err, name) {\r\n console.log('Chat message by ', name);\r\n });\r\n });\r\n });\r\n\r\nsocket.set和socket.get方法分为用于设置和获取变量。\r\n\r\n\r\n设置命名空间\r\n有的时候要一个程序支持多个应用，如果使用默认的 \"/\" 命名空间可能会比较混乱。如果想让一个连接可以支持多个连接，可以使用如下的命名空间的方法：\r\n\r\n app.js\r\n var io = require('socket.io').listen(80);\r\n \r\n var chat = io\r\n .of('/chat')\r\n .on('connection', function (socket) {\r\n socket.emit('a message', {\r\n that: 'only'\r\n , '/chat': 'will get'\r\n });\r\n chat.emit('a message', {\r\n everyone: 'in'\r\n , '/chat': 'will get'\r\n });\r\n });\r\n\r\nvar news = io\r\n .of('/news')\r\n .on('connection', function (socket) {\r\n socket.emit('item', { news: 'item' });\r\n });\r\n\r\n\r\n client.js\r\n \r\n\r\n发送获取数据\r\n有的时候，你需要在发送数据后，等待服务器的消息确认。当然简单的发，可以通过两次消息发送，来完成。这里介绍一种使用回调函数的方法：\r\n\r\n app.js\r\n var io = require('socket.io').listen(80);\r\n \r\n io.sockets.on('connection', function (socket) {\r\n socket.on('ferret', function (name, fn) {\r\n fn('woot');\r\n });\r\n });\r\n client.html\r\n \r\n\r\n广播\r\n向所有的连接触发事件，这里注意：不包括本身连接的事件。\r\n\r\n var io = require('socket.io').listen(80);\r\n \r\n io.sockets.on('connection', function (socket) {\r\n socket.broadcast.emit('user connected');\r\n });\r\n\r\n我写的聊天程序：\r\n\r\nindex.html\r\n\r\n \r\n \r\n \r\n
\r\n Message:\r\n \r\n \r\n NickName:\r\n \r\n \r\n\r\n\r\napp.js\r\n\r\n var app = require('http').createServer(handler)\r\n , io = require('socket.io').listen(app)\r\n , fs = require('fs');\r\n \r\n \r\n app.listen(80);\r\n \r\n function handler (req, res) {\r\n fs.readFile(__dirname + '/index.html',\r\n function (err, data) {\r\n if (err) {\r\n res.writeHead(500);\r\n return res.end('Error loading index.html');\r\n }\r\n \r\n res.writeHead(200);\r\n res.end(data);\r\n });\r\n }\r\n \r\n io.sockets.on('connection', function (socket) {\r\n // socket.emit('news', { hello: 'world' });\r\n // socket.on('my other event', function (data) {\r\n // console.log(data);\r\n // });\r\n \r\n socket.set('nickname', 'nickname', function(){\r\n });\r\n \r\n socket.on('set nickname', function(name){\r\n socket.set('nickname', name, function(){\r\n console.log(\"change nickname=>\" + name);\r\n socket.emit('nickname ready');\r\n });\r\n });\r\n \r\n socket.on('chat', function(data){\r\n socket.get('nickname', function(err, name){\r\n \r\n socket.emit(\"notice\", {message: name + \":\" + data.message});\r\n socket.broadcast.emit(\"notice\", {message: name + \":\" + data.message});\r\n console.log(\"chat: \" + data.message);\r\n });\r\n });\r\n });\r\n\r\n","socket.io入门整理","2015-12-11 09:30:25.987",23,161235,"2012-11-13 07:54:47.044",{"_13":68,"_23":69},"dtrex","http://www.gravatar.com/avatar/6540a9b314d54e11e61f3d1e0a503338?size=48"]