串口接口支持收到数据后的事件通知

NewLifeX · Dec 10, 2023 · eebbe70 · eebbe70
1 parent 30e92a2
commit eebbe70
Showing 1 changed file with 24 additions and 1 deletion.
diff --git a/NewLife.ModbusRTU/Controllers/DefaultSerialPort.cs b/NewLife.ModbusRTU/Controllers/DefaultSerialPort.cs
@@ -3,6 +3,7 @@
 using System.Diagnostics.CodeAnalysis;
 using System.IO.Ports;
 using NewLife.Data;
+using NewLife.Net;
 
 namespace NewLife.IoT.Controllers;
 
@@ -24,15 +25,25 @@ public class DefaultSerialPort : DisposeBase, ISerialPort
     /// <summary>缓冲区大小。默认256</summary>
     public Int32 BufferSize { get; set; } = 256;
 
+    /// <summary>收到数据事件</summary>
+    public event EventHandler<ReceivedEventArgs>? Received;
+
     private SerialPort? _port;
+    /// <summary>串口对象</summary>
+    public Object Port => _port ??= new(PortName, Baudrate) { ReadTimeout = Timeout, WriteTimeout = Timeout };
 
     /// <summary>销毁</summary>
     /// <param name="disposing"></param>
     protected override void Dispose(Boolean disposing)
     {
         base.Dispose(disposing);
 
-        _port.TryDispose();
+        if (_port != null)
+        {
+            if (Received != null) _port.DataReceived -= OnReceiveSerial;
+
+            _port.TryDispose();
+        }
     }
 
     /// <summary>打开</summary>
@@ -49,9 +60,21 @@ public virtual void Open()
             ReadTimeout = Timeout,
             WriteTimeout = Timeout
         };
+
+        if (Received != null) _port.DataReceived += OnReceiveSerial;
+
         _port.Open();
     }
 
+    void OnReceiveSerial(Object sender, SerialDataReceivedEventArgs e)
+    {
+        var rs = Invoke(null, 1);
+        if (rs != null)
+        {
+            Received?.Invoke(this, new ReceivedEventArgs { Packet = rs });
+        }
+    }
+
     /// <summary>发送数据</summary>
     /// <param name="buffer">待发送数据</param>
     /// <param name="offset">偏移</param>