mirror of
https://gitee.com/johng/gf
synced 2026-06-07 02:12:11 +08:00
45 lines
1.4 KiB
Go
45 lines
1.4 KiB
Go
// Copyright 2018 gf Author(https://github.com/gogf/gf). All Rights Reserved.
|
||
//
|
||
// This Source Code Form is subject to the terms of the MIT License.
|
||
// If a copy of the MIT was not distributed with this file,
|
||
// You can obtain one at https://github.com/gogf/gf.
|
||
// "不要通过共享内存来通信，而应该通过通信来共享内存"
|
||
|
||
package gproc
|
||
|
||
import (
|
||
"os"
|
||
|
||
"github.com/gogf/gf/container/gmap"
|
||
"github.com/gogf/gf/os/gfile"
|
||
"github.com/gogf/gf/util/gconv"
|
||
)
|
||
|
||
// 进程通信数据结构
|
||
type Msg struct {
|
||
SendPid int `json:"spid"` // 发送进程ID
|
||
RecvPid int `json:"rpid"` // 接收进程ID
|
||
Group string `json:"group"` // 分组名称
|
||
Data []byte `json:"data"` // 原始数据
|
||
}
|
||
|
||
// 本地进程通信接收消息队列(按照分组进行构建的map，键值为*gqueue.Queue对象)
|
||
var commReceiveQueues = gmap.NewStrAnyMap(true)
|
||
|
||
// (用于发送)已建立的PID对应的Conn通信对象，键值为一个Pool，防止并行使用同一个通信对象造成数据重叠
|
||
var commPidConnMap = gmap.NewIntAnyMap(true)
|
||
|
||
// 获取指定进程的通信文件地址
|
||
func getCommFilePath(pid int) string {
|
||
return getCommDirPath() + gfile.Separator + gconv.String(pid)
|
||
}
|
||
|
||
// 获取进程间通信目录地址
|
||
func getCommDirPath() string {
|
||
tempDir := os.Getenv(gPROC_TEMP_DIR_ENV_KEY)
|
||
if tempDir == "" {
|
||
tempDir = gfile.TempDir()
|
||
}
|
||
return tempDir + gfile.Separator + "gproc"
|
||
}
|