多个串行请求导致缓冲区为空

问题描述 投票:0回答:1

osx上运行在localhost上的第一个TCP连接总是正确地解析发送到它的二进制数据。随后的请求会丢失二进制数据,只看到第一个字节[8]。我的阅读器怎么会设置失败?

package main

import (
        "fmt"
        "log"
        "net"
        "os"
        "app/src/internal/handler"

        "github.com/golang-collections/collections/stack"
)

func main() {
        port := os.Getenv("SERVER_PORT")

        s := stack.New()

        ln, err := net.Listen("tcp", ":8080")
        if err != nil {
                log.Fatalf("net.Listen: %v", err)
        }

        fmt.Println("Serving on " + port)

        for {
                conn, err := ln.Accept()
                // defer conn.Close()
                if err != nil {
                        log.Fatal("ln.Accept")
                }
                go handler.Handle(conn, s)

        }
}
package handler

import (
        "fmt"
        "io"
        "log"
        "net"

        "github.com/golang-collections/collections/stack"
)

func Handle(c net.Conn, s *stack.Stack) {
        fmt.Printf("Serving %s\n", c.RemoteAddr().String())

        buf := make([]byte, 0, 256)
        tmp := make([]byte, 128)

        n, err := c.Read(tmp)
        if err != nil {
                if err != io.EOF {
                        log.Fatalf("connection Read() %v", err)
                }
                return
        }

        buf = append(buf, tmp[:n]...)
}

日志:

Serving [::1]:51699
 ------------- value ---------------:QCXhoy5t
Buffer Length: 9. First Value: 8
Serving [::1]:51700
------------- value ---------------:
Buffer Length: 1. First Value: 8
Serving [::1]:51701

测试发送完毕。

push random string:
QCXhoy5t

push random string:
GPh0EnbS
push random string:
4kJ0wN0R
go tcp binary byte
1个回答
0
投票

的文档 读者 说。

Read reads up to len(p) bytes into p. It returns the number of bytes read (0 <= n 
<= len(p)) and any error encountered. Even if Read returns n < len(p), it may use 
all of p as scratch space during the call. If some data is available but not 
len(p) bytes, Read conventionally returns what is available instead of waiting 
for more.

所以你的问题最可能的原因是Read正在返回可用的数据(在这种情况下是一个字符)。你可以通过使用 ioutil.ReadAll 或在循环中执行读取(数据被添加到缓冲区的事实使它看起来像是最初的意图),使用类似的东西。

for {
    n, err := c.Read(tmp)
    if err != nil {
        if err != io.EOF {
            // Note that data might have also been received - you should process that
            // if appropriate.
            log.Fatalf("connection Read() %v", err)
            return
        }
        break // All data received so process it
    }
    buf = append(buf, tmp[:n]...)
}

注意: 不能保证任何数据都被接收到;你应该在尝试访问数据之前检查数据的长度(即 buf[0] 可能会惊慌失措)

© www.soinside.com 2019 - 2024. All rights reserved.