修改存过函数名

api/grpc/base.go

@@ -1434,6 +1434,7 @@ func (Api) UserListenMsg(_ *pb.DefaultRequest, stream pb.Api_UserListenMsgServer
 
 				err = stream.Send(pbMsg)
 				if err != nil {
+					// 接收不到不会err信息，可做异常处理
 					return
 				}
 			}

assembly/base/model/msg.go

@@ -1,8 +1,10 @@
 package model
 
 type Msg struct {
+	// 发送者
 	UserIdSend int
-	UserIdRcv  int
-	Title      string
-	Content    string
+	// 接收者
+	UserIdRcv int
+	Title     string
+	Content   string
 }

assembly/base/service/msg_bus.go

@@ -1,9 +1,10 @@
 package service
 
 import (
-	"github.com/sirupsen/logrus"
 	"sportfitness/base/assembly/base/model"
 	"sync"
+
+	"github.com/sirupsen/logrus"
 )
 
 // 监听列表， key: userId
@@ -40,5 +41,8 @@ func (MsgBus) SendMsg(msg model.Msg) {
 		default:
 			logrus.Errorf("向用户ID[%d]发送信息失败，chan满", msg.UserIdRcv)
 		}
-	}
+	} //else {
+	// 设备不在线时，可在此处理
+	//}
+
 }