当前位置: 首页 > news >正文

go游戏后端开发29:实现游戏内聊天

接下来,我们再来开发一个功能,这个功能相对简单,就是聊天。在游戏里,我们会收到一个聊天请求,我们只需要做一个聊天推送即可。具体来说,就是谁发的消息,就推送给所有人,包括消息内容等信息。

为了实现这个功能,我们需要在合适的位置进行消息搜索。首先,我们要把消息搜出来。在搜索时,我们会参考笔记里的一些信息,比如 idtype(消息类型,不同发消息的情况会有不同的类型)、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),然后发送消息,比如“快点吧”。可以看到,消息成功发出且其他人也能收到,相当于所有人都能看到这条消息。这就是一个简单的聊天功能实现。

http://www.dtcms.com/a/122873.html

相关文章:

  • 用 HTML 网页来管理 Markdown 标题序号
  • 【微服务架构】SpringCloud Alibaba(九):分布式事务Seata使用和源码分析(TCC模式、Saga模式)
  • 分布式锁阿
  • 软件功能性测试有多重要?功能性测试工具有哪些?
  • Cocos Creator新手学习
  • day25学习Pandas库
  • mysql的主从复制
  • 中文语义相似度 + 去除标签后的网页文本(爬虫数据)
  • 彩色路径 第32次CCF-CSP计算机软件能力认证
  • 服务器运维ACL访问控制列表如何配置
  • 【Leetcode-Hot100】字母异位词分组
  • echarts图表相关
  • 【智能体开发】智能体前后端开发方案
  • 信奥赛之c++课后练习题及解析(算数运算符)
  • Java学习总结-线程池
  • 【NLP 56、实践 ⑬ LoRA完成NER任务】
  • 【golang】堆和栈的区别
  • MySQL主从复制技术详解:原理、实现与最佳实践
  • Docker与Kubernetes在ZKmall开源商城容器化部署中的应用
  • Linux内核页表缓存(TLB)与巨型页
  • 使用Alamofire下载网站首页内容
  • PDFBox/Itext5渲染生成pdf文档
  • Php laravel 留言板 curd 实战
  • 2025数据库系统工程师上午考试知识点汇总
  • 【C++游戏引擎开发】第10篇:AABB/OBB碰撞检测
  • error: RPC failed; HTTP 408 curl 22 The requested URL returned error: 408
  • 【大模型理论篇】关于生成式模型中联合分布概率学习必要性以及GPT是生成式模型的讨论
  • 【ida】ida笔记
  • C语言指针和函数
  • CSS 笔记——Flexbox(弹性盒布局)