wordpress刷量插件,网站建设优化服务方案,免费行情网站在线,动漫制作专业属于什么大类b站上面本期视频版本#xff0c;观看视频食用更佳#xff01;点击即可跳转,找不到视频可以直接搜索我 目前叫 呆呆呆呆梦
目前已经写的文章有。并且有对应视频版本。 git项目地址 【IM即时通信系统#xff08;企聊聊#xff09;】点击可跳转 sprinboot单体项目升级成sprin…b站上面本期视频版本观看视频食用更佳点击即可跳转,找不到视频可以直接搜索我 目前叫 呆呆呆呆梦
目前已经写的文章有。并且有对应视频版本。 git项目地址 【IM即时通信系统企聊聊】点击可跳转 sprinboot单体项目升级成springcloud项目 【第一期】 前端项目技术选型以及页面展示【第二期】 分布式权限 shiro jwt redis【第三期】 给为服务添加运维模块 统一管理【第四期】 微服务数据库模块【第五期】 netty与mq在项目中的使用(第六期)】 分布式websocket即时通信(IM)系统构建指南【第七期】
前言
上一篇中说了一下项目的构成比较枯燥一些基本构造方面这一片呢一定会更加枯燥。这一篇讲报文协议。后端嘛不像前端花里胡哨就是更有内涵一点。为什么这块需要着重说呢因为聊天系统中需要设计一套保证消息可靠的机制。否则消息都不知道发过去了没有。需要通过报文去保证这些。这些都是需要去设计的。具体设计思路如下。
1.如何保证两个用户之间消息可靠
主要有参考这个 IM消息送达保证机制实现 这篇文章有详细明确了一下消息可靠性的保证
1.1 正常逻辑 这个是正常的发送逻辑。客户A发送给服务器服务器发送给客户B。这个是之前的逻辑就是正常的发送逻辑msgA用于确认客户端消息发送到服务器。但是在这种逻辑中客户A是不清楚客户B是否收到消息的所以由此引入一个确认机制。
1.2带有确认机制
client-B向im-server发送一个ack请求包即ack:R im-server在成功处理后回复client-B一个ack响应包即ack:A 则im-server主动向client-A发送一个ack通知包即ack:N
你会发现一条消息的发送分别包含上下两个半场即msg的R/A/N三个报文ack的R/A/N三个报文。一个应用层即时通讯消息的可靠投递共涉及6个报文这就是im系统中消息投递的最核心技术如果某个im系统不包含这6个报文不要谈什么消息的可靠性。
理论知识讲解完毕下面是实战演练
2.具体实践 如果没有收到ack消息涉及到消息的重发。 然后中间涉及到消息的重发在报文中需要字段来确认是否是消息的重发。直接实操一遍看一下经过的报文吧。然后看具体的报文
0 注册消息报文
{type:7,params:{openid:56C02DF0516B4B079ABFCEC08169E577,userName:123,loginStatus:1}}1 用户A:发送消息报文
{type: 1,params: {msgid: 17301,toMessageId: 1879878-NKCNO-NKNK,message: 我要发消息啦,fileType: 0,isretry: false}
}2 用户A:客户端确认
{type: -1,params: {date: Thu Jan 18 18:38:27 CST 2024,msgid: 17301,online: true,message: 我要发消息啦,isretry: false},status: 200
}3 用户B:收到消息
{activeTime: 1705574308625,from: system,messageId: 17301,msg: {type: 2,params: {fromUser: {openid: 56C02DF0516B4B079ABFCEC08169E577,loginStatus: 1,userName: 123},message: 我要发消息啦,fileType: 0},status: 200},msgType: 1,requestId: 08808d38-3d4c-4b80-9f9c-9c19dfe1163e,sessionId: 192.168.56.1:8084_1879878-NKCNO-NKNK_20240118183556,to: [1879878-NKCNO-NKNK],trigger: 1
}4 用户B:发送ACK
{type:15,params:{from:client,msgid:17301,fromUser:56C02DF0516B4B079ABFCEC08169E577,toUser:1879878-NKCNO-NKNK}}5 用户B:收到服务器确认消息
{type:16,params:{date:Thu Jan 18 18:38:28 CST 2024,message:17301},status:200}6 用户A:客户端收到ack消息 流程结束
{activeTime: 1705574308647,from: system,messageId: 17301,msg: {type: 17,status: 200},msgType: 1,requestId: 85a16365-6a1d-4ce1-8f99-c49a583ed1d0,sessionId: 192.168.56.1:8084_56C02DF0516B4B079ABFCEC08169E577_20240118183655,to: [56C02DF0516B4B079ABFCEC08169E577],trigger: 1
}7 消息落库报文
{activeTime: 1705574309525,from: system,messageId: 17301,msg: {type: 18,status: 200},msgType: 1,requestId: 4ad1af60-56e4-4718-a668-8d94243a2173,sessionId: 192.168.56.1:8084_56C02DF0516B4B079ABFCEC08169E577_20240118183655,to: [56C02DF0516B4B079ABFCEC08169E577],trigger: 1
}基本步骤如上.
