Golang实现之TCP长连接-------服务端和客户端
在Golang中实现TCP长连接,可以使用net
标准库来创建TCP服务器和客户端。以下是服务器和客户端的简单实现。
服务器端代码:
package main
import (
"fmt"
"net"
"time"
)
func main() {
listener, err := net.Listen("tcp", "localhost:50000")
if err != nil {
fmt.Println("Error listening:", err)
return
}
defer listener.Close()
for {
conn, err := listener.Accept()
if err != nil {
fmt.Println("Error accepting:", err)
continue
}
go handleConnection(conn)
}
}
func handleConnection(conn net.Conn) {
defer conn.Close()
for {
_, err := conn.Write([]byte("Hello from server\n"))
if err != nil {
fmt.Println("Error writing to client:", err)
return
}
time.Sleep(5 * time.Second) // 每5秒发送一次消息
}
}
客户端代码:
package main
import (
"fmt"
"io/ioutil"
"net"
"time"
)
func main() {
conn, err := net.Dial("tcp", "localhost:50000")
if err != nil {
fmt.Println("Error dialing:", err)
return
}
defer conn.Close()
for {
_, err := conn.Write([]byte("Hello from client\n"))
if err != nil {
fmt.Println("Error writing to server:", err)
return
}
response, err := ioutil.ReadAll(conn)
if err != nil {
fmt.Println("Error reading from server:", err)
return
}
fmt.Printf("Server said: %s\n", response)
time.Sleep(5 * time.Second) // 每5秒发送一次请求
}
}
在这个例子中,服务器监听本地的50000端口,并接受来自客户端的连接。每当客户端连接后,服务器就会创建一个goroutine来处理这个连接,定期向客户端发送消息。客户端也是每隔5秒向服务器发送消息,并读取服务器的响应。这样就形成了一个简单的TCP长连接。
评论已关闭