Go 两个本地进程怎么通过 Unix Socket 通信

如果两个 Go 进程只在同一台 Linux 或 macOS 主机上通信，Unix Socket 通常比专门占用 TCP 端口更直接：服务端监听一个文件路径，客户端用同一路径拨号，连接建立后仍然可以使用熟悉的 Read、Write 接口。最小可用组合是 net.ListenUnix、AcceptUnix 和 DialUnix，再配一个明确的消息分隔规则。

实战中建议先用 unix 网络名实现流式请求-响应：服务端负责 socket 文件生命周期，客户端设置连接超时，双方用换行或长度前缀界定一条消息。这样既能跑通两个本地进程，也不会把一次 Read 误当成完整报文。

先确定 Unix Socket 的地址和消息边界

Unix Socket 的地址不是端口号，而是本机文件系统中的路径，例如 /tmp/go-echo.sock。服务端和客户端必须使用同一个路径，路径所在目录要允许服务进程创建文件。本文使用 unix，它提供面向连接的字节流；因此一次写入不等于对端一次读取，必须自己规定“读到哪里算一条消息”。

服务端用 ListenUnix 和 AcceptUnix 接收连接

服务端先把路径封装为 net.UnixAddr，再调用 ListenUnix("unix", addr)。路径已经存在时，监听可能失败，所以清理动作必须限定在自己明确管理的路径上，不能对任意文件直接删除。拿到监听器后，AcceptUnix 返回一个连接，连接处理函数可以独立读取请求并写回响应。

package main

import (
    "bufio"
    "fmt"
    "net"
    "os"
)

const socketPath = "/tmp/go-echo.sock"

func main() {
    // 只清理本示例固定管理的 socket 路径，避免误删普通文件。
    _ = os.Remove(socketPath)
    addr := &net.UnixAddr{Name: socketPath, Net: "unix"}
    listener, err := net.ListenUnix("unix", addr)
    if err != nil {
        panic(err)
    }
    defer listener.Close()
    // 让监听器关闭时一并清理由本次 ListenUnix 创建的路径。
    listener.SetUnlinkOnClose(true)

    conn, err := listener.AcceptUnix()
    if err != nil {
        panic(err)
    }
    defer conn.Close()
    request, err := bufio.NewReader(conn).ReadString('\n')
    if err != nil {
        panic(err)
    }
    // 响应也带换行，客户端才能知道本条消息已经结束。
    _, _ = fmt.Fprintf(conn, "收到: %s", request)
}

这里的关键不是把服务端写得很长，而是保持资源边界清楚：监听器负责接收连接，UnixConn 负责一条会话，读取器负责把字节流切成按行消息。真实服务通常会把 AcceptUnix 放入循环，并为每个连接启动处理函数；单次示例则更容易观察生命周期。

客户端用 DialUnix 发送请求并读取响应

客户端可以把远端地址传给 net.DialUnix，本地地址传 nil，让系统选择临时地址。连接成功后先写入带换行的请求，再用读取器等待响应。若服务端尚未启动、路径写错或权限不允许访问，拨号阶段就会返回错误，应该把它和“服务端读不到消息”区分开。

package main

import (
    "bufio"
    "fmt"
    "net"
    "time"
)

func main() {
    addr := &net.UnixAddr{Name: "/tmp/go-echo.sock", Net: "unix"}
    // 使用带超时的 Dialer，避免服务端缺席时无限等待。
    dialer := net.Dialer{Timeout: 3 * time.Second}
    conn, err := dialer.Dial("unix", addr.String())
    if err != nil {
        panic(err)
    }
    defer conn.Close()
    _ = conn.SetDeadline(time.Now().Add(5 * time.Second))

    // 换行是本文约定的消息边界，不能省略。
    if _, err := fmt.Fprintln(conn, "ping from client"); err != nil {
        panic(err)
    }
    response, err := bufio.NewReader(conn).ReadString('\n')
    if err != nil {
        panic(err)
    }
    fmt.Print(response)
}

为了让客户端代码可以复用 TCP 风格的调用方式，这里使用 Dialer.Dial；如果需要明确得到 *net.UnixConn，也可以用 net.DialUnix("unix", nil, addr)。两者都要把地址和网络名配对，不能把文件系统路径交给 tcp。

把清理、超时和权限纳入本地通信边界

最常见的故障是“第一次能启动，第二次提示地址已被占用”。原因往往是上次进程异常退出后留下了 socket 文件。可以在启动时只清理应用自己声明的固定路径，也可以把运行目录放在专用临时目录中。监听器关闭时，SetUnlinkOnClose(true) 能表达清理意图，但不要把它当作跨平台所有实现都一致的替代方案，启动清理仍要有明确边界。

第二个坑是阻塞。ReadString 会等待换行或错误，客户端没有设置期限时，服务端不响应就可能一直挂住；SetDeadline 同时约束读写，若读写方向需要不同期限，应改用 SetReadDeadline 和 SetWriteDeadline。第三个坑是权限：socket 文件的访问权限决定同机哪些用户可以连接，敏感服务应把路径放到权限受控目录，并在应用层再做身份或请求校验。

• 只用 unix 时按字节流设计协议；需要固定报文边界时再评估 unixpacket。
• 请求、响应都带换行，或改用长度前缀；不要依赖一次 Write 对应一次 Read。
• 服务端循环接受连接时，每个连接都要关闭；退出路径要关闭监听器并清理受控 socket 文件。

相关问题

Unix Socket 能替代所有 TCP 通信吗？

不能。它适合同一台主机内的进程间通信，不负责跨主机连接；跨机器仍应选择 TCP 或其他网络协议。

为什么 socket 文件存在就无法再次 ListenUnix？

路径通常仍指向上次监听创建的文件。确认没有旧服务占用后，再清理应用自己拥有的路径，不能盲目删除未知文件。

为什么客户端 ReadString 一直不返回？

读取器在等待换行，而服务端没有发送分隔符，或者服务端尚未写响应。统一消息格式并设置读取期限即可把问题暴露出来。