fix: conn nil

pkg/mqtt/connection.go

@@ -317,15 +317,15 @@ func (c *Connection) RcvMsgFromClient() {
 func (c *Connection) SendMsgToClient() {
 	c.mLock.Lock()
 	c.mLock.Unlock()
-	if c.Conn == nil {
-		return
-	}
 	host := c.Conn.RemoteAddr()
 	for {
 		select {
 		case <-c.closeChan:
 			return
 		case msg, ok := <-c.SendChan:
+			if c.Conn == nil {
+				return
+			}
 			if !ok {
 				server.Log.Errorf("%s is end now", host)
 				return