大家好,我是dandyhuang。记忆中,从大学接触编程开始,就觉得qq,wx这些聊天很神奇。就一直想弄明白它是怎么做的。直到毕业后,工作了一段时间这是根im相关的知识。golang中im鼻祖应该是毛老师(毛剑)的goim了。本期咱们还不做改代码分析,我们暂时简单的分析一下gim的实现。
gim
gim中,设计还是比较清晰的,花几天时间,基本上就搞清楚了。主要分为connect、logic、business三大模块,内部通过websocket、tcp、grpc协议进行通讯。思想理念和goim基本一致。涉及的中间件很少,所以建议看完gim再去看goim,会更容易理解一些。但gim还有很多缺陷,未完善,如果要使用到生产环境,还需要在做一定的修改。
- connect
维持与客户端的TCP和WebSocket长连接,心跳,以及TCP拆包粘包。通过connect发送消息编解码数据。如a、b同时和connect创建连接。a向b发送数据,通过先发送给connect,connect在中转到b。 - logic
设备信息,好友信息,群组信息管理,消息转发逻辑 - business
一个简单的业务服务器服务,可以根据自己的业务需求,进行扩展,但是前提是,你的业务服务器实现了business.int.proto接口
设备注册和用户登录
- 当设备和用户未注册时,需要调用注册接口。客户端可以根据自身设备id和用户id判断是否注册完成
- 当注册成功,向
connect
发起ws/tcp链接。connect
会校验链接的设备是否合法,失败关闭连接。成功返回登录成功消息。 -
connect
创建设备和connect
句柄映射关系。 - 创建协程,发送心跳包,维持ws和tcp之间的连接。conn.WS.SetReadDeadline和gn.WithTimeout(11*time.Minute)。心跳周期需要小于服务端连接的时间
- 创建协程,获取离线消息同步信息
- 创建协程,获取订阅获取广播消息
发送消息
- client A发送grpc消息给logic服务。
- logic校验A的信息和要发送的用户B。
- 持久化信息,获取用户B登录的所有设备,并将信息发送给Connect
- Connect获取对应要发送的设备的Conn句柄,发送websocket/tcp信息给B
大家可以添加我的wx一起探讨
我是dandyhuang_,码字不易,点个小赞,只希望大家能更加明白