socket编程
服务端处理流程的发展过程
初级 : 单进程, 单线程执行
中期 : 每个请求都由一个线程来完成
后期 : 监听socket状态, IO多路复用
go语言服务端处理流程
监听端口 -> 接收客户端的连接 -> 创建goroutine, 处理该链接
package main
import(
"fmt"
"net"
)
func main(){
fmt.Println("start server...")
listen,err := net.Listen("tcp", "127.0.0.1:8000") // 传输类型, 以及监听端口
if err != nil{
fmt.Println("listen failed, err", err)
return
}
for{
conn, err := listen.Accept() // 等待连接
if err != nil{
fmt.Println("accept failed, err", err)
continue
}
go process(conn) // 开启goroutine去执行
}
}
func process(conn net.Conn){
defer conn.Close() // 关闭连接
for {
buf := make([]byte, 512)
_, err := conn.Read(buf)
if err != nil{
fmt.Println("read err", err)
return
}
fmt.Println("read", string(buf))
}
}
客户端流程
连接服务端 -> 进行数据收发 -> 关闭连接
package main
import(
"bufio"
"fmt"
"net"
"os"
"strings"
)
func main(){
conn, err := net.Dial("tcp","127.0.0.1:8000") // 连接IP端口
if err != nil{
fmt.Println("Error dialing", err.Error())
return
}
defer conn.Close()
inputReader := bufio.NewReader(os.Stdin)
for{
input,_ := inputReader.ReadString(\'\n\') // 从命令行读取一行
trimmedInput := strings.Trim(input, "\r\n")
if trimmedInput == "Q"{
return
}
_, err = conn.Write([]byte(trimmedInput)) // 发送给服务端
if err != nil{
return
}
}
}
请发表评论