文章目录
- 一、Motivation
- 二、Solutions
- S1 - Writing webget
- S2 - An in-memory reliable byte stream
- 三、Results
- 四、Source
一、Motivation
第一个小测试 webget 是想让我们体验并模拟一下在浏览器中键入 URL 后获得远程服务器传来的内容，这并没有太大的难度，因为 Lab 本身已经为我们搭建好了 TCP/IP 五层协议栈的框架，我们要做的仅仅是解析传入的 host 和 path 即可，具体完善在 apps/webget.cc 的 get_URL() 中
第二个基本组件也比较简单，是想让我们实现一个最基本且最常用的字节流，可以将其理解成是一个队列，可以从头部读出数据，也可以从末端写入数据。同样，大体的框架 Lab 已经实现好了，只需要我们在 libsponge/byte_stream.cc 中完善其各功能即可
二、Solutions
S1 - Writing webget
针对第一个测试点 webget，应该在 apps/webget.cc 中完善具体的 get_URL() 即可，
void get_URL(const string &host, const string &path) {
TCPSocket sock;
sock.connect(Address(host, "http"));
sock.write("GET " + path + " HTTP/1.1\r\nHost: " + host +
"\r\nConnection: close\r\n\r\n");
sock.shutdown(SHUT_WR);
while (!sock.eof())
cout << sock.read();
sock.close();
}
首先，进入函数内不管三七二十一，先建 socket，然后尝试与目标 web 主机建立 TCP 连接。成功后，透过 write 将获取 URL 内容的请求发送给服务器。发送完成之后，关闭 socket 写的 Channel，意味着不能再向该 socket 当中写数据了，或许只能读
之后，就是等待 web 主机回复。通过eof判断可读的 Channel 内是否有数据送来，送来一份，读一份，直到读完为止
S2 - An in-memory reliable byte stream
针对第二个测试点稍微复杂一点，要修改 libsponge/byte_stream.h 和 libsponge/byte_stream.cc 的内容，让其支持一个队列的功能，
对于 writer，主要就是能够写入数据并且自知状态，包括队列的剩余容量及 Channel 是否已被关闭。在这里，我选用 deque 双端对列作为 ByteStream 的底层数据结构，来研究一下 write()，
size_t ByteStream::write(const string &data)
{
size_t len = data.length();
/* 有多少容量写多少数据 */
if(remaining_capacity() < data.length())
len = remaining_capacity();
for(size_t i=0; i<len; i++)
buf_.push_back(data[i]);
nwrite_ += len;
return len;
}
首先，要透过 remaining_capacity() 看一下当前对列还能不能容下将要写入的数据，其定义如下，
size_t ByteStream::remaining_capacity() const
{
return cap_ - buf_.size();
}
我们在此采用的是有多少容量，就写多少数据的策略，而不是 0 或 1 的策略（非写即丢）。定义了 nwrite_ 计数了一次 write 写了多少数据。end_input() 较为简单，只分辨是否还有字节将要写入，其定义如下，
void ByteStream::end_input()
{
ended_ = true;
}
关于读操作，Lab0 的文档是这样规范的，
第一个 peek_output() 主要用来查看队首元素，定义如下，
string ByteStream::peek_output(const size_t len) const
{
if(len > buf_.size())
return "";
return string(buf_.begin(), buf_.begin()+len);
}
pop_output() 和查看队首的功能差不多，只是将查看功能改为删除，
void ByteStream::pop_output(const size_t len)
{
if(len > buf_.size())
return;
for(size_t i=0; i<len; i++)
buf_.pop_front();
nread_ += len;
}
其中的 nread_ 和 nwrite_ 一样，用来统计 reader 已经读取了多少数据。read() 是框架定义好的，如下，
std::string read(const size_t len) {
const auto ret = peek_output(len);
pop_output(len);
return ret;
}
之后的一系列状态返回函数，我不一一展开了，无非就是封装一下成员变量，对外提供状态查看功能罢了
三、Results
根据文档在 sponge 目录下新建 build 文件夹，然后在 build 里透过 cmake .. 初始化编译环境，接着透过 make -j4 进行编译
完成编译之后，可以透过 make check_webget 和 make check_lab0 来检验自己程序的正确性
四、Source
- 【计算机网络】Stanford CS144 学习笔记
- [CS144] Lab 0: networking warmup
- 【斯坦福计网CS144项目】环境配置 & Lab0: ByteStream
