内容参考从零开始写Socket Server，但这个文章里面有明显的错误，并且作者不再维护了，所以重新写一遍。
从最简单的Server-Client结构开始，
//server.go
package main
import (
"log"
"net"
)
func main() {
netListen, err := net.Listen("tcp", "localhost:2048")
if err != nil {
log.Println(err.Error())
return
}
defer netListen.Close()
log.Println("Waiting for clients")
for {
conn, err := netListen.Accept()
if err != nil {
log.Println(err.Error())
continue
}
log.Println(conn.RemoteAddr().String(), " tcp connect success")
handleConnection(conn)
}
}
func handleConnection(conn net.Conn) {
buffer := make([]byte, 2048)
for {
n, err := conn.Read(buffer)
if err != nil {
log.Println(conn.RemoteAddr().String(), " read error: ", err.Error())
return
}
log.Println(conn.RemoteAddr().String(), "receive data string:\n", string(buffer[:n]))
}
}
//client.go
package main
import (
"log"
"net"
)
func send(conn net.Conn) {
words := "Hello World!"
conn.Write([]byte(words))
log.Println("send finished")
}
func main() {
server := "127.0.0.1:2048"
tcpAddr, err := net.ResolveTCPAddr("tcp4", server)
if err != nil {
log.Println(err.Error())
return
}
conn, err := net.DialTCP("tcp", nil, tcpAddr)
if err != nil {
log.Println(err.Error())
return
}
log.Println("connect success")
send(conn)
}
内容比较简单，Server端通过net.Listen()监听本地的端口2048，每次发现有新的连接netListen.Accept()便读取数据然后打印出来。
Client端通过net.DialTCP()连接到Server并发送数据。
现在这个Server-Client存在的问题是，如果Client连续的发送结构化的数据(如json)，Server端是识别不出数据的结构的。所以需要定义一个简单的报文协议来处理这个问题，这就是下一节的内容。
