Method webSocketHandler

http/websocket/websocket/server.go:254–291

(w http.ResponseWriter, r *http.Request)

}

func (self *WsServer) webSocketHandler(w http.ResponseWriter, r *http.Request) {
	wsConn, err := self.Upgrader.Upgrade(w, r, nil)
	if err != nil {
		log.Error("websocket Upgrader: ", err)
		return
	}
	wsConn.SetReadLimit(1024 * 1024)
	defer wsConn.Close()
	nsSession, err := self.SessionList.NewSession(wsConn)
	if err != nil {
		log.Error("websocket NewSession:", err)
		return
	}

	defer func() {
		self.deleteTxHashes(nsSession.GetSessionId())
		self.deleteSubscribe(nsSession.GetSessionId())
		self.SessionList.CloseSession(nsSession)
		if err := recover(); err != nil {
			log.Fatal("websocket recover:", err)
		}
	}()

	for {
		_, bysMsg, err := wsConn.ReadMessage()
		if err == nil {
			if self.OnDataHandle(nsSession, bysMsg, r) {
				nsSession.UpdateActiveTime()
			}
			continue
		}
		e, ok := err.(net.Error)
		if !ok || !e.Timeout() {
			log.Infof("websocket conn:", err)
			return
		}
	}
}
func (self *WsServer) IsValidMsg(reqMsg map[string]interface{}) bool {
	if _, ok := reqMsg["Hash"].(string); !ok && reqMsg["Hash"] != nil {
		return false