b站上面本期视频版本，观看视频食用更佳！点击即可跳转,找不到视频可以直接搜索我 目前叫 呆呆呆呆梦
目前已经写的文章有。并且有对应视频版本。
git项目地址 【IM即时通信系统（企聊聊）】点击可跳转
sprinboot单体项目升级成springcloud项目 【第一期】
前端项目技术选型以及页面展示【第二期】
分布式权限 shiro + jwt + redis【第三期】
给为服务添加运维模块 统一管理【第四期】
微服务数据库模块【第五期】
netty与mq在项目中的使用(第六期)】
分布式websocket即时通信(IM)系统构建指南【第七期】
前言
上一篇中说了一下项目的构成，比较枯燥，一些基本构造方面，这一片呢，一定会更加枯燥。这一篇讲报文协议。后端嘛，不像前端花里胡哨，就是更有内涵一点。为什么这块需要着重说呢，因为聊天系统中需要设计一套保证消息可靠的机制。否则消息都不知道发过去了没有。需要通过报文去保证这些。这些都是需要去设计的。具体设计思路如下。
1.如何保证两个用户之间消息可靠
主要有参考这个
IM消息送达保证机制实现
这篇文章有详细明确了一下消息可靠性的保证；
1.1 正常逻辑
这个是正常的发送逻辑。客户A发送给服务器，服务器发送给客户B。这个是之前的逻辑，就是正常的发送逻辑；msg：A用于确认客户端消息发送到服务器。但是在这种逻辑中，客户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
}
基本步骤如上.
