问如何使用Node.js处理多个聊天会话

EN

var chat_id, check_date;

var sys = require("sys"),  
    http = require("http"),  
    url = require("url"),  
    path = require("path"),  
    fs = require("fs"),  
    events = require("events");  

// Conntect to database
var Client = require('mysql').Client;
var client = new Client();
client.host = 'localhost';
client.port = 3306;
client.database = '****';
client.user = '****';
client.password = '****';
client.connect(function(error, results) {
  if(error) {
    console.log('Connection Error: ' + error.message);
    return;
  }
  console.log('Connected to MySQL');
});

// Check for chat updates
function getChatUpdates() {  

    if (typeof(check_date) == 'undefined')
        return;

    client.query('SELECT name, message FROM chat WHERE chat_id = "' + chat_id + '" AND date_entered > "' + check_date + '"', 
    function selectCb(error, results, fields) {
        if (error) {
            console.log('GetData Error: ' + error.message);
            client.end();
            return;
        }

        if (results.length > 0) {
            for(var i = 0;i<results.length;i++) {
                console.log('Name: ' + results[i]['name']);
                console.log('Message: ' + results[i]['message']);
            }
        }

  });

}  

// Set interval to check for chat updates every 2 seconds
setInterval(getChatUpdates, 2000);  

http.createServer(function(request, response) {  

    // Get the query strings
    var uri = url.parse(request.url, true);  
    chat_id = uri.query.chat_id;
    check_date = uri.query.check_date;
    console.log('Chat ID: ' + chat_id);
    console.log('Last Check: ' + check_date);

    // we'll do something here later.

}).listen(8080);  

sys.puts("Server running at http://localhost:8080/");