目前gproc组件提供的进程通信特性属于实验性特性!

    不要通过共享内存来通信,而应该通过通信来共享内存。

    常见的进程通信方式有5种:管道/信号/共享内存/共享文件/Socket,这几种方式通常有着各自比较擅长的使用场景。

    • 信号:信号常用在*nix系统中,跨平台性比较差,信息传递方式和内容单一。
    • 管道:包括普通管道命名管道,这种方式在子父进程通信场景比较常用,跨不同关系进程之间通信不太适用。
    • 共享内存/共享文件:按照并发架构的设计来讲,我们尽可能地少用锁机制,包括共享内存(内存锁)/共享文件(文件锁)其实都是需要依靠锁机制才能保证数据流的正确性,因为锁机制带来的维护复杂度往往会比其带来的收益更高。

    gproc实现的进程通信主要机制采用的是Socket,这种机制优点是功能比较稳定、使用场景比较通用。

    gproc的进程通信API非常简便,只需通过以下两个方法实现:

    1. func Send(pid int, data []byte) error
    2. func Receive() *Msg

    我们通过Send方法向指定的进程发送数据(每调用一次相当于发送一条消息),在指定的进程中可以通过Receive方法获得数据。其中,Receive方法提供了类似消息队列的形式来收取其他进程传递的数据,当队列为空时,该方法将会阻塞等待。

    我们来看一个进程间通信的基本使用示例:

    1. package main
    2. import (
    3. "context"
    4. "fmt"
    5. "github.com/gogf/gf/v2/os/gctx"
    6. "github.com/gogf/gf/v2/os/gproc"
    7. "github.com/gogf/gf/v2/os/gtime"
    8. "github.com/gogf/gf/v2/os/gtimer"
    9. "os"
    10. "time"
    11. )
    12. var (
    13. ctx = gctx.New()
    14. )
    15. func main() {
    16. fmt.Printf("%d: I am child? %v\n", gproc.Pid(), gproc.IsChild())
    17. if gproc.IsChild() {
    18. gtimer.SetInterval(ctx, time.Second, func(ctx context.Context) {
    19. err := gproc.Send(gproc.PPid(), []byte(gtime.Datetime()))
    20. if err != nil {
    21. return
    22. }
    23. })
    24. select {}
    25. } else {
    26. m := gproc.NewManager()
    27. p := m.NewProcess(os.Args[0], os.Args, os.Environ())
    28. p.Start(ctx)
    29. for {
    30. msg := gproc.Receive()
    31. fmt.Printf("receive from %d, data: %s\n", msg.SenderPid, string(msg.Data))
    32. }
    33. }
    34. }

    该示例中,我们的主进程启动时创建了一个子进程,该子进程每隔1秒钟向主进程发送当前的时间,主进程收取到子进程发送的参数后输出到终端上。执行后,终端输出的内容如下:

    1. 29978: I am child? false
    2. 29984: I am child? true
    3. receive from 29984, data: 2018-05-18 15:01:00
    4. receive from 29984, data: 2018-05-18 15:01:01
    5. receive from 29984, data: 2018-05-18 15:01:02
    6. receive from 29984, data: 2018-05-18 15:01:03
    7. receive from 29984, data: 2018-05-18 15:01:04
    8. ...