第二十章:Go语言socket编程

golang-gopher.png

1. 概述

Socket 起源于 Unix，而 Unix 基本哲学之一就是“一切皆文件”，都可以用“打开 open –>
读写 write/read –> 关闭 close”模式来操作。 Socket 就是该模式的一个实现，网络的 Socket
数据传输是一种特殊的 I/O， Socket 也是一种文件描述符

我们通常所说的网络编程有两种, 其一是TCP socket编程,其二是我们常用的HTTP编程,这两种网络编程都是基于tcp/ip协议的.HTTP编程使用的http协议,而http协议底层是tcp socket实现的

2. tcp socket示例

编写一个tcp socket 的服务端

TcpSocketServer.go

package main

import (
    "fmt"
    "log"
    "net"
)

func HandleCunc(c net.Conn) {
    defer c.Close()
    Addr := c.RemoteAddr().String()
    fmt.Println(Addr,"connect success")
    buf := make([]byte,1024)
    for{
        // 读取内容
        n,err := c.Read(buf)
        if err != nil{
            fmt.Println(err)
            return
        }
        result := buf[:n]
        // 提提示信息
        fmt.Printf("来自<%s>的数据:%s\n",Addr,string(result))
        // 关闭连接
        if "exit" == string(result){
            fmt.Println(Addr,"退出连接")
            return
        }
        // 发送给客户端数据
        c.Write([]byte(string(result)))
    }
}
func main() {
    // 监听本机的9000端口
    listener, err := net.Listen("tcp", "0.0.0.0:9000")
    if err != nil {
        log.Println(err)
        return
    }
    // 关闭监听
    defer listener.Close()
    // 循环等待连接
    for {
        // 等待客户端连接,返回一个连接句柄,等待下一个连接
        connect, err := listener.Accept()
        // 连接错误处理
        if err != nil {
            log.Println(err)
            continue
        }
        // 开启一协程处理客户端的连接
        go HandleCunc(connect)
    }
}

编写一个tcp socket 的客户端

TcpSocketClient.go

package main

import (
    "fmt"
    "log"
    "net"
)

func main() {
    addr := "127.0.0.1:9000"
    // 连接服务器
    conn, err := net.Dial("tcp", addr)
    if err != nil {
        log.Fatal(err.Error())
        return
    }
    defer conn.Close()
    // 设置缓冲
    buf := make([]byte, 2048)
    for {
        // 接收输入内容
        fmt.Println("please input :")
        fmt.Scan(&buf)
        // 写入内容
        conn.Write(buf)
        // 获取响应
        n,err := conn.Read(buf)
        if err != nil{
            fmt.Println(err)
            return
        }
        result := buf[:n]
        // 输入响应
        fmt.Println(string(result))
    }

}