tcp协议滑动窗口源代码

以下是基于C语言实现的TCP协议滑动窗口源代码，其中包括发送端和接收端的代码：

发送端代码：

#define WINDOW_SIZE 4 // 滑动窗口大小
#define MAX_SEQ_NUM 8 // 序列号最大值

typedef struct {
    int ack; // 确认号
    int seq; // 序列号
    char data; // 数据
} Packet;

int main() {
    int base = 0; // 当前窗口的起始位置
    int next_seq_num = 0; // 下一个要发送的序列号
    int expected_ack = 0; // 期望收到的确认号
    Packet window[WINDOW_SIZE]; // 滑动窗口
    bool acked[MAX_SEQ_NUM] = {false}; // 记录是否收到确认

    // 发送数据
    while (true) {
        // 发送窗口内未被确认的数据
        for (int i = 0; i < WINDOW_SIZE; i++) {
            int seq_num = (base + i) % MAX_SEQ_NUM;
            if (!acked[seq_num] && seq_num < next_seq_num) {
                Packet pkt;
                pkt.seq = seq_num;
                pkt.ack = expected_ack;
                pkt.data = 'a' + seq_num;
                send(pkt); // 发送数据包
            }
        }

        // 接收确认
        while (true) {
            Packet ack_pkt = receive(); // 接收确认
            if (ack_pkt.ack == expected_ack) {
                // 确认正确，更新窗口
                int acked_seq_num = (ack_pkt.seq + 1) % MAX_SEQ_NUM;
                while (acked[acked_seq_num]) {
                    acked[acked_seq_num] = false;
                    base = (base + 1) % MAX_SEQ_NUM;
                    expected_ack = (expected_ack + 1) % MAX_SEQ_NUM;
                    acked_seq_num = (acked_seq_num + 1) % MAX_SEQ_NUM;
                }
                acked[ack_pkt.seq] = true;
                break;
            }
        }

        // 发送下一个数据包
        next_seq_num = (next_seq_num + 1) % MAX_SEQ_NUM;
    }

    return 0;
}

接收端代码：

#define WINDOW_SIZE 4 // 滑动窗口大小
#define MAX_SEQ_NUM 8 // 序列号最大值

typedef struct {
    int ack; // 确认号
    int seq; // 序列号
    char data; // 数据
} Packet;

int main() {
    int expected_seq_num = 0; // 期望收到的序列号
    Packet window[WINDOW_SIZE]; // 滑动窗口

    // 接收数据
    while (true) {
        Packet pkt = receive(); // 接收数据包
        if (pkt.seq == expected_seq_num) {
            // 数据包正确，发送确认
            Packet ack_pkt;
            ack_pkt.ack = pkt.seq;
            ack_pkt.seq = expected_seq_num;
            ack_pkt.data = '\0';
            send(ack_pkt); // 发送确认

            // 更新窗口
            window[expected_seq_num % WINDOW_SIZE] = pkt;
            expected_seq_num++;

            // 输出数据
            while (true) {
                int index = expected_seq_num % WINDOW_SIZE;
                if (window[index].seq == expected_seq_num) {
                    printf("%c", window[index].data);
                    expected_seq_num++;
                } else {
                    break;
                }
            }
        } else {
            // 数据包错误，忽略
        }
    }

    return 0;
}