c.readRequest(ctx)读请求
先配置Header最长读取时间、req最长读取时间、req最大读取长度默认6M。
RFC7230禁止\r\n参数，Url中只允许包含英文字母（a-zA-Z）、数字（0-9）、-_.~4个特殊字符以及所有保留字符。但go net/http包放宽了这个要求。
读出Request
先构建newTextprotoReader，由于缓冲区是对象复用的，用完后要defer put。共完以以下解析任务：
- 协议第一行
- URL
- Header
- Body
TextprotoReader数据结构，将字节码Reader转成文本Reader。
type Reader struct
R *bufio.Reader
dot *dotReader
buf []byte // a re-usable buffer for readContinuedLineSlice
}
type dotReader struct {
r *Reader
state int
}
//struct之间相互引用
第一步，从第一行解析出method uri prototype。
第二步解析URL。url.URL数据结构：
type URL struct {
Scheme string
Opaque string
User *Userinfo
Host string
Path string
RawPath string
ForceQuery bool
RawQuery string
Fragment string
}
解析Scheme，协议前缀（小写）。有查询参数?，则配置url.ForceQuery url.RawQuery。有认证信息///...//，则解析url.User url.Host。最后配置url.Path和url.RawPath，如果Path==RawPath，则RawPath=""。
第三步解析MIMEHeader。
第四步readTransfer。重新配置如下参数：RequestMethod ProtoMajor ProtoMinor Header Trailer ContentLength Close。对于Body，如果encodings支持chunked，读取流用chunkedReader包裹。默认情况用LimitedReader，无body赋空的struct{}。
Request检查并补全
以下情况返回非空err，示得到正确的请求：
- 请求太大，超过了readLimitSize。
- 不支持的0.x和2+的HTTP协议版本。
- 请求Header中没有Host、超过1个或不合法。合法字符集为httpguts.validHostByte。
- Header的Key或Value不合法。Key的要求必须一httpguts.isTokenTable字符集，Value的要求不可以是控制字符集。
最后配置req.ctx req.RemoteAddr req.TLS body.doEarlyClose = true。
构建Response并包装chunkWriter
构建Response:
w = &response{
conn: c,
cancelCtx: cancelCtx,
req: req,
reqBody: req.Body,
handlerHeader: make(Header),
contentLength: -1,
closeNotifyCh: make(chan bool, 1),
wants10KeepAlive: req.wantsHttp10KeepAlive(),
wantsClose: req.wantsClose(),
}
其中closeNotifyCh必须在构建时初始化，没有content所以先置contentLength为-1。
配置w.cw并被w.w包裹。w.cw缓冲默认大小2M。
请求未正确获取的情况
获取Request可能出现如下错误：
- 请求超过readLimitSize，返回431错误，并刷新conn的读写缓冲。
- basRequest错误，返回400错误。包括网络原因导致的读取错误。
w.finishRequest()
先上响应数据结构：
type response struct {
conn *conn
req *Request
reqBody io.ReadCloser
cancelCtx context.CancelFunc
wroteHeader bool
wroteContinue bool
wants10KeepAlive bool
wantsClose bool
w *bufio.Writer
cw chunkWriter
handlerHeader Header
calledHeader bool
written int64
contentLength int64
status int
closeAfterReply bool
requestBodyLimitHit bool
trailers []string
handlerDone atomicBool
dateBuf [len(TimeFormat)]byte
clenBuf [10]byte
statusBuf [3]byte
closeNotifyCh chan bool
didCloseNotify int32
}
response字段可以分类为：大对象、缓冲、KV对或bool型的状态参数。
大对象有：
- conn为TCP连接指针
- req为对应的请求指针
- reqBody为req.Body
- cancelCtx为连接上下文context
状态字段：
- requestBodyLimitHit，读req.Body使用了maxBytesReader保护机制，当请求信息过大达到上限，就会在这个参数上反映。
- 4个Header参数：
- wroteHeader响应Header写入完成
- wroteContinue响应加入了100 Continue
- wants10KeepAlive为Connection "keep-alive"连接重用参数
- wantsClose为Connection "close"连接重用参数
- 3个数据： dateBuf clenBuf statusBuf对应Date Content-Length status cod
- 3个Body相关参数：contentLength written status三个字段用来校验响应内容是否写入完整，如果未写完则不对此连接进行复用。定位到上一篇文章serve()方法中有提到。
- trailers：指写完响应之后，还需要向TCP连接写入的数据
- handlerDone 表示handler是否存在
- handlerHeader calledHeader保存Header
缓冲区字段
chunkWriter数据结构：
type chunkWriter struct {
res *response
header Header
wroteHeader bool
chunking bool
}
chunkWriter包裹了Response，功能之一是完成Header设置，包括Content-Type Content-Length chunk-header。bufio.Writer是chunkWriter是缓冲包裹。
逻辑流
共完成三层缓冲写入：resp.w->resp.cw->conn.bufw
handler将响应写入到response.w。
调用w.w.Flush()将w写入到cw，注意到Flush()操作，如果未刷空缓存并报错，触发拷贝操作。报错不会退回已写出的数据。
copy(b.buf[0:b.n-n], b.buf[n:b.n]
进而调用cw.Write()，根据cw.chunking参数。
- 使能，则全部数据写入到TCP缓冲。
- 否则返回实际向TCP缓冲的写入量。
putBufioWriter(w.w)清空resp.w缓冲，如果池化放回sync.pool。
根据chunkWriter的定义，w.cw.close()负责cw的结束工作：写入换行符和resp.trailers数据。
最后刷新TCP缓冲w.conn.bufw.Flush()，完成响应包发送。并正确关闭request。
有疑问加站长微信联系（非本文作者）
