我编写了一个非常简单的TCP服务器，该服务器读取连接并使用HELLO WORLD进行响应。
import (
"fmt"
"log"
"net"
)
func handleRequest(conn net.Conn) {
buff := make([]byte, 10)
_, err := conn.Read(buff)
if err != nil {
log.Fatal(err)
}
fmt.Println(string(buff))
conn.Write([]byte("HELLO WORLD"))
conn.Close()
}
func main() {
ln, err := net.Listen("tcp", ":8080")
fmt.Println("Listening on Port 8080")
if err != nil {
log.Fatal(err)
}
for {
conn, err := ln.Accept()
if err != nil {
log.Fatal(err)
}
go handleRequest(conn)
}
}
此代码有什么问题？运行curl http://localhost:8080时，得到此输出
curl: (56) Recv failure: Connection reset by peer
HELLO WORLD%
buff:=make([]byte,1024)
现在，如果我增加缓冲区大小，此代码可以正常工作，并且在运行curl后我不会收到该错误。
echo -n "Hello" | nc localhost 8080
如果我运行上面的命令，它将正常工作。
我真的不明白原因。
最佳答案
Curl发送一个很大的HTTP请求。尝试打印出(或log)conn.Read得到了什么，您将看到它。 Curl可能会感到不满意，因为它没有收到正确的HTTP响应。conn.Read无论如何都不会溢出缓冲区，它会读取缓冲区的大小。
另一方面，通往nc的管道仅在TCP套接字上发送5个字节。
这是一个使用正确的HTTP的示例TCP服务器:
package main
import (
"bufio"
"fmt"
"log"
"net"
"strings"
)
// handleConnection handles a single connected client.
func handleConnection(c net.Conn) {
defer c.Close()
scanner := bufio.NewScanner(c)
// Scan first line for the request
if !scanner.Scan() {
log.Fatal(scanner.Err())
}
req := scanner.Text()
for scanner.Scan() {
// Scan until an empty line is seen
if len(scanner.Text()) == 0 {
break
}
}
fmt.Println("req:", req)
if strings.HasPrefix(req, "GET") {
rt := fmt.Sprintf("HTTP/1.1 200 Success\r\n")
rt += fmt.Sprintf("Connection: Close\r\n")
rt += fmt.Sprintf("Content-Type: text/html\r\n\r\n")
rt += fmt.Sprintf("<html><body>Nothing here</body></html>\r\n")
c.Write([]byte(rt))
} else {
rt := fmt.Sprintf("HTTP/1.1 %v Error Occurred\r\n\r\n", 501)
c.Write([]byte(rt))
}
}
func main() {
l, err := net.Listen("tcp", ":8080")
if err != nil {
log.Fatal(err)
}
defer l.Close()
for {
// Wait for a connection.
conn, err := l.Accept()
if err != nil {
log.Fatal(err)
}
go handleConnection(conn)
}
}
关于go - 运行curl命令时，TCP服务器返回错误，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/59572425/