package main
|
|
import (
|
"context"
|
"flag"
|
"math/rand"
|
"path"
|
"serfNode/ipc"
|
"serfNode/vrrp"
|
"serfNode/webServer"
|
|
"serfNode/config"
|
"serfNode/serf"
|
|
"basic.com/valib/logger.git"
|
_ "basic.com/valib/version.git"
|
)
|
|
var (
|
procName = "serfNode"
|
Priority int
|
Vrrp bool
|
)
|
|
func init() {
|
flag.IntVar(&Priority, "pri", 0, "router priority")
|
flag.BoolVar(&Vrrp, "vrrp", false, "enable vrrp")
|
|
// 日志初始化
|
var logFile = path.Join(config.LogConf.Path, procName+".log")
|
logger.InitLogger(logFile, config.LogConf.Level, config.LogConf.MaxSize, config.LogConf.MaxBackups, config.LogConf.MaxAge)
|
logger.Info("log init success !")
|
}
|
|
func main() {
|
flag.Parse()
|
|
// 如果未配置优先级, 先使用一个随机数, 用作节点选举
|
if Priority == 0 {
|
Priority = rand.Intn(100)
|
}
|
|
// 通过node-red读取集群配置
|
if err := ipc.GetConfigFromNodeRed(); err != nil {
|
logger.Error(err.Error())
|
return
|
}
|
|
// 启动serf节点
|
ctx := context.Background()
|
if err := serf.InitAgent(ctx, *config.SerfConf); err != nil {
|
logger.Debug("err:", err)
|
return
|
}
|
|
// 启动web通信服务
|
go webServer.Serve(config.WebConf.Port)
|
|
ipc.InitNsqClient()
|
|
// 启动vrrp服务
|
if Vrrp {
|
go vrrp.Start(Priority)
|
}
|
|
select {}
|
}
|
