php ipc实现
PHP IPC 实现方法
PHP 提供多种进程间通信(IPC)机制,适用于不同场景需求。以下是常见的实现方式:
共享内存(Shared Memory)
使用 shmop 或 sysvshm 扩展实现共享内存:
// 创建共享内存块
$shm_key = ftok(__FILE__, 't');
$shm_id = shmop_open($shm_key, "c", 0644, 100);
// 写入数据
$data = "IPC data";
shmop_write($shm_id, $data, 0);
// 读取数据
$read_data = shmop_read($shm_id, 0, shmop_size($shm_id));
消息队列(Message Queue)
通过 sysvmsg 扩展实现:
$msg_key = ftok(__FILE__, 'q');
$queue = msg_get_queue($msg_key, 0666);
// 发送消息
msg_send($queue, 1, "Message content");
// 接收消息
msg_receive($queue, 1, $msgtype, 1024, $message);
信号量(Semaphores)
用于进程同步:
$sem_key = ftok(__FILE__, 's');
$sem_id = sem_get($sem_key);
sem_acquire($sem_id);
// 临界区代码
sem_release($sem_id);
文件锁(File Locking)
通过文件系统实现简单IPC:
$fp = fopen("/tmp/ipc.lock", "w+");
if (flock($fp, LOCK_EX)) {
// 独占操作
flock($fp, LOCK_UN);
}
fclose($fp);
Unix Domain Sockets
高性能本地通信:
$socket = socket_create(AF_UNIX, SOCK_STREAM, 0);
socket_bind($socket, "/tmp/ipc.sock");
socket_listen($socket);
// 客户端连接
$client = socket_accept($socket);
socket_write($client, "Hello from server");
数据库存储
使用数据库表作为通信媒介:

$pdo = new PDO("mysql:host=localhost;dbname=ipc", "user", "pass");
$stmt = $pdo->prepare("INSERT INTO messages (content) VALUES (?)");
$stmt->execute(["IPC message"]);
选择建议
- 需要高性能时优先考虑共享内存或Unix Domain Sockets
- 简单场景可使用文件锁或数据库
- 复杂消息传递适合消息队列
- 多进程同步操作需要信号量
注意Windows系统对某些IPC方法的支持有限,需根据实际环境选择实现方式。






