我有一个服务器和 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
- 1 回答
- 0 关注
- 393 浏览
添加回答
举报
0/150
提交
取消