From c388f1acccd0b7e76a4366fbaddaca6551826b74 Mon Sep 17 00:00:00 2001
From: wanshenmean <cathay_xy@163.com>
Date: 星期四, 05 二月 2026 10:29:07 +0800
Subject: [PATCH] 添加拘束/插拔钉机和堆垛机基类
---
Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/SocketServer/TcpSocketServer.cs | 62 +++++++++++++++++++++++++++++++
1 files changed, 62 insertions(+), 0 deletions(-)
diff --git a/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/SocketServer/TcpSocketServer.cs b/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/SocketServer/TcpSocketServer.cs
index 16371be..4d8789b 100644
--- a/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/SocketServer/TcpSocketServer.cs
+++ b/Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/SocketServer/TcpSocketServer.cs
@@ -16,20 +16,81 @@
public partial class TcpSocketServer : IDisposable
{
private readonly SocketServerOptions _options;
+
+ /// <summary>
+ /// 提供一个可用于同步对包含实例的访问的对象。
+ /// </summary>
+ /// <remarks>在对实例实现线程安全操作时,可将此对象用作锁定目标。此模式通常用于避免死锁并确保一致的同步。</remarks>
public readonly object _syncRoot = new();
+
private TcpListener? _listener;
+
+ /// <summary>
+ /// 表示用于发出进行中操作的取消请求的取消令牌源。
+ /// </summary>
+ /// <remarks>如果当前没有活动的取消机制,此字段可能为null。使用此令牌源取消支持取消的任务或操作。</remarks>
public CancellationTokenSource? _cts;
+
+ /// <summary>
+ /// 提供表示活动客户端操作的任务列表。
+ /// </summary>
+ /// <remarks>此字段用于内部跟踪异步客户端活动。它是只读的,不应在包含类外部直接修改。</remarks>
public readonly List<Task> _clientTasks = new();
+
+ /// <summary>
+ /// 提供从客户端标识符到其关联的TCP客户端连接的映射。
+ /// </summary>
+ /// <remarks>此字典允许通过唯一字符串标识符访问活动的TCP客户端。在多线程场景中,对集合的修改应小心进行以避免并发问题。</remarks>
public readonly Dictionary<string, TcpClient> _clients = new();
+
+ /// <summary>
+ /// 提供从设备标识符到其对应绑定值的映射。
+ /// </summary>
+ /// <remarks>此字段是只读的,用于包含类内部使用。应通过指定的方法或属性对字典进行修改以确保一致性。</remarks>
public readonly Dictionary<string, string> _deviceBindings = new();
+
+ /// <summary>
+ /// 提供从客户端标识符到其关联锁的映射,用于同步对客户端特定资源的访问。
+ /// </summary>
+ /// <remarks>字典中的每个条目将一个唯一的客户端ID与一个<see cref="SemaphoreSlim"/>实例关联,实现每个客户端的线程安全操作。此集合用于内部协调并发访问,不应直接修改。</remarks>
public readonly Dictionary<string, SemaphoreSlim> _clientLocks = new();
+
+ /// <summary>
+ /// 提供从客户端标识符到其关联文本编码的映射。
+ /// </summary>
+ /// <remarks>此字典用于内部跟踪已连接客户端的编码偏好。键表示客户端标识符,值指定用于文本操作的对应<see cref="System.Text.Encoding"/>。</remarks>
public readonly Dictionary<string, Encoding> _clientEncodings = new();
+
+ /// <summary>
+ /// 存储每个客户端最后活动的时间戳,以客户端标识符为键。
+ /// </summary>
+ /// <remarks>此字段用于内部跟踪客户端活动。字典将客户端标识符映射到对应的最后活动时间(UTC)。直接修改此集合可能影响客户端会话管理逻辑。</remarks>
public readonly Dictionary<string, DateTime> _clientLastActive = new();
+
+ /// <summary>
+ /// 指定包含类型中字符数据使用的文本编码。
+ /// </summary>
+ /// <remarks>使用此字段确定处理字符数据时如何编码或解码文本。编码影响字节如何被解释为字符,反之亦然。常见的编码包括UTF8、ASCII和Unicode。</remarks>
public readonly Encoding _textEncoding;
+
+ /// <summary>
+ /// 表示自动检测到的GB2312编码(如果可用)。
+ /// </summary>
+ /// <remarks>通常从输入数据确定编码时设置此字段。如果检测失败或未执行检测,值可能为null。</remarks>
public readonly Encoding? _autoDetectedGb2312;
+
private readonly string _logFile;
+
private Task? _monitorTask;
+ /// <summary>
+ /// 使用指定的服务器选项初始化 TcpSocketServer 类的新实例。
+ /// </summary>
+ /// <remarks>如果启用了 AutoDetectEncoding 选项,服务器将默认使用 UTF-8 编码,
+ /// 并尝试支持 GBK 编码进行自动检测。如果编码检测失败或提供了无效的编码名称,
+ /// 将回退使用 UTF-8 编码。日志文件路径由 LogFilePath 选项决定,
+ /// 如果未指定,则默认为应用程序基目录下的 'socketserver.log' 文件。</remarks>
+ /// <param name="options">套接字服务器的配置选项。不能为 null。提供编码设置、日志文件路径和自动检测行为等配置。</param>
public TcpSocketServer(IOptions<SocketServerOptions> options)
{
_options = options.Value;
@@ -52,6 +113,7 @@
public bool IsRunning { get; private set; }
public event Func<string, bool, TcpClient, RobotSocketState, Task<string?>>? MessageReceived;
+
public event Func<string, Task<string?>>? RobotReceived;
private void Log(string message)
--
Gitblit v1.9.3