使用 Go 实现进程间通信 (IPC) 的方法-Golang-PHP中文网

使用 Go 实现进程间通信 (IPC) 的方法

心靈之曲

发布： 2025-08-26 21:24:02

原创

338人浏览过

使用 go 实现进程间通信 (ipc) 的方法

本文探讨了在 Go 语言中实现进程间通信（IPC）的多种方法。针对负载均衡服务器与本地应用服务器通信的需求，详细介绍了 Go 内置的 RPC 系统和基于 gob 编码的网络通信方式。同时，强调了本地网络通信（如命名管道）的实用性，并建议在考虑共享内存之前进行性能基准测试，以选择最适合的 IPC 方案。

在 Go 语言中，实现进程间通信（IPC）有多种选择，每种方法都有其优缺点，适用于不同的场景。本文将介绍几种常用的 IPC 方法，并提供相应的示例和建议。

1. Go 内置的 RPC 系统

Go 语言提供了一个内置的 RPC (Remote Procedure Call) 系统，它使得在不同的 Go 进程之间进行通信变得非常容易。RPC 允许一个进程调用另一个进程中的函数，就像调用本地函数一样。

使用 Go 的 RPC 系统，你需要定义一个服务接口，并在服务端和客户端分别实现该接口。

服务端示例：

package main

import (
    "fmt"
    "net"
    "net/rpc"
)

type Args struct {
    A, B int
}

type Quotient struct {
    Quo, Rem int
}

type Arith int

func (t *Arith) Multiply(args *Args, reply *int) error {
    *reply = args.A * args.B
    return nil
}

func (t *Arith) Divide(args *Args, quo *Quotient) error {
    if args.B == 0 {
        return fmt.Errorf("divide by zero")
    }
    quo.Quo = args.A / args.B
    quo.Rem = args.A % args.B
    return nil
}

func main() {
    arith := new(Arith)
    rpc.Register(arith)

    l, e := net.Listen("tcp", ":1234")
    if e != nil {
        fmt.Println("listen error:", e)
        return
    }

    for {
        conn, err := l.Accept()
        if err != nil {
            fmt.Println("accept error:", err)
            continue
        }
        go rpc.ServeConn(conn)
    }
}

登录后复制

客户端示例：

通义万相

通义万相，一个不断进化的AI艺术创作大模型

596

查看详情

package main

import (
    "fmt"
    "log"
    "net/rpc"
    "os"
)

type Args struct {
    A, B int
}

type Quotient struct {
    Quo, Rem int
}

func main() {
    if len(os.Args) != 2 {
        fmt.Println("Usage: ", os.Args[0], " server")
        os.Exit(1)
    }
    serverAddress := os.Args[1]

    client, err := rpc.Dial("tcp", serverAddress+":1234")
    if err != nil {
        log.Fatal("dialing:", err)
    }

    // Synchronous call
    args := Args{17, 8}
    var reply int
    err = client.Call("Arith.Multiply", &args, &reply)
    if err != nil {
        log.Fatal("arith error:", err)
    }
    fmt.Printf("Arith.Multiply: %d*%d=%d\n", args.A, args.B, reply)

    // Asynchronous call
    quotient := new(Quotient)
    divCall := client.Go("Arith.Divide", args, quotient, nil)
    replyCall := <-divCall.Done // will be same as divCall
    // check errors, print, etc.
    if replyCall.Error != nil {
        log.Fatal("arith error:", err)
    }
    fmt.Printf("Arith.Divide: %d/%d=%d remainder %d\n", args.A, args.B, quotient.Quo, quotient.Rem)
}

登录后复制

注意事项：

RPC 使用 TCP 连接进行通信，因此需要确保防火墙允许相应的端口。
RPC 系统对数据类型有一定的限制，需要使用可以被编码和解码的类型。

2. 使用 gob 编码进行网络通信

另一种实现 IPC 的方法是使用 encoding/gob 包，通过网络连接发送 gob 编码的数据。gob 是一种 Go 特有的二进制编码格式，可以高效地序列化和反序列化 Go 的数据结构。

服务端示例：

package main

import (
    "encoding/gob"
    "fmt"
    "net"
    "os"
)

type Message struct {
    Content string
}

func handleConnection(conn net.Conn) {
    defer conn.Close()

    dec := gob.NewDecoder(conn)
    var msg Message
    err := dec.Decode(&msg)
    if err != nil {
        fmt.Println("Error decoding message:", err)
        return
    }

    fmt.Println("Received message:", msg.Content)
}

func main() {
    listener, err := net.Listen("tcp", ":1234")
    if err != nil {
        fmt.Println("Error listening:", err)
        os.Exit(1)
    }
    defer listener.Close()

    fmt.Println("Server listening on :1234")

    for {
        conn, err := listener.Accept()
        if err != nil {
            fmt.Println("Error accepting connection:", err)
            continue
        }

        go handleConnection(conn)
    }
}

登录后复制

客户端示例：

package main

import (
    "encoding/gob"
    "fmt"
    "net"
    "os"
)

type Message struct {
    Content string
}

func main() {
    conn, err := net.Dial("tcp", "localhost:1234")
    if err != nil {
        fmt.Println("Error connecting:", err)
        os.Exit(1)
    }
    defer conn.Close()

    enc := gob.NewEncoder(conn)
    msg := Message{Content: "Hello from client!"}
    err = enc.Encode(msg)
    if err != nil {
        fmt.Println("Error encoding message:", err)
        return
    }

    fmt.Println("Message sent to server.")
}

登录后复制

注意事项：