浙江龙网

  1. 首页 > 生活百科 > >

Go的网络编程详解( 三 )

生活百科


TCP服务端程序的处理流程：
1.监听端口2.接收客户端请求建立链接3.创建goroutine处理链接 。我们使用Go语言的net包实现的TCP服务端代码如下：
// tcp/server/main.go// TCP server端// 处理函数func process(conn net.Conn) {defer conn.Close() // 关闭连接for {reader := bufio.NewReader(conn)var buf [128]byten, err := reader.Read(buf[:]) // 读取数据if err != nil {fmt.Println("read from client failed, err:", err)break}recvStr := string(buf[:n])fmt.Println("收到client端发来的数据：", recvStr)conn.Write([]byte(recvStr)) // 发送数据}}func main() {listen, err := net.Listen("tcp", "127.0.0.1:20000")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处理连接}}将上面的代码保存之后编译成server或server.exe可执行文件 。
TCP客户端【Go的网络编程详解】一个TCP客户端进行TCP通信的流程如下：
1.建立与服务端的链接2.进行数据收发3.关闭链接使用Go语言的net包实现的TCP客户端代码如下：
// tcp/client/main.go// 客户端func main() {conn, err := net.Dial("tcp", "127.0.0.1:20000")if err != nil {fmt.Println("err :", err)return}defer conn.Close() // 关闭连接inputReader := bufio.NewReader(os.Stdin)for {input, _ := inputReader.ReadString('\n') // 读取用户输入inputInfo := strings.Trim(input, "\r\n")if strings.ToUpper(inputInfo) == "Q" { // 如果输入q就退出return}_, err = conn.Write([]byte(inputInfo)) // 发送数据if err != nil {return}buf := [512]byte{}n, err := conn.Read(buf[:])if err != nil {fmt.Println("recv failed, err:", err)return}fmt.Println(string(buf[:n]))}}将上面的代码编译成client或client.exe可执行文件，先启动server端再启动client端，在client端输入任意内容回车之后就能够在server端看到client端发送的数据，从而实现TCP通信 。
四 UDP编程Go语言实现UDP通信UDP协议UDP协议（User Datagram Protocol）中文名称是用户数据报协议 ， 是OSI（Open System Interconnection，开放式系统互联）参考模型中一种无连接的传输层协议，不需要建立连接就能直接进行数据发送和接收，属于不可靠的、没有时序的通信，但是UDP协议的实时性比较好 ， 通常用于视频直播相关领域 。
UDP服务端使用Go语言的net包实现的UDP服务端代码如下：
// UDP/server/main.go// UDP server端func main() {listen, err := net.ListenUDP("udp", &net.UDPAddr{IP:net.IPv4(0, 0, 0, 0),Port: 30000,})if err != nil {fmt.Println("listen failed, err:", err)return}defer listen.Close()for {var data [1024]byten, addr, err := listen.ReadFromUDP(data[:]) // 接收数据if err != nil {fmt.Println("read udp failed, err:", err)continue}fmt.Printf("data:%v addr:%v count:%v\n", string(data[:n]), addr, n)_, err = listen.WriteToUDP(data[:n], addr) // 发送数据if err != nil {fmt.Println("write to udp failed, err:", err)continue}}}UDP客户端使用Go语言的net包实现的UDP客户端代码如下：
// UDP 客户端func main() {socket, err := net.DialUDP("udp", nil, &net.UDPAddr{IP:net.IPv4(0, 0, 0, 0),Port: 30000,})if err != nil {fmt.Println("连接服务端失败，err:", err)return}defer socket.Close()sendData := []byte("Hello server")_, err = socket.Write(sendData) // 发送数据if err != nil {fmt.Println("发送数据失败 ， err:", err)return}data := make([]byte, 4096)n, remoteAddr, err := socket.ReadFromUDP(data) // 接收数据if err != nil {fmt.Println("接收数据失败，err:", err)return}fmt.Printf("recv:%v addr:%v count:%v\n", string(data[:n]), remoteAddr, n)}五 http编程web工作流程Web服务器的工作原理可以简单地归纳为：

  • 客户机通过TCP/IP协议建立到服务器的TCP连接
  • 客户端向服务器发送HTTP协议请求包，请求服务器里的资源文档
  • 服务器向客户机发送HTTP协议应答包，如果请求的资源包含有动态语言的内容，那么服务器会调用动态语言的解释引擎负责处理“动态内容”，并将处理得到的数据返回给客户端
  • 客户机与服务器断开 。由客户端解释HTML文档，在客户端屏幕上渲染图形结果
HTTP协议超文本传输协议(HTTP，HyperText Transfer Protocol)是互联网上应用最为广泛的一种网络协议，它详细规定了浏览器和万维网服务器之间互相通信的规则，通过因特网传送万维网文档的数据传送协议HTTP协议通常承载于TCP协议之上
HTTP服务端package mainimport ("fmt""net/http")func main() {//http://127.0.0.1:8000/go// 单独写回调函数http.HandleFunc("/go", myHandler)//http.HandleFunc("/ungo",myHandler2 )// addr：监听的地址// handler：回调函数http.ListenAndServe("127.0.0.1:8000", nil)}// handler函数func myHandler(w http.ResponseWriter, r *http.Request) {fmt.Println(r.RemoteAddr, "连接成功")// 请求方式：GET POST DELETE PUT UPDATEfmt.Println("method:", r.Method)// /gofmt.Println("url:", r.URL.Path)fmt.Println("header:", r.Header)fmt.Println("body:", r.Body)// 回复w.Write([]byte("www.5lmh.com"))}

推荐阅读


上一篇：day09-1存储引擎

下一篇：python-绘图与可视化