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

直接上代码吧,被注释掉的主要是调试代码，和技术选型的测试代码

var app = require('express')();
var server = require('http').Server(app);
server.listen(8080);
app.get('/', 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(socket)
socket.on('disconnect', function () { console.log("disconnect") });
//socket.emit('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(){
//io_emitter.emit('time', new Date);
}, 2000);*/
var redis = require('redis')
subcriber = redis.createClient("redis://:redispassword@192.168.1.1:6379/0")
subcriber.on("message",function(channel,message){
console.log(message);
beijing.emit("message",message);
})
subcriber.subscribe("pub_comments")
/*
var SSE = require('sse-nodejs');
var express = require('express');
var app = express();
app.get('/', function (req,res) {
res.sendFile(__dirname+ '/index.html')
});
app.get('/time', function (req,res) {
var serverSent = SSE(res);
serverSent.sendEvent('time', function () {
return new Date
},1000);
serverSent.disconnect(function () {
console.log("disconnected");
})
//serverSent.removeEvent('time',2000);
});
app.listen(3333);
*/

前端核心代码：

秒客网