当前位置:网站首页>C# 三种方式实现Socket数据接收
C# 三种方式实现Socket数据接收
2022-07-06 14:48:00 【Phil Arist】
Stream.Read 方法
当在派生类中重写时,从当前流读取字节序列,并将此流中的位置提升读取的字节数。
语法:
public abstract int Read(byte[] buffer, int offset, int count)
参数:
buffer: 字节数组。此方法返回时,该缓冲区包含指定的字符数组,该数组的 offset 和 (offset + count -1) 之间的值由从当前源中读取的字节替换。
offset: buffer 中的从零开始的字节偏移量,从此处开始存储从当前流中读取的数据。
count: 要从当前流中最多读取的字节数。
返回值:
读入缓冲区中的总字节数。如果当前可用的字节数没有请求的字节数那么多,则总字节数可能小于请求的字节数,或者如果已到达流的末尾,则为零 (0)。
备注:
此方法的实现从当前流中读取最多的 count 个字节,并将它们存储在从 offset 开始的 buffer 中。流中的当前位置提升已读取的字节数;但是,如果出现异常,流中的当前位置保持不变。实现返回已读取的字节数。仅当位置当前位于流的末尾时,返回值才为零。如果没有任何可用的数据,该实现将一直阻塞到至少有一个字节的数据可读为止。仅当流中不再有其他的数据,而且也不再需要更多的数据(如已关闭的套接字或文件尾)时,Read 才返回 0。即使尚未到达流的末尾,实现仍可以随意返回少于所请求的字节。
之前一般采用如下方式进行数据接收:
int recv;//定义接收数据长度变量
IPEndPoint ipEnd = new IPEndPoint(IPAddress.Parse(textBox1.Text), int.Parse(textBox2.Text));
//接收端所监听的接口,ip也可以用IPAddress.Any
Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
//初始化一个Socket对象
socket.Bind(ipEnd);//绑定套接字到一个IP地址和一个端口上(bind());
socket.Listen(10);
while (true)
{
byte[] data = new byte[1024];//对data清零
Socket clientSocket = socket.Accept(); //一旦接受连接,创建一个客户端
recv = clientSocket.Receive(data);
if (recv == 0) //如果收到的数据长度小于0,则退出
break;
string stringData = "0x" + BitConverter.ToString(data).Replace("-", " 0x").ToLower();
this.Invoke((EventHandler)delegate
{
richTextBox1.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss") + stringData + "\n";
});
}
之前用的时候没发现什么问题,但是今天在测试金属门数据接收的时候发现会丢数据,金属门每隔十秒给我一次数据,用上面这个差不多60秒才能收到一组数据,针对以上问题,做了如下修改:
将数据接收放到 while (true),数据接收正常。
以下分别采用三种方式实现了数据的正常接收,代码如下:
测试:
Task.Run(() => {}); 这个可以去掉;
边栏推荐
- NPDP certification | how do product managers communicate across functions / teams?
- Inno setup packaging and signing Guide
- GPS from getting started to giving up (XI), differential GPS
- Netxpert xg2 helps you solve the problem of "Cabling installation and maintenance"
- Classification, function and usage of MySQL constraints
- 中国VOCs催化剂行业研究与投资战略报告(2022版)
- Support multiple API versions in flask
- 插入排序与希尔排序
- HDR image reconstruction from a single exposure using deep CNN reading notes
- 柔性数组到底如何使用呢?
猜你喜欢
Attack and defense world miscall
Spatial domain and frequency domain image compression of images
Clip +json parsing converts the sound in the video into text
Aardio - 不声明直接传float数值的方法
Management background --1 Create classification
自制J-Flash烧录工具——Qt调用jlinkARM.dll方式
Web APIs DOM time object
Barcodex (ActiveX print control) v5.3.0.80 free version
Chapter 3: detailed explanation of class loading process (class life cycle)
ZABBIX proxy server and ZABBIX SNMP monitoring
随机推荐
anaconda安装第三方包
Management background --2 Classification list
变量与“零值”的比较
数据处理技巧(7):MATLAB 读取数字字符串混杂的文本文件txt中的数据
Oracle-控制文件及日志文件的管理
NPDP认证|产品经理如何跨职能/跨团队沟通?
Anaconda installs third-party packages
[线性代数] 1.3 n阶行列式
[Digital IC hand tearing code] Verilog burr free clock switching circuit | topic | principle | design | simulation
剑指offer刷题记录1
Self made j-flash burning tool -- QT calls jlinkarm DLL mode
Aardio - 封装库时批量处理属性与回调函数的方法
Force deduction question 500, keyboard line, JS implementation
Assembly and interface technology experiment 5-8259 interrupt experiment
Memorabilia of domestic database in June 2022 - ink Sky Wheel
extern关键字
lora同步字设置
如何用程序确认当前系统的存储模式?
Leetcode exercise - Sword finger offer 26 Substructure of tree
0 basic learning C language - interrupt