1

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 {

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()