KCP源码解析系列(二)KCP协议结构体

news/2024/9/23 11:20:14/

一、KCP协议包

kcp_2">1.1 kcp协议包

kcp中只有一种数据包,不管是数据还是控制信息,都用这个数据包来表示

0               4   5   6       8 (BYTE)
+---------------+---+---+-------+
|     conv      |cmd|frg|  wnd  |
+---------------+---+---+-------+   8
|     ts        |     sn        |
+---------------+---------------+  16
|     una       |     len       |
+---------------+---------------+  24
|                               |
|        DATA (optional)        |
|                               |
+-------------------------------+
  1. conv (4 bytes): 会话号,用于区分不同的会话。由于kcp不处理握手,可以通过两端

  2. cmd (1 byte): 命令类型,可能的命令类型包括:

    • IKCP_CMD_PUSH(数据包)

    • IKCP_CMD_ACK(确认包)

    • IKCP_CMD_WASK(窗口探测包,请求对方告知窗口大小)

    • IKCP_CMD_WINS(窗口大小通告包,告知对方窗口大小)

  3. frg (1 byte): 分片标识,表示数据是否被分片及其序号。对于不分片的数据包,该值为 0。

  4. wnd (2 bytes): 窗口大小,用于流量控制。

  5. ts (4 bytes): 时间戳,用于计算往返时间(RTT)以及重传超时(RTO)。

  6. sn (4 bytes): 序号,用于数据包排序和确认。

  7. una (4 bytes): 未确认的序号,用于流量控制。

  8. len (4 bytes): 数据部分的长度。

kcpIKCPSEG_47">1.2 kcp源码IKCPSEG结构体

//=====================================================================
// SEGMENT
//=====================================================================
struct IKCPSEG
{struct IQUEUEHEAD node;//链表节点,结构体类型 IQUEUEHEAD,用于把该分段加入到发送或接收队列的链表中。IUINT32 conv;IUINT32 cmd;IUINT32 frg;IUINT32 wnd;IUINT32 ts;IUINT32 sn;IUINT32 una;IUINT32 len;IUINT32 resendts;//重传时间戳,32 位整数,表示该分段下一次进行重传的时间戳。IUINT32 rto;//重传超时时间,32 位整数,表示该分段的重传超时时间。根据 ACK 的 RTT 值调整。IUINT32 fastack;//快速重传计数,32 位整数,表示该分段被其他数据包跳过的次数,用于快速重传机制。IUINT32 xmit;//传输次数,32 位整数,表示该分段已被发送的次数。char data[1];
};

二、IKCPCB

IKCPCB 结构体是 KCP 协议中控制块的核心数据结构,包含了连接状态、传输参数、缓存和控制信息等。这是整个 KCP 协议运作的核心,用于管理连接的各个方面。下面是对每个字段的详细解释,

看不懂没关系,后边会在流程中解释。

