Netty+springboot开发即时通讯系统笔记(四)终

实时性

1.线程池多线程,把消息同步给其他端和对方用户,其中数据持久化往往是最浪费时间的操作,可以使用mq异步存储,因为其他业务不需要拿着整条数据,只需要这条数据的id进行操作。

2。消息校验前置,放在tcp层(netty服务中)

可靠性

在这里插入图片描述

tcp协议只能保证数据在传输过程中不丢失,但不能保证到某一端不会丢失,比如传输过程中接收方断网,数据就无法发送到接收方 。

可靠性可以通过消息重发来保证消息一定送到了对方手中。可以通过双重ack确认机制来实现:
在这里插入图片描述

A向im服务端发送数据,服务端收到就返回一个ack,A收到这个ack就停止重发,否则就再次尝试重发。当然重发需要设计上限次数的。

然后服务端接到A的数据,再发送给B,B接到之后告诉服务端,返回一个接受到的ack。服务端把收到的再传回给A,此时A确定了此次传输是成功的。中间任何环节出问题,A就执行重发就ok了。

如果B不在线,服务端是可以感知到的,服务端可以代替B向A回复停止重发指令。

有序性

因为我们使用多线程保证了消息的实时性,那么就会导致消息有乱序的风险。

解决方案:

使用redis的incr命令实现原子性的递增序列号,但是过度依赖redis可能会因为redis的崩溃而造成系统失效

幂等性

再im服务端存储每次发过来的消息id(设置过期时间),重复发送的消息id将不再进行持久化但仍会给另一个客户端发送消息。这样就会导致另一个客户端由于网络问题如果没有及时返回ack确认,那么他确实会收到2条相同的消息,但是在去重是完全可以处理的。

qq发消息失败会有红色感叹号,当再次点击重发时是把它当作一条新的消息id发送的,而不是之前的消息id。

消息已读功能

在写扩散中,每个人对自己的每条消息都可以直接获取,已读只不过是个字段罢了。

在读扩散中,以群聊为例,可以在群成员表中加入一个字段,该字段表示改成员读到的最后一条消息序列(保证有序性的那个递增序列),在这条消息之前的就表示读过了

离线消息存储

IM(即时通讯)系统中的离线消息是指在目标用户不在线或者不可达时,发送方发送的消息无法直接传递给目标用户,而是被服务器暂时存储起来,等到目标用户上线或者可达时再进行投递。

离线消息的存在是为了保证消息的可靠性和完整性。当发送方发送消息时,如果目标用户在线,消息可以直接传递给目标用户;但如果目标用户不在线,服务器会将该消息存储在消息队列或者数据库中,等到目标用户上线后,服务器会将离线消息投递给目标用户。

离线消息通常具有以下特点:

  1. 持久化存储:离线消息通常被存储在服务器的数据库或者消息队列中,确保消息的持久性,即使服务器重启或者断电,消息也不会丢失。
  2. 时效性:离线消息通常会设置一个过期时间,在一定时间范围内等待目标用户上线,过期后会被清理或者丢弃。
  3. 投递策略:服务器会在目标用户上线后,根据一定的投递策略(如先进先出、按时间戳等)将离线消息按顺序投递给目标用户。
  4. 通知机制:当目标用户上线后,服务器可能会发送通知给目标用户,告知其有离线消息待接收。

这里的存储使用redis,每人只存1000条,超过就淘汰最早的,使用zset存储,使用消息的递增序列号作为排序标准,zset支持查询范围内指定数量的元素(SMEMBERS命令)。

即使你错过了离线消息的通知和消息盒子,你仍然可以通过滚动查看聊天记录,找到之前的离线消息。

登录之后的数据同步(历史记录的拉取)

不可能说每次登录都把所有记录都删了重新拉取一遍的,所以这里采用增量拉取。

需要拉取的东西有会话,好友列表,好友申请,为每个需要拉取的数据记录下他的递增序列号,每次只拉取大于记录里最大的序列号。

客户端可以用数据库sqllite

在线状态设计

正常情况下,你的上线和下线等状态应该通知给你的所有好友,和你在的所有群里的所有成员,这将是非常恐怖的数据量。

改进1:只推给在线用户

