PHP 中的 Unix 域套接字通信

Unix 域套接字（Unix Domain socket）是同一主机上进程间通信（IPC）的高效方式，PHP 提供了完整的 API 支持这种通信机制。以下是其知识体系与底层原理：

一、知识体系详解

1. 基本概念与特点

• 定义：一种用于同一主机内不同进程间通信的机制，通过文件系统中的特殊文件作为通信端点
• 与 TCP 套接字的区别：
  • 仅用于本地通信，不支持跨主机
  • 标识为文件路径（如 /tmp/mysocket.sock）而非 IP:端口
  • 无需经过网络协议栈，性能更高（延迟降低约 50%）
  • 传输数据不需要封装 TCP/IP 头部，开销更小
• 应用场景：
  • Web 服务器与后端服务通信（如 Nginx 与 PHP-FPM）
  • 同一服务器上的微服务间通信
  • 进程间数据共享与命令传递

2. PHP 相关函数与扩展

• 核心函数（基于 ext-sockets 扩展）：

  • socket_create_domain(AF_UNIX)：创建 Unix 域套接字
  • socket_bind()：绑定到文件系统路径
  • socket_listen()：监听连接（服务端）
  • socket_accept()：接受连接（服务端）
  • socket_connect()：连接到服务器套接字（客户端）
  • socket_send()/socket_recv()：发送/接收数据
  • socket_close()：关闭套接字

• 流套接字函数（基于 PHP 流封装）：

  • stream_socket_server('unix:///tmp/sock.sock', ...)：创建服务端
  • stream_socket_client('unix:///tmp/sock.sock')：创建客户端
  • fwrite()/fread()：通过流操作发送/接收数据

3. 通信模式

• 流式套接字（SOCK_STREAM）：

  • 类似 TCP，提供可靠的双向字节流
  • 保证数据顺序和完整性，支持大数据传输
  • 适用于大多数需要可靠通信的场景

• 数据报套接字（SOCK_DGRAM）：

  • 类似 UDP，无连接、不可靠但速度更快
  • 数据以消息包形式发送，有大小限制
  • 适用于对实时性要求高、可容忍少量丢包的场景

4. 权限与安全

• 套接字文件权限：通过文件系统权限控制访问（通常设置为 0660）
• 路径选择：建议放在 /var/run/ 或 /tmp/ 目录
• 安全最佳实践：
  • 限制文件权限，避免全局可访问
  • 使用完后及时删除套接字文件
  • 验证通信内容，防止恶意数据注入

5. 典型应用架构

• C/S 模型：
  • 服务端：持续运行，监听并处理客户端请求
  • 客户端：按需连接服务端，发送请求并接收响应
• 长连接 vs 短连接：
  • 长连接：保持连接状态，适合频繁通信
  • 短连接：一次通信后关闭，适合偶尔通信

二、底层原理

1. 通信机制实现

• 内核介导：数据不经过网络协议栈，由内核直接在进程间转发
• 文件系统映射：套接字文件仅作为标识，实际通信在内存中进行
• 缓冲区管理：内核为每个套接字维护读写缓冲区，实现异步通信

2. 连接建立过程

1. 服务端初始化：

   • 创建套接字（socket() 系统调用）
   • 绑定到文件系统路径（bind() 系统调用）
   • 开始监听连接（listen() 系统调用）
   • 进入循环等待连接（accept() 系统调用，阻塞）

2. 客户端连接：

   • 创建客户端套接字（socket()）
   • 连接到服务端套接字文件（connect() 系统调用）
   • 内核权限检查（验证客户端对套接字文件的读写权限）
   • 内核创建连接对象，关联两个套接字

3. 数据传输：

   • 发送方通过 send() 写入数据到内核缓冲区
   • 内核将数据从发送方缓冲区复制到接收方缓冲区
   • 接收方通过 recv() 从缓冲区读取数据

3. PHP 实现的底层映射

• PHP 套接字函数最终调用操作系统的系统调用：
  • socket_create() → 内核 socket() 调用
  • socket_bind() → 内核 bind() 调用
  • socket_connect() → 内核 connect() 调用
