如何在PHP中使用命名管道在不同的函数甚至不同的进程之间没有分叉？

Question

我想写一个Ajax网络应用程序，具体来说是一个游戏。两个Web客户端必须通过PHP服务器相互通信。我解决这个问题的方法是在客户端和服务器以及服务器和客户端之间使用Ajax。每个客户端使用Ajax创建一个单独的服务器进程。我希望这两个服务器进程通过MySQL和命名管道进行通信。我需要命名管道来立即响应整个应用程序。

我不能使用一个服务器进程，它首先创建一个管道，然后分叉成两个进程，这两个进程使用管道。当Web浏览器发送请求时，Web应用程序创建服务器进程。因此，我需要命名管道，其中每个进程只知道命名管道的文件名。他们不能交换文件句柄（至少我不知道如何交换）。

我的问题是，只要在同一个函数中使用，以PHP方式命名的管道确实可以工作：

public function writeAndReadPipe_test(){
    $pipeA = fopen("testpipe",'r+');
    fwrite($pipeA, 'ABCD');

    $pipeB = fopen("testpipe",'r+');
    $content = fread($pipeB, 4);
    echo "[" . $content . "]<br>\n";
}

public function testingPipes_same_function(){
    posix_mkfifo("testpipe", 0777);
    $this->writeAndReadPipe_test();
}

但是，当我使用不同的函数时，fread（$pipeB，4）命令会阻塞整个应用程序：

public function writePipe_test(){
    $pipeA = fopen("testpipe",'r+');
    fwrite($pipeA, 'ABCD');
}

public function readPipe_test(){
    $pipeB = fopen("testpipe",'r+');
    $content = fread($pipeB, 4);
    echo "[" . $content . "]<br>\n";
}

public function testingPipes_different_functions(){
    posix_mkfifo("testpipe", 0777);
    $this->writePipe_test();
    $this->readPipe_test();
}

有人知道为什么吗？在第一步，我能做些什么来使它在不同的功能之间工作？在第二步中，它甚至应该在不同的过程之间工作！我发现，当作者在读者阅读之前关闭管道时，我也会遇到一个问题。我假设函数在结束时自动关闭它，但这只是一种猜测。

如果PHP方式不起作用，我计划让PHP打开一个命令行，生成BASH命令并让它们执行。只要我的网络服务器在LAMP环境中工作，这在任何情况下都应该有效。缺点是它不能在WAMP环境中工作。

那么，有人对此有什么想法吗？

我需要阻塞管道，让读者等待事件发送。我知道管道可以在非阻塞模式下使用

stream_set_blocking($pipe,false);

或者是这样，但是整个想法是不使用轮询来完成，只使用管道，一旦事件被触发，管道就会唤醒读取器。

Answer 1

我不确定我是否理解你最后的第二篇帖子。。

但是评论一下最后一个，如果我没有误解的话，TCP可能会更复杂，因为你必须在读写之前建立一个连接，所以你有不同的开销

至于功能端的管道手柄关闭，我假设您将面临与套接字相同的问题；但是管道文件仍然存在！

持久存储（文件，数据库）将使客户端在时间上独立，如果你想使用阻塞调用，那么文件实际上可能是一种方法...

Answer 2

当您像这样在单独的函数中使用管道时，写入管道A似乎再次被关闭/丢弃（$pipeA的本地范围）。假设管道必须打开以供读取和/或写入，以便保留任何信息，这真的很有意义。虽然我不知道内在的魔力。

您还可以观察到，当您从另一个进程馈送管道时，您的阻塞读取调用成功

如果你改变它如下工作：

    private $pipeA;
    public function writePipe_test(){
        $this->pipeA = fopen("testpipe",'r+');
        fwrite($this->pipeA, 'ABCD');
    }

编辑：或者将$pipeA设置为全局范围。。

Answer 3

只是一个简短的声明，我实际上找到了一个很好的解决方案，使用命名管道：

public function createPipe_test(){
    posix_mkfifo("testpipe", 0777);
}

public function writePipe_test($value){
    $pipeA = fopen("testpipe",'w');
    $valueString = number_format($value);
    $valueLen = number_format(strlen($valueString));
    fwrite($pipeA, $valueLen);
    fwrite($pipeA, $valueString);
}

public function readPipe_test(){
    $pipeB = fopen("testpipe",'r');
    $valueLen = fread($pipeB, 1);
    return fread($pipeB, $valueLen);
}

我有两个过程。

如果进程1调用writepe_test（），则它将等待进程2调用readPipe_test（）从管道中读取数据。

如果进程1调用readPipe_test（），则它会等到进程2调用writePipe_test（）将某些内容写入管道。

诀窍是“w”和“r”而不是“r”。