struct IKCPCB {IUINT32 conv;              // 会话 ID,用于区分不同的连接IUINT32 mtu;               // 最大传输单元大小,指网络层能够传输的最大数据包大小IUINT32 mss;               // 最大分段大小,为 MTU 减去固定的 KCP 头部大小IUINT32 state;             // 连接状态IUINT32 snd_una;           // 未确认的发送序号IUINT32 snd_nxt;           // 下一个发送序号IUINT32 rcv_nxt;           // 下一个接收序号IUINT32 ts_recent;         // 最近的时间戳IUINT32 ts_lastack;        // 最后一个确认包的时间戳IUINT32 ssthresh;          // 慢启动门限IINT32 rx_rttval;          // RTT 波动值IINT32 rx_srtt;            // 平滑后的 RTT 值IINT32 rx_rto;             // 重传超时时间IINT32 rx_minrto;          // 最小重传超时时间IUINT32 ff_recovery_point; // 快速恢复点IUINT32 snd_wnd;           // 发送窗口大小IUINT32 rcv_wnd;           // 接收窗口大小IUINT32 rmt_wnd;           // 远端窗口大小IUINT32 cwnd;              // 拥塞窗口大小IUINT32 probe;             // 探测变量IUINT32 current;           // 当前时间IUINT32 interval;          // 内部工作刷新间隔IUINT32 ts_flush;          // 下次刷新时间戳IUINT32 xmit;              // 传输次数IUINT32 next_send;         // 下一个发送时间IUINT32 nrcv_buf;          // 接收缓冲区大小IUINT32 nsnd_buf;          // 发送缓冲区大小IUINT32 nrcv_que;          // 接收队列大小IUINT32 nsnd_que;          // 发送队列大小IUINT32 wait_snd_bytes;    // 等待发送字节数IUINT32 wait_rcv_bytes;    // 等待接收字节数IUINT32 nodelay;           // 是否启用无延迟模式IUINT32 updated;           // 是否已更新IUINT32 ts_probe;          // 窗口探测时间IUINT32 probe_wait;        // 窗口探测等待时间IUINT32 dead_link;         // 最大重传次数,超过此次数认为连接失效IUINT32 incr;              // 拥塞窗口增加量IUINT32 ts_wait_ack;       // 等待 ACK 的时间戳IUINT32 flag_wait_ack;     // 等待 ACK 的标志IUINT32 ts_echo;           // ECHO 的时间戳pthread_mutex_t send_lock; // 发送锁,用于多线程环境struct IQUEUEHEAD snd_queue;  // 发送队列pthread_mutex_t recv_lock; // 接收锁,用于多线程环境struct IQUEUEHEAD rcv_queue;  // 接收队列struct IQUEUEHEAD snd_buf;    // 发送缓冲区struct IQUEUEHEAD rcv_buf;    // 接收缓冲区IUINT32 *acklist;          // 存储待发送的 ACK 列表IUINT32 ackcount;          // ACK 的数量IUINT32 ts_sack;           // SACK 时间戳IUINT32 ackblock;          // ACK 列表的大小(块大小)void *user;                // 用户数据void *user_send_queue;     // 用户发送队列void *user_recv_queue;     // 用户接收队列char *buffer;              // 缓冲区int fastresend;            // 快速重传标志int nocwnd;                // 关闭拥塞控制标志int stream;                // 流模式标志int logmask;               // 日志掩码int delay_ack;             // 延迟 ACK 处理void *ca_priv;             // 拥塞避免私用数据int (*output)(const char *buf, int len, struct IKCPCB *kcp, void *user); // 数据输出回调void (*writelog)(const char *log, struct IKCPCB *kcp, void *user);      // 日志写入回调int (*process_pkt)(void *user, int length, const char *input, char *output); // 数据包处理回调
};

http://www.ppmy.cn/news/1509982.html

相关文章

广义线性模型(4)逻辑回归(Logistic regression)

一 简介 从 广义线性模型(1)广义线性模型详解 中我们知道,逻辑回归是使用logit函数(Sigmod函数)作为连接函数,伯努利分布(二分类问题)或多项式分布(多分类问题&#xff…

Unity3D HybridCLR 从零开始 与众不同系列(一)

首先说一下最终目标, 一个主程序从网络上加载配置,通过配置得到功能模块(含美术和脚本资源)的下载地址,下载相关内容后动态加载运行功能模块。功能模块和主程序分属不相关的两个项目。 Unity项目中HybridCLR是特性完整…

Java填充PDF并返回填充后PDF文件及对应base64码

前期准备 下载PDF编辑工具(Adobe Acrobat 9 Pro): 可以主页关注小程序【白哥Java】回复【PDF编辑软件】即可获取 或者直接联系博主也可 主页如下: 软件使用流程 此处流程为文本域流程 图片或其他大致相同 生成模板PDF样式如下&…

计算机毕业设计选题推荐-宾馆酒店客房管理系统-民宿管理系统-Java/Python项目实战

✨作者主页:IT研究室✨ 个人简介:曾从事计算机专业培训教学,擅长Java、Python、微信小程序、Golang、安卓Android等项目实战。接项目定制开发、代码讲解、答辩教学、文档编写、降重等。 ☑文末获取源码☑ 精彩专栏推荐⬇⬇⬇ Java项目 Python…

英特尔新独显曝光,或于今年底发布

原文转载修改自(更多互联网新闻/搞机小技巧): 英特尔Arc Battlemage显卡参数规格曝光,或于年底发布 (不定时更新) Arc Battlemage显卡曝光 最近有报道称,英特尔计划将在今年晚些时候推出基于X…

Next.js中的客户端渲染和服务端渲染

前言 为什么会想着探究这个呢?因为我在学习的过程中发现:在next中默认是"use server"也就是如果使用服务端的话是不需要标明的,只有客户端才需要标明"use client",但是在我去掉代码中的"use server"后会报错c…

关于LLC知识7

光以R为输出,输出电压增益最大值不会超过1 但如果以电感作为输出的话,就可以让电压增益大于1或者小于1 ULXL*i 当回路电流足够大,UL也一定会高,就一定存在大于Vin的时候 当频率为谐振频率;R阻值刚好趋近于0的时候&…

基于 Android studio 实现停车场管理系统--原创

目录 一、项目演示 二、开发环境 三、项目页面 四、项目详情 五、项目完整源码 一、项目演示 二、开发环境 三、项目详情 1.启动页 这段代码是一个简单的Android应用程序启动活动(Activity),具体功能如下: 1. **延迟进入登…