为了账号安全,请及时绑定邮箱和手机立即绑定

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

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

Go
catspeake 2022-01-04 18:47:27
我有一个服务器和 2 个客户端,每个客户端都使用自己的端口。当客户端向服务器发送消息时,服务器将其回显给发送者。然后,服务器应该也将消息发送到另一个客户端。这是我遇到问题的地方。我相信我可能在 writeMessage() 中设置了错误的连接,但我不完全确定。目前,我的功能只是尝试在端口 8080 上写入客户端 2 以进行调试。服务器:package mainimport (    "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 mainimport (        "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 用户能够提供帮助!
查看完整描述

1 回答

?
慕神8447489

TA贡献1780条经验 获得超1个赞

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

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

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


查看完整回答
反对 回复 2022-01-04
  • 1 回答
  • 0 关注
  • 393 浏览
慕课专栏
更多

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信