socket简单通讯

base:

TCP/IP(Transmission Control Protocol/Internet Protocol) 即传输控制协议/网间协议，是一种面向链接（链接导向）的、可靠的、基于字节流的传输层（Transport layer）通讯协议，由于是面向链接的协议，数据像水流同样传输，会存在黏包问题。

TCP-server:

一个TCP服务端能够同时链接不少个客户端，例如世界各地的用户使用本身电脑上的浏览器访问淘宝网。由于Go语言中建立多个goroutine实现并发很是方便和高效，因此咱们能够每创建一次连接就建立一个goroutine去处理。

TCP服务端程序的处理流程：

1. 监听端口
2. 接收客户端请求创建连接
3. 建立goroutine处理连接。

咱们使用Go语言的net包实现的TCP服务端代码以下

package main

import (
    "bufio"
    "fmt"
    "net"
)

// server

// 监听端口
// 接收客户端请求创建连接
// 建立goroutine处理连接

func process(conn net.Conn) {
    defer conn.Close() // 关闭链接
    for {
        reader := bufio.NewReader(conn)
        var buf [128]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)
        recvStr += "\tto"
        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处理链接
    }
}

TCP-client

一个TCP客户端进行TCP通讯的流程以下：

1. 创建与服务端的连接
2. 进行数据收发
3. 关闭连接

使用Go语言的net包实现的TCP客户端代码以下：

package main

import (
    "bufio"
    "fmt"
    "net"
    "os"
    "strings"
)

// client
// 创建与服务端的连接
// 进行数据收发
// 关闭连接

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]))
    }
}