go 中 tcp socket 编程快速入门

Myth丶恋晨 2021-07-24 14:33 454阅读 0赞

# 一 tcp socket 编程的客户端和服务器端 #

下图为 Golang socket 编程中客户端和服务器的网络分布。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70][]

# 二 tcp socket 编程的快速入门 #

## 1 服务端的处理流程 ##

a 监听端口 8888。

b 接收客户端的 tcp 链接，建立客户端和服务器端的链接。

c 创建 goroutine，处理该链接的请求，通常客户端会通过链接发送请求包。

## 2 客户端的处理流程 ##

a 建立与服务端的链接。

b 发送请求数据，接收服务器端返回的结果数据。

c 关闭链接

# 三 程序示意图 #

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 1][]

# 四 服务端 #

## 1 功能说明 ##

编写一个服务器端程序，在 8888 端口监听。

可以和多个客户端创建链接。

链接成功后，客户端可以发送数据，服务器端接受数据，并显示在终端上。

## 2 代码 ##

package main
    
    import (
       "fmt"
       _ "io"
       "net" // 做网络 socket 开发时用到该包,net 包含有我们需要所有的方法和函数。
    )
    
    func process(conn net.Conn) {
       defer conn.Close() // 关闭conn
       // 循环的接收客户端发送的数据
       for {
          // 创建一个新的切片
          buf := make([]byte, 1024)
          // 1 等待客户端通过 conn 发送信息
          // 2 如果客户端没有 wrtie，那么协程就阻塞在这里
          // fmt.Printf("服务器在等待客户端%s 发送信息\n", conn.RemoteAddr().String())
          n, err := conn.Read(buf) // 从 conn 读取
          if err != nil {
             fmt.Printf("客户端退出 err=%v", err)
             return
          }
          // 3 显示客户端发送的内容到服务器的终端
          fmt.Print(string(buf[:n]))
       }
    }
    
    func main() {
       fmt.Println("服务器开始监听....")
       // net.Listen("tcp", "0.0.0.0:8888")
       // 1 tcp 表示使用网络协议是 tcp
       // 2 0.0.0.0:8888 表示在本地监听 8888 端口
       listen, err := net.Listen("tcp", "0.0.0.0:8888")
       if err != nil {
          fmt.Println("listen err=", err)
          return
       }
       defer listen.Close() // 延时关闭 listen
       // 循环等待客户端来链接
       for {
          // 等待客户端链接
          fmt.Println("等待客户端来链接....")
          conn, err := listen.Accept()
          if err != nil {
             fmt.Println("Accept() err=", err)
          } else {
             fmt.Printf("Accept() suc con=%v 客户端ip=%v\n", conn, conn.RemoteAddr().String())
          }
          // 启动一个协程，为客户端服务
          go process(conn)
       }
       // fmt.Printf("listen suc=%v\n", listen)
    }

# 五 客户端 #

## 1 功能说明 ##

编写一个客户端端程序，能链接到服务器端的 8888 端口。

客户端可以发送单行数据，然后就退出。

能通过终端输入数据(输入一行发送一行)，并发送给服务器端。

在终端输入 exit，表示退出程序。

## 2 代码 ##

package main
    
    
    import (
       "bufio"
       "fmt"
       "net"
       "os"
       "strings"
    )
    
    
    func main() {
       conn, err := net.Dial("tcp", "192.168.43.190:8888")
       if err != nil {
          fmt.Println("client dial err=", err)
          return
       }
       // 功能一：客户端可以发送单行数据，然后就退出
       reader := bufio.NewReader(os.Stdin) // os.Stdin 代表标准输入
       for {
          // 从终端读取一行用户输入，并准备发送给服务器
          line, err := reader.ReadString('\n')
          if err != nil {
             fmt.Println("readString err=", err)
          }
          // 如果用户输入的是 exit就退出
          line = strings.Trim(line, " \r\n")
          if line == "exit" {
             fmt.Println("客户端退出..")
             break
          }
          // 将 line 发送给 服务器
          _, err = conn.Write([]byte(line + "\n"))
          if err != nil {
             fmt.Println("conn.Write err=", err)
          }
       }
    }

# 六 测试 #

## 1 服务端 ##

> 服务器开始监听....
> 
> 等待客户端来链接....
> 
> Accept() suc con=&\{ \{0xc04207e240\}\} 客户端ip=192.168.43.190:59415
> 
> 等待客户端来链接....
> 
> hello
> 
> ok
> 
> 客户端退出 err=read tcp 192.168.43.190:8888->192.168.43.190:59415: wsarecv: An existing connection was forcibly closed by the remote host.

## 2 客户端 ##

> hello
> 
> ok
> 
> exit
> 
> 客户端退出..

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70]: /images/20210724/ebcff3e058ad4c038b43b937b3cad8d1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 1]: /images/20210724/9b4632d788de4b02a25e0c4a606b38b8.png