改进2:

  1. 按需拉取:在按需拉取的策略下,IM 系统不会主动向所有好友和群成员发送上线和下线等状态通知。相反,当其他用户需要获取某个用户的状态时,他们可以向服务器发送请求,然后服务器根据请求返回相应的状态信息。这种方式可以避免将状态通知广播给所有人,只有真正需要获取状态信息的用户才会发起请求,减少了不必要的数据传输和处理。
  2. 临时订阅:临时订阅是指用户可以临时订阅某个好友或群组的状态更新通知。当用户订阅了某个用户或群组后,只有在被订阅对象的状态发生变化时,系统才会向订阅者发送通知。这样可以避免向所有好友和群成员广播状态更新,只有被订阅的对象状态发生变化时,才会发送通知给订阅者。这种方式可以根据用户的实际需求,选择性地接收特定用户或群组的状态更新通知,减少了不必要的通知量。

陌生人发消息限制

  1. 计数限制:为每个用户设置一个计数器,记录他们发送给陌生人的消息数量。当陌生人发送消息时,系统会检查计数器的值。如果计数器小于等于三,允许发送消息并将计数器加一;如果计数器大于三,拒绝发送消息。

  2. 时间限制:除了计数限制,可以设置一个时间限制,例如每小时或每天只允许陌生人发送三条消息。系统会记录陌生人发送消息的时间,并在规定的时间段内检查发送数量。如果超过限制,拒绝发送消息。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/42722.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Vim的插件管理器之Vundle

1、安装Vundle插件管理器 Vim可以安装插件,但是需要手动安装比较麻烦,Vim本身没有提供插件管理器,所以会有很多的第三方的插件管理器,有一个vim的插件叫做 “vim-easymotion”,在它的github的安装说明里有列出对于不同…

GRPC 学习记录

GRPC 安装 安装 grpcio、grpcio-tools、protobuf、 pip install grpcio -i https://pypi.tuna.tsinghua.edu.cn/simple pip install grpcio-tools -i https://pypi.tuna.tsinghua.edu.cn/simple pip install protobuf -i https://pypi.tuna.tsinghua.edu.cn/simple常用类型 p…

Minio知识点+linux下安装+面试总结

一 Minio简介 MinIO 是一个基于Apache License v2.0开源协议的对象存储服务。它兼容亚马逊S3云存储服务接口,非常适合于存储大容量非结构化的数据,例如图片、视频、日志文件、备份数据和容器/虚拟机镜像等,而一个对象文件可以是任意大小&…

msvcp110.dll是什么意思,msvcp110.dll丢失的解决方法

装好软件或游戏之后,一打开就跳出各种报错信息的情况小伙伴一定见过,其中缺少各种msvcp110.dll文件最常见。小伙伴们一定奇怪,用得好好的电脑,怎么会缺文件呢?为啥其他游戏/应用就没事呢?其实这些“丢失”的…

visual studio 2022配置

前提:我linux c 开发 一直在使用vscode 更新了个版本突然代码中的查找所用引用和变量修改名称不能用了,尝试了重新配置clang vc都不行,估计是插件问题,一怒之下改用visual studio 2022 为了同步2个IDE之间的差别,目前…

QT的核心——信号与槽

目录 回顾C 语言信号 1、信号与槽 2、关联信号与槽 2.1自动关联信号与槽 2.2手动关联信号与槽 2.3断开信号与槽 3、自定义信号 3.1自定义信号使用条件 3.2自定义槽函数使用条件 4、信号与槽参数传递 4.1自定义一个带参的信号 4.2关联带参的信号与槽 4.3发送一个带…

YOLOv5、YOLOv8改进:S2注意力机制

目录 1.简介 2.YOLOv5改进 2.1增加以下S2-MLPv2.yaml文件 2.2common.py配置 2.3yolo.py配置 1.简介 S2-MLPv2注意力机制 最近,出现了基于 MLP 的视觉主干。与 CNN 和视觉Transformer相比,基于 MLP 的视觉架构具有较少的归纳偏差,在图像识…

LVS-DR+keepalived实现高可用负载群集

