douwo1517
2018-08-24 10:33
浏览 92
已采纳

Golang TCP服务器:如何写入HTTP2数据

I'm new to HTTP/2.0, and I'm trying to set up a TCP server, written in Golang, which receives and writes HTTP/2.0 frames. I'm having trouble writing any data back to the client.

The following code snippet shows how the request is handled.

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

SM

"
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()

The full server can be found here: https://play.golang.org/p/ONA_OoyAMg-

It is called by doing a curl:

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

As far as I know, after the SETTINGS frames, the connection should be ready for traffic. A stream should be opened by sending a HEADERS frame, after which a DATA frame can be send on the open stream. However, after sending the HEADERS frame I get the following error message:

curl: (16) Error in the HTTP2 framing layer

The clients responds with a GOAWAY.

  • 写回答
  • 关注问题
  • 收藏
  • 邀请回答

1条回答 默认 最新

  • duanposhi3641 2018-08-24 14:29
    已采纳

    I found the issue myself, if fact there were two. I found both issues in this article: http://undertow.io/blog/2015/04/27/An-in-depth-overview-of-HTTP2.html

    First of all the required response header containing the status code should be :status instead of :status:.

    And finally I didn't respond on the same stream ID from which the request was made and instead tried opening a new stream.

    So I should loop over the request frames, look for the stream ID, and use it for writing out the response headers.

    // 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()
    
    已采纳该答案
    打赏 评论

相关推荐 更多相似问题