Golang网络编程

TCP编程

编写服务端

```go package main

import ( “bufio” “fmt” “net” )

//处理函数 func process(conn net.Conn) { defer conn.Close() //关闭连接 for { //获取输入流 reader := bufio.NewReader(conn) //每次读取的大小 var buf [1024]byte n, 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:21000”) 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) //开启启程去处理读取数据 } }

  2. > > <a name="5dca7040"></a>
  3. #### 编写客户端
  5. > ```go
  6. package main
  8. import (
  9.    "bufio"
  10.    "fmt"
  11.    "net"
  12.    "os"
  13.    "strings"
  14. )
  16. func main() {
  17.    conn, err := net.Dial("tcp", "127.0.0.1:21000")
  18.    if err != nil {
  19.       fmt.Println("err:", err)
  20.       return
  21.    }
  22.    defer conn.Close()
  23.    inputReader := bufio.NewReader(os.Stdin)
  24.    for true {
  25.       input, err := inputReader.ReadString('\n') //读取用户输入
  26.       inputInfo := strings.Trim(input, "\r\n")
  27.       if strings.ToUpper(inputInfo) == "Q" { //如果输入q表示退出
  28.          return
  29.       }
  30.       _, err = conn.Write([]byte(inputInfo)) //发送数据
  31.       if err != nil {
  32.          return
  33.       }
  34.       buf := [512]byte{}
  35.       read, err := conn.Read(buf[:])
  36.       if err != nil {
  37.          fmt.Println("recv failed,err:", err)
  38.          return
  39.       }
  40.       fmt.Println(string(buf[:read]))
  41.    }
  43. }

采用 go build tcpclient.go编译成exe文件