VRRP 通信原理: VRRP就是虚拟路由冗余协议,它的出现就是为了解决静态路由的单点故障。 VRRP是通过一种竞选的一种协议机制,来将路由交给某台VRRP路由。 VRRP用IP多播的方式(多播地址224.0.0.18)来实现高可用的通信&…

基于STM32+OneNet设计的物联网智慧路灯

一、前言 近年来,构筑智慧城市、推动城镇发展被国家列入重要工作范畴。发布的《超级智慧城市报告》显示,全球已启动或在建的智慧城市有1000多个,中国在建500个,远超排名第二的欧洲(90个)。从在建智慧城市的…

Android oaid

官方GitHub地址 https://github.com/gzu-liyujiang/Android_CN_OAID 生成和用途介绍 https://www.jianshu.com/p/1c7ef27d6db4 图片来源于上述网站 其他关于id的介绍 https://www.cnblogs.com/chenKnowledgeConllection/p/17380960.html https://zhuanlan.zhihu.com/p/55…

微信小程序拉起支付报: 调用支付JSAPI缺少参数: total_fee

1. 调用支付JSAPI缺少参数: total_fee 2. 检查返回给前端调起支付的参数是否正确 一开始是params.put("package", prepay_id); 回来改回params.put("package", "prepay_id"prepay_id);

leetcode 415.字符串相加

⭐️ 题目描述 🌟 leetcode链接:https://leetcode.cn/problems/add-strings/description/ ps: 从两个字符串的末尾开始遍历,依次相加,若大于等于 10 则使用一个变量记录进位,遍历的时候若两个字符串其中一…

ASR(自动语音识别)任务中的LLM(大语言模型)

一、LLM大语言模型的特点 二、大语言模型在ASR任务中的应用 浅度融合 浅层融合指的是LLM本身并没有和音频信息进行直接计算。其仅对ASR模型输出的文本结果进行重打分或者质量评估。 深度融合 LLM与ASR模型进行深度结合,统一语音和文本的编码空间或者直接利用ASR…

OKCC在系统安全方面做了哪些措施?

语音通信行业,运营者普遍比较关心的问题是,运营风险如何控制?运营安全如何保证?OKCC呼叫中心又有那些风控措施来保证运营安全。 当前阶段,语音通信运营,最主要的风险主要包括以下几个方面: 一、…

无涯教程-Perl - wait函数

描述 该函数等待子进程终止,返回已故进程的进程ID。进程的退出状态包含在$?中。 语法 以下是此函数的简单语法- wait返回值 如果没有子进程,则此函数返回-1,否则将显示已故进程的进程ID Perl 中的 wait函数 - 无涯教程网无涯教程网提供描述该函数等待子进程终止,返回已故…

Three.js 实现模型材质局部辉光效果和解决辉光影响场景背景图显示的问题

1.Three.js 实现模型材质局部辉光效果 2.解决辉光效果影响场景背景图显示的问题 相关API的使用: 1. EffectComposer(渲染后处理的通用框架,用于将多个渲染通道(pass)组合在一起创建特定的视觉效果) 2. …

Java-运算符和控制语句(上)(基于c语言的补充)

算术运算符 关于求余 不管分子,分母是正还是负,对于分母,直接取正;对于分子若有负号,则先提取出来;剩下两个正的分子分母运算;最后,若刚才的分子有负号,对最后的结果添加…

Java版 招投标系统简介 招投标系统源码 java招投标系统 招投标系统功能设计tbms

​ 项目说明 随着公司的快速发展,企业人员和经营规模不断壮大,公司对内部招采管理的提升提出了更高的要求。在企业里建立一个公平、公开、公正的采购环境,最大限度控制采购成本至关重要。符合国家电子招投标法律法规及相关规范,以…

scala中json4s 使用详解

预备知识 json4s的数据结构AST (Abstract Syntax Tree)。 sealed abstract class JValue case object JNothing extends JValue // zero for JValue case object JNull extends JValue case class JString(s: String) extends JValue case class JDouble(num: Double) extend…

数字化时代,数据仓库和商业智能BI系统演进的五个阶段

数字化在逐渐成熟的同时,社会上也对数字化的性质有了进一步认识。当下,数字化除了前边提到的将复杂的信息、知识转化为可以度量的数字、数据,在将其转化为二进制代码,引入计算机内部,建立数据模型,统一进行…