我们进入该项目可以看到里面有这样的一些内容
按照官方的运行方式来运行这个项目
在浏览器中打开8080端口，可以看到该项目可以被成功运行了。
就是这样一个简单的demo。
然后我们去看一下它的具体实现。
在这个项目中首先定义了一个hub的结构体：
这个结构体中，clients代表所有已经注册的用户，broadcast管道会存储客户端发送来的信息。 register是一个Client类型的管道，用于存储新注册的用户，unregister管道反之。
我们打开maingo，main函数的源码为：
在这里首先会新开一个goroutine，去跑hub的run方法，run方法中一个死循环，不停地去轮询hub中的内容
如果取到了新用户，就加入到clients中，如果取到了信息，就循环所有的client,将信息写到clientsend中。
我们看到在请求路径为根的时候，它会请求一个函数，而这个函数就是将homehtml发送到客户端。
而在请求路径为“/ws”的时候，他会执行一个serveWS的函数。
每当一个新的用户进来之后，首先将连接升级为长连接，然后将当前的client写到register中，由hubrun函数去做处理。然后开启两个goroutine,一个去读client中发送来的数据，一个将数据写入到所有的client中，去发送给用户。
这就是整个聊天室的实现原理。
原因
1、有可能是国服或者国际服炸了。
这时候官方一般都会发公告，提示你服务器暂时不能连接，并让工程师进行维修，玩家耐心等待即可。
不过还有另外一种解决方法，就是删除游戏目录文件夹下的package文件夹，再重启游戏，这是官方工程师给出的解决方案。不放心的玩家可以先备份该文件夹，再执行删除。
2、网络不稳定
CSGO连接官方服务器是通过steam访问域名来查询服务器状态的，由于网络运营商访问国外站点的服务不稳定（尤其是移动网），会出问题。
Csgo游戏平台分为：
1、官匹。
2、完美世界平台。
3、5E对战平台。
4、B5对战平台。
第三方平台首选5E，功能服务都比较齐全，唯一的不足就是部分功能需要VIP或者SVIP（没有会员，要是脸黑被分到香港服务器，算你倒霉）。
10人自定义可以选择完美对战平台，应该来说，没啥人玩的平台，闲置资源更多，不至于像5e没服务器了还给你分个香港。B5对战平台就比较类似于官匹，但是人数又比不上官匹，不过服务器延迟低到只有个位数，要是5e和官匹打烦了，不妨也换换B5试试。
三次握手：1 主动发起连接请求端（客户端），发送 SYN 标志位，携带数据包、包号
2 被动接收连接请求端（服务器），接收 SYN，回复 ACK，携带应答序列号。同时，发送SYN标志位，携带数据包、包号
3 主动发起连接请求端（客户端），接收SYN 标志位，回复 ACK。
被动端（服务器）接收 ACK —— 标志着 三次握手建立完成（ Accept()/Dial() 返回 ）
四次挥手：
1 主动请求断开连接端（客户端）， 发送 FIN标志，携带数据包
2 被动接受断开连接端（服务器）， 发送 ACK标志，携带应答序列号。 —— 半关闭完成。
3 被动接受断开连接端（服务器）， 发送 FIN标志，携带数据包
4 主动请求断开连接端（客户端）， 发送 最后一个 ACK标志，携带应答序列号。—— 发送完成，客户端不会直接退出，等 2MSL时长。
等 2MSL待目的：确保服务器 收到最后一个ACK
滑动窗口：
通知对端本地存储数据的 缓冲区容量。—— write 函数在对端 缓冲区满时，有可能阻塞。
TCP状态转换：
1 主动发起连接请求端：
CLOSED ——> 发送SYN ——> SYN_SENT(了解) ——> 接收ACK、SYN，回发 ACK ——> ESTABLISHED (数据通信)
2 主动关闭连接请求端：
ESTABLISHED ——> 发送FIN ——> FIN_WAIT_1 ——> 接收ACK ——> FIN_WAIT_2 (半关闭、主动端)
——> 接收FIN、回复ACK ——> TIME_WAIT (主动端) ——> 等 2MSL 时长 ——> CLOSED
3 被动建立连接请求端：
CLOSED ——> LISTEN ——> 接收SYN、发送ACK、SYN ——> SYN_RCVD ——> 接收 ACK ——> ESTABLISHED (数据通信)
4 被动断开连接请求端：
ESTABLISHED ——> 接收 FIN、发送 ACK ——> CLOSE_WAIT ——> 发送 FIN ——> LAST_ACK ——> 接收ACK ——> CLOSED
windows下查看TCP状态转换：
netstat -an | findstr 端口号
Linux下查看TCP状态转换：
netstat -an | grep 端口号
TCP和UDP对比:
TCP: 面向连接的可靠的数据包传递。 针对不稳定的 网络层，完全弥补。ACK
UDP：无连接不可靠的报文传输。 针对不稳定的 网络层，完全不弥补。还原网络真实状态。
优点 缺点
TCP： 可靠、顺序、稳定 系统资源消耗大，程序实现繁复、速度慢
UDP：系统资源消耗小，程序实现简单、速度快 不可靠、无序、不稳定
使用场景：
TCP：大文件、可靠数据传输。 对数据的 稳定性、准确性、一致性要求较高的场合。
UDP：应用于对数据时效性要求较高的场合。 网络直播、电话会议、视频直播、网络游戏。
UDP-CS-Server实现流程：
1 创建 udp地址结构 ResolveUDPAddr(“协议”， “IP：port”) ——> udpAddr 本质 struct{IP、port}
2 创建用于 数据通信的 socket ListenUDP(“协议”, udpAddr ) ——> udpConn (socket)
3 从客户端读取数据，获取对端的地址 udpConnReadFromUDP() ——> 返回：n，clientAddr， err
4 发送数据包给 客户端 udpConnWriteToUDP("数据"， clientAddr)
UDP-CS-Client实现流程：
1 创建用于通信的 socket。 netDial("udp", "服务器IP：port") ——> udpConn (socket)
2 以后流程参见 TCP客户端实现源码。
UDPserver默认就支持并发！
------------------------------------
命令行参数： 在main函数启动时，向整个程序传参。 重点
语法： go run xxxgo argv1 argv2 argv3 argv4 。。。
xxxexe: 第 0 个参数。
argv1 ：第 1 个参数。
argv2 ：第 2 个参数。
argv3 ：第 3 个参数。
argv4 ：第 4 个参数。
使用： list := osArgs 提取所有命令行参数。
获取文件属性函数：
osstat(文件访问绝对路径) ——> fileInfo 接口
fileInfo 包含 两个接口。
Name() 获取文件名。 不带访问路径
Size() 获取文件大小。
网络文件传输 —— 发送端（客户端）
1 获取命令行参数，得到文件名（带路径）filePath list := osArgs
2 使用 osstat() 获取 文件名（不带路径）fileName
3 创建 用于数据传输的 socket netDial("tcp"， “服务器IP+port”) —— conn
4 发送文件名(不带路径) 给接收端， connwrite()
5 读取 接收端回发“ok”，判断无误。封装函数 sendFile(filePath, conn) 发送文件内容
6 实现 sendFile(filePath, conn)
1) 只读打开文件 osOpen(filePath)
for {
2) 从文件中读数据 fRead(buf)
3) 将读到的数据写到socket中 connwrite(buf[:n])
4）判断读取文件的 结尾。 ioEOF 跳出循环
}
网络文件传输 —— 接收端（服务器）
1 创建用于监听的 socket netListen() —— listener
2 借助listener 创建用于 通信的 socket listenerAccpet() —— conn
3 读取 connread() 发送端的 文件名， 保存至本地。
4 回发 “ok”应答 发送端。
5 封装函数，接收文件内容 recvFile(文件路径)
1) f = osCreate(带有路径的文件名)
for {
2）从 socket中读取发送端发送的 文件内容 。 connread(buf)
3) 将读到的数据 保存至本地文件 fWrite(buf[:n])
4) 判断 读取conn 结束， 代表文件传输完成。 n == 0 break
}
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）