通常,NoFlo 组件在接收某些输入(在本例中为要读取的文件路径)之前不会执行任何操作。从NoFlo 组件文档 http://noflojs.org/documentation/components/:
NoFlo 网络中组件的运行实例称为process。在进程接收数据之前,它应该inert,仅监听其输入端口。当网络启动时需要开始做某事的进程应该通过向它们发送初始信息包来触发。
你的最后一行.fbp 图定义 http://noflojs.org/documentation/fbp/正在发送字符串package.json
到 ReadFile 组件。
您还可以在将文件加载到 NoFlo 网络后以编程方式执行此操作:
noflo.loadFile(filepath, process.cwd(), function (network) {
// Now we have access to the NoFlo network instance
// Add Initial Information Packet programatically
network.graph.addInitial(someFileToRead, 'Read', 'in');
// Tell NoFlo to send the new IIPs
network.sendInitials();
});
导出的端口和子图
现在,还有一种更优雅的方法来做到这一点,即公开您的.fbp
文件作为 NoFlo 的 ComponentLoader 中的图形,然后像与任何其他组件交互一样与它交互。
要使您感兴趣的端口可从外部使用,您需要export他们。在这种情况下,至少是图中的 ReadFile IN 端口。这会将您的网络定义更改为:
# Export the filename port so it can be accessed from outside
INPORT=Read.IN:FILENAME
# The rest of the graph definition follows
Read(filesystem/ReadFile) OUT -> IN Display(core/Output)
(碰巧,这正是我在导出端口上使用的示例.fbp 语言定义 https://github.com/noflo/fbp#exporting-ports)
为了使你的图表可以作为一个组件使用,你需要将它保存到你的 Node.js 项目中(约定是graphs/
子目录)并将其注册到package.json
file:
{
"noflo": {
"graphs": {
"MyGraph": "graphs/MyGraph.fbp"
}
}
}
现在您可以将其视为任何其他组件。例如:
var loader = new noflo.ComponentLoader(__dirname);
loader.load('MyGraph', function (instance) {
// The instance is a running NoFlo subgraph with your graph definition
// Create a socket and attach it to the exported port
var filename = noflo.internalSocket.createSocket();
instance.inPorts.filename.attach(filename);
filename.send(someFileToRead);
filename.disconnect();
});
这是首选方法的原因之一是,您不仅可以使用它来发送 IIP,还可以将套接字附加到导出的输出端口并侦听它们上的事件。这样您就可以轻松地将任何 NoFlo 图用作 JavaScript 应用程序中的异步函数。