Как считать данные с tcp запроса метода net.Listen?

Question

[Bekkazy]

func main() {
	// Слушает входящие сообщения
	l, err := net.Listen(CONN_TYPE, CONN_HOST+":"+CONN_PORT)
	if err != nil {
		fmt.Println("Error listening:", err.Error())
		os.Exit(1)
	}
	// Закрывает Listener когда приложение закрывается
	defer l.Close()
	fmt.Println("Listening on " + CONN_HOST + ":" + CONN_PORT)

	for {
		// Прослушивает входящие сообщения
		conn, err := l.Accept()
		if err != nil {
			fmt.Println("Error accepting: ", err.Error())
			os.Exit(1)
		}
		// Обрабатывает содинения в новом goroutine
		go handleRequest(conn)
	}
}

// Обрабатывает входящие соединения
func handleRequest(conn net.Conn) {
	// Создаем буфер для хранения входящих данных
	buf := make([]byte, 1024)

	// Считывает входящие сообщения в буфер
	reqLen, err := conn.Read(buf)

	if err != nil {
		fmt.Println("Error reading:", err.Error())
	}
	fmt.Println(reqLen)
	// Отправляем ответ обратно
	conn.Write([]byte("Message received."))
	// Закрываем соединение когда обработали запрос
	conn.Close()
}

Есть такой код, не понятно как считать входящие данные запроса.

PS. использование пакета net/http запрещено(

Comments

[Roman]

TCP это транспортный протокол, причем здесь какой то запрос?
Тупо создается двустороннее соединение и шлются сырые данные.
Полученные данные находятся в буфере приема.

[Bekkazy]

Roman, как лучше всего прочитать данные из буфера? потому что сейчас в зависимости от того выбираю я from-data или raw в постмане, у меня приходят разные данные

При raw не приходит последняя строка

К слову, мне надо создать http 1.0 сервер без использования пакета net/http

Answer 1

[igorzakhar]

Bekkazy, попробовал сделать запрос через Postman, метод запроса POST, тип данных выбираю raw. Все данные приходят без потерь, ничего не "обрезается":

Код обработчика:

func handleRequest(conn net.Conn) {
	defer conn.Close()
	buf := make([]byte, 1024)
	b := bufio.NewReader(conn)
	for {
		line, err := b.ReadBytes('\n')
		if err != nil { // for example EOF
			break
		}
		buf = append(buf, line...)
	}
	fmt.Print(string(buf))
}

Еще, как вариант:

func handleRequest(conn net.Conn) {
	message := make([]byte, 1024)
	_, error := conn.Read(message)
	if error != nil {
		fmt.Println(error)
		os.Exit(1)
	}
	fmt.Println(string(message))
	conn.Close() 
}

Comments

[Bekkazy]

В ответе получаю:


Только одна фигурная скобка, следуя логике, он пытается прочитать body запроса но возвращает только один элемент?

[Bekkazy]

Изменил свой handleRequets на это:

func handleReq(conn net.Conn) {
	buf := make([]byte, 1024)
	reqLen, err := conn.Read(buf)
	if err != nil {
		fmt.Println("Error reading:", err.Error(), reqLen)
	}
	fmt.Println("\r\nRECVD: " + string(buf))

	message, err := bufio.NewReader(conn).ReadString('\n')
	fmt.Print("Message received:", string(message))

	conn.Write([]byte("Message received."))
	conn.Close()
}

В ответе получаю заголовки но самого тела запроса нет.
Как его можно вытащить?

[igorzakhar]

Bekkazy, для начала, попробуй так:

func handleRequest(conn net.Conn) {
	message, _ := bufio.NewReader(conn).ReadString('\n')
	fmt.Print("Message received:", string(message))
	conn.Write([]byte("Message received."))
	conn.Close()
}

[Bekkazy]

igorzakhar, ReadString возвращает body до разделителя '\n', тоесть до первого нахождения перевода строки.
body у меня такого типа:
{
"testKey": "testVal"
}
По этому он показывает мне только - {

В документации не указано как можно получить все данные до eof, как можно вытащить все данные из body?

[igorzakhar]

Bekkazy,

func handleRequest(conn net.Conn) {
	b := bufio.NewReader(conn)
	for {
		line, err := b.ReadBytes('\n')
		if err != nil { // for example EOF
			break
		}
		fmt.Print(string(line))
		conn.Write(line)
	}
}

[Bekkazy]

igorzakhar, Спасибо, работает!
Но есть одна проблема, он не возвращает последнюю строку, и если в теле запроса всего одна строка, подает в ошибку: wsarecv: An existing connection was forcibly closed by the remote host.exit status 2

Можно ли каким то идентификатором в ReadBytes вернуть все тело запроса?

[igorzakhar]

Bekkazy, первое, что пришло в голову:

func handler(conn net.Conn) {
	buf := make([]byte, 1024)
	b := bufio.NewReader(conn)
	for {
		line, err := b.ReadBytes('\n')
		if err != nil { // for example EOF
			break
		}
		buf = append(buf, line...)
	}
	fmt.Print(string(buf))
}

Когда не видишь весь код как то проблематично делать какие то заключения. + Вопрос, каким образом отправляются "запросы", что это за "запросы"?

[igorzakhar]

Bekkazy, Я все свои примеры проверял. Все передается без ошибок, брал вывод однострочного файла и отправлял содержимое в соединение, сервер все получает. Посылал вывод многострочного файла, тоже никаких проблем с получением на сервере. В качестве клиента использовал netcat.

[Bekkazy]

igorzakhar, Я использую для тестов Postman. Выбираю заголовок Content-type: application/json.
Тип запроса POST, тело запроса отправляю в формате raw, вот тогда то и не приходит последняя строчка:
POST / HTTP/1.1
Content-Type: application/json
cache-control: no-cache
Postman-Token: beaf768e-246a-4929-be19-1a7d41895c4b
User-Agent: PostmanRuntime/7.6.0
Accept: */*
Host: localhost:3334
accept-encoding: gzip, deflate
content-length: 26
Connection: keep-alive

{
"testKey1":"testVal1"

Если выбрать from-data то приходит нормально:
POST / HTTP/1.1
Content-Type: multipart/form-data; boundary=--------------------------279588776128353738612845
cache-control: no-cache
Postman-Token: 4f99a6dc-2c58-4c04-88c8-1a0329cde628
User-Agent: PostmanRuntime/7.6.0
Accept: */*
Host: localhost:3334
accept-encoding: gzip, deflate
content-length: 284
Connection: keep-alive

----------------------------279588776128353738612845
Content-Disposition: form-data; name="testKey"

testVal
----------------------------279588776128353738612845
Content-Disposition: form-data; name="testKey2"

testVal2
----------------------------279588776128353738612845--