当前位置: 首页 > news >正文

Socket通信

TCP/IP网络模型

最上层的是应用层,也就是我们日常可以接触到的,它会给数据添加对应的头部,并传输给传输层,应用层是我们日常会接触到的,比如HTTP,FTP,Telnet,DNS,SMTP。HTTPS默认端口是443.

传输层有两个协议:TCP和UDP,TCP常用于网络请求等可靠性要求高的场景下,UDP的特点是速度快,但可靠性较低,常用于VPN,域名查询的场景下。

TCP建立连接需要三次握手,客户端发送连接请求,服务器回应请求,客户端再次发送确认连接的请求。

客户端 ------SYN------>服务器(SYN=1,ACK=0,此时客户端还未连接,正发起连接请求)

客户端 <---SYN+ACK---服务器(SYN=1,ACK=1,此时服务器收到了连接请求,同意建立连接)

客户端 ------ACK------>服务器(SYN=0,ACK=1,连接已建立无需发送SYN去建立,只需发送ACK进行确认)

TCP断开连接需要四次挥手,客户端发送断开连接的请求,服务器回应请求表示可以,之后服务器再次发送断开连接的确认请求,客户端确认该请求。

客户端------FIN------>服务器(FIN=1,ACK=0,客户端发起断开连接的请求)

客户端<------ACK------服务器(FIN=0,ACK=1,服务器收到请求,向客户端确认请求,但还有部分数据未传完暂不断开)

客户端<------FIN------服务器(FIN=1,ACK=1,此时服务器的数据全部传输完成,可以断开连接)

客户端------ACK------>服务器(FIN=0,ACK=1,客户端确认收到了服务器的确认信息)

数据报文

数据报文是一次网络传输的基本单位,它包含多个部分:序列号,确认号,窗口,保留位,校验和。序列号用来打标记保证顺序是正确的,因为一次请求会被拆分为多个报文,确认号是告知接收方回应的标记,做到一一对应,保留字段包括刚刚提到的ACK,FIN,SYN,校验和是用来确认数据是否被篡改,如何无法通过校验会被丢弃,窗口是数据传输的吞吐量,受限于发送方和接收方的管道大小。

什么是拥塞窗口?

这是一种网络传输的过程,在初始阶段通信窗口的数量是成指数性增长,当达到临界值后,进行入拥塞避免阶段开始线性增长,当增长到出现丢包的情形时传输数量减半,并继续线性增长,如果接收到3次ACK请求,传输窗口的数量减半并加3,再进入线性增长。

网络层最常使用的是IP协议,这一层的职责是接收传输层的报文,将它封装为IP数据包,添加IP头。

两台电脑通过IP地址和端口号就可以建立Socket连接,一台电脑最多可以拥有2 ^ 16个端口。

通过在控制台中输入netstat -nao获取电脑的TCP和UDP连接,已经对应的PID。

Socket通信

Socket位于哪一层?

在 OSI 模型中,Socket 通常被认为是传输层的一部分,因为它直接与传输层协议(如 TCP 或 UDP)交互。

但从功能上看,Socket 更像是传输层和应用层之间的桥梁,因为它为应用层提供了访问传输层服务的接口。

如何用C#实现Socket通信?

这里需要用到一个第三方的类库TouchSocket,它比微软原生的Socket通信库多了很多功能,像是断点重连, 健康活性检验等等。

1、首先在Nuget上下载最新版的TouchSocket 3.1.1

2、创建一个TcpClient服务,进行事件绑定,配置插件,在Received事件中可以获取到服务器的反馈,发送数据通过Send方法

    // TCP客户端var _tcpClient = new TcpClient();#region 事件绑定_tcpClient.Connected = (client, e) =>{this.Invoke(new Action(() =>{this.richTextBoxMsgLog.AppendText($"连接到服务器".StringFormatLog() + Environment.NewLine);}));// 改变UI状态this._isOpen = true;this.Invoke(new Action(() => {this.btnOpen.Text = "断开连接";this.SwitchCheckBoxForSetting(false);}));return EasyTask.CompletedTask;};_tcpClient.Closed = (client, e) =>{this.Invoke(new Action(() =>{this.richTextBoxMsgLog.AppendText($"断开与服务器的连接".StringFormatLog() + Environment.NewLine);}));// 断开网络this._tcpClient.Close();this._isOpen = false;this.Invoke(new Action(() => {this.btnOpen.Text = "连接";this.SwitchCheckBoxForSetting(true);}));return EasyTask.CompletedTask;};_tcpClient.Received = (client, e) =>{string mes = e.ByteBlock.Span.ToString(Encoding.UTF8);this.Invoke(new Action(() =>{this.richTextBoxMsgLog.AppendText($"从服务器收到信息:{mes}".StringFormatLog() + Environment.NewLine);}));return EasyTask.CompletedTask;};#endregion// 配置断开重连机制var config = new TouchSocketConfig();config.ConfigurePlugins(plugins =>{// 自动重连plugins.UseTcpReconnection().UsePolling(TimeSpan.FromSeconds(1));});// 连接服务器await this._tcpClient.SetupAsync(config);await _tcpClient.ConnectAsync($"{ip}:{port}");

