jumpserver/websocket/index.js

var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var spawn = require('child_process').spawn;
var request = require("request");
var fs = require("fs");



var Tail = require('tail').Tail;


app.get('/', function(req, res){
    res.send('<h1>Welcome Realtime Server</h1>');
});

//在线用户
var onlineUsers = {};
//当前在线人数
var onlineCount = 0;

io.on('connection', function(socket){
    //console.log('a user connected');

    //监听新用户加入
    socket.on('login', function(obj){
        request({
            uri:"http://127.0.0.1/node_auth/",
            method:"POST",
            form:{
                username:obj.username,
                seed:obj.seed,
                filename:obj.filename
            }
        },function(error,response,body){
            try{
                var result = JSON.parse(body)
                console.log(body);
                if(result['auth']['result'] != 'failed'){
                    fs.exists(obj.filename, function(result) {                
                         //将新加入用户的唯一标识当作socket的名称，后面退出的时候会用到
                        socket.name = obj.userid;
                        socket.fileName = obj.filename;
                        var  tail = new Tail(obj.filename);

                        //2015-03-06 当用户打开监控窗口时，会把已存在的文件内容打印出来
                        fs.readFile(obj.filename, 'utf8', function (err,data) {
                            if (err) {
                                return console.log(err);
                            }
                            var existData = {userid:obj.userid,username:obj.username,content:data,option:'exist'};
                            socket.emit('message',existData);
                        });

                        tail.on('line',function(data) {
                            //console.log(data);
                           var newData = {userid:obj.userid,username:obj.username,content:data,option:'new'};
                            socket.emit('message',newData);
                        });
                        socket.tail = tail;

                        //检查在线列表，如果不在里面就加入
                        if(!onlineUsers.hasOwnProperty(obj.userid)) {
                            onlineUsers[obj.userid] = obj.username;
                            //在线人数+1
                            onlineCount++;
                        }
                    });
                }
            }catch(err){
                console.log(err)
            }
            
        });
       
        //var tail = spawn("tail", ['-f', obj.filename]);
        //tail.stdout.on('data',function(data){
        //    var content = data.toString();
        //    //console.log(content);
        //    var newData = {userid:obj.userid,username:obj.username,content:content};
        //    socket.emit('message',newData);
        //});


        

        //向所有客户端广播用户加入
        //io.emit('login', {onlineUsers:onlineUsers, onlineCount:onlineCount, user:obj});
        //console.log(obj.username+'加入了聊天室');
    });

    //监听用户退出
    socket.on('disconnect', function(){
        //将退出的用户从在线列表中删除
        if(onlineUsers.hasOwnProperty(socket.name)) {
            //退出用户的信息
            var obj = {userid:socket.name, username:onlineUsers[socket.name]};

            if( socket.tail){
                socket.tail.unwatch();
            }

            //删除
            delete onlineUsers[socket.name];
            //在线人数-1
            onlineCount--;

            //向所有客户端广播用户退出
            //io.emit('logout', {onlineUsers:onlineUsers, onlineCount:onlineCount, user:obj});
            ////console.log(obj.username+'退出了聊天室');
        }
    });

    //监听用户发布聊天内容
    socket.on('message', function(obj){
        //向所有客户端广播发布的消息
        //io.emit('message', obj);
        socket.emit('message',obj);
        ////console.log(obj.username+'说：'+obj.content);
    });

});

http.listen(3000, function(){
    console.log('listening on *:3000');
});