本文引用了架构师之路公众号作者沈剑的文章,内容有改动,感谢原作者。

1、前言我们平时在使用即时通讯应用时候,每当发出一条聊天消息,都希望对方尽快看到,并尽快回复,但对方到底有没有真的看到?我却并不知道。一个残酷的现实是,很多时候对方其实是早就已经看到了这条消息,但出出种种原因(大家都懂的),通常都是默默返回——假装没看见。像微信这样的熟人社交工具,在产品的设计理念上,为了保持使用者的隐私性,在线状态、已读回执等涉及隐私的功能,都没有提供。但很多时候,尤其商务、办公场合下,特别需要一种强反馈的工具,这对于打造高效的团队很有帮助(虽然员工很反感,但老板都喜欢这样的功能,哈哈)。目前市面上主流的移动端IM里,提供了已读回执的主要有阿里的钉钉、网易的易信、阿里的旺旺,如下图所示:▲ 上图从左至右分别为:钉钉、易信、旺旺(千牛)以阿里的钉钉为例,钉钉的产品定位是用于商务交流,其“强制已读回执”功能,让职场人无法再“假装不在线”、“假装没收到”。更有甚者,钉钉的群聊“强制已读回执”功能,甚至能够知道谁读了消息,谁没有读消息(老板的福音啊)。那么群聊消息的收发流程、消息的送达保证、已读回执机制,到底该怎么实现呢?这就是今天要讨论的话题。

学习交流:- 即时通讯开发交流3群:185926912[推荐](本文同步发布于:http://www.52im.net/thread-1611-1-1.html)

2、IM开发干货系列文章本文是系列文章中的第14篇,总目录如下:另外,如果您是IM开发初学者,强烈建议首先阅读《新手入门一篇就够:从零开发移动端IM》。

3、正文引言首先我们需要了解一下群消息的设计、投递流程以及可达性保证机制,因不是本文要讨论的重点,所以尽量言简意赅,更详细的资料请见下方的推荐文章列表。如您对聊天消息的投递和送达机制等尚无概念,可先读本系列文章的以下几篇,有助于您详细掌握这方面的内容:

4、群消息怎么设计?大家一起跟着楼主的节奏,一步一步来看群消息怎么设计。核心问题1:群消息,只存一份?还是,每个成员存一份?答:存一份,为每个成员设置一个群消息队列,会有大量数据冗余,并不合适。核心问题2:如果群消息只存一份,怎么知道每个成员读了哪些消息?答:可以利用群消息的偏序关系,记录每个成员的last_ack_msgid(last_ack_time),这条消息之前的消息已读,这条消息之后的消息未读。该方案意味着,对于群内的每一个用户,只需要记录一个值即可。解答上述两个核心问题后,很容易得到群消息的核心数据结构。群消息表:记录群消息

group_msgs(msgid, gid, sender_uid, time, content);各字段的含义为:消息ID,群ID,发送方UID,发送时间,发送内容。群成员表:记录群里的成员,以及每个成员收到的最后一条群消息

group_users(gid, uid, last_ack_msgid);各字段的含义为:群ID,群成员UID,群成员最后收到的一条群消息ID。

5、了解一下群消息发送的流程在核心数据结构设计完之后,一起来看看群消息发送的流程(本系列中的文章《IM群聊消息如此复杂,如何保证不丢不重?》详细讲解了这个过程,可以深入读一读)。业务场景:1)一个群中有A, uid1, uid2, uid3四名成员;

2)A, uid1, uid2在线,期望实时收到在线消息;

3)uid3离线,期望未来拉取到离线消息。其整个消息发送的流程1-4如上图:1)A发出群消息;

2)server收到消息后,一来要将群消息落地,二来要查询群里有哪些群成员,以便实施推送;

3)对于群成员,查询在线状态;

4)对于在线的群成员,实施推送。这个流程里,只要第二步消息落地完成,就能保证群消息不会丢失。核心问题3:如何保证接收方一定收到群消息?答:各个收到消息后,要修改各群成员的last_ack_msgid,以告诉系统,这一条消息确认收到了。在线消息,离线消息的last_ack_msgid的修改,又各有不同。对于在线的群友,收到群消息后,第一时间会ack、修改last_ack_msgid。对于离线的群友,会在下一次登录时,拉取未读的所有群离线消息,并将last_ack_msgid修改为最新的一条消息。核心问题4:如果ack丢失,群友会不会拉取重复的群消息?答:会,可以根据msgid在客户端本地做去重,即使系统层面收到了重复的消息,仍然可以保证良好的用户体验。上述流程,只能确保接收方收到消息,发送方仍然不知道哪些人在线阅读了消息,哪些人离线未阅读消息,并没有实现已读回执,那已读回执会对系统设计产生什么样的影响呢?

