diff --git a/transport/internet/headers/http/http.go b/transport/internet/headers/http/http.go
index f506eb4b1..abf12a0bb 100644
--- a/transport/internet/headers/http/http.go
+++ b/transport/internet/headers/http/http.go
@@ -16,6 +16,8 @@ import (
 const (
 	CRLF   = "\r\n"
 	ENDING = CRLF + CRLF
+
+	maxHeaderLength = 8192
 )
 
 var (
@@ -47,7 +49,8 @@ type HeaderReader struct {
 
 func (*HeaderReader) Read(reader io.Reader) (*buf.Buffer, error) {
 	buffer := buf.NewSmall()
-	for {
+	totalBytes := 0
+	for totalBytes < maxHeaderLength {
 		err := buffer.AppendSupplier(buf.ReadFrom(reader))
 		if err != nil {
 			return nil, err
@@ -57,7 +60,8 @@ func (*HeaderReader) Read(reader io.Reader) (*buf.Buffer, error) {
 			break
 		}
 		if buffer.Len() >= len(ENDING) {
-			leftover := buffer.BytesFrom(buffer.Len() - len(ENDING))
+			totalBytes += buffer.Len() - len(ENDING)
+			leftover := buffer.BytesFrom(-len(ENDING))
 			buffer.Reset(func(b []byte) (int, error) {
 				return copy(b, leftover), nil
 			})