cicv_data_closed_loop/pji/control/pkg/cfg/control_rpc_client.go

package cfg

import (
	"cicv-data-closedloop/common/config/c_log"
	"cicv-data-closedloop/pji/common/cfg"
	"net/rpc"
	"os"
)

var KillRpcClient *rpc.Client

func InitRpcClient() {
	var err error
	KillRpcClient, err = rpc.Dial("tcp", cfg.CloudConfig.Hosts[0].Ip+":"+cfg.CloudConfig.RpcPort)
	if err != nil {
		c_log.GlobalLogger.Error("创建rpc连接master失败，程序退出：", err)
		os.Exit(-1)
	}
}