kcp 协议分析基于udp的可靠协议

冷不防 2021-07-28 14:47 555阅读 0赞

项目地址：[https://github.com/skywind3000/kcp][https_github.com_skywind3000_kcp]

此项目是基于c语言的 其他语言实现自行搜索

### 简介 ###

KCP是一个快速可靠协议，能以比 TCP浪费10%-20%的带宽的代价，换取平均延迟降低 30%-40%，且最大延迟降低三倍的传输效果。纯算法实现，并不负责底层协议（如UDP）的收发，需要使用者自己定义下层数据包的发送方式，以 callback的方式提供给 KCP。 连时钟都需要外部传递进来，内部不会有任何一次系统调用。

整个协议只有 ikcp.h, ikcp.c两个源文件，可以方便的集成到用户自己的协议栈中。也许你实现了一个P2P，或者某个基于 UDP的协议，而缺乏一套完善的ARQ可靠协议实现，那么简单的拷贝这两个文件到现有项目中，稍微编写两行代码，即可使用。

### 基本概念 ###

**超时与重传**  
超时重传指的是，发送数据包在一定的时间内没有收到相应的ACK，等待一定的时间，超时之后就认为这个数据包丢失，就会重新发送。这个等待时间被称为RTO，即重传超时时间。

**滑动窗口**  
TCP通过确认机制来保证数据传输的可靠性。在早期的时候，发送数据方在发送数据之后会启动定时器，在一定时间内，如果没有收到发送数据包的ACK报文，就会重新发送数据，直到发送成功为止。但是这种停等的重传机制必须等待确认之后才能发送下一个包，传输速度比较慢。  
为了提高传输速度，发送方不必在每发送一个包之后就进行等待确认，而是可以发送多个包出去，然后等待接收方一 一确认。但是接收方不可能同时处理无限多的数据，因此需要限制发送方往网络中发送的数据数量。接收方在未收到确认之前，发送方在只能发送wnd大小的数据，这个机制叫做滑动窗口机制。TCP的每一端都可以收发数据。每个TCP活连接的两端都维护一个发送窗口和接收窗口结构。

### 技术特性 ###

TCP是为流量设计的（每秒内可以传输多少KB的数据），讲究的是充分利用带宽。而 KCP是为流速设计的（单个数据包从一端发送到一端需要多少时间），以10%-20%带宽浪费的代价换取了比 TCP快30%-40%的传输速度。TCP信道是一条流速很慢，但每秒流量很大的大运河，而KCP是水流湍急的小激流。KCP有正常模式和快速模式两种，通过以下策略达到提高流速的结果：

RTO翻倍vs不翻倍：

TCP超时计算是RTOx2，这样连续丢三次包就变成RTOx8了，十分恐怖，而KCP启动快速模式后不x2，只是x1.5（实验证明1.5这个值相对比较好），提高了传输速度。

选择性重传 vs 全部重传：

TCP丢包时会全部重传从丢的那个包开始以后的数据，KCP是选择性重传，只重传真正丢失的数据包。

快速重传：

发送端发送了1,2,3,4,5几个包，然后收到远端的ACK: 1, 3, 4, 5，当收到ACK3时，KCP知道2被跳过1次，收到ACK4时，知道2被跳过了2次，此时可以认为2号丢失，不用等超时，直接重传2号包，大大改善了丢包时的传输速度。

延迟ACK vs 非延迟ACK：

TCP为了充分利用带宽，延迟发送ACK（NODELAY都没用），这样超时计算会算出较大 RTT时间，延长了丢包时的判断过程。KCP的ACK是否延迟发送可以调节。

UNA vs ACK+UNA：

ARQ模型响应有两种，UNA（此编号前所有包已收到，如TCP）和ACK（该编号包已收到），光用UNA将导致全部重传，光用ACK则丢失成本太高，以往协议都是二选其一，而 KCP协议中，除去单独的 ACK包外，所有包都有UNA信息。

非退让流控：

KCP正常模式同TCP一样使用公平退让法则，即发送窗口大小由：发送缓存大小、接收端剩余接收缓存大小、丢包退让及慢启动这四要素决定。但传送及时性要求很高的小数据时，可选择通过配置跳过后两步，仅用前两项来控制发送频率。以牺牲部分公平性及带宽利用率之代价，换取了开着BT都能流畅传输的效果。

### 基本使用 ###

1.  创建 KCP对象：
    
        // 初始化 kcp对象，conv为一个表示会话编号的整数，和tcp的 conv一样，通信双
        // 方需保证 conv相同，相互的数据包才能够被认可，user是一个给回调函数的指针
        ikcpcb *kcp = ikcp_create(conv, user);
2.  设置回调函数：
    
        // KCP的下层协议输出函数，KCP需要发送数据时会调用它
        // buf/len 表示缓存和长度
        // user指针为 kcp对象创建时传入的值，用于区别多个 KCP对象
        int udp_output(const char *buf, int len, ikcpcb *kcp, void *user)
        {
          ....
        }
        // 设置回调函数
        kcp->output = udp_output;
3.  循环调用 update：
    
        // 以一定频率调用 ikcp_update来更新 kcp状态，并且传入当前时钟（毫秒单位）
        // 如 10ms调用一次，或用 ikcp_check确定下次调用 update的时间不必每次调用
        ikcp_update(kcp, millisec);
4.  输入一个下层数据包：
    
        // 收到一个下层数据包（比如UDP包）时需要调用：
        ikcp_input(kcp, received_udp_packet, received_udp_size);
    
    处理了下层协议的输出/输入后 KCP协议就可以正常工作了，使用 ikcp\_send 来向 远端发送数据。而另一端使用 ikcp\_recv(kcp, ptr, size)来接收数据。

### 协议配置 ###

协议默认模式是一个标准的 ARQ，需要通过配置打开各项加速开关：

1.  工作模式：
    
        int ikcp_nodelay(ikcpcb *kcp, int nodelay, int interval, int resend, int nc)
    
     *  nodelay ：是否启用 nodelay模式，0不启用；1启用。
     *  interval ：协议内部工作的 interval，单位毫秒，比如 10ms或者 20ms
     *  resend ：快速重传模式，默认0关闭，可以设置2（2次ACK跨越将会直接重传）
     *  nc ：是否关闭流控，默认是0代表不关闭，1代表关闭。
     *  普通模式： ikcp\_nodelay(kcp, 0, 40, 0, 0);
     *  极速模式： ikcp\_nodelay(kcp, 1, 10, 2, 1);
2.  最大窗口：
    
        int ikcp_wndsize(ikcpcb *kcp, int sndwnd, int rcvwnd);
    
    该调用将会设置协议的最大发送窗口和最大接收窗口大小，默认为32. 这个可以理解为 TCP的 SND\_BUF 和 RCV\_BUF，只不过单位不一样 SND/RCV\_BUF 单位是字节，这个单位是包。
3.  最大传输单元：
    
    纯算法协议并不负责探测 MTU，默认 mtu是1400字节，可以使用ikcp\_setmtu来设置该值。该值将会影响数据包归并及分片时候的最大传输单元。
4.  最小RTO：
    
    不管是 TCP还是 KCP计算 RTO时都有最小 RTO的限制，即便计算出来RTO为40ms，由于默认的 RTO是100ms，协议只有在100ms后才能检测到丢包，快速模式下为30ms，可以手动更改该值：
    
        kcp->rx_minrto = 10;

## ##

### KCP提高速率的方式 ###

（1）RTO。  
TCP的RTO是以2倍的方式来计算的。当丢包的次数多的时候，重传超时时间RTO就非常非常的大了，重传就非常的慢，效率低，性能差。而KCP的RTO可以以1.5倍的速度增长，相对于TCP来说，有更短的重传超时时间。  
（2）快速重传机制—无延迟ACK回复模式  
假如开启KCP的快速重传机制，并且设置了当重复的ACK个数大于resend时候，直接进行重传。 当发送端发送了1,2,3,4,5五个包，然后收到远端的ACK：1,3,4,5。当收到ACK3时，KCP知道2被跳过1次，当收到ACK4的时候，KCP知道2被跳过2次，当次数大于等于设置的resend的值的时候，不用等到超时，可直接重传2号包。这就是KCP的快速重传机制。  
（3）选择重传  
KCP采用滑动窗口机制来提高发送速度。由于UDP是不可靠的传输方式，会存在丢包和薄、包的乱序。而KCP是可靠的且保证数据有序的协议。为了保证包的顺序，接收方会维护一个接收窗口，接收窗口有一个起始序号 \*\*rcv\_nxt（待接收消息序号）\*\*以及尾序号 rcv\_nxt + rcv\_wnd（接收窗口大小）。如果接收窗口收到序号为 rcv\_nxt 的分片（刚好是接收端待接收的消息序号），那么 rcv\_nxt 就加一，也就是滑动窗口右移，并把该数据放入接收队列供应用层取用。如果收到的数据在窗口范围内但不是 rcv\_nxt ，那么就把数据保存起来，等收到rcv\_nxt序号的分片时再一并放入接收队列供应用层取用。  
当丢包发生的时候，假设第n个包丢失了，但是第n+1,n+2个包都已经传输成功了，此时只重传第n个包，二部重传成功传输的n+1,n+2号包，这就是选择重传。为了能够做到选择重传，接收方需要告诉发送方哪些包它收到了。比如在返回的ACK中包含rcv\_nxt和sn，rcv\_nxt的含义是接收方已经成功按顺序接收了rcv\_nxt序号之前的所有包，大于rcv\_nxt的序号sn表示的是在接收窗口内的不连续的包。那么根据这两个参数就可以计算出哪些包没有收到了。发送方接收到接收方发过来的数据时，首先解析rcv\_nxt，把所有小于rcv\_nxt序号的包从发送缓存队列中移除。然后再解析sn（大于rcv\_nxt），遍历发送缓存队列，找到所有序号小于sn的包，根据我们设置的快速重传的门限，对每个分片维护一个快速重传的计数，每收到一个ack解析sn后找到了一个分片，就把该分片的快速重传的计数加一，如果该计数达到了快速重传门限，那么就认为该分片已经丢失，可以触发快速重传，该门限值在kcp中可以设置。  
（4）拥塞窗口  
当网络状态不好的时候，KCP会限制发送端发送的数据量，这就是拥塞控制。拥塞窗口（cwnd）会随着网络状态的变化而变化。这里采用了慢启动机制，慢启动也就是控制拥塞窗口从0开始增长，在每收到一个报文段确认后，把拥塞窗口加1，多增加一个MSS的数值。但是为了防止拥塞窗口过大引起网络阻塞，还需要设置一个慢机制的的门限（ssthresh即拥塞窗口的阈值）。当拥塞窗口增长到阈值以后，就减慢增长速度，缓慢增长。  
但是当网络很拥堵的情况下，导致发送数据出现重传时，这时说明网络中消息太多了，用户应该减少发送的数据，也就是拥塞窗口应该减小。怎么减小呢，在快速重传的情况下，有包丢失了但是有后续的包收到了，说明网络还是通的，这时采取拥塞窗口的退半避让,拥塞窗口减半，拥塞门限减半。减小网络流量，缓解拥堵。当出现超时重传的时候，说明网络很可能死掉了，因为超时重传会出现，原因是有包丢失了，并且该包之后的包也没有收到，这很有可能是网络死了，这时候，拥塞窗口直接变为1，不再发送新的数据，直到丢失的包传输成功。

设置快速重传机制的源码：

//nodelay:   0 不启用，1启用快速重传模式
    //interval： 内部flush刷新时间
    //resend:    0（默认）表示关闭。可以自己设置值，若设置为2（则2次ACK跨越将会直接重传）
    //nc:        是否关闭拥塞控制，0（默认）代表不关闭，1代表关闭
    int ikcp_nodelay(ikcpcb *kcp, int nodelay, int interval, int resend, int nc)
    {
    	if (nodelay >= 0)              //大于0表示启用快速重传模式
    	{             
    		kcp->nodelay = nodelay;
    		if (nodelay) {
    			kcp->rx_minrto = IKCP_RTO_NDL;	//最小重传超时时间（如果需要可以设置更小）
    		} else{
    			kcp->rx_minrto = IKCP_RTO_MIN;  
    		}
    	}
    	if (interval >= 0) {
    		if (interval > 5000) 
    			interval = 5000;
    		else if (interval < 10) 
    			interval = 10;
    		kcp->interval = interval;           //内部flush刷新时间
    	}
    	if (resend >= 0) {                     // ACK被跳过resend次数后直接重传该包, 而不等待超时
    		kcp->fastresend = resend           // fastresend : 触发快速重传的重复ack个数
    	}
    	if (nc >= 0) {
    		kcp->nocwnd = nc;
    	}
    	return 0;
    }

### KCP主要工作过程 ###

把要发送的buffer分片成KCP的数据包格式，插入待发送队列中。  
当用户的数据超过一个MSS(最大分片大小)的时候，会对发送的数据进行分片处理。KCP采用的是流的方式进行分片处理。通过frg进行排序区分，frg即message中的segment分片ID，在message中的索引，由大到小，0表示最后一个分片。比如3,2,1,0。即把message分成了四个分片，分片的ID分别是4,3,2,1

分片方式共有两种：  
消息方式。将用户数据分片，为每个分片设置ID，将分片后的数据一个一个地存入发送队列，接收方通过id解析原来的包，消息方式一个分片的数据量可能不能达到MSS  
流方式。检测每个发送队列里的分片是否达到最大MSS，如果没有达到就会用新的数据填充分片。  
网络速度：流方式 > 消息方式  
接收数据：流方式一个分片一个分片的的接收。消息方式kcp的接收函数会把自己原本属于一个数据的分片重组

int ikcp_send(ikcpcb *kcp, const char *buffer, int len)
    {
    	IKCPSEG *seg;
    	int count, i;
    
    	assert(kcp->mss > 0);
    	if (len < 0) return -1;
    
    	//根据len计算出需要多少个分片
    	if (len <= (int)kcp->mss) 
    		count = 1;
    	else 
    		count = (len + kcp->mss - 1) / kcp->mss;   
    
    	if (count > 255) 
    		return -2;
    
    	if (count == 0) 
    		count = 1;
    
    	// fragment
    	for (i = 0; i < count; i++) {
    		int size = len > (int)kcp->mss ? (int)kcp->mss : len;   //获取当前分片的长度，存放到size中
    		seg = ikcp_segment_new(kcp, size);      
    		assert(seg);
    		if (seg == NULL) {
    			return -2;
    		}
    		if (buffer && len > 0) {
    			memcpy(seg->data, buffer, size);
    		}
    		seg->len = size;
    		seg->frg = count - i - 1;    //frg用来表示被分片的序号，从大到小递减
    		iqueue_init(&seg->node);
    		iqueue_add_tail(&seg->node, &kcp->snd_queue);   //把segment分片插入到发送队列中
    		kcp->nsnd_que++;
    		if (buffer) {
    			buffer += size;
    		}
    		len -= size;
    	}
    
    	return 0;
    }

将发送队列中的数据通过下层协议UDP进行发送

void ikcp_flush(ikcpcb *kcp)

主要处理以下情况：  
(1)发送ack

// flush acknowledges
    count = kcp->ackcount;
    for (i = 0; i < count; i++) {
    	size = (int)(ptr - buffer);
    	if (size + IKCP_OVERHEAD > IKCP_OVERHEAD) {
    		ikcp_output(kcp, buffer, size);
    		ptr = buffer;
    	}
    	ikcp_ack_get(kcp, i, &seg.sn, &seg.ts);   //sn:message分片segment的序号,ts:message发送时刻的时间戳
    	ptr = ikcp_encode_seg(ptr, &seg);
    }
    
    kcp->ackcount = 0;

(2)发送探测窗口消息

// probe window size (if remote window size equals zero)
    if (kcp->rmt_wnd == 0) {								//远端接收窗口大小为0的时候
    	if (kcp->probe_wait == 0) {                         //探查窗口需要等待的时间为0
    		kcp->probe_wait = IKCP_PROBE_INIT;              //设置探查窗口需要等待的时间
    		kcp->ts_probe = kcp->current + kcp->probe_wait; //设置下次探查窗口的时间戳 = 当前时间 + 探查窗口等待时间间隔
    	}	
    	else {
    		if (_itimediff(kcp->current, kcp->ts_probe) >= 0) { //当前时间 > 下一次探查窗口的时间
    			if (kcp->probe_wait < IKCP_PROBE_INIT) 
    				kcp->probe_wait = IKCP_PROBE_INIT;
    			kcp->probe_wait += kcp->probe_wait / 2;   //等待时间变为之前的1.5倍
    			if (kcp->probe_wait > IKCP_PROBE_LIMIT)
    				kcp->probe_wait = IKCP_PROBE_LIMIT;   //若超过上限，设置为上限值
    			kcp->ts_probe = kcp->current + kcp->probe_wait;  //计算下次探查窗口的时间戳
    			kcp->probe |= IKCP_ASK_SEND;         //设置探查变量。IKCP_ASK_TELL表示告知远端窗口大小。IKCP_ASK_SEND表示请求远端告知窗口大小
    		}
    	}
    }	else {
    	kcp->ts_probe = 0;
    	kcp->probe_wait = 0;
    }
    
    // flush window probing commands。IKCP_ASK_SEND表示请求远端告知窗口大小
    if (kcp->probe & IKCP_ASK_SEND) {
    	seg.cmd = IKCP_CMD_WASK;
    	size = (int)(ptr - buffer);
    	if (size + IKCP_OVERHEAD > IKCP_OVERHEAD) {
    		ikcp_output(kcp, buffer, size);     //KCP的下层输出协议，通过设置回调函数来实现
    		ptr = buffer;
    	}
    	ptr = ikcp_encode_seg(ptr, &seg);
    }
    
    // flush window probing commands。IKCP_ASK_TELL表示告知远端窗口大小
    if (kcp->probe & IKCP_ASK_TELL) {
    	seg.cmd = IKCP_CMD_WINS;
    	size = (int)(ptr - buffer);
    	if (size + IKCP_OVERHEAD > IKCP_OVERHEAD) {
    		ikcp_output(kcp, buffer, size);
    		ptr = buffer;
    	}
    	ptr = ikcp_encode_seg(ptr, &seg);
    }
    
    // flash remain no data segments
    size = (int)(ptr - buffer);
    if (size > 0) {
    	ikcp_output(kcp, buffer, size);
    	ptr = buffer;
    }
    
    kcp->probe = 0;

（3）计算拥塞窗口大小

// calculate window size
    cwnd = _imin_(kcp->snd_wnd, kcp->rmt_wnd);    //cwnd = 发送窗口大小 和 远端接收窗口大小的最小值
    if (kcp->nocwnd == 0)                         //不取消拥塞控制
    	cwnd = _imin_(kcp->cwnd, cwnd);           //拥塞窗口 = 当前拥塞窗口和cwnd的最小值（也就是取当前拥塞窗口、发送窗口、接收窗口的最小值）

（4）将发送队列中的消息存入发送缓存队列(发送缓存队列就是发送窗口)

while (_itimediff(kcp->snd_nxt, kcp->snd_una + cwnd) < 0) {
    	IKCPSEG *newseg;
    	if (iqueue_is_empty(&kcp->snd_queue)) 
    		break;
    
    	newseg = iqueue_entry(kcp->snd_queue.next, IKCPSEG, node);  //snd_queue：发送消息的队列
    
    	iqueue_del(&newseg->node);                      //从发送消息队列中，删除节点
    	iqueue_add_tail(&newseg->node, &kcp->snd_buf);  //然后把删除的节点，加入到kcp的发送缓存队列中
    	kcp->nsnd_que--; 
    	kcp->nsnd_buf++;
    
    	newseg->conv = kcp->conv;     //会话id
    	newseg->cmd = IKCP_CMD_PUSH;  //cmd：用来区分分片的作用。IKCP_CMD_PUSH:数据分片，IKCP_CMD_ACK:ack分片，IKCP_CMD_WASK：请求告知窗口大小，IKCP_CMD_WINS:告知窗口大小
    	newseg->wnd = seg.wnd;  
    	newseg->ts = current;           
    	newseg->sn = kcp->snd_nxt++;  //下一个待发报的序号
    	newseg->una = kcp->rcv_nxt;   //待收消息序号
    	newseg->resendts = current;   //下次超时重传的时间戳
    	newseg->rto = kcp->rx_rto;    //由ack接收延迟计算出来的重传超时时间
    	newseg->fastack = 0;          //收到ack时计算的该分片被跳过的累计次数
    	newseg->xmit = 0;             //发送分片的次数，每发送一次加一
    }

（5）检查缓存队列中当前需要发送的数据(包括新传数据和重传数据)

// flush data segments
    for (p = kcp->snd_buf.next; p != &kcp->snd_buf; p = p->next) {
    	IKCPSEG *segment = iqueue_entry(p, IKCPSEG, node);
    	int needsend = 0;
    	if (segment->xmit == 0) {
    		needsend = 1;
    		segment->xmit++;     			//发送分片的次数
    		segment->rto = kcp->rx_rto; 	//该分片超时重传的时间戳
    		segment->resendts = current + segment->rto + rtomini;  //下次超时重传的时间戳
    	}
    	else if (_itimediff(current, segment->resendts) >= 0) {   //当前时间>下次重传时间。说明没有重传，即丢包了？
    		needsend = 1;
    		segment->xmit++;
    		kcp->xmit++;
    		if (kcp->nodelay == 0) {        //0：表示不启动快速重传模式
    			segment->rto += kcp->rx_rto;    //不启动快速重传模式，每次重传之后rto的时间就是之前的2倍
    		}	else {
    			segment->rto += kcp->rx_rto / 2;  //启用快速重传之后，rto变成原来的1.5倍
    		}
    		segment->resendts = current + segment->rto;
    		lost = 1;
    	}
    	else if (segment->fastack >= resent) {     //fastack：表示收到ack计算的该分片被跳过的累积次数
    		needsend = 1;
    		segment->xmit++;
    		segment->fastack = 0;
    		segment->resendts = current + segment->rto;
    		change++;
    	}
    
    	if (needsend) {
    		int size, need;
    		segment->ts = current;
    		segment->wnd = seg.wnd;       //剩余接收窗口大小。即接收窗口大小-接收队列大小
    		segment->una = kcp->rcv_nxt;  //待接收消息序号
    
    		size = (int)(ptr - buffer);
    		need = IKCP_OVERHEAD + segment->len;   //segment报文默认大小 + segment的长度
    
    		// 禁止数据包合包
    		if (size + need > IKCP_OVERHEAD) {
    			ikcp_output(kcp, buffer, size, IKCP_RETRY_FLAG);
    			ptr = buffer;
    		}
    
    		ptr = ikcp_encode_seg(ptr, segment);
    
    		if (segment->len > 0) {
    			memcpy(ptr, segment->data, segment->len);
    			ptr += segment->len;
    		}
    
    		if (segment->xmit >= kcp->dead_link) {
    			kcp->state = -1;
    		}
    
    		// 重试次数打日志
    		if (segment->xmit > 1)
    		{
    			ikcp_log(kcp, 0x80000000, "xmit: %d, sn: %d, rto: %u", segment->xmit, segment->sn, segment->rto);
    		}
    	}
    }
    
    // flash remain segments
    size = (int)(ptr - buffer);
    if (size > 0) {
    	ikcp_output(kcp, buffer, size, IKCP_RETRY_FLAG);
    }

（6）根据重传数据更新发送窗口大小

（7）在发生快速重传的时候，会将慢启动阈值调整为当前发送窗口的一半，并把拥塞窗口大小调整为kcp.ssthresh + resent，resent是触发快速重传的丢包的次数，resent的值代表的意思在被弄丢的包后面收到了resent个数的包的ack，也就是我们在ikcp\_nodelay方法中设置的resend的值。这样调整后kcp就进入了拥塞控制状态。

if (change) {
    	IUINT32 inflight = kcp->snd_nxt - kcp->snd_una;   //下一个要分配的包 - 第一个未确认的包
    	kcp->ssthresh = inflight / 2;                     //change=1说明发生过快速重传。当发生快速重传的时候，会将慢启动阈值调整为当前发送窗口的一半
    	if (kcp->ssthresh < IKCP_THRESH_MIN)
    		kcp->ssthresh = IKCP_THRESH_MIN;   
    	kcp->cwnd = kcp->ssthresh + resent;   //并把拥塞窗口大小 = 拥塞窗口阈值 + 触发快速重传的ack大小
    	kcp->incr = kcp->cwnd * kcp->mss;
    }

（8）如果发生的超时重传，那么就重新进入慢启动状态。

if (lost) {
    	kcp->ssthresh = cwnd / 2;   //丢包了。窗口的大小需要减半
    	if (kcp->ssthresh < IKCP_THRESH_MIN)
    		kcp->ssthresh = IKCP_THRESH_MIN;
    	kcp->cwnd = 1;
    	kcp->incr = kcp->mss;
    }

kcp接收到下层协议UDP传进来的数据底层数据buffer转换成kcp的数据包格式

int ikcp_input(ikcpcb *kcp, const char *data, long size)

KCP报文分为ACK报文、数据报文、探测窗口报文、响应窗口报文四种。  
kcp报文的una字段（snd\_una：第一个未确认的包）表示对端希望接收的下一个kcp包序号，也就是说明接收端已经收到了所有小于una序号的kcp包。解析una字段后需要把发送缓冲区里面包序号小于una的包全部丢弃掉。

ack报文则包含了对端收到的kcp包的序号，接到ack包后需要删除发送缓冲区中与ack包中的发送包序号（sn）相同的kcp包。

if (cmd == IKCP_CMD_ACK) {
    	if ((_itimediff(kcp->current, ts) >= 0) && (_itimediff(sn, kcp->maxsn) >= 0)) {
    		ikcp_update_ack(kcp, _itimediff(kcp->current, ts));
    	}
    #if 0
    	{
    		ikcp_log(kcp, 0x80000000, "[ACK]conv: %d, sn: %d, ts: %u, current: %u", kcp->conv, sn, ts, kcp->current);
    	}
    #endif
    	ikcp_parse_ack(kcp, sn);
    	ikcp_shrink_buf(kcp);
    	if (ikcp_canlog(kcp, IKCP_LOG_IN_ACK)) {
    		ikcp_log(kcp, IKCP_LOG_IN_DATA, 
    			"input ack: sn=%lu rtt=%ld rto=%ld", sn, 
    			(long)_itimediff(kcp->current, ts),
    			(long)kcp->rx_rto);
    	}
    }

static void ikcp_parse_ack(ikcpcb *kcp, IUINT32 sn)
    {
    	struct IQUEUEHEAD *p, *next;
    
    	if (_itimediff(sn, kcp->snd_una) < 0 || _itimediff(sn, kcp->snd_nxt) >= 0)
    		return;
    
    	for (p = kcp->snd_buf.next; p != &kcp->snd_buf; p = next) {
    		IKCPSEG *seg = iqueue_entry(p, IKCPSEG, node);
    		next = p->next;
    		if (sn == seg->sn) {
    			iqueue_del(p);
    
    			kcp->sumxmit += seg->xmit;
    			++kcp->sumseg;
    
    			ikcp_segment_delete(kcp, seg);
    			kcp->nsnd_buf--;
    			break;
    		}
    		else {
    			// 序号为sn的被跳过了
    			seg->fastack++;
    		}
    	}
    }

收到数据报文时，需要判断数据报文是否在接收窗口内，如果是则保存ack，如果数据报文的sn正好是待接收的第一个报文rcv\_nxt，那么就更新rcv\_nxt(加1)。如果配置了ackNodelay模式（无延迟ack）或者远端窗口为0（代表暂时不能发送用户数据），那么这里会立刻fulsh（）发送ack。

else if (cmd == IKCP_CMD_PUSH) {    //数据报文
    	if (ikcp_canlog(kcp, IKCP_LOG_IN_DATA)) {
    		ikcp_log(kcp, IKCP_LOG_IN_DATA, 
    			"input psh: sn=%lu ts=%lu", sn, ts);
    	}
    	if (_itimediff(sn, kcp->rcv_nxt + kcp->rcv_wnd) < 0) {
    		ikcp_ack_push(kcp, sn, ts);     //sn:message分片segment的序号,ts:message发送时刻的时间戳
    		if (_itimediff(sn, kcp->rcv_nxt) >= 0) {
    			seg = ikcp_segment_new(kcp, len);
    			seg->conv = conv;
    			seg->cmd = cmd;
    			seg->frg = frg;
    			seg->wnd = wnd;
    			seg->ts = ts;
    			seg->sn = sn;
    			seg->una = una;
    			seg->len = len;
    
    			if (len > 0) {
    				memcpy(seg->data, data, len);
    			}
    
    			ikcp_parse_data(kcp, seg);
    		}
    	}
    }

如果snd\_una增加了那么就说明对端正常收到且回应了发送方发送缓冲区第一个待确认的包，此时需要更新cwnd（拥塞窗口）

if (_itimediff(kcp->snd_una, una) > 0) {     //如果第一个未确认的包的序号>待接收消息序号
        if (kcp->cwnd < kcp->rmt_wnd) {          //用拥塞口大小 < 远端接收窗口大小
           IUINT32 mss = kcp->mss;
            if (kcp->cwnd < kcp->ssthresh) {     //拥塞窗口大小 < 拥塞窗口阈值
                kcp->cwnd++;                     //拥塞窗口+1
                 kcp->incr += mss;                //可发送最大数据量增加最大分片个大小
             }   else {
               if (_itimediff(kcp->snd_una, una) > 0) {
    		if (kcp->cwnd < kcp->rmt_wnd) {
    			IUINT32 mss = kcp->mss;
    			if (kcp->cwnd < kcp->ssthresh) {
    				kcp->cwnd++;
    				kcp->incr += mss;
    			}	else {
    				if (kcp->incr < mss) kcp->incr = mss;
    				kcp->incr += (mss * mss) / kcp->incr + (mss / 16);
    				if ((kcp->cwnd + 1) * mss <= kcp->incr) {
    					kcp->cwnd++;
    				}
    			}
    			if (kcp->cwnd > kcp->rmt_wnd) {
    				kcp->cwnd = kcp->rmt_wnd;
    				kcp->incr = kcp->rmt_wnd * mss;
    			}
    		}
    	}

kcp将接收到的kcp数据包还原成之前kcp发送的buffer数据

int ikcp_recv(ikcpcb *kcp, char *buffer, int len)

[https_github.com_skywind3000_kcp]: https://github.com/skywind3000/kcp