PHP与Go通过Unix域套接字进行进程间通信的实践指南

package main

import (
    "fmt"
    "log"
    "net"
    "os"
    "time"
)

const socketAddr = "/tmp/odc_ws.sock"

// echoServer 处理单个客户端连接
func echoServer(c net.Conn) {
    // 确保在函数结束时关闭连接，这是解决PHP阻塞问题的关键
    defer c.Close() 

    buf := make([]byte, 512)
    size, err := c.Read(buf)
    if err != nil {
        log.Printf("Read error: %v", err) // 使用Printf而不是Fatal，避免单个连接错误导致服务器退出
        return
    }
    data := buf[0:size]
    fmt.Printf("Server received: %s\n", string(data))

    // 构建响应消息
    t := time.Now()
    retMsg := fmt.Sprintf("OK+ at %s", t.Format("15:04:05"))

    // 将响应写入连接
    writtenBytes, err := fmt.Fprintln(c, retMsg) // fmt.Fprintln 会自动添加换行符
    if err != nil {
        log.Printf("Write error: %v", err)
        return
    }
    fmt.Printf("Wrote %d bytes: %s\n", writtenBytes, retMsg)
}

func main() {
    // 启动前清理旧的套接字文件，避免绑定失败
    if err := os.RemoveAll(socketAddr); err != nil {
        log.Fatalf("Failed to remove old socket file: %v", err)
    }

    // 监听Unix域套接字
    l, err := net.Listen("unix", socketAddr)
    if err != nil {
        log.Fatalf("Failed to listen on Unix socket: %v", err)
    }
    defer l.Close() // 确保主程序退出时关闭监听器

    fmt.Printf("Go server listening on %s\n", socketAddr)

    for {
        // 接受新的客户端连接
        fd, err := l.Accept()
        if err != nil {
            log.Fatalf("Accept error: %v", err) // 接受连接错误通常是严重问题
        }
        // 为每个连接启动一个goroutine处理
        go echoServer(fd)
    }
}

<?php
// 开启隐式刷新，确保缓冲区内容立即发送到浏览器
ob_implicit_flush(); 

$socket_file = "/tmp/odc_ws.sock";

// 创建Unix域套接字
if (($socket = socket_create(AF_UNIX, SOCK_STREAM, 0)) === false) {
    echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "<br>";
    exit();
}

// 连接到Go服务器
if (socket_connect($socket, $socket_file) === false) {
    echo "socket_connect() failed: reason: " . socket_strerror(socket_last_error($socket)) . "<br>";
    // 注意：socket_last_error() 应该传入 $socket 才能获取到当前套接字的错误
    exit();
}

$msg = 'PHP sent Go a message at ' . date('H:i:s');
$msg_len = strlen($msg);

// 写入数据到套接字
$write_res = socket_write($socket, $msg, $msg_len);
if ($write_res === false || $write_res != $msg_len) {
    echo '<div>Socket write error: ' . socket_strerror(socket_last_error($socket)) . '</div>';
    socket_close($socket);
    exit();
}
echo "<div>PHP sent: $msg</div>";

// 从套接字读取数据，直到Go服务器关闭连接
while ($read_data = socket_read($socket, 512, PHP_NORMAL_READ)) {
    // PHP_NORMAL_READ 模式会读取到换行符或达到指定长度
    // 当Go服务器关闭连接时，socket_read 会返回 FALSE
    echo "<div>Server says: $read_data</div>";
    // 如果Go服务器发送的是单行响应，通常一次读取即可
    // 如果Go服务器发送多行，此循环会继续
    break; // 对于单次请求/响应模式，读取一次后即可跳出
}

// 关闭套接字连接
socket_close($socket);
echo "<div>Connection closed.</div>";

?>