温馨提示:
本文最后更新于
2021-9-21,已超过半年没有更新,若内容或图片失效,请留言反馈。
IM消息架构主要有:
- 消息
redis
缓存队列及用户信息memcache
, 消息的数据落地mysql
- 消息发送
- 离线消息服务
- 过期消息服务
消息Redis缓存队列
服务端落地队列
-
客户端通过
HTTPS
请求通过接口将IM消息数据传递到服务器,服务器把消息数据写入随机分配的redis
队列中 -
服务器后台
loop
服务不停的读取前面的消息队列,从中取出数据,进行分析落地(将消息数据添加到不同分库中,并添加到消息发送队列中(根据消息中的数据把群中每个用户的消息都写入消息发送队列)。
消息发送
客户端通过 scoket(TCP)
连接到服务器的 swoole
服务,swoole
有一个 task
任务,这个任务就是一个循环 loop
服务,从前面存储到的消息发送队列中取出数据,根据数据中的消息接收者发送给消息接收者,从存储用户信息的 memcache
中取出用户的fd
和from_id
,如果有说明用户在线,直接发送给用户,并且存入离线消息队列中,以免客户端接收信息失败用于信息确认,如果用户不在线直接存入离线消息队列中。用户接受到消息后会向服务器发送一个命令的数据包确认收到消息,服务器收到后从离线消息中删除该条消息。
离线消息服务
客户端通过scoket(TCP)
连接到服务器的swoole
服务,用心跳保持长连接,客户端成功连接后swoole
会给客户端分配一个fd
(TCP客户端
连接的文件描述符),from_id
(TCP连接所在的Reactor线程ID
),我们将用户的fd
,from_id
等用户信息存储到memcache
中。同时客户端在连接成功后会发送一个带有请求离线消息的命令的数据包来请求离线消息,我们就将用户存储在离线消息redis
中的消息发送给客户端。
过期消息服务
放在离线消息redis
中的数据有一个过期处理,超过一定期限的消息将不再发送给用户,将过期的消息从redis
中删除,用户在客户端中通过HTTPS
接口请求还是可以从数据库中拉取到以往的消息。
评论一下?