networking - 从一个端口向另一个端口发送消息

Question

我有一台服务器和两个客户端，每个客户端都使用自己的端口。当客户端向服务器发送消息时，服务器将其回显给发送方。然后，服务器也应该将消息发送给其他客户端。这是我遇到问题的地方。

我相信我可能在 writeMessage() 中设置了错误的连接，但我不完全确定。目前，我的功能只是为了调试目的而尝试在端口 8080 上写入客户端 2。

服务器:

package main

import (
    "fmt"
    "log"
    "net"
)

var message string = ""

func main() {
    fmt.Println("The server is listening on Port 3000 and 8080")
    listener, err := net.Listen("tcp", "localhost:3000")
    if err != nil {
        log.Fatal(err) 
    }

    listener2, err := net.Listen("tcp", "localhost:8080")
    if err != nil {
        log.Fatal(err)
    }

    go acceptLoop(listener)
    acceptLoop(listener2)


}

func acceptLoop(l net.Listener) {
    defer l.Close()
    for {
            c, err := l.Accept()
            if err != nil {
                log.Fatal(err)
            }
            fmt.Println("New connection found!")
            listenConnection(c)
    }
}

func listenConnection(conn net.Conn) {
        for {
                buffer := make([]byte, 1400)
                dataSize, err := conn.Read(buffer)
                if err != nil {
                    fmt.Println("Connection has closed")
                    return
                }

                //This is the message you received
                data := buffer[:dataSize]
                fmt.Print(string(data))
                conn.Write(data)
                message = string(data)
                writeMessage()
        }
}

func writeMessage(){
    conn2, e := net.Dial("tcp", "localhost:8080")
    if e != nil {
        log.Fatalln(e)
    }
    defer conn2.Close()
    conn2.Write([]byte(message))
}

客户 1:

package main

import (
        "fmt"
        "log"
        "net"
        "bufio"
        "os"
)

func main() {
        conn, err := net.Dial("tcp", "localhost:3000")
        if err != nil {
                log.Fatalln(err)
        }

        go listenConnection(conn, err)
        writeMessage(conn, err)

}

func listenConnection(conn net.Conn, err error){
    for {
                buffer := make([]byte, 1400)
                dataSize, err := conn.Read(buffer)
                if err != nil {
                        fmt.Println("connection closed")
                        return
                }

                data := buffer[:dataSize]
                fmt.Print("Server: ", string(data))
        }
}

func writeMessage(conn net.Conn, err error){
    for {
        reader := bufio.NewReader(os.Stdin)
        //fmt.Print("Enter message: ")
        text, _ := reader.ReadString('\n')
        text = "3000: " + text

        _, err = conn.Write([]byte(text))
        if err != nil {
                log.Fatalln(err)
        }
    }
}

(我的第二个客户端与我的第一个客户端相同，除了端口 3000 被替换为 8080。)

为了重现问题，用户必须先运行服务器代码，然后再运行两个客户端。然后客户端可以向服务器发送消息。

如有任何帮助，我们将不胜感激。我根本想不通。希望一些更有经验的 Go 用户能够提供帮助!

Answer 1

你的逻辑似乎有缺陷，acceptloop 调用 listenconnection，它在无限循环中创建了一个无限循环。我认为你需要用用例和场景重构系统。

如果我的理解是正确的，你喜欢有一个等待客户端连接的服务器。首先，client1 进来，发送一些数据。服务器接受这个连接，它只需要为每个客户端接受一次。此时如果client2在线，则向client2发送数据。所有这一切都发生在一个无限循环中。

checkout 此代码 https://play.golang.org/p/_5AREG3jnG