使用C#和SerialPort类进行实时数据采集与控制

using System;
using System.IO.Ports;
 
class SerialPortCommunication
{
    private SerialPort serialPort;
 
    public SerialPortCommunication(string portName, int baudRate)
    {
        // 创建 SerialPort 实例并配置基本参数
        serialPort = new SerialPort
        {
            PortName = portName,        // 串口号
            BaudRate = baudRate,        // 波特率
            DataBits = 8,               // 数据位
            Parity = Parity.None,       // 校验位
            StopBits = StopBits.One,    // 停止位
            Handshake = Handshake.None  // 无握手协议
        };
        
        // 设置事件处理程序，当接收到数据时触发事件
        serialPort.DataReceived += new SerialDataReceivedEventHandler(DataReceivedHandler);
    }
 
    // 打开串口
    public void Open()
    {
        if (!serialPort.IsOpen)
        {
            serialPort.Open();
            Console.WriteLine("串口已打开");
        }
    }
 
    // 关闭串口
    public void Close()
    {
        if (serialPort.IsOpen)
        {
            serialPort.Close();
            Console.WriteLine("串口已关闭");
        }
    }
 
    // 发送数据到串口
    public void WriteData(string data)
    {
        if (serialPort.IsOpen)
        {
            serialPort.WriteLine(data);
            Console.WriteLine("数据发送: " + data);
        }
        else
        {
            Console.WriteLine("串口未打开，无法发送数据");
        }
    }
 
    // 读取串口数据并触发事件
    private void DataReceivedHandler(object sender, SerialDataReceivedEventArgs e)
    {
        string data = serialPort.ReadLine();
        Console.WriteLine("接收到数据: " + data);
        
        // 根据接收到的数据进行控制
        ProcessReceivedData(data);
    }
 
    // 处理接收到的数据
    private void ProcessReceivedData(string data)
    {
        if (data.Contains("ERROR"))
        {
            Console.WriteLine("设备错误，采取控制措施");
            // 执行相应的控制命令
            // 比如发送关闭命令
            WriteData("CLOSE");
        }
        else
        {
            Console.WriteLine("设备状态正常");
            // 执行其他控制命令
        }
    }
}
 
class Program
{
    static void Main()
    {
        SerialPortCommunication spComm = new SerialPortCommunication("COM1", 9600);
 
        try
        {
            // 打开串口并开始接收数据
            spComm.Open();
            
            // 主循环：模拟持续监控
            while (true)
            {
                // 模拟实时采集数据
                spComm.WriteData("REQUEST_DATA");
 
                // 每2秒请求一次数据
                System.Threading.Thread.Sleep(2000);
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine("出现错误: " + ex.Message);
        }
        finally
        {
            // 程序结束时关闭串口
            spComm.Close();
        }
    }
}