为什么我无法从nodeJS的httpServer收到前几个响应？
|
我打算将nodeJS用作我的彗星服务器，并且编写了一些测试代码，但是存在一个问题，即客户端第一次连接到服务器时，它无法从服务器获得响应。
这是服务器端代码（server.js）：
var util = require(\'util\');
var redis = require(\'redis\').createClient(6379, \'192.168.1.254\');
var http = require(\'http\');
redis.on(\"error\", function (err) {
console.log(\"Error \" + err);
});
var server = http.createServer(requestListener);
server.listen(9898, \'192.168.1.254\');
function requestListener(req, res) {
util.log(\'Connected.\');
redis.brpoplpush(\'msg:q:1\', \'msg:s:1\', 20, function(err, reply) {
if (err) {
util.log(\'ERROR: \' + err);
}
var length = reply ? reply.length : 0;
res.writeHead(200, {
\'Content-Type\':\'text/plain\',
\'Content-Length\':length
});
if (length) {
res.end(reply);
util.log(\'Sent: \' + reply);
} else {
res.end(\'\');
}
});
}
#!/bin/bash
while [ 1 ]
do
curl -i http://192.168.1.254:9898
done
res.end(reply)
没有找到相关结果
已邀请:
1 个回复
系漏
var util = require(\'util\'); var redis = require(\'redis\').createClient(); var http = require(\'http\'); redis.on(\"error\", function (err) { console.log(\"Redis error \" + err); }); redis.on(\"ready\", function () { console.log(\"Redis client ready\"); }); var server = http.createServer(requestListener); server.listen(9898); function requestListener(req, res) { var aborted = false; res.writeHead(200, { \"Content-Type\": \"text/plain\" }); res.write(\"Checking redis...\\n\"); redis.brpoplpush(\'q\', \'s\', 20, function (err, reply) { if (aborted) { return console.log(\"Client aborted before redis reply came back.\"); } if (err) { return res.end(\"Redis error\"); } res.end(\"Redis reply: \" + reply); }); req.on(\"aborted\", function () { console.log(\"HTTP client aborted.\"); aborted = true; }); }