[{"_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":14,"_25":26,"_27":28,"_29":30,"_31":16,"_32":33},"loginname","nickropark","page",1,"limit",50,"total","id","18924","avatar_url","https://avatars.githubusercontent.com/u/4743941?v=3","githubUsername","create_at","2015-09-28 01:51:29.121","score",5,"topic_count",0,"reply_count","is_star",false,{"_20":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_47":33,"_31":48,"_49":50,"_25":51,"_52":53},"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-11 09:30:25.987","good",true,"top",23,"visit_count",161235,"2012-11-13 07:54:47.044","author",{"_13":54,"_22":55},"dtrex","http://www.gravatar.com/avatar/6540a9b314d54e11e61f3d1e0a503338?size=48"]