GO网络编程（二）：客户端与服务端通信【重要】

news/2024/12/22 0:24:02/

本节是新知识，偏应用，需要反复练习才能掌握。

目录

    • 1.C/S通信示意图
    • 2.服务端通信
    • 3.客户端通信
    • 4.通信测试
    • 5.进阶练习：客户端之间通信

1.C/S通信示意图

客户端与服务端通信的模式也称作C/S模式，流程图如下
在这里插入图片描述
其中P是协程调度器。可以看到，客户端都是通过一个共同的端口和服务端通信的，且服务端开了两个协程并发处理两个客户端。注意，协程和P之间，协程和端口之间，端口和客户端之间的链接都是双向的。

2.服务端通信

服务端功能要求如下：

（1）编写一个服务器端程序，在8888端口监听

fmt.Println("服务器开始监听....")
//net.Listen("tcp", "0.0.0.0:8888")
//1. tcp 表示使用网络协议是tcp
//2. 0.0.0.0:8888 表示在本地监听 8888端口
listen, err := net.Listen("tcp", "0.0.0.0:8888")

（2）可以和多个客户端创建链接

//循环等待客户端来链接我
for {//等待客户端链接fmt.Println("等待客户端来链接....")conn, err := listen.Accept()//这里准备其一个协程，为客户端服务go process(conn)
}

（3）链接成功后，客户端可以发送数据，服务器端接受数据，并显示在终端上

完整代码如下：

package main
import ("fmt""net" //做网络socket开发时,net包含有我们需要所有的方法和函数_"io"
)func process(conn net.Conn) {//这里我们循环的接收客户端发送的数据defer conn.Close() //关闭connfor {//创建一个新的切片buf := make([]byte, 1024)//conn.Read(buf)//1. 等待客户端通过conn发送信息//2. 如果客户端没有wrtie[发送]，那么协程就阻塞在这里//fmt.Printf("服务器在等待客户端%s 发送信息\n", conn.RemoteAddr().String())n , err := conn.Read(buf) //从conn读取if err != nil {fmt.Printf("客户端退出 err=%v", err)return //!!!}//3. 显示客户端发送的内容到服务器的终端fmt.Print(string(buf[:n])) }}func main() {fmt.Println("服务器开始监听....")//net.Listen("tcp", "0.0.0.0:8888")//1. tcp 表示使用网络协议是tcp//2. 0.0.0.0:8888 表示在本地监听 8888端口listen, err := net.Listen("tcp", "0.0.0.0:8888")if err != nil {fmt.Println("listen err=", err)return }defer listen.Close() //延时关闭listen//循环等待客户端来链接我for {//等待客户端链接fmt.Println("等待客户端来链接....")conn, err := listen.Accept()if err != nil {fmt.Println("Accept() err=", err)} else {fmt.Printf("Accept() suc con=%v 客户端ip=%v\n", conn, conn.RemoteAddr().String())}//这里准备其一个协程，为客户端服务go process(conn)}//fmt.Printf("listen suc=%v\n", listen)
}

流程总结：
1.使用net.Listen()初始化监听端口，把初始信息存在变量listen中
2.循环使用listen.Accept()，接收监听到的基本信息，存在变量conn中
3.每次循环用conn.Read(buf)读取客户端发送的内容，将这些操作封装到一个协程中，并发执行

3.客户端通信

客户端功能：
（1）编写一个客户端程序，能链接到服务器端的8888端口

conn, err := net.Dial("tcp", "localhost:8888")

（2）客户端可以发送单行数据，然后就退出

reader := bufio.NewReader(os.Stdin) //os.Stdin 代表标准输入[终端]

（3）能通过终端输入数据(输入一行发送一行),并发送给服务器端

line, err := reader.ReadString('\n')
if err != nil {fmt.Println("readString err=", err)
}

其中ReadString(‘\n’)表示以换行符为截止符号，读取包括换行符在内的之前的字符，所以之后还需要去除line中的换行符。
（4）在终端输入exit,表示退出程序

	line = strings.Trim(line, " \r\n")if line == "exit" {fmt.Println("客户端退出..")break}

完整代码如下：

package main
import ("fmt""net""bufio""os""strings"
)func main() {conn, err := net.Dial("tcp", "localhost:8888")if err != nil {fmt.Println("client dial err=", err)return }//功能一：客户端可以发送单行数据，然后就退出reader := bufio.NewReader(os.Stdin) //os.Stdin 代表标准输入[终端]for {//从终端读取一行用户输入，并准备发送给服务器line, err := reader.ReadString('\n')if err != nil {fmt.Println("readString err=", err)}//如果用户输入的是 exit就退出line = strings.Trim(line, " \r\n")if line == "exit" {fmt.Println("客户端退出..")break}//再将line 发送给 服务器_, err = conn.Write([]byte(line + "\n"))if err != nil {fmt.Println("conn.Write err=", err)	}}
}

