使用 NodeJS 的 UDP 聊天服务器中的用户名

Question

我正在使用仅使用服务器和客户端的 NodeJS 设置一个简单的聊天服务器。它可以工作，我可以在同一台机器上打开多个客户端窗口，但现在我需要更多。

我想：

• 为每个客户提供设置用户名的选项
• 让客户端从服务器请求当前时间
• 诸如“/me 给术士打”之类的动作命令，服务器将其他命令显示为“用户给术士打”

这听起来像是一天的工作，但我刚开始研究 UDP，除了发送和获取消息的通用服务器/客户端之外，我在网上找不到任何示例。我将如何处理这些任务？ 代码：

Server.js：

var dgram = require('dgram'); //import datagram to get everything needed for UDP

var PORT = 22222;
var CLIENT_PORT = 2223;

// An IP address that's reserved on each network
// Gets sent to the server
var ADDRESS = "-"; //dont want to show my IP :)

var sock = dgram.createSocket({reuseAddr: true, type: 'udp4'}); //can now open multiple clients

var current_time = Date.now(); //?

function sendMessage(data) {
    sock.send(data, 0, data.length, PORT, ADDRESS, function(err){
       if(err){
            throw err;
       }
    });
}

sock.on("message", function(data, rinfo) {
    //listen for messages and print them
    console.log(data);

    //Check if the client's port was equal to the port to find client data on
  //If so, get packet
  if (rinfo.port === CLIENT_PORT) {
    console.log('\nreceived');

    //call function to broadcast the data out to everyone on the local network
    sendMessage(data);
 }


//Get the string data from the data buffer.
var stringData = data.toString(); //also could be toJSON()
console.log(stringData);

//Convert that string back into a buffer by making a new Buffer and passing it in.
//The buffer class can take a string, an array or just a number of bytes to allocate to memory
var backToBuffer = new Buffer(stringData); //can take a string, array or just a size to allocate
console.log(backToBuffer);

});

//This opens the connection and starts listening
//(Client Port, Address to listen to which is ALL, What to do)
sock.bind(CLIENT_PORT, '', function(){

    sock.setBroadcast(true);
    console.log('listening on port ' + PORT + "\n"); 

});

Client.js：

var dgram = require('dgram');

var SERVER_PORT = 22222;
var PORT = 22223;

var ADDRESS = "-";

//read input from the command line
var stdin = process.stdin;
var stdout = process.stdout;

var sock = dgram.createSocket({reuseAddr: true, type: 'udp4'});

var server_sock = dgram.createSocket({reuseAddr: true, type: 'udp4'});

function sendMessage(data) {
//onsole.log("sending data");
    sock.send(data, 0, data.length, PORT, ADDRESS, function(err) {
        if(err) {
             throw err;
        }
        //nsole.log("sent");
    });
}

server_sock.on("message", function(data, rinfo) {
    console.log("received " + data.toString());
});

server_sock.bind(SERVER_PORT, '', function() {
    console.log('listening to server port');
});

sock.bind(PORT, '', function() {
    sock.setBroadcast(true);
    console.log("please enter a message\n");

    stdin.resume();

    stdin.on("data", function(data) {
        sendMessage(data);
    });
});

Answer 1

Node.js 有很多库可以进行实时通信聊天，我不明白选择使用 UDP 并自己管理所有内容，而且看起来你也不是这方面的专家。我的建议是使用一个 websocket 库，比如 socket.io，他们甚至在他们的网站 http://socket.io/get-started/chat/ 中有一个简单聊天的例子@

使用 socket.io（或类似的）它会对你有很大帮助，因为它有会话，所以你可以保存用户名并在每次发布消息时返回它。 下面我写了一个服务端的小例子（取自上面get-started的index.js）。

io.on('connection', function(socket){
    var username = 'RANDOM';
  socket.on('chat message', function(msg){
    //here you should catch messages starting with "/" and parse them to write a different message
    io.emit('chat message', username + ': ' msg);
  });
  socket.on('update username', function(msg) {
    username = msg;
    io.emit('username changed', username);
  });
});

希望对你有帮助。