我有一个类，它使用 C# 中的 DataReceived 事件处理程序从串行端口读取。当我收到数据时，我知道标头将有 5 个字节，所以我不想对数据做任何事情，直到我至少有这个。我当前的代码如下：
while (serialPort.BytesToRead<5)
{
//Do nothing while we have less bytes than the header size
}
//Once at least 5 bytes are received, process header
据我了解，这段代码是阻塞的，需要改进。我正在寻找有关如何执行此操作的建议。 DataReceived 事件处理程序中的另一个事件处理程序是否合适？
【问题讨论】：
标签： c# asynchronous serial-port blocking
使用异步编程（不要忘记首先将您的应用程序定位到 .NET Framework 4.5）。
这里有我的实现作为SerialPort 的扩展方法。
using System;
using System.IO.Ports;
using System.Threading.Tasks;
namespace ExtensionMethods.SerialPort
{
public static class SerialPortExtensions
{
public async static Task ReadAsync(this SerialPort serialPort, byte[] buffer, int offset, int count)
{
var bytesToRead = count;
var temp = new byte[count];
while (bytesToRead > 0)
{
var readBytes = await serialPort.BaseStream.ReadAsync(temp, 0, bytesToRead);
Array.Copy(temp, 0, buffer, offset + count - bytesToRead, readBytes);
bytesToRead -= readBytes;
}
}
public async static Task<byte[]> ReadAsync(this SerialPort serialPort, int count)
{
var buffer = new byte[count];
await serialPort.ReadAsync(buffer, 0, count);
return buffer;
}
}
}
这里是如何阅读的：
public async void Work()
{
try
{
var data = await serialPort.ReadAsync(5);
DoStuff(data);
}
catch(Exception excepcion)
{
Trace.WriteLine(exception.Message);
}
}
【讨论】：
System.IO.Ports.SerialPort serialPort 而不仅仅是SerialPort serialPort。不知道我是否搞砸了什么，但它只想那样工作。是的，我是using System.IO.Ports。 --- 但是，我仍然无法让它读取任何内容:(
ReadTimeout 不适用于BaseStream
这会消耗 100% 的核心，你不想那样做。正确的方法是让您的程序块在 Read() 调用上。你可以这样写：
private byte[] rcveBuffer = new byte[MaximumMessageSize];
private int rcveLength;
void ReceiveHeader() {
while (rcveLength < 5) {
rcveLength += serialPort.Read(rcveBuffer, rcveLength, 5 - rcveLength);
}
}
或者，如果您使用 DataReceived 事件，那么它可能如下所示：
private void serialPort_DataReceived(object sender, System.IO.Ports.SerialDataReceivedEventArgs e) {
if (e.EventType != System.IO.Ports.SerialData.Chars) return;
if (rcveLength < 5) {
rcveLength += serialPort.Read(rcveBuffer, rcveLength, 5 - rcveLength);
}
if (rcveLength >= 5) {
// Got the header, read the rest...
}
}
在获得整个消息并对其进行处理后，不要忘记将 rcveLength 设置回 0。
【讨论】：