使用 Node.js 和 ajax 进行长轮询
Long polling with Node.js and ajax
我有以下服务器代码。
var http = require('http');
var mysql = require('mysql');
var querystring = require('request');
var util = require('util');
var url = require('url');
var singer_name;
var currentmodif, lastmodif;
var requests=[];
var response;
var connection = mysql.createConnection({
host : 'localhost',
user : 'someone',
password : 'xxxxxxx',
database : 'rest', //mysql database to work with (optional)
});
connection.connect(); //connect to mysql
connection.query('SELECT * FROM musics WHERE id=1', function(err, rows, fields) {
if (err) throw err;
singer_name=rows[0].singer_name;
currentmodif=rows[0].time_added;
});
http.createServer(function (req, res) {
console.log('request received');
requests.push({
response: res,
timestamp: new Date().getTime()
});
if(req.method=='GET'){
var url_parts = url.parse(req.url,true);
lastmodif = url_parts.query.timestamp;
}
//check_update(req, res);
}).listen(9000);
setInterval(function() {
var expiration = new Date().getTime() - 30000;
for (var i = requests.length - 1; i >= 0; i--) {
//console.log("Request timestamp: "+requests[i].timestamp+" Expiration : "+expiration);
response = requests[i].response;
if (requests[i].timestamp < expiration) {
console.log("The condition is met");
response.writeHead(200, {
'Content-Type' : 'text/plain',
'Access-Control-Allow-Origin' : '*'
});
// return response
response.write('_testcb(''ok'')', 'utf8');
response.end();
//break;
}
}
connection.query('SELECT * FROM musics WHERE id=1', function(err, rows, fields) {
if (err) throw err;
currentmodif=rows[0].time_added;
//console.log("currentmodif: "+currentmodif+" lastmodif: "+lastmodif);
if (currentmodif > lastmodif){
singer_name=rows[0].singer_name;
var _arrays = {'singer_name': singer_name, 'time': currentmodif}
var data = "_testcb"+"("+JSON.stringify(_arrays)+")";
response.writeHead(200, {
'Content-Type' : 'text/plain',
'Access-Control-Allow-Origin' : '*'
});
if (response.end(data))
console.log("Response successfully sent");
//return false;
}
});
}, 2000);
和客户端代码：
<html>
<head>
<script src="http://code.jquery.com/jquery-1.10.1.min.js"></script>
<title>Node.js Ajax test</title>
</head>
<body>
</body>
<script>
var timestamp = "1380020402";
function callNode() {
var time = "1380020402";
$.ajax({
url: 'http://xx.xxx.xx.xxx:9000/',
dataType: "jsonp",
data: {"timestamp":timestamp},
type: 'POST',
jsonpCallback: "_testcb",
cache: false,
timeout: 35000,
success: function(response, code, xhr) {
if ('ok' == response) {
callNode();
return false;
}
console.log(response);
timestamp = response.time;
// make new call
callNode();
},
error: function(jqXHR, textStatus, errorThrown) {
console.log('error ' + textStatus + " " + errorThrown);
}
});
}
$(function () {
callNode();
});
</script>
</html>
我正在尝试进行长时间的投票。因此，在数据库中的数据更新之前，对 ajax 请求的响应应该暂停，但上面的代码不起作用。我正在从不同的域发出 ajax 请求，因此使用 jsonp。
确切的问题是，当前当数据库中的数据发生更改时，不会发送响应。它时不时地工作，但它并不总是可靠的。
另一个问题是超时的代码块不起作用。如果请求是 30 秒前的，则应发送空白响应以避免来自 ajax 的超时。
如果有人能帮忙，我将不胜感激。
干杯。
我已经想通了。修订后有效的代码如下：
客户端：
<html>
<head>
<script src="http://code.jquery.com/jquery-1.10.1.min.js"></script>
<title>Node.js Ajax test</title>
</head>
<body>
</body>
<script>
var timestamp;
function callNode() {
$.ajax({
url: 'http://xx.xxx.xx.xxx:9000/',
dataType: "jsonp",
data: {"timestamp":timestamp},
//type: 'POST', //don't need this with jsonp
jsonpCallback: "_testcb",
cache: false,
timeout: 35000,
success: function(response, code, xhr) {
if ('ok' == response) {
console.log(response);
callNode();
return false;
}
console.log(response);
timestamp = response.time;
// make new call
callNode();
},
error: function(jqXHR, textStatus, errorThrown) {
console.log('error ' + textStatus + " " + errorThrown);
}
});
}
$(function () {
setTimeout(callNode, 1); //call function with setTimeout in order to avoid ugly constant browser loading
});
</script>
</html>
端(服务器.js(：
var http = require('http');
var mysql = require('mysql');
var util = require('util');
var url = require('url');
var singer_name, currentmodif, lastmodif, request, response, time_of_request;
//var requests=[];
var connection = mysql.createConnection({
host : 'localhost',
user : 'someone',
password : 'xxxxxx',
database : 'rest', //mysql database to work with (optional)
});
connection.connect(); //connect to mysql
connection.query('SELECT * FROM musics WHERE id=1', function(err, rows, fields) {
if (err) throw err;
singer_name=rows[0].singer_name;
currentmodif=rows[0].time_added;
});
http.createServer(function (req, res) {
request = req;
response = res;
time_of_request = new Date().getTime();
console.log('request received');
if(req.method=='GET'){
var url_parts = url.parse(req.url,true);
lastmodif = url_parts.query.timestamp;
}
req.on('error', function(e) {
console.log('problem with request: ' + e.message);
});
//checkupdate();
}).listen(9000);
var response;
function checkupdate() {
var expiration = new Date().getTime() - 30000;
//for (var i = requests.length - 1; i >= 0; i--) {
//console.log("Request timestamp: "+time_of_request+" Expiration : "+expiration);
if (time_of_request < expiration) {
console.log("The condition is met");
// return response
response.write('_testcb(''ok'')', 'utf8');
response.end();
}
//}
connection.query('SELECT * FROM musics WHERE id=1', function(err, rows, fields) {
if (err) throw err;
currentmodif=rows[0].time_added;
if (lastmodif == undefined)
lastmodif = 0;
console.log("currentmodif: "+currentmodif+" lastmodif: "+lastmodif);
if (currentmodif > lastmodif){
singer_name=rows[0].singer_name;
var _arrays = {'singer_name': singer_name, 'time': currentmodif}
var data = "_testcb"+"("+JSON.stringify(_arrays)+")";
//response.writeHead(200, { 'content-type':'application/json',
//'Access-Control-Allow-Origin' : '*'});
//response.write(data);
response.end(data);
console.log("Response successfully sent");
//return false;
}
});
};
setInterval(checkupdate, 2000);
问题出在服务器端。当服务器想要回复时，响应对象不可用(未定义(，因此未发送响应。我可能忽略了节点控制台中的错误.js。
这几乎是使用 node.js MYSQL 数据库进行长轮询的完整示例。此脚本将等待新数据可用，然后再回复 ajax 请求。如果在请求后 30 秒内没有新数据(在 MYSQL 中(，则会进行虚假回复，以便请求不会超时。ajax 的成功回调中有一个条件，当收到此演示响应时，它会重新启动此 ajax 请求，因此使其成为无限循环。
我已经成功测试了上面的代码，它似乎工作正常。我运行了脚本，然后更新了数据库中的数据(主要是time_added字段(，这触发了对我等待的 ajax 调用的回复，其中包含来自 node.js 服务器的新数据。
我希望这段代码可以帮助那里的人。
查看教程在这里进一步解释：http://www.sahilsaid.com/blog/long-polling-node-js-mysql-database-ajax/
相关文章：
- node.js请求数据事件未在CORS ajax调用中触发
- AJAX调用并在Node中获取返回数据
- 使用node.js发送并发ajax请求的限制是什么
- 为什么在Node.js上使用jQuery时未定义$.ajax
- 如何通过ajax将值从表单控件传递到node.js
- Node.js中$.ajax(）的替换
- 带有ajax xml请求的Node js脚本不起作用
- Node/Express对MongoDB的AJAX调用示例
- 通过ajax和url更新页面，而无需重新加载页面(node.js）
- 如何使用Ember Ajax从Node JS Express传入数据
- JQuery Ajax does not response to Node JS
- Ajax with node.js
- Node.js / Express :通过 ajax 下载文件
- 将 ajax 转换为 node.js
- 轮询冻结，Pebble.js，ajax，node.js
- node.js相当于标准的PHP ajax保存方案
- 如何保护我的 ajax 免受 XSS 漏洞 (NODE.JS） 的侵害
- 当 AJAX-get 在本地主机上与 node.js 时收到错误消息
- 使用 Node.js 和 ajax 进行长轮询
- net::ERR_CONNECTION_REFUSED Error jQuery ajax node.js
