tcp server 在处理请求前需要做两个事情:
1. 监听
2. 获取tcp 连接
使用net包中的net.Listen()方法获取监听器。
使用Accept()方法获取tcp连接
simple_tcp_server.go
package main
import (
"bufio"
"log"
"net"
)
func main() {
log.Println("starting server...")
listener, err := net.Listen("tcp", ":9999")
if err != nil {
log.Println("listen faild")
}
conn, _ := listener.Accept()
for {
message, _ := bufio.NewReader(conn).ReadString('\n')
log.Println("receive message: ", message)
conn.Write([]byte("thanks" + "\n"))
}
}
tcp client 在向server发送数据前需要获取tcp连接。
使用net包中的net.Dial()方法向指定地址获取连接。
simple_tcp_client
package main
import (
"bufio"
"fmt"
"log"
"net"
"os"
)
func main() {
conn, err := net.Dial("tcp", "127.0.0.1:9999")
if err != nil {
log.Println("Dial faild")
return
}
for {
reader := bufio.NewReader(os.Stdin)
message, _ := reader.ReadString('\n')
fmt.Fprintf(conn, message+"\n")
reply, _ := bufio.NewReader(conn).ReadString('\n')
log.Println("recieve message from server: ", reply)
}
}