using HslCommunication;using HslCommunication.WebSocket;

public class WebSktClientHelper{private string webSocketUrl = "ws://IP地址:端口号";
private WebSocketClient client = null;
/// <summary>/// websocket服务端接收到信息后回调/// </summary>public Action<string> ActMsgReceived = null;

public WebSktClientHelper(string ipAddr, string port)	{this.webSocketUrl = $"ws://{ipAddr}:{port}";	}
//打开连接public void TurnOn()	{		TurnOff();		client = new WebSocketClient(webSocketUrl);		client.OnClientApplicationMessageReceive += client_MessageReceived;		OperateResult connect = client.ConnectServer();	}
//接收消息private void client_MessageReceived(WebSocketMessage message)	{string msg = Encoding.UTF8.GetString(message.Payload);
		logMessage("接收到消息："+ msg);if (!string.IsNullOrEmpty(msg))			ActMsgReceived?.Invoke(msg);	}
//发送消息public void SendData(string msg)	{try		{if (client != null)			{				logMessage("发送消息：" + msg);				client.SendServer(true, msg);			}		}catch (Exception ex)		{			logMessage($"发送消息异常，{ex.Message}");		}	}
//关闭连接public void TurnOff()	{try		{if (client != null)			{				client.ConnectClose();				client.Dispose();			}		}catch (Exception)		{		}	}}

public class WebSktSvrHelper{private WebSocketServer server = null;
private int serverPort = 8080;
/// <summary>/// websocket服务端接收到信息后回调/// </summary>public Action<string, string> ActMsgReceived = null;
public WebSktSvrHelper(string port)	{		serverPort = int.Parse(port);	}
//打开连接public void TurnOn()	{		TurnOff();
// 创建WebSocket服务器实例		server = new WebSocketServer();
// 启动服务器监听8080端口		server.ServerStart(serverPort);
//// 证书加密//server.UseSSL("certificate.pfx", "password");
// 消息接收事件处理		server.OnClientApplicationMessageReceive += (session, message) =>		{string receivedMsg = Encoding.UTF8.GetString(message.Payload);
			logMessage($"收到客户端消息: {receivedMsg}");			ActMsgReceived?.Invoke(session.Remote.ToString(), receivedMsg);
// 回复客户端			server.SendClientPayload(session, $"服务器已收到: {receivedMsg}");		};	}
//关闭连接public void TurnOff()	{try		{if (server != null)			{				server.ServerClose();				server.Dispose();			}		}catch (Exception)		{		}	}}