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

Question

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

我相信我可能在 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)

}

（我的第二个客户端与我的第一个客户端相同，只是端口 3000 被替换为 8080。）

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

对此的任何帮助将不胜感激。我根本无法弄清楚这一点。希望更多有经验的 Go 用户能够提供帮助！

Answer 1

您的逻辑似乎有缺陷，其中acceptloop 调用listenconnection，它在无限循环内创建了一个无限循环。我认为您需要使用用例和场景重建系统。如果我的理解是正确的，你喜欢有一个服务器等待客户端连接。首先，client1 进来，发送一些数据。服务器接受这个连接，它只需要为每个客户端接受一次。此时，如果client2在线，则向client2发送数据。所有这一切都发生在无限循环中。签出此代码 https://play.golang.org/p/_5AREG3jnG