package ipc
|
|
import (
|
"encoding/json"
|
"errors"
|
"os"
|
"strconv"
|
|
"serfNode/config"
|
"serfNode/logger"
|
)
|
|
const (
|
configRequestUrl = "http://127.0.0.1:1880/config"
|
)
|
|
type ConfigResponse struct {
|
NodeName string `json:"nodename"`
|
VirtualIp string `json:"virtualip"`
|
NsqServerIp string `json:"nsqserverip"`
|
NsqServerPort string `json:"nsqserverport"`
|
EthDevice string `json:"ethdevice"`
|
}
|
|
// 响应的数据格式
|
/*
|
[
|
{
|
"nodename": "7876",
|
"virtualip": "7686",
|
"nsqserverip": "6786",
|
"nsqserverport": "67867",
|
"ethdevice": ""
|
}
|
]
|
*/
|
func GetConfigFromNodeRed() error {
|
config.SerfConf = &config.SerfConfig{
|
ClusterName: "aps-client-cluster",
|
NodeName: strconv.Itoa(os.Getpid()),
|
BindAddr: "0.0.0.0:5000",
|
RPCAddr: "0.0.0.0:7373",
|
RPCPort: 7373,
|
AuthKey: "cqmyg,ysdss",
|
}
|
|
body, err := HttpPost(configRequestUrl, nil)
|
|
var response []ConfigResponse
|
|
err = json.Unmarshal(body, &response)
|
if err != nil {
|
logger.Warn(err.Error())
|
} else {
|
if len(response) > 0 {
|
if response[0].NodeName == "" {
|
err = errors.New("node-red 返回节点名称为空")
|
return err
|
}
|
|
// 修改节点id
|
config.SerfConf.NodeName = response[0].NodeName
|
|
config.VRRPConf.VirtualIp = response[0].VirtualIp
|
|
config.NsqConf.ServerAddr = response[0].NsqServerIp + ":" + response[0].NsqServerPort
|
} else {
|
err = errors.New("node-red 响应内容为空")
|
}
|
}
|
|
return err
|
}
|
