Chapter018 golang tcp socket编程快速入门

上一章：Chapter017 golang反射 官方文档：https://studygolang.com/pkgdoc

一、tcp socket编程的快速入门

（一）案例
1、服务器端的处理流程

package main

import ( "fmt" "net" )

func main() { fmt.Println("服务器开始监听。。。") //使用协议为tcp //0.0.0.0:8888 表示本地监听 8888端口 listen, err := net.Listen("tcp", "0.0.0.0:8888") if err != nil{ fmt.Println("listen error:",err) return } defer listen.Close() //延时关闭listen

//循环等待客户端来连接我
for{
    //等待客户端来连接
    conn,err :=listen.Accept()
    if err != nil{
        fmt.Println("Accept() err=",err)
    }else {
        fmt.Println("connect sucess",conn)
    }
    //这里准备起一个协程为客户端服务
}
fmt.Println("listen sucess =",listen)

}

:<br> windows cmd 连接测试端口  
``` cmd
telnet 127.0.0.1 8888

退出输入

quit

如果报错
参考文章 ：https://www.cnblogs.com/chenmingjun/p/10323404.html
此时就会出现sever.go运行面板就会出现连接情况

package main

import ( "fmt" "net" )

func main() { conn ,err := net.Dial("tcp","127.0.0.1:8888") if err!=nil{ fmt.Println("client dial err=",err) return } fmt.Println("conn sucess = ",conn) }

服务器结果<br> ![描述](https://static.404bugs.com/jishushequ/2021-12-09/ade84267ded44d13842f97e8877341cc-20200206170938350.png)  
<br> 客户端结果<br> ![描述](https://static.404bugs.com/jishushequ/2021-12-09/6b633b1667f043598f77a7b374030d88-20200206170953788.png)  

:<br> 输出客户端ip  
``` go
fmt.Println("客户端ip=",conn,conn.RemoteAddr().String())

（2）阶段二，客户端输出信息
client.go

package main

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

func main()  {
    conn ,err := net.Dial("tcp","127.0.0.1:8888")
    if err!=nil{
        fmt.Println("client dial err=",err)
        return
    }
    fmt.Println("conn sucess = ",conn)
    reader :=bufio.NewReader(os.Stdin)

    //从终端读取一行用户输入并准备发送给服务器
    for{
        line ,err3:=reader.ReadString('\n')
        if err3 != nil{
            fmt.Println("read error = ",err3)
        }
        //要去掉"\r\n"才可以匹配
        line=strings.Trim(line,"\r\n")
        if line == "exit"{
            fmt.Println("客户端退出")
            break
        }
        //发送给服务器 ，并同时加上"\n"表示美观
        n,err4:=conn.Write([]byte(line+"\n"))
        if err4!=nil{
            fmt.Println("conn.Write err=",err4)
        }
        fmt.Printf("客户端发送了%d字节的数据\n",n)

    }
}

os包，从键盘中获取输入，将从键盘获取的数据保存到文件中


发送给服务器：


server.go：不变

package main

import (
    "fmt"
    "net"
)

//传入连接
func process(conn net.Conn)  {
    //循环接受客户端发送的数据
    defer conn.Close()
    for{
        //创建一个切片
        buf :=make([]byte,1024)
        //conn.Read(buf)
        //1.等待客户端通过conn发送信息
        //2.如果客户端没有write[发送]，那么协程就阻塞在这里
        fmt.Printf("服务器在等待客户端%s发送信息\n",conn.RemoteAddr().String())
        n,err :=conn.Read(buf) //从conn读取
        if err !=nil{
            fmt.Println("服务器的Read err=",err)
            return
        }
        //3.显示客户端发送的内容到服务器的终端
        fmt.Print(string(buf[:n])) //这里很重要
    }
}

func main()  {
    fmt.Println("服务器开始监听。。。")
    //使用协议为tcp
    //0.0.0.0:8888 表示本地监听 8888端口
    listen, err := net.Listen("tcp", "0.0.0.0:8888")
    if err != nil{
        fmt.Println("listen error:",err)
        return
    }
    defer listen.Close() //延时关闭listen

    //循环等待客户端来连接我
    for{
        //等待客户端来连接
        conn,err :=listen.Accept()
        if err != nil{
            fmt.Println("Accept() err=",err)
        }else {
            fmt.Println("connect sucess",conn)
            fmt.Println("客户端ip=",conn,conn.RemoteAddr().String())
        }
        //这里准备起一个协程为客户端服务
        go process(conn)
    }
    fmt.Println("listen sucess =",listen)

}

服务端：


客户端A:


客户端B:

二、经典项目——海量用户即时通讯

1、需求分析

• 用户注册
• 用户登录
• 显示在线客户列表
• 群聊（广播）
• 点对点聊天（私聊）
• 离线留言

  2、界面设计（文本界面）

• 登录界面
• 通讯界面