背景
我正在开发一个当前通过 Process.Start() 运行 Node 的 C# 程序。我正在从这个子进程中捕获标准输出和标准错误,并出于我自己的原因重定向它。我正在考虑用对 Edge.js 的调用来替换 Node.exe 的调用。为了能够做到这一点,我必须能够从 Edge 中运行的 Javascript 可靠地捕获 stdout 和 stderr,并将消息返回到我的 C# 应用程序中。
方法一
如果有人推荐它,我将描述这种方法的完整性:)
msgs
如果 Edge 进程终止,通过简单地声明一个数组并覆盖process.stdout.write
并process.stderr.write
使用在该数组上累积消息的新函数,然后在最后简单地返回该数组来处理这个问题是相当容易的msgs
。例子:
var msgs = [];
process.stdout.write = function (string) {
msgs.push({ stream: 'o', message : string });
};
process.stderr.write = function (string) {
msgs.push({ stream: 'e', message: string });
};
// Return to caller.
var result = { messages: msgs; ...other stuff... };
callback(null, result);
显然,这仅在 Edge 代码终止时才有效,并且在最坏的情况下 msgs 可能会变大。但是,它可能表现良好,因为只需要一次编组调用即可获取所有消息。
方法二
这有点难以解释。我们不是累积消息,而是使用从 C# 发送的委托来“挂钩”stdout 和 stderr。在 C# 中,我们创建一个将传递给 Edge 的对象,该对象有一个名为 的属性stdoutHook
:
dynamic payload = new ExpandoObject();
payload.stdoutHook = GetStdoutHook();
public Func<object, Task<object>> GetStdoutHook()
{
Func<object, Task<object>> hook = (message) =>
{
TheLogger.LogMessage((message as string).Trim());
return Task.FromResult<object>(null);
};
return hook;
}
我真的可以使用 Action,但 Edge 似乎需要Func<object, Task<object>>
,否则它不会代理该功能。然后,在 Javascript 中,我们可以检测到该函数并像这样使用它:
var func = Edge.Func(@"
return function(payload, callback) {
if (typeof (payload.stdoutHook) === 'function') {
process.stdout.write = payload.stdoutHook;
}
// do lots of stuff while stdout and stderr are hooked...
var what = require('whatever');
what.futz();
// terminate.
callback(null, result);
}");
dynamic result = func(payload).Result;
问题
Q1。这两种技术似乎都有效,但是有没有更好的方法来做到这一点,Edge 内置的东西可能我错过了?这两种解决方案都是侵入性的——它们需要一些 shim 代码来包装要在 Edge 中完成的实际工作。这不是世界末日,但如果有一种非侵入性的方法会更好。
Q2。在方法 2 中,我必须在这里返回一个任务
return Task.FromResult<object>(null);
返回一个已经完成的“空任务”感觉不对。但是还有另一种写法吗?
Q3。在挂钩 stdout 和 stderr 时,我是否需要在 Javascript 代码中更加严格?我注意到在 double-edge.js 中有这段代码,坦率地说我不确定这里发生了什么,但它比我对 process.stdout.write 的粗略覆盖要复杂得多 :-)
// Fix #176 for GUI applications on Windows
try {
var stdout = process.stdout;
}
catch (e) {
// This is a Windows GUI application without stdout and stderr defined.
// Define process.stdout and process.stderr so that all output is discarded.
(function () {
var stream = require('stream');
var NullStream = function (o) {
stream.Writable.call(this);
this._write = function (c, e, cb) { cb && cb(); };
}
require('util').inherits(NullStream, stream.Writable);
var nullStream = new NullStream();
process.__defineGetter__('stdout', function () { return nullStream; });
process.__defineGetter__('stderr', function () { return nullStream; });
})();
}