即时通讯：单聊消息逻辑
在线消息（对方在线）
1.client发送消息到msg_server
2.msg_server判断消息有效性，每秒发送的消息不能超过限制，无误后转发给db_server
3.db_server判断为单聊
- 查找对应的会话，不存在则创建两个会话（双方都有）
- 获取关系id（两人唯一），不存在则创建
- 获取会话消息id（个人唯一），会话消息id = 关系id_(用户id)
- 将消息写入数据库，更新会话的update time
- 增加对方未读消息计数
- 将处理结果放入回复队列，通过事件循环回发给msg_server
4.msg_server收到回复后，回复ACK给发送方client，发送方会显示消息已发送，但其实此刻没有发送
5.msg_server向route_server查询接收方在线状态，不在线则结束，在线则继续
6.msg_server首先广播该消息到本server的其它client，再转发到route_server
7.route_server广播消息到所有msg_server
注：6和7保证将消息发送到 ： 1.同账号不同端的client 2.不同账号的接收方
注：6和7的广播可以优化为 ：先查找有没有目标接收方，再进行定向转发
db_server处理细节：
离线消息（对方不在线）
与在线消息相同，但只有其中1，2，3，4，5条逻辑
点击获取更多Linux C/C++开发学习资料
相关文章：
即时通讯：单聊消息逻辑
在线消息（对方在线） 1.client发送消息到msg_server 2.msg_server判断消息有效性，每秒发送的消息不能超过限制，无误后转发给db_server 3.db_server判断为单聊 查找对应的会话，不存在则创建两个会话（双方…...
Libevent源码剖析之reactor
1 简介 reactor 是一种事件驱动的并发处理模式，常用于网络服务器和事件循环系统中。它主要的功能是通过单线程或者多线程处理I/O操作，避免阻塞，并且能够高效处理大量并发的事件。 one loop per thread or process，以下摘自 reacto…...
分享一套SpringBoot+Vue民宿(预约)系统
大家好，我是java1234_小锋老师，看到一个不错的SpringBootVue民宿(预约)系统，分享下嘿嘿。 项目介绍 传统办法管理信息首先需要花费的时间比较多，其次数据出错率比较高，而且对错误的数据进行更改也比较困难，…...
Linux——应用软件的生命周期
功能开发测试： 功能性测试 对应开发框架的测试用例代码的漏洞扫描 Web服务器版本应用开发语言的依赖关系和版本信息是否会造成类似内存泄露等影响系统性能的问题压力测试应用的部署 获取应用代码以及应用静态文件的代码包将安装包中的文件按照服务器配置的架构&…...
【Linux】exec系列函数详细介绍
首先，exec 是 execute (意为:执行) 的缩写。 exec系列函数 各个“后缀”的意思： l 为 list 可变参数列表、v 为 vector、p 为 PATH、e 为环境变量数组 envp execl：l 为 list 可变参数列表 原型：int execl(const char *path, cons…...
ARINC 429总线协议
一、概述 ARINC 是美国航空无线电公司英文字头的缩写， 该公司1977年7月21日出版了“ARINC 429规范”一书，429规范就是飞机电子系统之间数字式数据传输的标准格式，在飞机上使用429总线的电子设备均应遵守这个规范，这样才能保证电子…...
Qt解决槽函数中发送的信号的参数会变化带来的错误
connect(item, &MusicItemWidget::playRequest, this, [this] { emit playMusic(QUrl(this->m_mediaPath)； ); 如上图，this->m_mediaPath是个成员变量，但自己的初衷是发送一个最开始捕获的值，那么可以使用下面的方法…...
C C++ 如何编写库级接口
初级代码游戏的专栏介绍与文章目录-CSDN博客 我的github：codetoys，所有代码都将会位于ctfc库中。已经放入库中我会指出在库中的位置。 这些代码大部分以Linux为目标但部分代码是纯C的，可以在任何平台上使用。 源码指引：github源…...
安装TDengine数据库3.3版本和TDengine数据库可视化管理工具
安装TDengine数据库3.3版本和TDengine数据库可视化管理工具 一、下载安装包二、解压安装包三、部署四、启动服务五、进入数据库六、创建数据库、表和往表中插入数据七、测试 TDengine 性能八、使用数据库九、查询数据十、TDengine数据库可视化界面 一、下载安装包 TDengine-cl…...
详解CAS
一、CAS是什么？ CAS是Java中Unsafe类里面的一个方法，是Compare and Swap的缩写，中文翻译成比较并交换，主要功能是能够去保证在多线程的环境下对于共享变量修改的一个原子性，实现并发算法时常用到的一种技术。它包含三…...
《环境感知方案：探索未来智能世界的关键技术》
《环境感知方案：探索未来智能世界的关键技术》 一、环境感知方案的研究现状（一）机器人领域的环境感知（二）农业领域的环境感知（三）智能网联汽车领域的环境感知 二、先进的环境感知技术࿰…...
Android 编译时出现Android resource linking failed.without required default value.
错误信息如下： Execution failed for task :app:processDebugResources. > A failure occurred while executing com.android.build.gradle.internal.res.LinkApplicationAndroidResourcesTask$TaskAction> Android resource linking failedwarn: removing r…...
golang ws升级为wss
首先需要一份openssl证书 1.安装openssl windows安装openssl 的下载地址在 https://slproweb.com/products/Win32OpenSSL.html 无脑点安装就行，记得最后安装完成的页面取消勾选 安装完成后记得配置环境变量 2.生成证书 openssl req -x509 -days 36500 -nodes …...
FFMPEG录屏（17）--- 使用 DwmRegisterThumbnail 捕获指定窗口图像数据
使用 DwmRegisterThumbnail 捕获指定窗口图像数据 在 Windows 平台上，捕获指定窗口的图像数据可以通过多种方法实现，其中一种高效的方法是使用 [DwmRegisterThumbnail] 本文将介绍如何使用 [DwmRegisterThumbnail] 捕获窗口图像数据，并提供一…...
点亮一个LED（51）
目录 1.LED介绍 2.硬件电路 3.程序设计 3.1.点亮一颗LED 3.2.LED闪烁 3.3.LED流水灯实现 1.LED介绍 发光二极管也具有二极管普遍的特性单向导电性，有阳极和阴极之分 ，上图左侧式插件式LED ，长的引脚是阳极；左侧是贴片式的带…...
Flink窗口分配器WindowAssigner
前言 Flink 数据流经过 keyBy 分组后，下一步就是 WindowAssigner。 WindowAssigner 定义了 stream 中的元素如何被分发到各个窗口，元素可以被分发到一个或多个窗口中，Flink 内置了常用的窗口分配器，包括：tumbling wi…...
【Tinymce】富文本编辑器在vue项目中的使用；引入付费格式刷，上传视频、图片
引言 富文本编辑器有很多，对比了一下，还是决定用tinymce（号称宇宙最强），基础的插件确实好用，但是一些更好用的插件，比如格式刷等都是高级版（付费），当然也有人…...
Java实现简单的5阶m序列密钥生成
选择5阶本原多项式：x^5 x^2 1,初始值为{1,0,0,1,1}，易得，递推公式为：ak ak-5 ⊕ ak-2 ，其中k≥5。于是可以写出下面这段代码： class BitsEncode {public static void main(String[] args) {//初始化数组…...
013_django基于大数据的高血压人群分析系统2024_dcb7986h_055
目录 系统展示 开发背景 代码实现 项目案例 获取源码 博主介绍：CodeMentor毕业设计领航者、全网关注者30W群落，InfoQ特邀专栏作家、技术博客领航者、InfoQ新星培育计划导师、Web开发领域杰出贡献者，博客领航之星、开发者头条/腾讯云/AW…...
暂停程序执行并等待用户按键输入函数waitKey()的使用)
OpenCV高级图形用户界面(21)暂停程序执行并等待用户按键输入函数waitKey()的使用
操作系统：ubuntu22.04 OpenCV版本：OpenCV4.9 IDE:Visual Studio Code 编程语言：C11 算法描述 等待按键 该函数 waitKey 在 delay≤0 时无限等待按键事件，或者在 delay 为正数时等待 delay 毫秒。由于操作系统在切换线程时有最小…...
【WiFi帧结构】
文章目录 帧结构MAC头部管理帧 帧结构 Wi-Fi的帧分为三部分组成：MAC头部frame bodyFCS，其中MAC是固定格式的，frame body是可变长度。 MAC头部有frame control，duration，address1，address2，addre…...
Oracle查询表空间大小
1 查询数据库中所有的表空间以及表空间所占空间的大小 SELECTtablespace_name,sum( bytes ) / 1024 / 1024 FROMdba_data_files GROUP BYtablespace_name; 2 Oracle查询表空间大小及每个表所占空间的大小 SELECTtablespace_name,file_id,file_name,round( bytes / ( 1024 …...
第一篇：Agent2Agent (A2A) 协议——协作式人工智能的黎明
AI 领域的快速发展正在催生一个新时代，智能代理（agents）不再是孤立的个体，而是能够像一个数字团队一样协作。然而，当前 AI 生态系统的碎片化阻碍了这一愿景的实现，导致了“AI 巴别塔问题”——不同代理之间…...
算法笔记2
1.字符串拼接最好用StringBuilder，不用String 2.创建List<>类型的数组并创建内存 List arr[] new ArrayList[26]; Arrays.setAll(arr, i -> new ArrayList<>()); 3.去掉首尾空格...
与常用工具深度洞察App瓶颈)
iOS性能调优实战：借助克魔(KeyMob)与常用工具深度洞察App瓶颈
在日常iOS开发过程中，性能问题往往是最令人头疼的一类Bug。尤其是在App上线前的压测阶段或是处理用户反馈的高发期，开发者往往需要面对卡顿、崩溃、能耗异常、日志混乱等一系列问题。这些问题表面上看似偶发，但背后往往隐藏着系统资源调度不当…...
人机融合智能 | “人智交互”跨学科新领域
本文系统地提出基于“以人为中心AI(HCAI)”理念的人-人工智能交互(人智交互)这一跨学科新领域及框架,定义人智交互领域的理念、基本理论和关键问题、方法、开发流程和参与团队等,阐述提出人智交互新领域的意义。然后,提出人智交互研究的三种新范式取向以及它们的意义。最后,总结…...
纯 Java 项目（非 SpringBoot）集成 Mybatis-Plus 和 Mybatis-Plus-Join
纯 Java 项目（非 SpringBoot）集成 Mybatis-Plus 和 Mybatis-Plus-Join 1、依赖1.1、依赖版本1.2、pom.xml 2、代码2.1、SqlSession 构造器2.2、MybatisPlus代码生成器2.3、获取 config.yml 配置2.3.1、config.yml2.3.2、项目配置类 2.4、ftl 模板2.4.1、…...
热烈祝贺埃文科技正式加入可信数据空间发展联盟
2025年4月29日，在福州举办的第八届数字中国建设峰会“可信数据空间分论坛”上，可信数据空间发展联盟正式宣告成立。国家数据局党组书记、局长刘烈宏出席并致辞，强调该联盟是推进全国一体化数据市场建设的关键抓手。 郑州埃文科技有限公司&am…...
QT开发技术【ffmpeg + QAudioOutput】音乐播放器
一、 介绍 使用ffmpeg 4.2.2 在数字化浪潮席卷全球的当下，音视频内容犹如璀璨繁星，点亮了人们的生活与工作。从短视频平台上令人捧腹的搞笑视频，到在线课堂中知识渊博的专家授课，再到影视平台上扣人心弦的高清大片，音…...
篇章二 论坛系统——系统设计
目录 2.系统设计 2.1 技术选型 2.2 设计数据库结构 2.2.1 数据库实体 1. 数据库设计 1.1 数据库名: forum db 1.2 表的设计 1.3 编写SQL 2.系统设计 2.1 技术选型 2.2 设计数据库结构 2.2.1 数据库实体 通过需求分析获得概念类并结合业务实现过程中的技术需要&#x…...