diff --git a/server/imserver/WSPListener.go b/server/imserver/WSPListener.go index 24d54260..56662153 100644 --- a/server/imserver/WSPListener.go +++ b/server/imserver/WSPListener.go @@ -7,6 +7,7 @@ import ( "q5" "f5" "cs" + "mt" proto "github.com/golang/protobuf/proto" ) @@ -21,7 +22,8 @@ var wspListener = new (WSPListener) func (this *WSPListener) Init() { this.ch = make(chan *f5.MsgHdr) - listener, err := net.Listen("tcp", "0.0.0.0:8888") + listener, err := net.Listen("tcp", "0.0.0.0:" + + q5.ToString(mt.Table.IMServer.GetById(0).GetListenPort())) if err != nil { } else { diff --git a/server/imserver/app.go b/server/imserver/app.go index 5562ff5c..13bdda84 100644 --- a/server/imserver/app.go +++ b/server/imserver/app.go @@ -28,6 +28,7 @@ func (this *App) Init() { this.workList.Init(nil) f5.LoadMetaTable(mt.Table) fmt.Println("listen_port", mt.Table.IMServer.GetById(0).GetListenPort()) + handlerMgr.Init() wspListener.Init() go this.goReportServerState()