TCP-сервер Golang: как записать данные HTTP2 - PullRequest
Новая
       29

TCP-сервер Golang: как записать данные HTTP2

0 голосов
/ 24 августа 2018

Я новичок в HTTP / 2.0 и пытаюсь настроить TCP-сервер, написанный на Golang, который получает и записывает кадры 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: 

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

Насколько я знаю, после фреймов SETTINGS соединение должно быть готово к трафику.Поток должен быть открыт путем отправки кадра HEADERS, после чего кадр DATA может быть отправлен в открытом потоке.Однако после отправки кадра HEADERS я получаю следующее сообщение об ошибке: 

curl: (16) Error in the HTTP2 framing layer

Клиенты отвечают GOAWAY.

1 Ответ

0 голосов
/ 24 августа 2018

Я нашел проблему сам, если фактов было два.В этой статье я обнаружил обе проблемы: http://undertow.io/blog/2015/04/27/An-in-depth-overview-of-HTTP2.html

Прежде всего, обязательный заголовок ответа, содержащий код состояния, должен быть :status вместо :status:.

И, наконец, я не ответил на тот же идентификатор потока, с которого был сделан запрос, а вместо этого попытался открыть новый поток.

Так что я должен перебрать кадры запроса, поискатьидентификатор потока и используйте его для записи заголовков ответа. 

// 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()
...