在Web工作者中发出HTTP请求
我第一次尝试在我的节点应用程序中使用web工作者或线程。我正在使用webworker-线程npm模块。
基本上，我希望每个工作人员向服务器发出请求，测量响应时间并将其发送回主线程。
我尝试了很多不同的方法，但我似乎无法让它发挥作用。文档中的基本示例起作用。但是当我试图要求一个模块(在我的例子中是“请求”)时，工作人员似乎停止工作，没有任何错误消息。我在文档中看到，需要在工作人员内部不工作，所以我尝试了"importScripts()"，这也不起作用。在使用线程池时，我尝试使用.all.eval()，但它也不起作用。
由于这是第一次在节点中使用web工作者/线程，我可能会误解如何在一般情况下使用这些东西。下面是我尝试过的一个例子：
server.js
var Worker = require('webworker-threads').Worker;
var worker = new Worker('worker.js');worker.js
console.log("before import");
importScripts('./node_modules/request/request.js');
console.log("after import");这个基本示例只打印before import，然后停止。
回答 1
Stack Overflow用户
发布于 2015-05-24 21:00:58
Web工作者只是本机javascript，所以您无法通过他们实现您想要的结果。工作线程不支持node.js api或npm包(比如http或request.js)。对于并发性，您不需要任何多线程魔术，只需使用async.js或承诺即可。如果您想玩线程，那么child_processes就是方法。您还可以使用API来管理child_processes (如https://github.com/rvagg/node-worker-farm )。
考虑到您的示例，您可以编写如下内容：
main.js
var workerFarm = require('worker-farm')
, workers = workerFarm(require.resolve('./child'))
, ret = 0;
var urls = ['https://www.google.com', 'http://stackoverflow.com/', 'https://github.com/'];
urls.forEach(function (url) {
workers(url, function (err, res, body, responseTime) {
console.log('Url ' + url + 'finished in ' + responseTime + 'ms');
//Ugly code here use async/promise instead
if (++ret == urls.length)
workerFarm.end(workers);
});
});child.js
var request = require('request');
module.exports = function(url, cb) {
var start = new Date();
request(url, function(err, res, body) {
var responseTime = new Date() - start;
cb(err, res, body, responseTime);
});
};https://stackoverflow.com/questions/30387469
复制相似问题
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号