[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_11":-5,"_57":58,"_59":60,"_61":62},"routes/user.$name.collections",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":16},"topics",[35],"user",{"_20":21,"_13":14,"_22":23,"_24":14,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34},"loginname","yujuncode","page",1,"limit",20,"total","id","28855","avatar_url","https://avatars3.githubusercontent.com/u/26291343?v=4","githubUsername","create_at","2017-06-21T16:06:52.815Z","score",55,"topic_count",3,"reply_count",8,"is_star",false,{"_20":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":47,"_48":34,"_31":49,"_50":51,"_25":52,"_53":54},"1941","author_id","5432","tab","content","我自己在用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","title","socket.io入门整理","last_reply_at","2015-12-11T09:30:25.972Z","good",true,"top",23,"visit_count",161284,"2012-11-13T07:54:47.044Z","author",{"_13":55,"_22":56},"dtrex","http://www.gravatar.com/avatar/6540a9b314d54e11e61f3d1e0a503338?size=48","zones",[135],"tabs",[77,78,79,80,81,82,83,84,85,86,87],"publicConfig",{"_63":64,"_65":66,"_67":68},"apiBaseUrl","https://api.cnodejs.org","turnstileSiteKey","0x4AAAAAAD_J2wBk6UWPDHNQ","build",{"_69":70,"_71":72,"_73":74,"_75":76},"service","cnode-web","version","0.1.0","commit","059db5a0db5ce5e793fd6cb52582968c2370ecc1","buildTime","2026-08-11T17:36:41Z",{"_20":16,"_89":132,"_90":133,"_92":47,"_93":134,"_95":96},{"_20":129,"_89":130,"_90":131,"_92":47,"_93":18,"_95":96},{"_20":125,"_89":126,"_90":127,"_92":47,"_93":128,"_95":96},{"_20":121,"_89":122,"_90":123,"_92":47,"_93":124,"_95":96},{"_20":117,"_89":118,"_90":119,"_92":47,"_93":120,"_95":96},{"_20":113,"_89":114,"_90":115,"_92":34,"_93":116,"_95":96},{"_20":109,"_89":110,"_90":111,"_92":47,"_93":112,"_95":96},{"_20":105,"_89":106,"_90":107,"_92":34,"_93":108,"_95":96},{"_20":30,"_89":102,"_90":103,"_92":47,"_93":104,"_95":96},{"_20":97,"_89":98,"_90":99,"_92":34,"_93":100,"_95":101},{"_20":88,"_89":46,"_90":91,"_92":47,"_93":94,"_95":96},4,"key","label","精华","visible","sort_order",110,"scope","public",9,"dev","开发",100,"admin","job","招聘",90,18,"event","活动",80,17,"life","生活",70,16,"career","职场",60,15,"ideas","创意",50,14,"ai","AI",40,13,"tech","技术",30,2,"ask","问答","share","分享",10,{"_20":16,"_136":137,"_138":103,"_139":140,"_141":142,"_92":47,"_93":16},"slug","jobs","name","description","Node.js 招聘信息专区","icon","briefcase"]