Chapter018 golang tcp socket编程快速入门

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

一、tcp socket编程的快速入门

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

• 监听端口 8888
• 接收客户端的tcp连接，建立客户端和服务器端的连接
• 创建gorountine，处理该连接的请求（通常客户端会通过连接发送请求包）

2、客户端的处理流程

• 建立与服务器端的连接
• 发送请求数据（终端），接收服务端返回的结果数据
• 关闭连接

3、程序示意图

4、代码（这里是一台电脑为案例）

（1）阶段一，小试牛刀

1. server.go

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)

}

tips:
windows cmd 连接测试端口

telnet 127.0.0.1 8888

退出输入

quit

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

2. client.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)
}

服务器结果

客户端结果

tips:
输出客户端ip

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、界面设计（文本界面）

• 登录界面
• 通讯界面