node.js

Question

我是 node.js 的新手，所以在发布我的 node.js 应用程序之前，我需要确保它能够正常工作。

假设我有一个数组变量并在我的脚本开始时初始化它

myArray = [];

然后我从外部 API 提取一些数据，将其存储在 myArray 中，并使用 setInterval() 方法每 30 分钟再次提取此数据：

pullData();
setInterval(pullData, 30*60*1000);

pullData() 函数大约需要 2-3 秒才能完成。

客户端将能够使用此函数获取 myArray：

http.createServer(function(request, response){
var path = url.parse(request.url).pathname;
if(path=="/getdata"){

    var string = JSON.stringify(myArray);
    response.writeHead(200, {'Content-Type': 'text/plain'});
    response.end(string);              

}
}).listen(8001);

所以我想问的是，下一种情况会发生吗？：客户端试图从这个 node.js 服务器获取数据，并且在同一时刻，数据被 pullData() 函数写入 myArray，导致向客户端发送无效数据？

我阅读了一些文档，我意识到当 pullData() 为运行时，createServer() 在 pullData() 完成其工作之前不会响应客户端？我真的不太了解并发编程，所以我需要您对此进行确认，或者您是否有更好的解决方案？

编辑：这里是我的 pullData() 函数的代码：

 var now = new Date();

Date.prototype.addDays = function(days){

        var dat = new Date(this.valueOf());
        dat.setDate(dat.getDate() + days);
        return dat;
}


var endDateTime = now.addDays(noOfDays);
var formattedEnd = endDateTime.toISOString(); 

var url = "https://api.mindbodyonline.com/0_5/ClassService.asmx?wsdl";
    soap.createClient(url, function (err, client) {
        if (err) {
            throw err;
        }

        client.setEndpoint('https://api.mindbodyonline.com/0_5/ClassService.asmx');
        var params = {
            "Request": {
                "SourceCredentials": {
                    "SourceName": sourceName,
                    "Password": password,
                    "SiteIDs": {
                        "int": [siteIDs]
                    }
                },
                "EndDateTime" : formattedEnd

            }
        };


client.Class_x0020_Service.Class_x0020_ServiceSoap.GetClasses(params, function (errs, result) {
            if (errs) {
                console.log(errs);
            } else {

                    var classes = result.GetClassesResult.Classes.Class;
                    myArray = [];

                    for (var i = 0; i < classes.length; i++) {
                        var name = classes[i].ClassDescription.Name;
                        var staff = classes[i].Staff.Name;
                        var locationName = classes[i].Location.Name;
                        var start = classes[i].StartDateTime.toISOString();
                        var end = classes[i].EndDateTime.toISOString();
                        var klasa = new Klasa(name,staff,locationName,start,end);

                        myArray.push(klasa);
                    }

                    myArray.sort(function(a,b){
                        var c = new Date(a.start);
                        var d = new Date(b.start);
                        return c-d;
                    });

                    string = JSON.stringify(myArray);
     }
        })


    });

Answer 1

总的来说：没有

JavaScript 是单线程的。虽然一个函数是运行，但没有其他函数可以是。

例外情况是访问数组值的函数之间存在延迟。

例如

var index = i;
function getNext() {
    async.get(myArray[i], function () {
        i++;
        if (i < myArray.length) {
            getNext()
        }
    });
}

…在这种情况下，可以在调用异步函数之间更新数组。

您可以通过在开始第一个异步操作时创建数组的 deep copy 来缓解这种情况。

Answer 2

Javascript 是单线程语言，因此您不必担心这种并发性。这意味着不会同时执行两部分代码。与许多其他编程语言不同，javascript 具有基于 event loop 的不同并发模型。为了获得最佳性能，您应该使用由回调函数、承诺或事件处理的非阻塞操作。我想您的外部 API 提供了一些非常适合 node.js.

的异步 i/o 函数

Answer 3

不，NodeJs 不是多线程的，所有东西运行都在一个线程上，这意味着除了非阻塞调用（即 IO）之外的所有东西都将参与 CPU 直到它 returns，并且 NodeJS 绝对不会 return 向最终用户中途填充数组， 只要您只执行一次 HTTP 调用来填充数组 。

更新： 正如@RyanWilcox 所指出的那样，任何异步（非阻塞系统调用）调用都可能会提示 NodeJS 解释器将您的函数执行中途并return稍后再执行。

Answer 4

如果您的 pullData 调用不会花费太长时间，另一种解决方案是缓存数据。

仅在需要时获取数据（因此当客户端访问/getdata 时）。如果它被获取，您可以使用时间戳缓存数据。如果 /getdata 再次被调用，检查缓存数据是否超过 30 分钟，如果是则再次获取。

还将数组解析为json..

var string = JSON.stringify(myArray);

..可能在 /getdata 调用之外完成，因此不必为访问 /getdata 的每个客户端都完成此操作。可能会稍微快一点。

node.js - 互变量

node.js - mutual variable

javascript

concurrent-programming