advance-practice/frame

[giscus[bot]]

advance-practice/frame

https://course.rs/advance-practice/frame.html

[zxcvc]

请问如果缓冲区容量很大 那么要等到缓冲区满了才往socket写数据 是否会导致客户端一直等待

[fengbianyun]

看需求吧，可以看最后个例子，提供了flush手动刷缓冲区。

[siliangZ]

在解析完成后，利用advance来将缓冲区该帧数据删除。这个地方我没有很理解。我们现在有一个BufMut， read_buf会写入并且update内部游标。而我们解析完数据后，调用advance也会update内部游标。这里的游标和read_buf 中的游标一样吗？感觉需要两个游标，一个标记当前的读入位置，一个标记当前的写入位置

[ruaruagerry]

let mut buf = Cursor::new(&self.buffer[..]);
这句话可以理解为创建了一个新的指针buf指向buffer，不管你怎么变动buf的位置，跟buffer本身的位置是没有关系的。

[Grothendieck42]

可以看看完整代码的注释
https://github.com/tokio-rs/mini-redis/blob/tutorial/src/connection.rs

[bxb100]

[iscas-zac]

书的评论区好像刷不出这张流程图，可以点名字边上的日期去 github 看

[Xiaobaishushu25]

求问这里： if 0 == self.stream.read_buf(&mut self.buffer).await? {
// 代码能执行到这里，说明了对端关闭了连接，
}
我的tcp服务端没有关闭连接，为什么客户端也会走到这里面？我查了资料，返回值为0的情况有两种：1.这个读取器已经达到了文件的“末尾”，并且可能不再能够产生字节。注意，这并不意味着读取器总是不能再产生字节。
2.指定的缓冲区剩余的容量为零。 我使用的缓冲区是BytesMut，应该会自动扩容所以不会容量不够吧？
那么第一点是什么意思，我的服务端并没有关闭。

[yuzheng14]

// 确保缓冲区长度足够
if self.buffer.len() == self.cursor {
    // 若不够，需要增加缓冲区长度
    self.buffer.resize(self.cursor * 2, 0);
}

这种扩容方式感觉还是不能保证缓冲区长度足够，还是应该封装一个结构体实现 BufMut 特征吧。在读取的时候自动扩容

[yuzheng14]

不过封装结构体就不如直接用 BytesMut 了