构建PHP与Go的Unix域套接字通信：连接管理与实践指南

package main

import (
    "fmt"
    "log"
    "net"
    "os"
    "time" // 导入time包
)

const socketAddr = "/tmp/odc_ws.sock" // 定义Unix域套接字地址

// echoServer 处理单个客户端连接
func echoServer(c net.Conn) {
    defer c.Close() // 关键：确保连接在函数退出时关闭

    buf := make([]byte, 512) // 创建一个缓冲区用于读取数据
    size, err := c.Read(buf) // 从连接中读取数据
    if err != nil {
        log.Println("Read error:", err) // 使用Println而不是Fatal，避免程序退出
        return
    }
    data := buf[0:size]
    fmt.Println("Server received:", string(data))

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

    // 将响应写入连接，并确保发送换行符
    writtenSize, err := fmt.Fprintln(c, retMsg) 
    if err != nil {
        log.Println("Write error:", err) // 使用Println而不是Fatal
        return
    }
    fmt.Println("Wrote this many bytes:", writtenSize)
}

func main() {
    // 确保套接字文件不存在，避免绑定失败
    if _, err := os.Stat(socketAddr); err == nil {
        if err := os.Remove(socketAddr); err != nil {
            log.Fatalf("Failed to remove existing socket file: %v", err)
        }
    }

    l, err := net.Listen("unix", socketAddr) // 监听Unix域套接字
    if err != nil {
        log.Fatalf("Failed to listen on Unix socket: %v", err) // 使用Fatalf输出错误并退出
    }
    defer l.Close() // 确保监听器在main函数退出时关闭
    fmt.Printf("Go server listening on %s\n", socketAddr)

    for {
        fd, err := l.Accept() // 接受新的客户端连接
        if err != nil {
            log.Println("Accept error:", err) // 打印错误，但不退出，继续接受其他连接
            continue
        }
        go echoServer(fd) // 为每个连接启动一个goroutine处理
    }
}

<?php
ob_implicit_flush(); // 开启隐式刷新，确保输出立即发送

$socket_file = "/tmp/odc_ws.sock"; // 定义Unix域套接字地址

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

// 2. 连接到服务器
// 注意：socket_last_error() 在某些情况下需要传入套接字资源，但在连接失败时可能不需要
if (socket_connect($socket, $socket_file) === false) {
    // 尝试获取连接失败的错误信息
    $error_code = socket_last_error($socket);
    echo "socket_connect() failed: reason: " . socket_strerror($error_code) . "<br>";
    socket_close($socket);
    exit();
}

// 3. 构造并发送消息
$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();
} else {
    echo "<div>PHP sent $write_res bytes: '$msg'</div>";
}

// 4. 从服务器读取响应
// PHP_NORMAL_READ 标志指示 socket_read 读取到换行符或达到指定长度
echo "<div>Waiting for server response...</div>";
while (($read = socket_read($socket, 512, PHP_NORMAL_READ)) !== false && $read !== '') {
    echo "<div>Server says: " . htmlspecialchars($read) . "</div>";
    // 如果服务器关闭连接，socket_read 会返回 false 或空字符串，循环将终止
    // 如果服务器发送了多行数据，这里会逐行读取
}

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