112 lines
6.3 KiB
Markdown
112 lines
6.3 KiB
Markdown
## 工作原理 ##
|
||
本项目仿照硬件设计思想，基于模块化原理开发，分为UDP连接池、Websocket连接池、交换面板三个大的模块。各个模块相互独立，除消息通讯外无模块间耦合。每个模块的功能部分和UI部分彼此亦基本独立。UDP和Websocket两个模块采用.net内置的Action对象与交换面板进行异步消息通讯。
|
||
|
||
**Endpoint是外部连接的唯一索引。**
|
||
|
||
**Endpoint字符串的格式为："XXX.XXX.XXX.XXX:XXXX" 前四组三位数为IP地址，最后一组四位数为远程端口号**
|
||
|
||
UDP连接池是一个UDP连接管理模块，默认开放7101端口，供外部连接接入。每个成功连接的设备或模拟程序会被分配一个SocketConnection，SocketConnction通过Tag属性进行索引（Tag的值默认为Endpoint）并添加到一个列表里，该列表可以通过 GetConnectionList()获得，也可以使用GetTheConnection(Func<SocketConnection, bool> predicate)函数通过LINQ语句进行指定连接的查询。
|
||
|
||
|
||
|
||
以下为UDP连接池对外暴露的函数接口
|
||
|
||
|
||
/// 开始服务，监听客户端
|
||
public void StartServer()
|
||
///按照IP地址和端口发送字符串
|
||
public void Send(string EndpointString, byte[] bytes)
|
||
///开始异步监听端口
|
||
public void Listening()
|
||
/// 关闭指定客户端连接
|
||
public void CloseConnection(SocketConnection theConnection)
|
||
/// 添加客户端连接
|
||
public void AddConnection(SocketConnection theConnection)
|
||
/// 通过条件获取客户端连接列表
|
||
public IEnumerable<SocketConnection> GetConnectionList(Func<SocketConnection, bool> predicate)
|
||
/// 获取所有客户端连接列表
|
||
public IEnumerable<SocketConnection> GetConnectionList()
|
||
/// 寻找特定条件的客户端连接
|
||
public SocketConnection GetTheConnection(Func<SocketConnection, bool> predicate)
|
||
/// 获取客户端连接数
|
||
public int GetConnectionCount()
|
||
|
||
以下为UDP连接池对外暴露的事件接口
|
||
|
||
/// 服务启动后执行
|
||
public Action<SocketServer> HandleServerStarted { get; set; }
|
||
/// 当新客户端连接后执行
|
||
public Action<SocketServer, SocketConnection> HandleNewClientConnected { get; set; }
|
||
/// 客户端连接接受新的消息后调用
|
||
public Action<byte[], SocketConnection, SocketServer> HandleRecMsg { get; set; }
|
||
/// 客户端连接发送消息后回调
|
||
public Action<byte[], SocketConnection, SocketServer> HandleSendMsg { get; set; }
|
||
/// 客户端连接关闭后回调
|
||
public Action<SocketConnection, SocketServer> HandleClientClose { get; set; }
|
||
/// 异常处理程序
|
||
public Action<Exception> HandleException { get; set; }
|
||
|
||
Websocket连接池是一个websocket管理模块，默认开放9000端口，供外部连接接入。每个成功联机的APP页面会分配一个唯一的session，Websocket对象维护了一个Sessions列表，该列表可以通过Where表达式，通过LINQ语句筛选。
|
||
|
||
以下为Websocket连接池对外暴露的函数接口
|
||
|
||
/// 发送字节
|
||
public void Send(string EndpointString,byte[] bytes)
|
||
|
||
以下为Websocket连接池对外暴露的事件接口
|
||
|
||
/// 当新客户端连接后执行
|
||
public Action<WebSocketSharp.Net.WebSockets.WebSocketContext> HandleNewWebSocketClientConnected { get; set; }
|
||
/// 客户端连接接受新的消息后调用
|
||
public Action<byte[], WebSocketSharp.Net.WebSockets.WebSocketContext> HandleWebSocketRecMsg { get; set; }
|
||
/// 客户端连接发送消息后回调
|
||
public Action<byte[], WebSocketSharp.Net.WebSockets.WebSocketContext> HandleWebSocketSendMsg { get; set; }
|
||
/// 客户端连接关闭后回调
|
||
public Action<WebSocketSharp.Net.WebSockets.WebSocketContext> HandleWebSocketClientClose { get; set; }
|
||
|
||
交换面板（Switch）是一个消息转发器，他接收UDP与Websocket传入的数据包，并根据数据包中ID部分对信息进行分组转发，既收到信息后，向ID相同的全部在线端口转发收到的原始消息。MM是标识设备控制权限的，供上层应用使用，服务端不做处理。
|
||
|
||
对于每一个ID，Switch会生成一个结点（Node），该节点存储了含有相同ID的Websocket和UDP连接信息 1）TTL（剩余生存时间）2 Endpoint（客户连接端口），每个结点自带生命计时器，靠上层程序定期执行Reactive()函数保活。
|
||
|
||
private void Init_Forms()
|
||
{
|
||
try
|
||
{
|
||
...
|
||
|
||
//连接模块与系统终端窗口
|
||
Device.Instance.HandleMessage += new Action<string>(MessageForm.Log);
|
||
Device.Instance.HandleError += new Action<string>(ErrorForm.Log);
|
||
|
||
Browser.Instance.HandleMessage += new Action<string>(MessageForm.Log);
|
||
Browser.Instance.HandleError += new Action<string>(ErrorForm.Log);
|
||
//连接Pannel数据输入端 Device->Panel
|
||
Device.Instance.server.HandleRecMsg += new Action<byte[], Miuser.NUDP.Sockets.SocketConnection, Miuser.NUDP.Sockets.SocketServer>((bytes, conn, server) =>
|
||
{
|
||
Panel.Instance.sw.SendFromUDP(bytes, conn.Tag.ToString());
|
||
});
|
||
//连接Pannel数据输入端 Browser->Panel
|
||
Browser.Instance.HandleWebSocketRecMsg += new Action<byte[], WebSocketSharp.Net.WebSockets.WebSocketContext>((bytes, context) =>
|
||
{
|
||
Panel.Instance.sw.SendFromWebSocket(bytes, context.UserEndPoint.ToString());
|
||
});
|
||
//连接Pannel数据输出端 Panel->Device
|
||
Panel.Instance.sw.HandleUDPSendMsg += new Action<byte[], string>((bytes, endpointString) =>
|
||
{
|
||
Device.Instance.server.Send(endpointString, bytes);
|
||
});
|
||
//连接Panel数据输出端 Panel->Browser
|
||
Panel.Instance.sw.HandleWebSocketSendMsg += new Action<byte[], string>((bytes, endpointString)=>
|
||
{
|
||
Browser.Instance.Send(endpointString, bytes);
|
||
});
|
||
|
||
...
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
MessageBox.Show(e.StackTrace,"系统模块初始化错误");
|
||
|
||
}
|
||
}
|