锐客网

  1. 首页 > 睿知 > it技术 > >

go语言异步tcp框架 golang channel同步与异步

连接IT技术

go语言TCP连接池rocket049/connpool使用安装：
go get -v -u github.com/rocket049/connpool
go get -v -u gitee.com/rocket049/connpool
rocket049/connpool 包是本人用go语言开发的，提供一个通用的TCP连接池，初始化参数包括最高连接数、超时秒数、连接函数，放回连接池的连接被重新取出时，如果已经超时，将会自动重新连接；如果没有超时，连接将被复用 。
可调用的函数：
调用示例：
Go语言做Web应用开发的框架，哪一个更适合入门可以先直接使用go自带go语言异步tcp框架的http server 框架，这个框架涵盖了绝大多数的功能，比如requestresponse 的基本封装，简单的路由管理，文件上传处理 。
如果发现Go 自带的框架解决不了问题，可以引入相应的第三方组件，比如ORM可以采用中国人写的gorm 比如web 的session 管理可以使用gorilla/session
当然go语言异步tcp框架你也可以直接上大一统的框架比如你提到的beego 还有大名鼎鼎的martini。不过不推荐，因为这样的大框架和Go 语言本身的模块设计有冲突 。
实际开发建议用vscode 加Go 插件来做IDE，基本包含了其go语言异步tcp框架他成熟IDE的所有功能，而且还自带强大的debug 功能 。其他IDEdebug 用起来非常麻烦比如idea 和liteIDE 。题主也可以自己试下 。
go语言框架有的不支持windows根据资料显示，go语言框架有的不支持windows，是因为与运行的 Windows 版本不兼容 。那么需要安装与windows兼容的版本 ， 即可 。
【golang】高并发下TCP常见问题解决方案首先，看一下TCP握手简单描绘过程：
其握手过程原理 ， 就不必说了，有很多详细文章进行叙述，本文只关注研究重点 。
在第三次握手过程中，如果服务器收到ACK，就会与客户端建立连接，此时内核会把连接从半连接队列移除，然后创建新的连接，并将其添加到全连接队列 ， 等待进程调用 。
如果服务器繁忙，来不及调用连接导致全连接队列溢出，服务器就会放弃当前握手连接，发送RST给客户端，即connection reset by peer 。
在linux平台上，客户端在进行高并发TCP连接处理时 ， 最高并发数量都要受系统对用户单一进程同时打开文件数量的限制（这是因为系统每个TCP都是SOCKET句柄 ， 每个soker句柄都是一个文件），当打开连接超过限制，就会出现too many open files 。
使用下指令查看最大句柄数量：
增加句柄解决方案
Go 语言自我提升 (三次握手 - 四次挥手 - TCP状态图 - udp - 网络文件传输)三次握手：
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.从客户端读取数据，获取对端的地址 udpConn.ReadFromUDP() —— 返回：n，clientAddr，err
4.发送数据包给 客户端 udpConn.WriteToUDP("数据"，clientAddr)
UDP-CS-Client实现流程：
1.创建用于通信的 socket 。net.Dial("udp", "服务器IP：port") —— udpConn (socket)
2.以后流程参见 TCP客户端实现源码 。
UDPserver默认就支持并发！
------------------------------------
命令行参数： 在main函数启动时，向整个程序传参 。【重点】
语法： go run xxx.goargv1 argv2argv3argv4。。。
xxx.exe:第 0 个参数 。
argv1 ：第 1 个参数 。
argv2 ：第 2 个参数 。
argv3 ：第 3 个参数 。
argv4 ：第 4 个参数 。
使用： list := os.Args提取所有命令行参数 。
获取文件属性函数：
os.stat(文件访问绝对路径) —— fileInfo 接口
fileInfo 包含 两个接口 。
Name() 获取文件名 。不带访问路径
Size() 获取文件大小 。
网络文件传输 —— 发送端（客户端）
1.获取命令行参数，得到文件名（带路径）filePathlist := os.Args
2.使用 os.stat() 获取 文件名（不带路径）fileName
3.创建 用于数据传输的 socketnet.Dial("tcp"，“服务器IP port”) —— conn
4.发送文件名(不带路径)给接收端 ， conn.write()
5.读取 接收端回发“ok”，判断无误 。封装函数 sendFile(filePath, conn) 发送文件内容
6.实现 sendFile(filePath,conn)
1) 只读打开文件 os.Open(filePath)
for {
2) 从文件中读数据f.Read(buf)
3) 将读到的数据写到socket中conn.write(buf[:n])
4）判断读取文件的 结尾 。io.EOF. 跳出循环
}
网络文件传输 —— 接收端（服务器）
1. 创建用于监听的 socket net.Listen() —— listener
2. 借助listener 创建用于 通信的 socket listener.Accpet()—— conn
3. 读取 conn.read() 发送端的 文件名 ， 保存至本地 。
4. 回发 “ok”应答 发送端 。
5. 封装函数，接收文件内容 recvFile(文件路径)
1) f = os.Create(带有路径的文件名)
for {
2）从 socket中读取发送端发送的 文件内容。conn.read(buf)
3)将读到的数据 保存至本地文件 f.Write(buf[:n])
4)判断 读取conn 结束，代表文件传输完成 。n == 0break
}
go语言有没有类似tp5框架有，go语言有框架 ， 例如：Beego（Go语言下开源的，高性能Web框架 ）、Buffalo（Go语言下快速Web开发框架）、Echo、Gin、Iris、Revel（高生产率，全栈Go语言的Web框架）等 。
【go语言异步tcp框架 golang channel同步与异步】go语言异步tcp框架的介绍就聊到这里吧，感谢你花时间阅读本站内容 ， 更多关于golang channel同步与异步、go语言异步tcp框架的信息别忘了在本站进行查找喔 。

    推荐阅读


    上一篇：如何将ERP部署到云服务器上？ erp放云服务器怎么放

    下一篇：如何进行腾讯云服务器的实名认证？ 腾讯云服务器怎么实名认证