我有一个节点http服务器。它有一个主进程,我在其中分叉了子进程/webworker。
我希望主节点进程处理http请求,并将此请求传递给分叉进程或web工作者,以便他们能够独立处理请求并向其发送响应
问题:-这里我无法将响应对象发送到子进程/web worker。
节点也不允许共享变量。所以我不能将它存储在父进程上,也不能与子进程共享它的引用。
有什么可能的办法吗?
正如您所说,您不能传递响应对象。但是,您可以传递某种标识符,让主线程在工作线程完成工作时检索正确的响应对象。
例如,你可以
- 在主线程中,通过一个唯一的整数ID存储每个响应对象
- 将此ID传递给工作人员
- 工作线程完成后,将此ID连同其工作结果一起传回主线程
- 主线程检索正确的响应对象,并将结果传递回客户端(即web浏览器)
以下是的基本实现
var http = require('http');
var Worker = require('webworker-threads').Worker;
// Store in-progress responses by unique(-enough) ID
// that is passed to the worker that then passes it back
var responses = {
_nextResponseId: 0,
_responses: {},
store: function store(response) {
var id = this._nextResponseId;
this._nextResponseId = this._nextResponseId === Number.MAX_SAFE_INTEGER ? 0 : (this._nextResponseId + 1);
this._responses[id] = response;
return id;
},
remove: function remove(id) {
var response = this._responses[id];
delete this._responses[id];
return response;
}
};
// Worker,simulating something long and synchronous
var worker = new Worker(function() {
onmessage = function(event) {
var id = event.data.id;
for (var i = 0; i < 1000000000; ++i) {}
self.postMessage({
id: id,
message: 'From worker, request ' + id
});
};
});
// A worker message ends the original http response
worker.onmessage = function(event) {
var response = responses.remove(event.data.id);
response.end(event.data.message);
};
// Simple server that calls the worker with the id of the response
var server = http.createServer(function handleRequest(request, response) {
var id = responses.store(response);
worker.postMessage({
id: id
});
});
server.listen(8083);