如何在node.js中创建命名管道?

iyr7buue  于 2023-03-07  发布在  Node.js
关注(0)|答案(3)|浏览(166)

如何在node. js中创建命名管道?
注:现在我正在创建一个命名管道,如下所示。但我认为这不是最好的方法

var mkfifoProcess = spawn('mkfifo',  [fifoFilePath]);
mkfifoProcess.on('exit', function (code) {
    if (code == 0) {
        console.log('fifo created: ' + fifoFilePath);
    } else {
        console.log('fail to create fifo with code:  ' + code);
    }
});
uajslkp6

uajslkp61#

在Windows上使用命名管道

节点版本0.12.4

var net = require('net');

var PIPE_NAME = "mypipe";
var PIPE_PATH = "\\\\.\\pipe\\" + PIPE_NAME;

var L = console.log;

var server = net.createServer(function(stream) {
    L('Server: on connection')

    stream.on('data', function(c) {
        L('Server: on data:', c.toString());
    });

    stream.on('end', function() {
        L('Server: on end')
        server.close();
    });

    stream.write('Take it easy!');
});

server.on('close',function(){
    L('Server: on close');
})

server.listen(PIPE_PATH,function(){
    L('Server: on listening');
})

// == Client part == //
var client = net.connect(PIPE_PATH, function() {
    L('Client: on connection');
})

client.on('data', function(data) {
    L('Client: on data:', data.toString());
    client.end('Thanks!');
});

client.on('end', function() {
    L('Client: on end');
})
    • 输出:**
Server: on listening
Client: on connection
Server: on connection
Client: on data: Take it easy!
Server: on data: Thanks!
Client: on end
Server: on end
Server: on close

有关管道名称的注意事项:
C/C ++/节点:
\\.\pipe\PIPENAME * 创建命名管道 *
. Net/动力 shell :
\\.\PIPENAME * 命名管道客户端流/命名管道服务器流 *
两者都将使用文件句柄:
\Device\NamedPipe\PIPENAME

dgenwo3n

dgenwo3n2#

看起来Node核心不支持名称管道,也不会支持-来自Ben Noordhuis 10/11/11:
Windows有命名管道的概念,但由于您提到mkfifo,我假设您指的是UNIX FIFO。
我们不支持它们,而且可能永远不会支持(非阻塞模式下的FIFO有可能导致事件循环死锁),但是如果需要类似的功能,可以使用UNIX套接字。
https://groups.google.com/d/msg/nodejs/9TvDwCWaB5c/udQPigFvmgAJ
命名管道和套接字非常相似,但是net模块通过指定path而不是hostport来实现本地套接字:

  • http://nodejs.org/api/net.html#net_server_listen_path_callback
  • http://nodejs.org/api/net.html#net_net_connect_path_connectlistener

示例:

var net = require('net');

var server = net.createServer(function(stream) {
  stream.on('data', function(c) {
    console.log('data:', c.toString());
  });
  stream.on('end', function() {
    server.close();
  });
});

server.listen('/tmp/test.sock');

var stream = net.connect('/tmp/test.sock');
stream.write('hello');
stream.end();
vdzxcuhz

vdzxcuhz3#

可能使用fs.watchFile而不是命名管道?请参阅文档

相关问题