0
我在运行ExpressJS/Nodejs的Amazon Ec2（m1.large）上有一台服务器。这我的服务器每秒接收2.000个请求，但nodejs一段时间后停止..显示在我的浏览器“此网页不可用”.. nodejs不支持几个请求？或者它可以是我的服务器配置？Nodejs服务器停止
app.js
/**
* Module dependencies.
*/
var express = require('express');
var mysql = require('mysql');
var routes = require('./routes');
var verify = require('./routes/verify');
var http = require('http');
var path = require('path');
pool = mysql.createPool({
host : 'rds.amazonaws.com', //old db
user : '123123',
password : '123123',
database : '123'
});
var app = express();
// all environments
app.set('port', process.env.PORT || 8080); //3000, 8080
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'jade');
// app.use(express.favicon());
app.use(express.logger('dev'));
app.use(express.json());
app.use(express.cookieParser());
app.use(express.urlencoded());
app.use(express.methodOverride());
app.use(app.router);
app.use(express.static(path.join(__dirname, 'public')));
// development only
if ('development' == app.get('env')) {
app.use(express.errorHandler());
}
app.get('/', routes.index);
app.get('/l.node', verify.checkin); //l.cpp?q=31&w=c
app.get('/crossdomain.xml', verify.crossdomain);
http.createServer(app).listen(app.get('port'), function(){
console.log('@Express server listening on port ' + app.get('port'));
});
verify.js
/*
|--------------------------------------------------------------------------
| CROSSDOMAIN.XML
|--------------------------------------------------------------------------
*/
exports.crossdomain = function (req, res){
res.set('Content-Type', 'text/xml; charset=utf-8');
res.send('<?xml version="1.0"?><cross-domain-policy><allow-access-from domain="*" /></cross-domain-policy>');
};
/*
|--------------------------------------------------------------------------
| BANNER CHECK-IN
|--------------------------------------------------------------------------
*/
exports.checkin = function(req, res){
banner_id = req.query.q;
type_req = req.query.w;
updateBannerView(banner_id, type_req, true);
if(type_req == 'c'){
updateBannerClick(banner_id, res);
} else {
res.send('commit range ' + banner_id + '..' + type_req + '; l:');
}
}; //end exposts
/*
|--------------------------------------------------------------------------
| ADD CLICK BANNER
|--------------------------------------------------------------------------
*/
var updateBannerClick = function (p_banner_id, p_res) {
var link = '';
pool.getConnection(function(err, connection) {
connection.query("UPDATE `reportbanners` SET `clicks` = `clicks`+1 WHERE `date` = ? AND `banner_id` = ?", [getDateTime(), p_banner_id],
function(err,rows,field){
});
connection.query('SELECT * FROM `banners` WHERE `id` = ?', [p_banner_id], function(err, rows, fields) {
if(rows.length != 0){
link = rows[0].banner_clicklink;
p_res.send('<script>window.location = "' + link + '";</script>');
console.log("Link Active");
} else {
console.log("Error Link Active");
p_res.send('<script>window.location = "http://www.google.com.br";</script>');
}
});
connection.release();
});//end pool
};
/*
|--------------------------------------------------------------------------
| ADD VIEW BANNER
|--------------------------------------------------------------------------
*/
var updateBannerView = function (p_banner_id, p_type_req, p_isSessionViewUpdate) {
pool.getConnection(function(err, connection) {
console.log(err);
var getQuery = "";
connection.query('SELECT * FROM `reportbanners` WHERE `date` = ? AND `banner_id` = ?', [getDateTime(), p_banner_id], function(err, rows, fields) {
if(rows.length == 0){
if(p_isSessionViewUpdate){
getQuery = "INSERT INTO `reportbanners` (`id` , `date` , `clicks` , `views` , `session_views` , `banner_id`) VALUES (NULL , NOW(), '0', '1', '1', ?)";
} else {
getQuery = "INSERT INTO `reportbanners` (`id` , `date` , `clicks` , `views` , `session_views` , `banner_id`) VALUES (NULL , NOW(), '0', '1', '0', ?)";
}
connection.query(getQuery, [p_banner_id],
function(err,rows,field){
});
// debug
console.log("INSERT REG");
} else {
if(p_isSessionViewUpdate){
getQuery = "UPDATE `reportbanners` SET `views` = `views`+1, `session_views` = `session_views`+1 WHERE `date` = ? AND `banner_id` = ?";
} else {
getQuery = "UPDATE `reportbanners` SET `views` = `views`+1 WHERE `date` = ? AND `banner_id` = ?";
}
connection.query(getQuery, [getDateTime(), p_banner_id],
function(err,rows,field){
});
console.log("ATT REG");
};
console.log('Results: ', rows.length);
console.log('date: ', getDateTime());
// console.log('s: ', the_banner_link);
});
connection.release();
});//end pool
};
var getDateTime = function() {
var date = new Date();
var hour = date.getHours();
hour = (hour < 10 ? "0" : "") + hour;
var min = date.getMinutes();
min = (min < 10 ? "0" : "") + min;
var sec = date.getSeconds();
sec = (sec < 10 ? "0" : "") + sec;
var year = date.getFullYear();
var month = date.getMonth() + 1;
month = (month < 10 ? "0" : "") + month;
var day = date.getDate();
day = (day < 10 ? "0" : "") + day;
// return year + ":" + month + ":" + day + ":" + hour + ":" + min + ":" + sec;
return year + "-" + month + "-" + day;
}
您确实需要为任何人添加更多信息，以提供对您有用的任何内容。 NodeJS应该能够服务数千甚至数千个请求。发布实际的错误日志，或许你的nodejs/express implmementation的代码将是非常有益的，所以SO用户可以更准确地排除你的情况。 – tremor
你有什么错误吗？你记录什么？你能在你的开发机器上重现这个问题吗？ – tadman
不，没有错误..我的err.log是空的。 – Fernando