Go-从多个读取器从TCP连接读取数据

Question

I'm working on Cloud Server's networking thing using Go programming language. And I faced a problem with reading same TCPconn at the same time from different Goroutines.

Here is a simple example

package main

import (
    "fmt"
    "net"
)

func main() {
    addr, _ := net.ResolveTCPAddr("tcp", ":8888")
    listener, _ := net.ListenTCP("tcp", addr)

    for {
        conn, err := listener.AcceptTCP()
        if err != nil {
            fmt.Println(err)
            return
        }
        go Handle(conn) // output always coming from here
        go Handle(conn)
    }
}

func Handle(conn *net.TCPConn) {
    data := make([]byte, 1024)
    fmt.Println("Ok")
    for {
        len_data, err := conn.Read(data)
        fmt.Println(err)
        fmt.Println(len_data)
    }
}

In this example console output always coming from 1st goroutine go Handle(conn) ...

How to make Read functionality from 2 Goroutines at the same time ?

Thanks

Answer 1

Start a single go routine to perform conn.Read(data) and put the result into a channel.

Then (concurrently, without waiting for the first go routine to finish) start multiple go routines to read from this channel.

You don't want to directly read from the conn concurrently from multiple go routine since it is not thread-safe (the fact that it runs, and only run only on a single go routine probably because your MAXGOPROCS == 1).