我有一个服务器和两个使用各自端口的客户端。当客户端向服务器发送消息时,服务器会将其回显给发送方。然后,服务器也应该将消息发送到另一个客户端。这就是我遇到的问题。
我相信我可能在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用户能够为您提供帮助!
您的逻辑似乎有缺陷,其中acceptloop要求进行listenconnection,它会在无限循环内创建无限循环。我认为您需要使用用例和场景来重建系统。
如果我的理解是正确的,则您希望有一个服务器在等待客户端连接。首先,client1进入,发送一些数据。服务器接受此连接,并且只需要为每个客户端接受一次。此时,如果client2在线,则将数据发送到client2。所有这些都是无限循环发生的。
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句