6、已读回执流程的设计前面的基础知识我们已经了解的差不多,本节来讨论本文的重点内容,即群聊已读回执流程到底该怎么设计。对于发送方发送的任何一条群消息,都需要知道,这条消息有多少人已读多少人未读,就需要一个基础表来记录这个关系。消息回执表:用来记录消息的已读回执

msg_acks(sender_uid, msgid, recv_uid, gid,if_ack);各字段的含义为:发送方UID,消息ID,回执方UID,群ID,回执标记。增加了已读回执逻辑后,群消息的流程会有细微的改变,见下图:接着,server收到消息后,除了要:1)将群消息落地;

2)查询群里有哪些群成员,以便实施推送;之外,还需要:3)插入每条消息的初始回执状态。接收方修改last_ack_msgid的流程,会变为:1)发送ack请求;

2)修改last_ack_msgid,并且,修改已读回执if_ack状态;

3)查询发送方在线状态;

4)向发送方实时推送已读回执(如果发送方在线);如果发送方不在线,ta会在下次登录的时候:5)从关联表里拉取每条消息的已读回执。这里的初步结论是:如果发送方在线:会实时被推送已读回执;

如果发送方不在线:会在下次在线时拉取已读回执。

7、已读回执流程优化方案再次详细的分析下,群消息已读回执的“消息风暴扩散系数”,假设每个群有200个用户,其中20%的用户在线,即40各用户在线。那么,群用户每发送一条群消息,会有:40个消息,通知给群友;

40个ack修改last_ack_msgid,发给服务端;

40个已读回执,通知给发送方。可见,其消息风暴扩散系数非常之大。同时:需要存储40条ack记录。群数量,群友数量,群消息数量越来越多之后,存储也会成为问题。是否有优化方案呢?群消息的推送,能否改为接收方轮询拉取?答:不能,消息接收,实时性是核心指标。对于last_ack_msgid的修改,真的需要每个群消息都进行ack么?答:其实不需要,可以批量ack,累计收到N条群消息(例如10条),再向服务器发送一次last_ack_msgid的修改请求,同时修改这个请求之前所有请求的已读回执,这样就能将40个发送给服务端的ack请求量,降为原来的1/10。会带来什么副作用?答:last_ack_msgid的作用是,记录接收方最近新取的一条群消息,如果不实时更新,可能导致,异常退出时,有一些群消息没来得及更新last_ack_msgid,使得下次登陆时,会拉取到重复的群消息。但这不是问题,客户端可以根据msgid去重,用户体验不会受影响。发送方在线时,对于已读回执的发送,真的需要实时推送么?答:其实不需要,发送方每发一条消息,会收到40个已读回执,采用轮询拉取(例如1分钟一次,一个小时也就60个请求),可以大大降低请求量。(画外音:或者直接放到应用层keepalive请求里,做到0额外请求增加。)会带来什么副作用?答:已读回执更新不实时,最坏的情况下,1分钟才更新回执。当然,可以根据性能与产品体验来折衷配置这个轮询时间。如何降低数据量?答:回执数据不是核心数据已读的消息,可以进行物理删除,而不是标记删除;

超过N长时间的回执,归档或者删除掉。

8、本文小结对于群消息已读回执,一般来说:如果发送方在线,会实时被推送已读回执;

如果发送方不在线,会在下次在线时拉取已读回执。如果要对进行优化,可以:接收方累计收到N条群消息再批量ack;

