之前有用python写过tcp的C/S,今天用golang完成同样的操作,分别写了客户端和服务端 客户端:
代码语言:javascript复制package main
import (
"fmt"
"net"
)
func main() {
conn, err := net.Dial("tcp", "127.0.0.1:8000")
if err != nil {
fmt.Println("net.Dail err", err)
return
}
defer conn.Close()
// 主动写数据给服务器
conn.Write([]byte("来自客户端的连接..."))
// 接受服务器回发数据
buf := make([]byte, 4096)
n, err := conn.Read(buf)
if err != nil {
fmt.Println("net.Dail err", err)
return
}
fmt.Println("服务器的消息是:", string(buf[:n]))
}
服务端:
代码语言:javascript复制package main
import (
"fmt"
"net"
)
func main() {
// 指定服务器通信协议ip地址和端口号
listener, err := net.Listen("tcp", "127.0.0.1:8000") // 这里的listen并不是监听,而是创建一个用于监听的socket
if err != nil {
fmt.Println("net.Listen err:", err)
return
}
defer listener.Close()
fmt.Println("服务器等待客户端建立连接.......")
// 阻塞监听客户端连接请求
conn, err := listener.Accept() // 监听
if err != nil {
fmt.Println("accept err",err)
return
}
defer conn.Close()
fmt.Println("服务器与客户端成功建立连接")
// 读取客户端发送数据
buf := make([]byte,4096)
n, err := conn.Read(buf) // n是字节数
if err != nil{
fmt.Println("conn Read err",err)
return
}
conn.Write(buf[:n]) // 读什么就往回写什么
// 处理数据
fmt.Println("服务器读取数据成功:",string(buf[:n]))
}