PHP Socket 服务器与 Node.js：网络聊天

Question

我想使用长期保存的 HTTP 请求（Comet）、ajax 和 websockets（取决于所使用的浏览器）来编写 HTTP WebChat 程序。用户数据库位于mysql中。聊天是用 PHP 编写的，除了聊天流本身也可以用 javascript (node.js) 编写：

我不想为每个用户启动一个 php 进程，因为没有好的方法在这些 php 之间发送聊天消息孩子们。 所以我考虑用 PHP 或 Node.js 编写一个自己的套接字服务器，它应该能够处理超过 1000 个连接（聊天用户）。作为一名纯粹的 Web 开发人员（php），我对套接字不太熟悉，因为我通常让 Web 服务器关心连接。聊天消息不会保存在磁盘上，也不会保存在 mysql 中，而是作为数组或对象保存在 RAM 中，以获得最佳速度。

据我所知，没有办法在单个 php 进程（套接字服务器）中同时处理多个连接，但是您可以接受大量套接字连接并在循环中连续处理它们（读取和写入；传入消息 -> 写入所有套接字连接）。问题是，大约 1000 个用户很可能会出现延迟，并且 mysql 操作可能会减慢整个过程，从而影响所有用户。

我的问题是：node.js 能否以更好的性能处理套接字服务器？ Node.js 是基于事件的，但我不确定它是否可以同时处理多个事件（这不需要多线程吗？）或者是否只有一个事件队列。对于事件队列，它就像 php：一个接一个地处理用户。

我还可以为每个聊天室（更少的用户）生成一个 php 进程，但据我所知，单线程 IRC 服务器也能够处理数千个用户。 （用 C++ 或其他语言编写）所以也许在 php 中也是可能的。

我更喜欢 PHP 而不是 Node.js，因为这样该项目将仅包含 php，而不是混合编程语言。但是，如果 Node 可以同时处理连接，我可能会选择它。

Answer 1

JavaScript，或者在本例中是 Node 使用的引擎 V8，是设计单线程的。所以是的，只有一个事件队列。

但最终，这不是问题，总是会先发生一些事情，除非您使用多个处理器，即使如此，您很可能只有一个网卡...一个路由器。 ..你明白了。另外，使用 1000 多个线程...不是一个好主意，扩展性很差，并且您会发现自己处于并发地狱之中。

1000 个聊天用户，对于 Node.js 来说完全没有问题。

我可以给你一个非常基本的想法，你如何设置它，这个普通的普通聊天工具通过 telnet 工作，它......没有任何功能，但它可以工作：

var net = require('net'); // require the net module

var users = []; // keep track of the users

// setup a new tcp socket server
net.createServer(function(socket) { // provide a callback in case a new connection gets
                                    // established, socket is the socket object

    // keep track of this users names, via use of closures
    var name = '';

    // ask the new user for a name
    socket.write('Enter a Name(max 12 chars): ');

    // register a callback on the socket for the case of incoming data
    socket.on('data', function(buffer) { // buffer is a Buffer object containing the data
        if (name !== '') {  // in case this user has a name...

            // send out his message to all the other users...
            for(var i = 0; i < users.length; i++) {
                if (users[i] !== socket) { // ...but himself
                    users[i].write(name + ': '
                                   + buffer.toString('ascii').trim()
                                   + '\r\n');
                }
            }

        // otherwise take the data and use that as a name
        } else {
            name = buffer.toString('ascii').substring(0, 12).trim().replace(/\s/g, '_');
            socket.write('> You have joined as ' + name + '\r\n');

            // push this socket to the user list
            users.push(socket);
            for(var i = 0; i < users.length; i++) {
                if (users[i] !== socket) {
                    users[i].write('> ' + name + ' has joined' + '\r\n');
                }
            }
        }
    });

    // another callback for removing the user aka socket from the list
    socket.on('end', function() {
        users.splice(users.indexOf(socket), 1);
    });

// bind the server to port 8000
}).listen(8000);

这里没有涉及任何魔法（除了使用闭包），你不必与原始套接字编程，你不会有任何并发​​问题。并且您可以了解一些最新热点；）

我建议您观看我们的 Node.js< 上列出的一些演讲/a> 标签 wiki，以更好地掌握 Node.js 的工作原理。

Answer 2

我回答的另一个主题可以帮助您并且可以轻松地满足您的需求=> 如何使用redis发布/使用 Nodejs 订阅以在数据值发生变化时通知客户端？