构建稳定的PHP与Go Unix域套接字通信：连接管理与最佳实践

func echoServer(c net.Conn){
    buf := make([]byte, 512)
    size, err := c.Read(buf)
    if err != nil {
        log.Fatal("Read error: ", err)
    }
    data := buf[0:size]     
    fmt.Println("Server received: ", string(data))

    t := time.Now()
    retMsg := fmt.Sprintf("OK+ at %s", t)
    size, err = fmt.Fprintln(c, retMsg) // 发送响应

    if err == nil{
        fmt.Println("Wrote this many bytes: ", size)
    } else {
        log.Fatal("Write error: ", err)
    }
    // 注意：此处缺少连接关闭操作
}

ob_implicit_flush();
$socket_file = "/tmp/odc_ws.sock";

if (($socket = socket_create(AF_UNIX, SOCK_STREAM, 0)) === false) {
    echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "<br>";
}
if (socket_connect($socket, $socket_file) === false) {
    echo "socket_connect() failed: reason: " . socket_strerror(socket_last_error($sock)) . "<br>";
}

$msg = 'PHP sent Go a message at ' . date('H:i:s');
$write_res = socket_write($socket, $msg, $msg_len = strlen($msg));
if($write_res != $msg_len){
    echo '<div>Socket write error: ' . socket_strerror( socket_last_error($socket) ) . '</div>';
}

// 循环读取服务器响应
while($read = socket_read($socket, 512, PHP_NORMAL_READ)){
    echo "<div>Server says: $read</div>";
}
socket_close($socket);

package main

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

const socket_addr = "/tmp/odc_ws.sock"

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)
    size, err = fmt.Fprintln(c, retMsg)     

    if err == nil{
        fmt.Println("Wrote this many bytes: ", size)
    } else {
        log.Println("Write error: ", err) // 使用Println而非Fatal
        return
    }
}

func main(){
    // 确保在程序启动前移除可能存在的旧套接字文件
    if err := os.RemoveAll(socket_addr); err != nil {
        log.Fatal("Failed to remove old socket file: ", err)
    }

    l, err := net.Listen("unix", socket_addr)
    if err != nil{
        fmt.Printf("Error listening on Unix socket: %s\n", err) // 使用Printf更规范
        return
    }
    defer l.Close() // 确保监听器关闭
    fmt.Printf("Go server listening on %s\n", socket_addr)

    for{
        fd, err := l.Accept()
        if err != nil{
            log.Fatal("Accept error", err)
        }
        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) {
    // 错误处理时，socket_last_error()需要传入socket资源
    echo "socket_connect() failed: reason: " . socket_strerror(socket_last_error($socket)) . "<br>"; 
    socket_close($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>";

// 循环读取服务器响应，直到服务器关闭连接
$response_received = false;
while($read = socket_read($socket, 512, PHP_NORMAL_READ)){
    if ($read === false) { // 错误或连接关闭
        break;
    }
    echo "<div>Server says: $read</div>";
    $response_received = true;
    // 如果是单次请求/响应模式，收到数据后可以考虑跳出循环
    // 但更健壮的方式是等待远程关闭，PHP_NORMAL_READ会处理换行符
}

if (!$response_received) {
    echo "<div>No response received or connection closed prematurely.</div>";
}

// 关闭PHP客户端套接字
socket_close($socket);
echo "<div>Connection closed by PHP.</div>";
?>