Go语言进程间通信（IPC）策略：优化本地服务交互

// 服务器端
type Args struct {
    A, B int
}

type Reply struct {
    C int
}

type Arith int

func (t *Arith) Add(args *Args, reply *Reply) error {
    reply.C = args.A + args.B
    return nil
}

// 在main函数中注册服务并监听
// rpc.Register(new(Arith))
// listener, _ := net.Listen("tcp", ":1234")
// rpc.Accept(listener)

// 客户端
// client, _ := rpc.Dial("tcp", "localhost:1234")
// args := &Args{7, 8}
// var reply Reply
// client.Call("Arith.Add", args, &reply)
// fmt.Println(reply.C) // 15

// 发送方
// enc := gob.NewEncoder(conn) // conn 是一个网络连接
// err := enc.Encode(myDataStruct)

// 接收方
// dec := gob.NewDecoder(conn)
// var receivedData MyDataStruct
// err := dec.Decode(&receivedData)

package main

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

func main() {
    socketPath := "/tmp/unix.sock"
    os.Remove(socketPath) // 确保文件不存在

    // 启动服务器
    go func() {
        listener, err := net.Listen("unix", socketPath)
        if err != nil {
            fmt.Println("Server listen error:", err)
            return
        }
        defer listener.Close()
        fmt.Println("Server listening on", socketPath)

        conn, err := listener.Accept()
        if err != nil {
            fmt.Println("Server accept error:", err)
            return
        }
        defer conn.Close()
        fmt.Println("Server accepted connection")

        buf := make([]byte, 512)
        n, err := conn.Read(buf)
        if err != nil && err != io.EOF {
            fmt.Println("Server read error:", err)
            return
        }
        fmt.Printf("Server received: %s\n", string(buf[:n]))

        _, err = conn.Write([]byte("Hello from server!"))
        if err != nil {
            fmt.Println("Server write error:", err)
            return
        }
    }()

    time.Sleep(100 * time.Millisecond) // 等待服务器启动

    // 客户端连接
    conn, err := net.Dial("unix", socketPath)
    if err != nil {
        fmt.Println("Client dial error:", err)
        return
    }
    defer conn.Close()
    fmt.Println("Client connected")

    _, err = conn.Write([]byte("Hello from client!"))
    if err != nil {
        fmt.Println("Client write error:", err)
        return
    }

    buf := make([]byte, 512)
    n, err := conn.Read(buf)
    if err != nil && err != io.EOF {
        fmt.Println("Client read error:", err)
        return
    }
    fmt.Printf("Client received: %s\n", string(buf[:n]))
}