我有一個服務器和 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 關注
- 445 瀏覽
添加回答
舉報
0/150
提交
取消