PHP Unix域套接字详解：从socket_create到常驻进程IPC实战

第一次看到$sock socket_create(AF_UNIX, SOCK_STREAM, 0);这行 PHP我愣了一下。以前写网络程序不是 TCP 就是 UDP地址长这样127.0.0.1:9501突然冒出个AF_UNIX还拿文件路径当地址总觉得像在文件系统里打洞。后来在几个常驻 CLI 服务里把它跑顺才意识到这行代码是本地进程间通信IPC里最值得先弄明白的入口。这篇文章就把它当一头牛来解从三个参数、系统调用链、常见坑到常驻进程里的进阶姿势一次讲透。1. 一行代码的三层解剖域、类型、协议各是什么庖丁看牛不看整头牛而是看骨节、经络、缝隙。这行 PHP 也一样它由三个参数组成每一层都在缩小 socket 的选择范围AF_UNIX限定地址空间SOCK_STREAM限定传输语义0则让内核在某个协议族里挑出默认协议。三个参数叠在一起最终生成一个专门用于本机进程间通信的字节流套接字。1.1 AF_UNIX地址是文件而不是 IPAF_UNIX也叫AF_LOCAL是 Unix 域套接字。它的地址不是一个 IP 加端口而是一个文件系统路径。比如socket_bind($sock, /tmp/app.sock)之后/tmp/app.sock会变成一个类型为 socket 的节点ls -l看过去一般是srwxrwxrwx。这个路径就是服务端的“门牌号”客户端要连接时只要知道这个路径就行。它和普通文件完全不同。你不能拿file_get_contents(/tmp/app.sock)去读数据也不能用touch或unlink去创建/删除一个活跃的 socket 节点。它只负责在进程之间传递连接和数据不是“存放内容”的地方。可以这样类比TCP 服务是把信写好丢给本机邮局再由邮局派送到回环地址给自己Unix 域套接字则是两个程序之间直接焊了一根管子数据从管子一头进去另一头出来中途不需要封装成 IP 包。1.2 SOCK_STREAM 和 0字节流语义与默认协议选择SOCK_STREAM表示创建的是一个流式套接字。它的特征是有序、可靠、面向连接语义上和 TCP 很像但在 Unix 域里它不是 TCP既没有 IP 头也没有 TCP 头更没有网卡/MAC 地址的概念。和SOCK_DGRAM数据报套接字相比流式套接字不保留消息边界你连续两次socket_write的数据接收方可能一次就全读走也可能被拆成两段才读到。第三个参数0可能是这行代码里最容易被忽略的。它并不是“没有协议”而是让内核根据前面domain type的组合自动选择该协议族下的默认协议。对AF_UNIX来说协议族里只有一个本地协议所以0就是正确选择。作为对比socket_create(AF_INET, SOCK_STREAM, 0)会默认选择 TCP但更清晰的写法是socket_create(AF_INET, SOCK_STREAM, IPPROTO_TCP)。在 Unix 域场景下没有那么多分支写0非常自然不需要纠结。1.3 扩展未启用时这行代码甚至走不到执行socket_create属于 PHP 的sockets扩展这个扩展默认在不少环境里是未启用的。你写好了这行代码运行却报“未定义函数”或者“Call to undefined function socket_create()”问题很可能不是代码而是扩展没开。检查方式很简单php -m看输出里有没有sockets或者直接跑var_dump(function_exists(socket_create))。如果输出false要么在编译 PHP 时带上--enable-sockets要么在当前环境里启用扩展扩展。Docker 环境相对好办官方镜像里通常有一行专门编译扩展的命令。普通 Linux 环境改一下php.ini里extensionsockets.so就能解决。这个检查虽然基础但我见过不少人在这一点上卡了很久越往上排查越觉得诡异结果第一行就没过。2. 为什么本机进程间通信偏爱 Unix 域套接字性能、权限和适用场景很多 PHP 开发者第一次接触socket_create时下意识会用AF_INET 127.0.0.1做本机通信毕竟这一套大家更熟。但如果你需要的是同一台机器上的两个进程通信尤其是高频、小消息、已经在内网或本地部署的场景Unix 域套接字往往更合适。它和 TCP 回环地址的差距不是一两句“本机不走网卡”能说清的。2.1 省掉协议栈的那点事127.0.0.1的 TCP 通信虽然不经过物理网卡但内核仍然会走完整的 TCP/IP 协议栈组包、校验、序列号、拥塞控制这些逻辑一个不少。Unix 域套接字则把这些几乎全部省掉数据直接从发送进程的内核缓冲区搬运到接收进程像一个本地管道。短消息、高频连接这种场景下Unix 域套接字的延迟更低吞吐也更高。我在本机最小 echo 服务上做过简单对比通常能感觉到十几到几十个百分点的差距数据包越短小差距越明显。但要注意PHP 里真正的性能瓶颈有时不在协议栈而在扩展层造成的用户态/内核态切换次数。你每调一次socket_read或socket_writePHP 就要做一次系统调用。真正高并发的时候与其纠结AF_UNIX还是AF_INET不如先想清楚你的通信频率是不是高到系统调用本身成了问题。如果只是每天跑一次的后台任务选哪个都无所谓选你熟悉的就好。2.2 文件权限既是安全边界也是麻烦来源Unix 域套接字的一个好处是它受文件系统权限控制。你可以让一个 socket 文件只属于某个用户或组再通过权限位控制谁可以连接而不是像 TCP 那样只要端口能连通任何本机进程都能接入。这个特性在混部或多人共用一台服务器时很有用。但也正因为如此权限会成为排查问题的重灾区。服务端用 A 用户启动客户端用 B 用户运行socket_connect很可能直接返回Permission denied。你bind成功不代表客户端一定能连接成功最终能不能连取决于 socket 文件的权限位。常见做法是让两个进程使用同一个系统用户运行或者在 socket 路径上设置好目录和文件的权限必要时用chmod($path, 0777)打开限制但这只能用在安全边界清晰的场景。2.3 什么场景该用它什么场景别硬上Unix 域套接字适合单机内多个服务实例之间的通信比如本地命令通道、日志收集、内部 RPC、共享缓存代理。它不适合跨机器通信这是硬性限制。如果你有两个节点需要组网老老实实走 TCP 或更高层的消息队列。另外容器环境里还得注意只有当两个进程共享同一个文件系统命名空间、或者真在同一台宿主机上时Unix 域套接字才有效。跨容器但没共享文件系统的场景用 Unix 域套接字就是个隐蔽的坑。如果你只是想在 PHP-FPM 的请求里临时发一条消息给另一个进程用 Unix 域套接字反而增加复杂度不如直接写本地文件或用共享内存。选择它的标准很简单进程都在本机、要低延迟、要稳定的流式通信并且你有信心处理好文件路径、权限和清理问题。否则TCP 回环地止住够用。3. 从 create 到 accept一次最小可运行服务的完整握手链理论再熟不如能跑起来。这一节把整条链路走一遍服务端socket_create - socket_bind - socket_listen - socket_accept客户端socket_create - socket_connect - socket_write - socket_read。每个函数和 C 语言里的系统调用几乎一一对应这也是 PHPsockets扩展的一个特点它很低层你能看到真实的 Unix 编程长什么样。3.1 服务端create、bind、listen、accept先写一个极简的 Unix 域套接字服务端它监听/tmp/demo.sock收到一行文本后把内容转成大写返回然后关闭连接。为了演示先忽略复杂的并发串行处理一个连接再接受下一个。?php $path /tmp/demo.sock; // 清理上次遗留的 socket 文件 if (file_exists($path)) { unlink($path); } $server socket_create(AF_UNIX, SOCK_STREAM, 0); if ($server false) { $errno socket_last_error(); printf(create failed: %s\n, socket_strerror($errno)); exit(1); } // 把 socket 绑定到文件系统路径 if (!socket_bind($server, $path)) { $errno socket_last_error($server); printf(bind failed: %s\n, socket_strerror($errno)); socket_close($server); exit(1); } // 开始监听backlog 设为 8 if (!socket_listen($server, 8)) { $errno socket_last_error($server); printf(listen failed: %s\n, socket_strerror($errno)); socket_close($server); exit(1); } printf(listening on %s\n, $path); while (true) { $conn socket_accept($server); if ($conn false) { $errno socket_last_error($server); // 收到 SIGINT 等信号导致 accept 被中断时可以 continue 重试 if ($errno SOCKET_EINTR) { continue; } break; } // 按行读取PHP_NORMAL_READ 会阻塞到遇到换行符或流结束 $line socket_read($conn, 8192, PHP_NORMAL_READ); if ($line ! false $line ! ) { $line trim($line); $response strtoupper($line) . \n; socket_write($conn, $response, strlen($response)); } socket_close($conn); } socket_close($server); unlink($path);执行php server.php终端会输出listening on /tmp/demo.sock。这时另开一个终端运行客户端即可。服务端每次只处理一个连接连接处理完就关闭随后继续socket_accept等待下一个。代码里的socket_last_error($server)很关键函数失败时要立刻取出错误码否则后续操作可能把它覆盖掉。3.2 客户端connect 之后的读写客户端代码同样直白。先创建同类型套接字再socket_connect到服务端路径然后写入一行文本读取响应。?php $path /tmp/demo.sock; $client socket_create(AF_UNIX, SOCK_STREAM, 0); if ($client false) { $errno socket_last_error(); printf(create failed: %s\n, socket_strerror($errno)); exit(1); } if (!socket_connect($client, $path)) { $errno socket_last_error($client); printf(connect failed: %s\n, socket_strerror($errno)); socket_close($client); exit(1); } $msg hello unix socket\n; socket_write($client, $msg, strlen($msg)); $line socket_read($client, 8192, PHP_NORMAL_READ); if ($line ! false) { printf(response: %s, $line); } socket_close($client);运行客户端正常会输出response: HELLO UNIX SOCKET。如果先关掉服务端再跑客户端socket_connect会失败错误码多半是Socket refused也就是连接被拒绝。遇到这种情况先确认服务端进程是否还活着、socket 文件是否还存在再往下排查。3.3 错误不是靠猜是靠 last_error 和 strerrorsocket_*家族并没有像PDO那样抛出异常它默认返回false并设置一个内核错误码。你要自己把它取出来翻译成可读信息。每次失败后的标准动作是用socket_last_error($sock)拿到错误码再用socket_strerror($errno)转成文字最后用socket_clear_error($sock)清掉错误状态。用全局的socket_last_error()也可以但传参更可靠因为一个进程里可能同时握着多个 socket不要拿 A 套接字的失败去套 B 套接字的错误状态。开发阶段我习惯把错误码和错误信息同时打出来比如bind failed(98): Address already in use这样一眼能看到底层原因而不是只看到一个笼统的中文提示。4. 常驻进程里继续解剖非阻塞、select 和 stream 桥接上面的服务端能把一个客户端服务好但真实生产环境不可能一个连接处理完再处理下一个。客户端连接数多起来或者某个客户端长时间不发送数据串行accept循环就会卡住。这时候要把代码从“阻塞式一连接一处理”升级成“事件驱动、同时盯多个连接”的模式。4.1 accept 循环的阻塞陷阱socket_accept是一个阻塞调用默认会一直等下去直到有客户端连进来才返回。这意味着当你正在处理某个连接的读取时其他想连接的客户端都得排在后面。更糟糕的是如果某个客户端建立了连接但迟迟不发送数据socket_read也会阻塞后面的连接全部被堵死。解决思路有两个一是用pcntl_fork多进程每个连接交给子进程处理二是在单进程内用socket_select监听多个 socket 的可读事件。后者在 PHP 里更容易把逻辑讲清楚也不容易吃多进程共享资源的亏。真正的生产级代码我不会在 PHP CLI 里硬刚多进程更多是把 socket 转成 stream再套一层事件循环。4.2 用 socket_select 在 PHP 里同时盯着多个连接socket_select相当于把一组套接字交给内核去监听一旦其中某个变得可读它就返回并告诉你哪些套接字有事件。下面是一个骨架它同时监听服务端 socket 和一堆客户端连接谁有数据就处理谁不再按固定顺序阻塞。?php $server socket_create(AF_UNIX, SOCK_STREAM, 0); $path /tmp/demo.sock; if (file_exists($path)) unlink($path); socket_bind($server, $path); socket_listen($server, 8); $clients []; while (true) { $read $clients; $read[] $server; $write null; $except null; $n socket_select($read, $write, $except, 0, 200000); if ($n false) { $errno socket_last_error($server); if ($errno SOCKET_EINTR) { continue; } break; } if ($n 0) { continue; } foreach ($read as $key $sock) { if ($sock $server) { $conn socket_accept($server); if ($conn ! false) { $clients[] $conn; } continue; } $data socket_read($sock, 8192, PHP_BINARY_READ); if ($data false || $data ) { $idx array_search($sock, $clients, true); if ($idx ! false) { unset($clients[$idx]); } socket_close($sock); continue; } $resp strtoupper(trim($data)) . \n; socket_write($sock, $resp, strlen($resp)); } }这里把socket_accept放进$server可读事件里只有在有新连接到达时才调用避免了无谓的阻塞。普通客户端 socket 则可读时表示有数据到达或连接断开我用PHP_BINARY_READ尽量取走当前已经到达的数据块再根据约定处理。这个骨架没有做半包处理但已经能把“同时处理多个连接”的原理展示清楚。4.3 把 socket 转成 stream接入现成事件循环如果你不想自己维护一套 select 循环还有一个桥接办法socket_export_stream()可以把原生 socket 资源转成 PHP stream 资源之后就能用fread、fgets、stream_set_blocking以及stream_select这些更常见的流式写法。示例如下$conn socket_accept($server); $stream socket_export_stream($conn); stream_set_blocking($stream, false); $line fgets($stream);这个桥接的好处是很多现成的 PHP 事件循环库都建立在 stream 之上转成 stream 之后就能顺手接入。但要注意同一个底层连接不要混用socket_*和fread/fwrite一旦用socket_export_stream转出去后续读写尽量走 stream 接口否则资源状态可能乱掉。5. 实战中容易翻车的四个细节路径、权限、残留文件和消息边界理论讲完说点真正容易让人栽跟头的细节。每一个我都遇到过甚至有些是在线上环境里才暴露的。把这些记下来能帮你省掉几个小时。5.1 sun_path 的 108 字节上限Unix 域套接字的路径不是无限长的。内核里struct sockaddr_un的sun_path字段有限常见内核实现下只有大约 108 个字节。路径太长的话socket_bind会失败错误可能表现为bind failed或者File name too long。解决办法是把 socket 文件放到短路径比如/tmp/app.sock、/var/run/app.sock。开发时也要检查你拼接出来的路径长度别为了组织目录写出一串超长目录名。特别是在代码里动态生成路径、带上 UUID 或用户 ID 的时候更容易突然越过限制。5.2 socket 文件的属主、umask 和临时目录socket_bind成功创建 socket 文件时它的属主是当前 PHP 进程的运行用户权限位还受进程umask影响。如果你在 CLI 下用 root 启动服务端客户端用普通用户运行连接时轻则权限不足重则直接被拒。排查方法很直接ls -l /tmp/demo.sock看属主和权限。如果发现权限不对可以在 bind 之后执行chmod($path, 0777)或者设置好 socket 文件所在目录的权限让两个用户都能访问。生产环境更推荐统一运行用户而不是把 socket 文件设成全世界可写。5.3 重启即报 Address already in use这是最经典的一个坑。服务端进程被杀掉但/tmp/demo.sock文件还残留着。再次启动时socket_bind会发现路径已经被占用报Address already in use。不少人误以为是端口冲突其实只是残留的 socket 节点没删。所以在服务端启动时我一般会先判断文件是否存在存在就unlink就像前面示例里那样。但如果旧服务进程还活着贸然删掉旧 socket 文件再重新 bind会产生一个“新文件占新路径、旧进程占旧 inode”的分裂状态外部连接走新路径会进新服务走旧路径的旧连接还在旧进程里。开发环境无所谓生产环境要先确认旧进程确实退出了再清理文件。5.4 字节流没有信封协议自己定SOCK_STREAM是流式传输不保留消息边界。你调一次socket_write发出两条业务消息接收方一次socket_read可能把两条都读走也可能只读到第一条的一半。如果直接用PHP_NORMAL_READ按行读一旦业务消息又不是按行分隔就会乱套。成熟的方案是设计一个帧协议前四个字节表示消息体长度后面跟着消息体。发送方这样打包$body packet; $frame pack(N, strlen($body)) . $body; socket_write($sock, $frame, strlen($frame));接收方先读满四个字节得到长度再按长度读后续数据。这样即使底层把数据切碎你也能重组出完整消息。另外socket_write不能保证一次写完最好封装一个循环写入函数检查每次写入的字节数没写完就继续写剩余的。就我个人的实际体验来说Unix 域套接字在 PHP 里最舒服的组合是CLI 常驻进程跑一个服务端业务侧通过短连接发送消息双方用清晰的帧协议通信。别一上来就追求复杂的并发模型先把参数、权限、清理、边界这几个基本功搞扎实这行socket_create就不会再让你发怵。