发送方轮询拉取已读回执。物理删除已读回执数据,定时删除或归档非核心历史数据。(本文同步发布于:http://www.52im.net/thread-1611-1-1.html)

IM消息重试机制Java实现_IM群聊消息的已读回执功能该怎么实现?相关推荐

  1. im即时通讯开发:IM群聊消息的已读回执功能

    我们平时在使用即时通讯应用时候,每当发出一条聊天消息,都希望对方尽快看到,并尽快回复,但对方到底有没有真的看到?我却并不知道. 一个残酷的现实是,很多时候对方其实是早就已经看到了这条消息,但出出种种原 ...

  2. IM即时通讯开发群聊消息的已读回执功能该怎么实现?

    我们平时在使用即时通讯应用时候,每当发出一条聊天消息,都希望对方尽快看到,并尽快回复,但对方到底有没有真的看到?我却并不知道.一个残酷的现实是,很多时候对方其实是早就已经看到了这条消息,但出出种种原因 ...

  3. #即时通讯#实现消息已读回执功能的思路与实现

    最近项目的聊天模块中增加了一个消息已读回执的功能,从技术上不是很难实现,但还是在这里记录一下,以便以后查阅. 所谓的消息已读回执,就是双方聊天时,如果对方看到了你新发的信息,这条消息在你这端就会标为& ...

  4. java 邮件 已读回执_java – 在Firebase群组消息传递应用中实施已读回执功能

    为此,您需要在名为seenBy的Firebase数据库中添加另一个节点,该节点必须嵌套在meassage部分中的每个messageId下.您的数据库应如下所示: Firebase-root | --- ...

  5. IM群聊消息的已读未读功能在存储空间方面的实现思路探讨

    1.引言 IM系统中,特别是在企业应用场景下,消息的已读未读状态是一个强需求. 以阿里的钉钉为例,钉钉的产品定位是用于商务交流,其"强制已读回执"功能,让职场人无法再"假 ...

  6. netty之微信-群聊消息的收发及 Netty 性能优化(二十)

    群聊消息的收发及 Netty 性能优化 通过前面小节的学习,相信大家看到本小节标题就已经知道该如何实现本小节的功能了吧,为了给大家学到更多的知识,在实现了群聊消息收发之后,本小节将带给大家更多的惊喜. ...

  7. Java教程:如何对接自定义钉钉机器人并实现群聊消息发送

    正文: 钉钉对机器人提供了多种使用场景,但目前我们只针对群聊消息的发送,@所有 或 @某某 以实现目的,此场景只需实现自定义机器人介入即可! 这是官方介绍: 点击此处直达 **自定义机器人支持5种消息 ...

  8. RabbitMQ之消息重试机制

    1.消息重试机制 消费者消费消息的时候,发生异常情况,导致消息未确认,该消息会被重复消费(默认没有重复次数,即无限循环消费),但可以通过设置重试次数以及达到重试次数之后的消息处理 spring:rab ...

  9. 面试官:群聊消息的已读未读功能,你来设计一个?

    欢迎关注方志朋的博客,回复"666"获面试宝典 一朋友和我讨论他前段时间面试某大公司的一题目 : 企业IM比如企业微信.钉钉里面的群消息的有个已读未读的功能,发送者刚发出消息时,当 ...

最新文章

  1. 【java】4.27上课及做作业时遇到的问题及第十六节课笔记整理
  2. mysql设置text字段为not null,并且没有默认值,插入报错:doesn't have a default value
  3. kaggle机器学习作业(房价预测)
  4. Pytorch 版YOLOV5训练自己的数据集
  5. Java操作mongoDB2.6的常见API使用方法
  6. REST API 的安全认证,我放弃OAuth 2.0 ,选择 JWT 令牌
  7. python列表中存类对象_python中对类的操作,怎么增加或删除类中的对象呢?比如下面这个题...
  8. tukey 窗口_C语言完成窗口算法
  9. 百度云盘超4G大文件上传不了怎么办?
  10. 文本框内容改变的绑定事件
  11. Win10 Synaptics触摸板无法实现双指单击模拟鼠标右键点击的解决办法
  12. 电脑开机显示器不显示BIOS界面,直接进入系统解决办法
  13. win10一直卡在自动修复_win10卡在开机欢迎界面转圈解决方法
  14. 证伪主义 | A Little Sight of Falsification
  15. 香港公司银行开户需要注意。
  16. SQL server in 用法
  17. uni-app图片显示
  18. 效用最大化准则:离散选择模型的核心(二项Logit模型)——离散选择模型之九
  19. Indian English(印度英语)
  20. UWP实现ListBox颜色相间显示

热门文章

  1. cisco S3750交换机配置VLAN
  2. 《逃出生天》:华语影视特效新视角
  3. “新基建”呼唤数据中心“整合者”
  4. 趋势科技将安全工具HijackThis开源
  5. CF 237A (Cash)
  6. 20200224在微软官网下载WIN10专业版的步骤
  7. 收到骗子的短信后......
  8. kaggle比赛流程(转)
  9. geetest php,geetest简单部署
  10. 深入了解基于ASR650x的LoRaMESH方案优势