【发布时间】：2011-10-02 12:19:27
【问题描述】：
我使用 node.js、Python 和 Java 为 zeromq 编写了一个简单的回显请求/回复测试。该代码运行一个包含 100K 请求的循环。该平台是一台运行 Snow Leopard 的 2 核和 3G RAM 的 5yo MacBook Pro。
node.js 始终比其他两个平台慢一个数量级。
Java：
real 0m18.823s
user 0m2.735s
sys 0m6.042s
Python：
real 0m18.600s
user 0m2.656s
sys 0m5.857s
node.js：
real 3m19.034s
user 2m43.460s
sys 0m24.668s
有趣的是，对于 Python 和 Java，客户端和服务器进程都使用大约一半的 CPU。 node.js 的客户端使用了大约一个完整的 CPU，而服务器使用了大约 30% 的 CPU。客户端进程也有大量的页面错误，让我相信这是一个内存问题。此外，在 10K 请求时，节点仅慢 3 倍；运行时间越长，它的速度肯定越慢。
这是客户端代码（请注意，process.exit() 行也不起作用，这就是我在使用 time 命令之外还包括一个内部计时器的原因）：
var zeromq = require("zeromq");
var counter = 0;
var startTime = new Date();
var maxnum = 10000;
var socket = zeromq.createSocket('req');
socket.connect("tcp://127.0.0.1:5502");
console.log("Connected to port 5502.");
function moo()
{
process.nextTick(function(){
socket.send('Hello');
if (counter < maxnum)
{
moo();
}
});
}
moo();
socket.on('message',
function(data)
{
if (counter % 1000 == 0)
{
console.log(data.toString('utf8'), counter);
}
if (counter >= maxnum)
{
var endTime = new Date();
console.log("Time: ", startTime, endTime);
console.log("ms : ", endTime - startTime);
process.exit(0);
}
//console.log("Received: " + data);
counter += 1;
}
);
socket.on('error', function(error) {
console.log("Error: "+error);
});
服务器代码：
var zeromq = require("zeromq");
var socket = zeromq.createSocket('rep');
socket.bind("tcp://127.0.0.1:5502",
function(err)
{
if (err) throw err;
console.log("Bound to port 5502.");
socket.on('message', function(envelope, blank, data)
{
socket.send(envelope.toString('utf8') + " Blancmange!");
});
socket.on('error', function(err) {
console.log("Error: "+err);
});
}
);
为了比较，Python客户端和服务器代码：
import zmq
context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect("tcp://127.0.0.1:5502")
for counter in range(0, 100001):
socket.send("Hello")
message = socket.recv()
if counter % 1000 == 0:
print message, counter
import zmq
context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind("tcp://127.0.0.1:5502")
print "Bound to port 5502."
while True:
message = socket.recv()
socket.send(message + " Blancmange!")
以及Java客户端和服务器代码：
package com.moo.test;
import org.zeromq.ZMQ;
import org.zeromq.ZMQ.Context;
import org.zeromq.ZMQ.Socket;
public class TestClient
{
public static void main (String[] args)
{
Context context = ZMQ.context(1);
Socket requester = context.socket(ZMQ.REQ);
requester.connect("tcp://127.0.0.1:5502");
System.out.println("Connected to port 5502.");
for (int counter = 0; counter < 100001; counter++)
{
if (!requester.send("Hello".getBytes(), 0))
{
throw new RuntimeException("Error on send.");
}
byte[] reply = requester.recv(0);
if (reply == null)
{
throw new RuntimeException("Error on receive.");
}
if (counter % 1000 == 0)
{
String replyValue = new String(reply);
System.out.println((new String(reply)) + " " + counter);
}
}
requester.close();
context.term();
}
}
package com.moo.test;
import org.zeromq.ZMQ;
import org.zeromq.ZMQ.Context;
import org.zeromq.ZMQ.Socket;
public class TestServer
{
public static void main (String[] args) {
Context context = ZMQ.context(1);
Socket socket = context.socket(ZMQ.REP);
socket.bind("tcp://127.0.0.1:5502");
System.out.println("Bound to port 5502.");
while (!Thread.currentThread().isInterrupted())
{
byte[] request = socket.recv(0);
if (request == null)
{
throw new RuntimeException("Error on receive.");
}
if (!socket.send(" Blancmange!".getBytes(), 0))
{
throw new RuntimeException("Error on send.");
}
}
socket.close();
context.term();
}
}
我喜欢 node，但由于代码大小、简单性和性能方面的巨大差异，我现在很难说服自己。
那么，以前有没有人看到过这样的行为，或者我在代码中做了什么愚蠢的事情？
【问题讨论】：
-
您可以尝试从您的 Python 示例中模拟逻辑（例如，我仅在收到上一条消息后才发送下一条消息）？
-
你必须记住 Node 还很年轻。你不能指望像 python 这样的老手在其 1.0.0 版本还没有发布的框架下的简单性和口才。
-
我想知道 Node.js 的
zmq模块是否有问题？我做了一个simple micro benchmark，它显示 Node.js 比所有版本的 Python 都快得多，用于简单的数字运算，与 Java 的速度相当。 -
我不知道这是不是一个公平的测试。正如您所说，您的节点进程只使用了一个核心。由于节点使用单个进程，因此它只能使用一个内核，而线程解决方案可以免费使用您机器上的所有内核。这个页面展示了如何（用很少的代码行）spool up N 个节点进程，其中 N 是核心数：nodejs.org/api/cluster.html
-
@Jess 其他两个示例都没有使用线程。
标签： java python node.js zeromq