编写Golang TCP服务器以支持HTTP2数据流

珍惜时间，勤奋学习！今天给大家带来《编写Golang TCP服务器以支持HTTP2数据流》，正文内容主要涉及到等等，如果你正在学习Golang，或者是对Golang有疑问，欢迎大家关注我！后面我会持续更新相关内容的，希望都能帮到正在学习的大家！

我是 http/2.0 的新手，我正在尝试设置一个用 golang 编写的 tcp 服务器，它接收和写入 http/2.0 帧。我在将任何数据写回客户端时遇到问题。

以下代码片段显示了如何处理请求。

conn, err := l.accept()
if err != nil {
    log.fatal("could not accept connection:", err)
}
defer conn.close()

// every connection starts with a connection preface send first, which has to be read prior
// to reading any frames (rfc 7540, section 3.5)
const preface = "pri * http/2.0\r\n\r\nsm\r\n\r\n"
b := make([]byte, len(preface))
if _, err := io.readfull(conn, b); err != nil {
    log.fatal("could not read from connection:", err)
}
if string(b) != preface {
    log.fatal("invalid preface")
}

framer := http2.newframer(conn, conn)

// read client request (settings and headers)
readframes(framer)

// send empty settings frame to the client
framer.writerawframe(http2.framesettings, 0, 0, []byte{})

// read clients response (contains empty settings with end_stream flag)
readframes(framer)

// prepare headers
hbuf := bytes.newbuffer([]byte{})
encoder := hpack.newencoder(hbuf)
encoder.writefield(hpack.headerfield{name: ":status:", value: "200"})
encoder.writefield(hpack.headerfield{name: "date", value: time.now().utc().format(http.timeformat)})
encoder.writefield(hpack.headerfield{name: "content-length", value: strconv.itoa(len("ok"))})
encoder.writefield(hpack.headerfield{name: "content-type", value: "text/html"})

// write headers frame 
err = framer.writeheaders(http2.headersframeparam{streamid: 2, blockfragment: hbuf.bytes(), endheaders: true})
if err != nil {
    log.fatal("could not write headers: ", err)
}

// clients response contains goaway
readframes(framer)

framer.writedata(2, true, []byte("ok"))
conn.close()

完整的服务器可以在这里找到：https://play.golang.org/p/ona_ooyamg-

它是通过卷曲来调用的：

curl -kv https://127.0.0.1:8080 --http2

据我所知，在 settings 帧之后，连接应该准备好流量。应通过发送 headers 帧来打开流，然后可以在打开的流上发送 data 帧。但是，发送 headers 帧后，我收到以下错误消息：

curl: (16) Error in the HTTP2 framing layer

客户回复“goaway”。

解决方案

我自己发现了这个问题，如果事实上有两个。我在这篇文章中发现了这两个问题：http://undertow.io/blog/2015/04/27/An-in-depth-overview-of-HTTP2.html

首先，包含状态代码的所需响应标头应该是 :status 而不是 :status:。

最后，我没有对发出请求的同一流 id 做出响应，而是尝试打开一个新流。

所以我应该循环请求帧，查找流 id，并用它来写出响应标头。

// Read client request (SETTINGS and HEADERS)
readFrames(framer)
var streamID uint32
for _, frame := range frames {
    if headersframe, ok := frame.(*http2.HeadersFrame); ok {
        streamID = headersframe.StreamID
    }
}

//... Prepare headers

// Write HEADERS frame 
err = framer.WriteHeaders(http2.HeadersFrameParam{StreamID: streamID, BlockFragment: hbuf.Bytes(), EndHeaders: true})
if err != nil {
    log.Fatal("could not write headers: ", err)
}

framer.WriteData(streamID, true, []byte("ok"))
conn.Close()

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。