处理多个网络客户端

Question

我发现用go语言编写的TCP服务器和TCP客户端。问题是服务器无法处理多个客户端，我不知道如何允许它。

服务器：

package main 

import "net" 
import "fmt" 
import "bufio" 
import "strings" // only needed below for sample processing 

func main() { 

    fmt.Println("Launching server...") 

    // listen on all interfaces 
    ln, _ := net.Listen("tcp", ":8081") 

    // accept connection on port 
    conn, _ := ln.Accept() 

    // run loop forever (or until ctrl-c) 
    for { 
    // will listen for message to process ending in newline (\n) 
    message, _ := bufio.NewReader(conn).ReadString('\n') 
    // output message received 
    fmt.Print("Message Received:", string(message)) 
    // sample process for string received 
    newmessage := strings.ToUpper(message) 
    // send new string back to client 
    conn.Write([]byte(newmessage + "\n")) 
    } 
} 

客户：

package main 

import "net" 
import "fmt" 
import "bufio" 
import "os" 

func main() { 

    // connect to this socket 
    conn, _ := net.Dial("tcp", "127.0.0.1:8081") 
    for { 
    // read in input from stdin 
    reader := bufio.NewReader(os.Stdin) 
    fmt.Print("Text to send: ") 
    text, _ := reader.ReadString('\n') 
    // send to socket 
    fmt.Fprintf(conn, text + "\n") 
    // listen for reply 
    message, _ := bufio.NewReader(conn).ReadString('\n') 
    fmt.Print("Message from server: "+message) 
    } 
} 

谁能帮助我？

Soruce：https://systembash.com/a-simple-go-tcp-server-and-tcp-client/

Answer 1

你有几个问题。首先，您要接受的传入连接您的for循环。然后，你有可能会要产卵断的goroutine来处理请求中：

for { 
    // Listen for an incoming connection. 
    conn, err := l.Accept() 
    if err != nil { 
     log.Println("Error accepting: ", err.Error()) 
     continue 
    } 

    // Handle connections in a new goroutine. 
    go myHandler(conn) 
} 

资源来：
https://tour.golang.org/concurrency

GoPlay：
https://play.golang.org/p/7EovqNWJIx