0

我正在尝试运行 jxcore。但我不能。请帮帮我，因为我是新手。

服务器.js

var http = require("http");

jxcore.tasks.on('message', function (threadId, param)  {   
    console.log('Main thread received a message from subthread no ' +
                   threadId + '. Message: ', param);
});

http.createServer(function(req,resp) {
    console.log("Listening To Thread " + process.threadId);   
    resp.writeHead(200,{"Content-Type":"text/html"});    
    resp.end("Running JXCORE "+process.threadId);
}).listen(3000);

服务器jx.js

var method = function() {
    try  {
        process.keepAlive();
        require("server");
        console.log("Welcome To NodeJS");
        return {
            someResult: "some result";
        };
    } catch(e) {
        console.log("Error Occured : "+e);
        return {"Error":e};
    }
}

jxcore.tasks.runOnce(code, {count:1000}, function(obj) {
    process.sendToMain({started:true});
    console.log("Return Value " + obj);

    setTimeout(function() {
        console.log("Waiting For TimeOut 5 Sec");
    }, 5000);
});

我在 cmd 上输入为jx server.js jx mt-keep server.js

我没有看到线程正在运行。请帮忙

4

1 回答 1

1

这里有几个结构性错误。另外，您要做什么并不明显。

场景 1 - 仅运行server.js

他们都工作：jx mt server.js或jx mt-keep server.js

场景 2 - 运行serverjx.js为每个线程加载server.js

在这里，您可能尝试使用jxcore.tasks.runOnce(). 所以每个线程都会加载server.js并在那里创建它自己的 http 服务器实例。

这应该以这种方式启动：（jx serverjx.js没有 mt 或 mt-keep）

虽然我没有看到这样做的意义（为什么不像场景 1 那样运行它，因为它是多线程 http 服务器的正确方法？），经过几次修复后，代码看起来像这样：

服务器jx.js：

var method = function () {
    try {
        process.keepAlive();
        require("./server");
        console.log("Welcome To NodeJS");
        return {
            someResult: "some result"
        };
    } catch (e) {
        console.log("Error Occured : " + e);
        return {"Error": e};
    }
};

jxcore.tasks.runOnce(method, {count: 1000});

请注意几点：

  • require('server')如果您尝试加载server.js是错误的- 您必须调用require('./server')
  • jxcore.tasks.runOnce(code, ...)是错误的 - 应该是jxcore.tasks.runOnce(method, ...)
  • jxcore.tasks.runOnce没有收到回调参数，所以我删除了这个。

另一件事是，在您的回调中，您试图将一个对象发送到主线程（process.sendToMain({started:true})），但是您在server.js（jxcore.tasks.on('message')）中找到了侦听器，实际上它被加载到了一个线程中（因此它不是主线程）并且消息无法到达那里。

于 2015-01-15T13:12:28.603 回答