tquic 多次发送数据异常

[lion117]

背景

1. ubuntuX64
2. simple_client.c simaple_server.c
3. libtquic.a

描述

基于 simple_client.c 我尝试让client 发送多次命令给服务器. 为了避免回传数据后自动关闭, 我屏蔽掉了客户端的自动关闭接口. 但是数据还是只能发送被接受一次. 想咨询一下我是卡在哪里了?

void client_on_conn_established(void *tctx, struct quic_conn_t *conn) {


    const char *data = "GET one  /\r\n";
    quic_stream_write(conn, 0, (uint8_t *)data, strlen(data), true);

    const char *data1 = "GET  two /\r\n";
    quic_stream_write(conn, 0, (uint8_t *)data1, strlen(data1), true);


    printf("\r\n[send] %s\r\n", data);
}

void client_on_stream_readable(void *tctx, struct quic_conn_t *conn,
                               uint64_t stream_id) {
    static uint8_t buf[READ_BUF_SIZE];
    bool fin = false;
    ssize_t r = quic_stream_read(conn, stream_id, buf, READ_BUF_SIZE, &fin);
    if (r < 0) {
        fprintf(stderr, "stream[%ld] read error\n", stream_id);
        return;
    }

    printf("\r\n-----------[recv] %.*s", (int)r, buf);

    if (fin) {
        const char *reason = "ok";
        // quic_conn_close(conn, true, 0, (const uint8_t *)reason, strlen(reason));
    }
}

[glime-ai[bot]]

根据您提供的代码和描述，您尝试在客户端发送多次命令给服务器，但数据只能被接受一次。以下是一些可能的原因和解决方案：

1. Stream ID 重用问题：
   您在两次 quic_stream_write 调用中都使用了相同的 stream_id（即0）。在 QUIC 协议中，每个流（stream）应该有一个唯一的 ID。您需要为每个新的请求创建一个新的流。

   void client_on_conn_established(void *tctx, struct quic_conn_t *conn) {
       const char *data = "GET one  /\r\n";
       quic_stream_write(conn, 0, (uint8_t *)data, strlen(data), true);
   
       const char *data1 = "GET  two /\r\n";
       quic_stream_write(conn, 1, (uint8_t *)data1, strlen(data1), true); // 使用不同的 stream_id
       printf("\r\n[send] %s\r\n", data);
   }

2. 流的关闭：
   在您的代码中，您在每次 quic_stream_write 调用中都将 fin 参数设置为 true，这表示这是流的最后一部分数据。您可以尝试将 fin 参数设置为 false，以便流保持打开状态，直到您明确关闭它。

   void client_on_conn_established(void *tctx, struct quic_conn_t *conn) {
       const char *data = "GET one  /\r\n";
       quic_stream_write(conn, 0, (uint8_t *)data, strlen(data), false); // 设置 fin 为 false
   
       const char *data1 = "GET  two /\r\n";
       quic_stream_write(conn, 1, (uint8_t *)data1, strlen(data1), false); // 设置 fin 为 false
       printf("\r\n[send] %s\r\n", data);
   }

3. 流的创建：
   确保在发送数据之前，流已经被正确创建。您可以在 client_on_conn_established 回调中创建新的流。

   void client_on_conn_established(void *tctx, struct quic_conn_t *conn) {
       uint64_t stream_id1, stream_id2;
       quic_stream_new(conn, &stream_id1, 0, false); // 创建新的流
       quic_stream_new(conn, &stream_id2, 0, false); // 创建新的流
   
       const char *data = "GET one  /\r\n";
       quic_stream_write(conn, stream_id1, (uint8_t *)data, strlen(data), false);
   
       const char *data1 = "GET  two /\r\n";
       quic_stream_write(conn, stream_id2, (uint8_t *)data1, strlen(data), false);
       printf("\r\n[send] %s\r\n", data);
   }

请根据以上建议进行修改，并确保每个流都有唯一的 ID，并且在需要时正确关闭流。如果问题仍然存在，请提供更多的日志信息以便进一步诊断。

This comment was generated by Glime.