• 流套接字函数通过 PHP 流封装层间接调用相同系统调用
• 错误处理：PHP 将内核返回的错误码转换为可读性更强的错误信息

4. 性能优势的技术原因

• 减少上下文切换：避免网络协议栈的多层处理
• 省略协议处理：无需 TCP 握手、校验和计算、路由等
• 内存高效：数据在内核空间直接复制，减少用户态/内核态切换
• 文件系统权限集成：直接利用成熟的文件权限系统进行访问控制

三、实践示例

1. 流式套接字服务端

<?php
// 创建Unix域流式套接字
$socket = socket_create(AF_UNIX, SOCK_STREAM, 0);
if (!$socket) {
    die("socket_create() failed: " . socket_strerror(socket_last_error()));
}

// 绑定到套接字文件
$socketPath = '/tmp/php_unix_socket.sock';
if (file_exists($socketPath)) {
    unlink($socketPath);
}
if (socket_bind($socket, $socketPath) === false) {
    die("socket_bind() failed: " . socket_strerror(socket_last_error($socket)));
}

// 设置权限（允许同组访问）
chmod($socketPath, 0660);

// 开始监听，最多允许5个等待连接
if (socket_listen($socket, 5) === false) {
    die("socket_listen() failed: " . socket_strerror(socket_last_error($socket)));
}

echo "Server listening on $socketPath...\n";

// 接受并处理连接
while (true) {
    $client = socket_accept($socket);
    if ($client === false) {
        echo "socket_accept() failed: " . socket_strerror(socket_last_error($socket)) . "\n";
        continue;
    }
    
    // 读取客户端数据
    $data = socket_read($client, 1024);
    echo "Received: $data\n";
    
    // 发送响应
    $response = "Hello from server: " . $data;
    socket_write($client, $response, strlen($response));
    
    // 关闭客户端连接
    socket_close($client);
}

// 关闭服务器套接字（实际不会执行到这里）
socket_close($socket);
unlink($socketPath);
?>

2. 流式套接字客户端

<?php
// 创建客户端套接字
$socket = socket_create(AF_UNIX, SOCK_STREAM, 0);
if (!$socket) {
    die("socket_create() failed: " . socket_strerror(socket_last_error()));
}

// 连接到服务器
$socketPath = '/tmp/php_unix_socket.sock';
if (socket_connect($socket, $socketPath) === false) {
    die("socket_connect() failed: " . socket_strerror(socket_last_error($socket)));
}

// 发送数据
$message = "Hello from client!";
socket_write($socket, $message, strlen($message));

// 接收响应
$response = socket_read($socket, 1024);
echo "Server response: $response\n";

// 关闭连接
socket_close($socket);
?>

3. 使用流函数的简化实现

// 服务端
$server = stream_socket_server('unix:///tmp/stream_socket.sock', $errno, $errstr);
if (!$server) {
    die("stream_socket_server() failed: $errstr ($errno)");
}

while ($conn = stream_socket_accept($server)) {
    $data = fread($conn, 1024);
    fwrite($conn, "Received: $data");
    fclose($conn);
}
fclose($server);

// 客户端
$client = stream_socket_client('unix:///tmp/stream_socket.sock', $errno, $errstr);
if (!$client) {
    die("stream_socket_client() failed: $errstr ($errno)");
}
fwrite($client, "Hello via stream!");
echo fread($client, 1024);
fclose($client);

四、常见问题与解决方案

1. 权限问题

• 错误：Permission denied
• 解决：确保套接字文件权限正确，客户端用户属于适当的组

2. 套接字文件残留

• 错误：Address already in use
• 解决：程序退出时删除套接字文件，启动前检查并清理残留文件

3. 数据截断

• 错误：接收数据不完整
• 解决：实现循环读取，直到获取完整数据或超时

4. 性能优化

• 使用非阻塞模式处理多个连接
• 合理设置缓冲区大小
• 长连接场景下定期发送心跳包检测连接状态

PHP 中的 Unix 域套接字通信是构建高效本地服务间交互的重要方式，特别适合需要低延迟、高吞吐量的本地进程间通信场景。理解其底层原理有助于设计更高效、更安全的通信方案。