Node.js로 여러 채팅 세션을 처리하는 방법

Question

현재 Node.js를 사용하여 채팅 시스템을 개발 중입니다. 내 질문은 Node.js를 사용하여 여러 채팅 세션을 처리하는 방법입니다. 다소 모호해서 설명해 드리겠습니다 ...

예를 들어 두 사람이 채팅 세션에 참여할 수 있습니다. Node.js는 몇 초마다 새 메시지를 확인합니다. 이 코드는 아래 코드를 사용하여 잘 작동하도록 충분히 간단합니다.

내 문제는 다른 두 사람이 동시에 다른 채팅 세션에있을 때입니다.

현재 "chat_id"및 "check_date"라는 두 개의 쿼리 문자열을 전송하므로 특정 날짜와 시간 후에 새 채팅 메시지를 확인할 수 있습니다.

문제는 "chat_id"및 "check_date"는 두 채팅방에서 서버를 사용하고 있기 때문에 새 채팅이 시작될 때마다 덮어 쓰여집니다.

나는 의미가 있습니까? 아래

내 코드 : 당신이 메시지 큐로 MySQL을 사용하려고처럼

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/"); 

Answer 1

PHP 배경을 가지고 있고 node.js에서 프로그래밍 할 때 완전히 다른 사고 방식을 가져야합니다. (setInterval(getChatUpdates, 2000);
) 메시지에는 응답하지 말고 이벤트가 발생하면 사용자에게 콜백/이벤트 메시지를 보내야합니다. socket.io을보고 redis (mysql 대신)과 같은 메모리 내장 데이터베이스를 사용하여 메시지를 저장하십시오.이 코드를 작성하면 사이트 성능이 훨씬 향상되고 실시간 (more)이 될 것입니다. express을 프레임 워크로 사용하여 w 개발 ebsites 대신 원시 http 모듈을 사용합니다. 이미 npm에 대해 알고 있다면 잘 모르겠지만, 의존성을 관리하는 데 사용해야합니다.

Answer 2

것 같습니다. RabbitMQ?

Answer 3

var chat_id, check_date;

전역 변수입니다. 모든 연결에서 chat_id을 무시하려고합니다 (예 : createServer). 사용자와 채팅을 연결하기 위해 일종의 세션 저장이 필요합니다. 예 : 배열, Redis 등