From 38d3b7450e9b961deeeb2e7b670229710021e12d Mon Sep 17 00:00:00 2001 From: TsMask <340112800@qq.com> Date: Mon, 21 Aug 2023 18:48:40 +0800 Subject: [PATCH] =?UTF-8?q?=E5=90=AF=E5=8A=A8=E5=85=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- nbi_alarm_agent.go => nb_alarm_agent.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) rename nbi_alarm_agent.go => nb_alarm_agent.go (94%) diff --git a/nbi_alarm_agent.go b/nb_alarm_agent.go similarity index 94% rename from nbi_alarm_agent.go rename to nb_alarm_agent.go index b0916a1..a09657f 100644 --- a/nbi_alarm_agent.go +++ b/nb_alarm_agent.go @@ -2,6 +2,7 @@ package main import ( "fmt" + "github.com/aceld/zinx/zutils/commandline/args" "omc/conf" @@ -68,6 +69,7 @@ func OnConnectionLost(conn ziface.IConnection) { } +// go run nb_alarm_agent.go -c conf\nbi_alarm_agent.json func main() { //配置初始化 conf.Init(args.Args.ConfigFile) @@ -83,8 +85,8 @@ func main() { TCPPort: cg.TCPPort, Name: serverName, Host: "0.0.0.0", - MaxConn: 3000, - WorkerPoolSize: 10, + MaxConn: conf.OmcConf.MaxConn, + WorkerPoolSize: uint32(conf.OmcConf.WorkerPoolSize), HeartbeatMax: conf.OmcConf.HeartbeatMax, LogDir: conf.OmcConf.LogDir, LogFile: conf.OmcConf.LogFile, @@ -103,6 +105,8 @@ func main() { s.AddRouter(omc.ReqCMCALoginSeq, &api2.SyncAlarmFileApi{}) s.AddRouter(omc.ReqCMCALoginAlarm, &api2.SyncAlarmFileApi{}) + s.AddRouter(290, &api2.ServerRouter{}) + //添加LTV数据格式Decoder s.SetDecoder(decoder.NewOmcDecoder()) //添加LTV数据格式的Pack封包Encoder