注：localhost是本地ip地址，默认ipv6。
流程总结：
1.使用net.Dial()建立与服务端的链接，把初始信息存在变量conn中
2.循环使用bufio.NewReader(os.Stdin)创建缓冲区，读入用户输入的信息并存在reader中
3.使用reader.ReadString('\n')提取每行字符
4.判断输入是否为exit，若是则退出循环
4.若输入步是exit，则用conn.Write()将每行内容发送到服务端

4.通信测试

先启动服务端，内容如下：

服务器开始监听....
等待客户端来链接....

注意，如果出现类似下图的提示框请点击允许！
在这里插入图片描述

再打开当前目录的命令行，启动客户端，命令行会显示如下语句

Accept() suc con=&{{0xc00008a508}} 客户端ip=[::1]:端口号

注意：这个端口号不是8888，而是客户端用来连接服务器时的本地端口。每个客户端在连接到服务器时，操作系统会为它分配一个临时的随机端口。
客户端输入几行语句

D:\code\golang\尚硅谷golang\代码\chapter18\tcpdemo\client>go run "client(1).go"
123
你好

服务端内容

服务器开始监听....
等待客户端来链接....
Accept() suc con=&{{0xc00008a508}} 客户端ip=[::1]:端口号
等待客户端来链接....
123
你好

客户端输入exit即可结束

客户端退出..D:\code\golang\尚硅谷golang\代码\chapter18\tcpdemo\client>

服务端内容

客户端退出 err=read tcp [::1]:8888->[::1]:端口号: wsarecv: An existing connection was forcibly closed by the remote host.

注意，此时服务端仍在循环监听，按ctrl+c即可结束程序。

5.进阶练习：客户端之间通信

为了使两个客户端能够相互通信，需要一个中介服务器（通常称为“中转服务器”），它负责转发每个客户端的消息给另一个客户端。服务器在两个客户端之间保持连接，接收其中一个客户端的消息，然后将其转发给另一个客户端。
实现步骤：
服务器端：
1.服务器负责接收客户端 A 和客户端 B 的连接。
2.服务器读取每个客户端发送的消息，然后将消息转发给另一个客户端。

