IM消息架构主要有

1、消息redis缓存队列及用户信息memcache
2、消息的数据落地（入库mysql）
3、消息的发送
4、离线消息服务
5、过期消息服务

消息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接口请求还是可以从数据库中拉取到以往的消息。

IM 消息服务架构