3、创建一个TcpServer服务,用于接收客户端发送的消息,代码和客户端的差不多。

    TcpService _service = new TcpService();// 创建一个TCP服务器_service.Connecting = (client, e) =>{return EasyTask.CompletedTask;};_service.Connected = (client, e) =>{this.Invoke(new Action(() =>{this.richTextBoxMsgLog.AppendText($"有客户端连接:{client.IP}:{client.Port}".StringFormatLog() + Environment.NewLine);}));return EasyTask.CompletedTask;};_service.Closing = (client, e) =>{return EasyTask.CompletedTask;};_service.Closed = (client, e) =>{this.Invoke(new Action(() =>{this.richTextBoxMsgLog.AppendText($"有客户端断开连接:{client.IP}:{client.Port}".StringFormatLog() + Environment.NewLine);}));return EasyTask.CompletedTask;};_service.Received = (client, e) =>{//从客户端收到信息var mes = e.ByteBlock.Span.ToString(Encoding.UTF8);this.Invoke(new Action(() =>{this.richTextBoxMsgLog.AppendText($"客户端:{client.IP}:{client.Port},发送消息:{mes}".StringFormatLog() + Environment.NewLine);}));return EasyTask.CompletedTask;};var config = new TouchSocketConfig();config.ConfigurePlugins(plugins =>{// 健康活性检验插件(CheckClearPlugin)用于检测当前连接是否有正常的数据交流,如果没有,则主动断开连接。plugins.UseCheckClear().SetCheckClearType(CheckClearType.All).SetTick(TimeSpan.FromSeconds(60)).SetOnClose(async (c, t) =>{await c.ShutdownAsync(System.Net.Sockets.SocketShutdown.Both);await c.CloseAsync("超时无数据");});});await this._service.SetupAsync(config);await this._service.StartAsync($"{ip}:{port}");

http://www.xdnf.cn/news/246439.html

相关文章:

  • Beetle-RP2350 扩展板设计
  • 力扣——23合并升序链表
  • 【ESP32】st7735s + LVGL使用-------图片显示
  • python多线程输入字符和写入文件
  • 关系型数据库设计指南
  • 2025五一杯数学建模竞赛选题建议+初步分析
  • terraform实现本地加密与解密
  • sftp连接报错Received message too long 168449893
  • 大鱼吃小鱼开源
  • leetcode 977. Squares of a Sorted Array
  • 【免费】1992-2021年各省GDP数据/各省地区生产总值数据
  • GoogleTest:简单示例及ASSERT/EXPECT说明
  • [FPGA 官方 IP] Binary Counter
  • 多节点监测任务分配方法比较与分析
  • 深度学习-神经网络参数优化的约束与迭代策略
  • 今日行情明日机会——20250430
  • python拜占庭将军
  • 基于开源AI智能名片链动2+1模式S2B2C商城小程序的电商直播流量转化路径研究
  • 计算机操作系统知识集合
  • 2025五一杯B题五一杯数学建模思路代码文章教学: 矿山数据处理问题
  • android 中的AMS 和 WMS
  • 【Day 14】HarmonyOS分布式数据库实战
  • linux下安装ollama网不好怎么办?
  • C++类和对象
  • c++文字游戏_废弃医院篇1.0
  • MySQL 查找指定表名的表的主键
  • javaScript——DOM续(五)
  • Vercel 全面指南:从零部署到高级实践
  • RAG技术完全指南(一):检索增强生成原理与LLM对比分析
  • Java反射机制终极指南:从基础到高级应用