package mainimport ("fmt""net""sync"
)var (clients = make(map[net.Conn]bool) // 存储连接的客户端mu      sync.Mutex                // 保护 clients 的并发访问
)func main() {listener, err := net.Listen("tcp", ":8888")if err != nil {fmt.Println("服务器启动错误:", err)return}defer listener.Close()fmt.Println("服务器正在监听8888端口...")for {conn, err := listener.Accept()if err != nil {fmt.Println("接受连接时发生错误:", err)continue}// 在服务端提示有新的客户端连接fmt.Printf("新的客户端已连接: %v\n", conn.RemoteAddr())// 将客户端添加到客户端列表mu.Lock()clients[conn] = truemu.Unlock()go handleConnection(conn) // 处理每个连接}
}func handleConnection(conn net.Conn) {defer func() {conn.Close()mu.Lock()delete(clients, conn) // 从列表中删除客户端mu.Unlock()}()buf := make([]byte, 1024)for {n, err := conn.Read(buf) // 读取客户端消息if err != nil {fmt.Printf("客户端 %v 断开连接: %v\n", conn.RemoteAddr(), err)return}message := string(buf[:n])// 判断是否是退出消息if message == "exit\n" || message == "exit" {fmt.Printf("客户端 %v 退出。\n", conn.RemoteAddr())return}// 转发消息给其他客户端mu.Lock()for client := range clients {if client != conn { // 不给发送者发送消息_, _ = client.Write(buf[:n]) // 将消息发送到其他客户端}}mu.Unlock()}
}

客户端：
1.客户端连接到服务器，通过服务器发送和接收消息。
2.客户端之间不会直接通信，而是通过服务器中转消息。

package mainimport ("bufio""fmt""net""os""strings"
)func main() {// 使用 localhost 连接到服务器conn, err := net.Dial("tcp", "localhost:8888")if err != nil {fmt.Println("连接服务器失败:", err)return}defer conn.Close() // 确保在退出时关闭连接// 启动一个 goroutine 负责接收服务器的消息go func() {buf := make([]byte, 1024)for {n, err := conn.Read(buf) // 从服务器读取数据if err != nil {fmt.Println("与服务器断开连接:", err)return}// 显示来自服务器的消息fmt.Print("收到消息: ", string(buf[:n]))}}()// 主协程负责发送用户输入的消息reader := bufio.NewReader(os.Stdin)fmt.Println("连接到服务器，输入消息发送，输入 'exit' 退出...")for {// 从终端读取一行用户输入line, err := reader.ReadString('\n')if err != nil {fmt.Println("读取输入时发生错误:", err)continue}// 去掉输入行的换行符和空格go ruline = strings.TrimSpace(line)// 如果用户输入的是 exit，退出程序if line == "exit" {fmt.Println("客户端退出...")break}// 将用户输入发送给服务器_, err = conn.Write([]byte(line + "\n"))if err != nil {fmt.Println("发送消息时发生错误:", err)}}
}

效果截图
在这里插入图片描述


http://www.ppmy.cn/news/1536698.html

相关文章

一分钟掌握 Java20 新特性

一分钟掌握 Java20 新特性

1. 预览特性：模式匹配 for switch (JEP 427) 描述： Java 20 继续完善了模式匹配 for switch ，使得 switch 语句可以处理更多类型的输入，并且语法更加灵活。 代码示例： public class SwitchPatternMatchingExample {p…
阅读更多...
HarmonyOS NEXT应用开发(一、打造最好用的网络通信模块组件)

HarmonyOS NEXT应用开发(一、打造最好用的网络通信模块组件)

随着HarmonyOS NEXT 的发布，越来越多的开发者开始关注如何在这个新平台上高效地进行应用开发。其中网络通信模块的封装尤为关键。纵观HarmonyOS的众多三方网络库及封装，竟没有一个简单好用的。虽然有个axios的鸿蒙版，但有点儿重了也不是很好用…
阅读更多...
初识Linux · 自主Shell编写

初识Linux · 自主Shell编写

目录 前言： 1 命令行解释器部分 2 获取用户命令行参数 3 命令行参数进行分割 4 执行命令 5 判断命令是否为内建命令 前言： 本文介绍是自主Shell编写，对于shell，即外壳解释程序，我们目前接触到的命令行解释器&am…
阅读更多...
【网络安全 | 渗透工具】自动化 .env/.git文件检测

【网络安全 | 渗透工具】自动化 .env/.git文件检测

原创文章，禁止转载。 文章目录 1. 安装 DotGit2. 配置 DotGit3. 使用 DotGit 检测 .env / .git 文件1. 安装 DotGit 在谷歌应用商店中搜索 DotGit 并进行安装： 2. 配置 DotGit 安装完成后，可以在设置中开启或关闭相关功能： 3. 使用 DotGit 检测 .env / .git 文件 接下来…
阅读更多...
【深度学习】—激活函数、ReLU 函数、 Sigmoid 函数、Tanh 函数

【深度学习】—激活函数、ReLU 函数、 Sigmoid 函数、Tanh 函数

【深度学习】—激活函数、ReLU 函数、 Sigmoid 函数、Tanh 函数 4.1.2 激活函数ReLU 函数参数化 ReLU Sigmoid 函数背景绘制 sigmoid 函数Sigmoid 函数的导数 Tanh 函数Tanh 函数的导数总结 4.1.2 激活函数 激活函数（activation function）用于计算加权和…
阅读更多...
通过MySQL Workbench 将 SQL Server 迁移到GreatSQL

通过MySQL Workbench 将 SQL Server 迁移到GreatSQL

通过MySQL Workbench 将 SQL Server 迁移到GreatSQL 一、概述 MySQL Workbench 提供了可以将Microsoft SQL Server的表结构和数据迁移到 GreatSQL 的功能，此次将通过MySQL Workbench将SQL Server的数据迁移到GreatSQL。 本文章只是简单演示一下单张表的迁移&…
阅读更多...
滚雪球学Oracle[3.2讲]：查询与数据操作基础

滚雪球学Oracle[3.2讲]：查询与数据操作基础

全文目录： 前言一、复杂查询的优化：索引与查询重写1.1 使用索引优化查询索引的原理索引类型索引的使用场景案例演示：创建和使用索引 1.2 查询重写技术常见的查询重写方法 1.3 查询计划分析案例演示：使用EXPLAIN查看查询计划 二、D…
阅读更多...
销售团队管理全面指南：从结构到流程

销售团队管理全面指南：从结构到流程

“除非卖出东西，否则就不能叫生意。” ——Thomas Watson的这段话表明，无论您经营哪个行业，销售都应该成为企业最重要的部分。您可能拥有出色的产品，但真正重要的是如何销售它。为此，您需要一支出色的销售团队&#xf…
阅读更多...
最新文章

Copyright @ 2022~2023