PHP 进程间通信：方法、应用与实践要点

2026-03-11 12:10:02 7226阅读

在 PHP 开发中，随着业务需求的日益复杂，单个进程往往难以满足性能和功能上的要求。这时，进程间通信（Inter - Process Communication，简称 IPC）就成为了一个关键的技术。通过进程间通信，不同的 PHP 进程可以相互协作，共享数据，从而提高系统的整体性能和可扩展性。本文将详细介绍 PHP 中常见的进程间通信方法及其应用场景。

管道通信

管道是一种最基本的进程间通信方式，它分为匿名管道和命名管道。

匿名管道

匿名管道只能在具有亲缘关系的进程间使用，通常是父子进程。在 PHP 中，可以使用 proc_open 函数来创建匿名管道。以下是一个简单的示例：

<?php
// 定义要执行的命令
$descriptorspec = array(
    0 => array("pipe", "r"),  // 标准输入
    1 => array("pipe", "w"),  // 标准输出
    2 => array("pipe", "w")   // 标准错误
);

// 打开一个进程
$process = proc_open('php -r \'$input = fgets(STDIN); echo "Process received: ". $input;\'', $descriptorspec, $pipes);

if (is_resource($process)) {
    // 向子进程的标准输入写入数据
    fwrite($pipes[0], "Hello from parent process!\n");
    fclose($pipes[0]);

    // 读取子进程的标准输出
    $output = stream_get_contents($pipes[1]);
    fclose($pipes[1]);

    // 读取子进程的标准错误
    $errors = stream_get_contents($pipes[2]);
    fclose($pipes[2]);

    // 关闭进程
    $return_value = proc_close($process);

    echo "Output: ". $output;
    echo "Errors: ". $errors;
    echo "Return value: ". $return_value;
}
?>

在这个示例中，父进程通过匿名管道向子进程发送数据，子进程接收数据并返回处理结果。

命名管道

命名管道可以在不相关的进程间进行通信。在 PHP 中，可以使用 posix_mkfifo 函数创建命名管道。以下是一个简单的示例：

<?php
// 定义命名管道的路径
$pipeName = '/tmp/myfifo';

// 创建命名管道
if (!file_exists($pipeName)) {
    posix_mkfifo($pipeName, 0666);
}

// 打开命名管道进行写入
$pipe = fopen($pipeName, 'w');
fwrite($pipe, "Message from writer process");
fclose($pipe);
?>

读取命名管道的示例：

<?php
// 定义命名管道的路径
$pipeName = '/tmp/myfifo';

// 打开命名管道进行读取
$pipe = fopen($pipeName, 'r');
$message = fread($pipe, 8192);
fclose($pipe);

// 删除命名管道
unlink($pipeName);

echo "Received message: ". $message;
?>

消息队列

消息队列是一种异步通信机制，进程可以将消息发送到队列中，其他进程可以从队列中接收消息。在 PHP 中，可以使用 msg_* 系列函数来操作消息队列。以下是一个简单的示例：

<?php
// 创建或获取一个消息队列
$queue = msg_get_queue(ftok(__FILE__, 'a'));

// 发送消息到队列
$message = "This is a test message";
msg_send($queue, 1, $message);

// 从队列中接收消息
msg_receive($queue, 1, $msgtype, 1024, $receivedMessage);

echo "Received message: ". $receivedMessage;

// 删除消息队列
msg_remove_queue($queue);
?>

在这个示例中，一个进程将消息发送到消息队列，另一个进程从队列中接收消息。

共享内存

共享内存是一种高效的进程间通信方式，多个进程可以直接访问同一块物理内存。在 PHP 中，可以使用 shm_* 系列函数来操作共享内存。以下是一个简单的示例：

<?php
// 创建或获取一个共享内存段
$key = ftok(__FILE__, 'a');
$shmid = shm_attach($key, 1024);

// 向共享内存中写入数据
$data = array('name' => 'John', 'age' => 30);
shm_put_var($shmid, 1, $data);

// 从共享内存中读取数据
$readData = shm_get_var($shmid, 1);
print_r($readData);

// 从共享内存中删除数据
shm_remove_var($shmid, 1);

// 分离共享内存段
shm_detach($shmid);
?>

在这个示例中，一个进程将数据写入共享内存，另一个进程可以从共享内存中读取数据。

信号量

信号量是一种用于控制多个进程对共享资源访问的机制。在 PHP 中，可以使用 sem_* 系列函数来操作信号量。以下是一个简单的示例：

<?php
// 创建或获取一个信号量
$key = ftok(__FILE__, 'a');
$sem = sem_get($key);

// 获取信号量
sem_acquire($sem);

// 访问共享资源
echo "Accessing shared resource...\n";

// 释放信号量
sem_release($sem);

// 删除信号量
sem_remove($sem);
?>

在这个示例中，进程通过获取和释放信号量来控制对共享资源的访问。