[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_11":-5,"_54":55,"_56":57,"_58":59},"routes/user.$name.topics",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":16},"topics",[35],"user",{"_20":21,"_13":14,"_22":23,"_24":25,"_26":27,"_28":29,"_30":16,"_31":32,"_33":34},"loginname","dtrex","page",1,"limit",20,"total","id","5432","avatar_url","http://www.gravatar.com/avatar/6540a9b314d54e11e61f3d1e0a503338?size=48","githubUsername","","create_at","2012-10-29T10:43:36.834Z","score",45,"topic_count","reply_count",8,"is_star",false,{"_20":36,"_37":21,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_47":34,"_31":48,"_49":50,"_26":51,"_52":53},"1941","author_id","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.987Z","good",true,"top",23,"visit_count",161250,"2012-11-13T07:54:47.044Z","author",{"_13":14,"_22":23},"zones",[104],"tabs",[73,74,75,76,77,78],"publicConfig",{"_60":61,"_62":25,"_63":64},"apiBaseUrl","https://api.cnodejs.org","turnstileSiteKey","build",{"_65":66,"_67":68,"_69":70,"_71":72},"service","cnode-web","version","0.1.0","commit","09940aa1bc0ad3dfe64235540ced544300ba2865","buildTime","2026-08-02T04:10:22Z",{"_20":16,"_80":102,"_82":103,"_84":46,"_85":16,"_87":95},{"_20":99,"_80":100,"_82":101,"_84":46,"_85":99,"_87":95},{"_20":96,"_80":97,"_82":98,"_84":46,"_85":96,"_87":95},{"_20":93,"_80":45,"_82":94,"_84":46,"_85":93,"_87":95},{"_20":89,"_80":90,"_82":91,"_84":34,"_85":92,"_87":88},{"_20":79,"_80":81,"_82":83,"_84":34,"_85":86,"_87":88},10,"key","test","label","测试","visible","sort_order",91,"scope","admin",9,"dev","开发",90,4,"精华","public",3,"job","招聘",2,"ask","问答","share","分享",{"_20":16,"_105":106,"_107":98,"_108":109,"_110":111,"_84":46,"_85":16},"slug","jobs","name","description","Node.js 招聘信息专区","icon","briefcase"]