Method Start

http/websocket/websocket/server.go:88–128

start websocket server

()

//start websocket server
func (self *WsServer) Start() error {
	wsPort := int(cfg.DefConfig.Ws.HttpWsPort)
	if wsPort == 0 {
		log.Error("Not configure HttpWsPort port ")
		return nil
	}
	self.registryMethod()
	self.Upgrader.CheckOrigin = func(r *http.Request) bool {
		return true
	}

	tlsFlag := false
	if tlsFlag || wsPort%1000 == rest.TLS_PORT {
		var err error
		self.listener, err = self.initTlsListen()
		if err != nil {
			log.Error("Https Cert: ", err.Error())
			return err
		}
	} else {
		var err error
		self.listener, err = net.Listen("tcp", ":"+strconv.Itoa(wsPort))
		if err != nil {
			log.Fatal("net.Listen: ", err.Error())
			return err
		}
	}
	var done = make(chan bool)
	go self.checkSessionsTimeout(done)

	self.server = &http.Server{Handler: http.HandlerFunc(self.webSocketHandler)}
	err := self.server.Serve(self.listener)

	done <- true
	if err != nil {
		log.Fatal("ListenAndServe: ", err.Error())
		return err
	}
	return nil

}

//registry handler method
func (self *WsServer) registryMethod() {