SuZhouGuanHong/ShanMeiXinNengYuan.git

			@@ -10,10 +10,13 @@
			public partial class TcpSocketServer
			{
			/// <summary>
			/// 检索当前在服务中注册的所有客户端标识符的只读列表。
			/// 获取所有已连接客户端 ID 列表
			/// </summary>
			/// <remarks>返回的列表表示调用时刻客户端ID的快照。后续对客户端集合的更改不会影响返回的列表。此方法是线程安全的。</remarks>
			/// <returns>包含客户端ID的<see cref="IReadOnlyList{String}"/>。如果没有客户端注册，列表将为空。</returns>
			/// <remarks>
			/// 返回当前在服务器注册的客户端标识列表。
			/// 这是一个只读列表的快照，线程安全。
			/// </remarks>
			/// <returns>客户端 ID 列表</returns>
			public IReadOnlyList<string> GetClientIds()
			{
			lock (_syncRoot)
			@@ -23,11 +26,13 @@
			}

			/// <summary>
			/// 检索与指定设备标识符关联的客户端标识符。
			/// 根据设备 ID 获取客户端 ID
			/// </summary>
			/// <remarks>此方法是线程安全的。如果未找到设备标识符，方法将返回null而不是抛出异常。</remarks>
			/// <param name="deviceId">要检索客户端标识符的设备的唯一标识符。不能为null。</param>
			/// <returns>与指定设备标识符关联的客户端标识符，如果不存在关联则返回null。</returns>
			/// <remarks>
			/// 在设备绑定表中查找对应的客户端 ID。
			/// </remarks>
			/// <param name="deviceId">设备唯一标识</param>
			/// <returns>客户端 ID，如果未找到则返回 null</returns>
			public string? GetClientIdByDevice(string deviceId)
			{
			lock (_syncRoot)
			@@ -37,13 +42,15 @@
			}

			/// <summary>
			/// 异步向指定设备发送消息。
			/// 异步向指定设备发送消息
			/// </summary>
			/// <remarks>如果指定设备未注册或无法找到，则返回 <see langword="false"/>。</remarks>
			/// <param name="deviceId">目标设备的唯一标识符。不能为null或空。</param>
			/// <param name="message">要发送给设备的消息。不能为null。</param>
			/// <returns>表示异步操作的任务。如果消息成功发送，任务结果为 <see langword="true"/>；
			/// 否则为 <see langword="false"/>。</returns>
			/// <remarks>
			/// 通过设备 ID 查找对应的客户端连接，然后发送消息。
			/// 如果设备未注册或连接不存在，返回 false。
			/// </remarks>
			/// <param name="deviceId">目标设备唯一标识</param>
			/// <param name="message">要发送的消息</param>
			/// <returns>发送是否成功</returns>
			public Task<bool> SendToDeviceAsync(string deviceId, string message)
			{
			var clientId = GetClientIdByDevice(deviceId);
			@@ -52,15 +59,16 @@
			}

			/// <summary>
			/// 通过TCP连接异步向指定客户端发送带帧的文本消息。
			/// 异步向指定客户端发送消息
			/// </summary>
			/// <remarks>如果客户端未连接或不存在，此方法将返回 <see langword="false"/> 且不发送消息。
			/// 消息将优先使用客户端首选的文本编码进行编码；否则使用默认编码。
			/// 此方法对于向不同客户端的并发调用是线程安全的。</remarks>
			/// <param name="clientId">要发送消息到的客户端的唯一标识符。必须对应已连接的客户端。</param>
			/// <param name="message">要发送给客户端的文本消息。不能为null。</param>
			/// <returns>表示异步操作的任务。如果消息成功发送，任务结果为 <see langword="true"/>；
			/// 否则，如果客户端未连接或不存在，结果为 <see langword="false"/>。</returns>
			/// <remarks>
			/// 使用帧格式发送消息（添加头尾标识）。
			/// 每个客户端的发送操作是互斥的（通过信号量实现）。
			/// 如果客户端未连接或不存在，发送失败返回 false。
			/// </remarks>
			/// <param name="clientId">目标客户端 ID</param>
			/// <param name="message">要发送的消息</param>
			/// <returns>发送是否成功</returns>
			public async Task<bool> SendToClientAsync(string clientId, string message)
			{
			TcpClient? client;
			@@ -80,9 +88,11 @@

			enc ??= _textEncoding;

			// 获取客户端发送锁
			if (sem != null) await sem.WaitAsync();
			try
			{
			// 发送消息
			var ns = client.GetStream();
			var framedMessage = BuildFramedMessage(message);
			var data = enc.GetBytes(framedMessage);
			@@ -96,12 +106,13 @@
			}

			/// <summary>
			/// 异步向所有已连接的客户端发送指定的消息。
			/// 异步广播消息到所有客户端
			/// </summary>
			/// <remarks>如果向某个客户端发送消息时发生错误，异常将被抑制并继续向其他客户端广播。
			/// 当所有发送操作完成后，此方法结束。</remarks>
			/// <param name="message">要广播给所有客户端的消息。不能为null。</param>
			/// <returns>表示异步广播操作的任务。</returns>
			/// <remarks>
			/// 将消息发送给所有已连接的客户端。
			/// 如果某个客户端发送失败，不影响其他客户端的发送。
			/// </remarks>
			/// <param name="message">要广播的消息</param>
			public async Task BroadcastAsync(string message)
			{
			List<TcpClient> clients;
			@@ -110,6 +121,7 @@
			clients = _clients.Values.ToList();
			}

			// 并行发送消息到所有客户端
			await Task.WhenAll(clients.Select(c => Task.Run(async () =>
			{
			try { await SendMessageAsync(c, message); } catch { }
			@@ -117,13 +129,14 @@
			}

			/// <summary>
			/// 通过网络流异步向指定的TCP客户端发送带帧的文本消息。
			/// 通过 NetworkStream 发送消息
			/// </summary>
			/// <remarks>如果客户端为null或未连接，此方法将立即返回而不发送消息。
			/// 消息将使用配置的文本编码进行编码并添加帧头后通过网络流发送。</remarks>
			/// <param name="client">要发送消息到的TCP客户端。必须处于连接状态；否则方法不执行任何操作。</param>
			/// <param name="message">要发送给客户端的文本消息。消息在传输前将被编码并添加帧头。</param>
			/// <returns>表示异步发送操作的任务。</returns>
			/// <remarks>
			/// 直接使用 TcpClient 的 NetworkStream 发送消息。
			/// 消息会添加帧头帧尾。
			/// </remarks>
			/// <param name="client">TCP 客户端</param>
			/// <param name="message">消息内容</param>
			public async Task SendMessageAsync(TcpClient client, string message)
			{
			if (client == null \|\| !client.Connected)