发布版本：1.0.0

Author: aaasoft

logo.png

@@ -19,8 +19,9 @@
     IPAddress = ipadress,
     Port = port
 });
-centralStation.TelemetryStationConnected += (sender, telemetryStation) =>
+centralStation.TelemetryStationConnected += (sender, e) =>
 {
+    var telemetryStation = e.TelemetryStation;
     Console.WriteLine($"[{DateTime.Now}] 遥测站[端点：{telemetryStation.RemoteEndPoint}]已连接！遥测站地址：{telemetryStation.TelemetryStationInfo.TelemetryStationAddress_Text}");
     telemetryStation.Disconnected += (sender2, e) =>
     {

src/Quick.SL651.Test/Program.cs

@@ -12,7 +12,10 @@ public class CentralStation
         public CentralStationOptions Options { get; private set; }
         private TcpListener tcpListener;
         private CancellationTokenSource cts;
-        public event EventHandler<TelemetryStationContext> TelemetryStationConnected;
+        /// <summary>
+        /// 遥测站已连接事件
+        /// </summary>
+        public event EventHandler<TelemetryStationConnectedEventArgs> TelemetryStationConnected;
         private List<TelemetryStationContext> telemetryStationList = new List<TelemetryStationContext>();
 
         public CentralStation(CentralStationOptions options)
@@ -64,7 +67,14 @@ private void TelemetryStation_Disconnected(object sender, Exception e)
         private void TelemetryStation_Connected(object sender, EventArgs e)
         {
             var telemetryStation = (TelemetryStationContext)sender;
-            TelemetryStationConnected?.Invoke(this, telemetryStation);
+            var telemetryStationConnectedEventArgs = new TelemetryStationConnectedEventArgs()
+            {
+                TelemetryStation = telemetryStation
+            };
+            TelemetryStationConnected?.Invoke(this, telemetryStationConnectedEventArgs);
+            //如果不允许连接，则断开
+            if (!telemetryStationConnectedEventArgs.Allowed)
+                telemetryStation.OnError(new ApplicationException(telemetryStationConnectedEventArgs.Message));
         }
 
         public void Stop()

src/Quick.SL651/CentralStation.cs

@@ -3,6 +3,22 @@
 	<PropertyGroup>
 		<TargetFramework>net6.0</TargetFramework>
 		<ImplicitUsings>enable</ImplicitUsings>
+		<PackageProjectUrl>https://github.com/aaasoft/Quick.SL651</PackageProjectUrl>
+		<RepositoryUrl>https://github.com/aaasoft/Quick.SL651</RepositoryUrl>
+		<Copyright />
+		<GeneratePackageOnBuild>true</GeneratePackageOnBuild>
+		<Authors>scbeta</Authors>
+		<Version>1.0.0</Version>
+		<Company />
+		<Description>《水文监测数据通信规约》(SL651-2014)</Description>
+		<PackageIcon>logo.png</PackageIcon>
+		<PackageTags>SL651</PackageTags>
 	</PropertyGroup>
 
+	<ItemGroup>
+		<None Include="..\..\logo.png">
+			<Pack>True</Pack>
+			<PackagePath>\</PackagePath>
+		</None>
+	</ItemGroup>
 </Project>

src/Quick.SL651/Quick.SL651.csproj

@@ -0,0 +1,24 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Quick.SL651
+{
+    public class TelemetryStationConnectedEventArgs : EventArgs
+    {
+        /// <summary>
+        /// 遥测站上下文
+        /// </summary>
+        public TelemetryStationContext TelemetryStation { get; set; }
+        /// <summary>
+        /// 是否允许连接
+        /// </summary>
+        public bool Allowed { get; set; } = true;
+        /// <summary>
+        /// 当拒绝连接时返回的消息
+        /// </summary>
+        public string Message { get; set; }
+    }
+}

src/Quick.SL651/TelemetryStationConnectedEventArgs.cs

@@ -80,7 +80,7 @@ internal void Start()
             _ = beginReadData();
         }
 
-        private void onError(Exception ex)
+        internal void OnError(Exception ex)
         {
             stream?.Dispose();
             stream = null;
@@ -170,7 +170,7 @@ private async Task beginReadData()
             }
             catch (Exception ex)
             {
-                onError(ex);
+                OnError(ex);
                 return;
             }
             _ = beginReadData();