当将数据从jquery发布到node.js进程时,有时它能工作,有时它不工作。这取决于我如何构建代码。这种工作方式:
http.createServer(router).listen(5000, '127.0.0.1');
console.log('Server running at http://127.0.0.1:5000/');
function router(req, res){
var page = url.parse(req.url, true);
switch(page.pathname){
case '/new-task': tasks.postNewTask(req, res); break;
}
}
"任务"是我加载的模块。里面有postNewTask:
function postNewTask(req, res){
core.postRequest(req, res, function () {
// lots of stuff inside
})
}
postRequest是我在这里从Stackoverflow"借用"的一个函数。它被定义为:
function postRequest(request, response, callback) {
var queryData = "";
if(typeof callback !== 'function') return null;
if(request.method == 'POST') {
console.log("it's post");
request.on('data', function(data) {
console.log("it's data");
queryData += data;
if(queryData.length > 1e6) {
console("too much stuff");
queryData = "";
response.writeHead(413, {'Content-Type': 'text/plain'});
request.connection.destroy();
}
});
request.on('end', function() {
console.log("it's end");
response.post = querystring.parse(queryData);
callback();
});
} else {
console.log("no post");
response.writeHead(405, {'Content-Type': 'text/plain'});
response.end();
}
}
这非常有效,tasks.postNewTask中的代码也会运行。然而,当我将路由器更改为:
function router(req, res){
var page = url.parse(req.url, true);
var session = core.getCookies(req).s;
if (page.pathname == '/login') {
core.postLogin(req, res); return; }
database.query('SELECT * from Members WHERE Session = ?;', [session], function(err, rows, fields) {
if (err) throw err;
if (rows.length>0) {
switch(page.pathname){
case '/new-task': tasks.postNewTask(req, res); break;
}
} else {
res.writeHead(200, "OK", {'Content-Type': 'application/json'});
res.end(JSON.stringify('login'));
};
});
}
则postRequest不再工作。它只会打印"It’s post",仅此而已。它从不打印数据或到达终点。当我在浏览器上超时时,它似乎永远不会返回到客户端。
这里的问题是postRequest中的"data"one_answers"end"事件从未被调用,而我所做的唯一更改是将数据库调用封装在switch语句中。
谢谢!
postRequest 中有3个控制台输出
it's post
it's data
it's end
第一个被触发,因为if条件只是检查请求类型,其余两个在请求异步获取数据和结束信号时完成。因此,如果postNewTask返回或发送对请求的响应,那么它可能无法到达该部分。检查您在// lots of stuff inside
中执行的操作
同样关于搜索mysql文档https://npmjs.org/package/mysql我发现:
You MUST NOT provide a callback to the query() method when streaming rows.
所以也要检查一下。