接下来，我们再来开发一个功能，这个功能相对简单，就是聊天。在游戏里，我们会收到一个聊天请求，我们只需要做一个聊天推送即可。具体来说，就是谁发的消息，就推送给所有人，包括消息内容等信息。
为了实现这个功能，我们需要在合适的位置进行消息搜索。首先，我们要把消息搜出来。在搜索时，我们会参考笔记里的一些信息，比如 id、type（消息类型，不同发消息的情况会有不同的类型）、message（消息内容）以及收件人 ID（如果要发送给指定用户）。不过，我们这种消息一般是广播，发送给所有用户，所以通常都会成功。
有了这些信息后，我们对其进行解析，并返回结果。如果 type 等于聊天通知，我们就进入聊天相关流程，把用户 ID 等信息传递过去。之后，我们把消息原模原样地进行数据发送，即 send data。在发送过程中，我们会涉及聊天形式的编写等操作，最终实现消息发送。
具体代码如下：
func (g *GameFrame) onGameChat(user *proto.RoomUser, session *remote.Session, data MessageData) {
g.sendDataAll(GameChatPushData(user.ChairID, data.Type, data.Msg, data.RecipientID), session)
}
func (r *Room) SendDataAll(msg *stream.Msg, data any) {
users := make([]stream.PushUser, 0)
for _, v := range r.users {
users = append(users, stream.PushUser{
Uid: v.UserInfo.Uid,
ConnectorId: v.UserInfo.FrontendId,
})
}
r.ServerMessagePush(msg, users, data)
}
func (r *Room) ServerMessagePush(msg *stream.Msg, users []stream.PushUser, data any) {
pusher.GetPusher().Push(msg, users, data, "ServerMessagePush")
}
func (p *Pusher) Push(m *stream.Msg, users []stream.PushUser, data any, router string) {
msgData, _ := json.Marshal(data)
pm := stream.PushData{
Data: msgData,
Router: router,
}
upm := &stream.PushMessage{
Users: users,
PushData: pm,
Msg: m,
}
p.pushChan <- upm
}在实现后，我们重新启动程序，在相应位置创建房间并加入房间（如 411126），然后发送消息，比如“快点吧”。可以看到，消息成功发出且其他人也能收到，相当于所有人都能看到这条消息。这就是一个简单的聊天功能实现。