Socket.io文字直播聊天室的简单代码

Socket.io文字直播聊天室的简单代码

var app = require('express')();
var server = require('http').Server(app);server.listen(8080);('/', function (req, res) {res.sendFile(__dirname + '/index.html');
});var io = require('socket.io')(3000);
var beijing = io.of('/beijing').on('connection', function (socket) {console.log("beijing connected")//console.log(('disconnect', function () { console.log("disconnect") });//it('item', { news: 'item' });});
//var redis = require('socket.io-redis');
//io.adapter(redis({ host: '192.168.20.16', port: 6379 }));//var io_emitter = require('socket.io-emitter')({ host: '192.168.20.16', port: 6379 });
/*setInterval(function(){//it('time', new Date);
}, 2000);*/var redis = require('redis')
subcriber = ateClient("redis://:redispassword@192.168.1.1:6379/0")
("message",function(channel,message){console.log(message);it("message",message);
})subcriber.subscribe("pub_comments")
/*
var SSE = require('sse-nodejs');var express = require('express');var app = express();('/', function (req,res) {res.sendFile(__dirname+ '/index.html')
});('/time', function (req,res) {var serverSent = SSE(res);serverSent.sendEvent('time', function () {return new Date},1000);serverSent.disconnect(function () {console.log("disconnected");})//veEvent('time',2000);});app.listen(3333);
*/

前端核心代码：

  var socket = io.connect('servername:3000/beijing');('message', function (data) {$ssages.push(data)//此处使用了angularjs$scope.$apply()console.log(data)//socket.disconnect()//it('my other event', { my: 'data' });});