消息的设计
- 先定义好需要的消息,可使用枚举类型给每一个消息定义一个值
- 定义一个通用的消息 header,包含 MESSAGE ID 字段
- 然后根据需要定义不同的消息,使用同样的 header
- 消息总大小不要大于 MTU 值。通常是 1500 ? 20 ? 8。
- 消息结构体声明 1 字节对齐。
接收
- 定义一个足够大(1500)的 buffer,每次指定读取 1500 字节
- 若返回值等于 ?1,打印系统错误信息,返回
- 若返回值小于 header 的大小,打印错误信息,返回
- 若返回值大于 header 的大小,强制转型出 header,访问 msgid
- 若 id 不支持,打印错误信息,返回
- 若读取返回的 size 与 msgid 对应的结构体不相等,打印错误信息,返回
- 强制转型出对应的消息结构体进行使用。对于 64、32、16 位的数值类型,进行字节序转换。
发送
- 声明需要发送的消息结构体,初始化 header 和消息体。
- 调用 send 发送该结构体 buffer。
- 检查 send 的返回值。
- 若返回值等于 ?1,重启程序,进入异常恢复流程。
重发
- 为了确保消息被对方接收处理,每一个发送的消息都需要对方恢复相应的 ACK 消息。
- 每次调用 send 发送消息后,保存该消息,然后启动定时器,超时时间根据实际网络情况设定。
- 定时器超时后,再次进行消息发送,并启动新的定时器。
- 每次收到 ACK 消息,清除对应消息的定时器。
心跳
- 看实际业务的需要,若客户端存在掉线后不再重新连接的情况,应维持一个心跳包收发。当心跳停止持续一定时间后,认定死亡,放弃重发消息。
补充说明
|