Mikrotik Netwatch 网络监控网页应用提示词

好的，这是一个基于您要求的完整开发计划。我将以专业全栈开发者的身份，为您提供详细的架构设计、数据库结构、API 端点以及核心功能实现方案。 ### 1. 项目结构设置 (数据库设计) 我将提供一个规范化的数据库模式，包含所有必要的表和关系。 **表结构 (SQL - PostgreSQL 示例):** ```sql -- 角色表 CREATE TABLE roles ( id SERIAL PRIMARY KEY, name VARCHAR(50) UNIQUE NOT NULL -- 'Admin' 或 'User' ); -- 用户表 CREATE TABLE users ( id SERIAL PRIMARY KEY, username VARCHAR(100) UNIQUE NOT NULL, password_hash VARCHAR(255) NOT NULL, -- 使用 bcrypt 等强哈希算法 email VARCHAR(255) UNIQUE, role_id INT REFERENCES roles(id), balance DECIMAL(12, 2) DEFAULT 0.00, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ); -- 路由器表 (Mikrotik 服务器) CREATE TABLE routers ( id SERIAL PRIMARY KEY, user_id INT REFERENCES users(id) ON DELETE CASCADE, -- 路由器属于特定用户 name VARCHAR(100) NOT NULL, host VARCHAR(255) NOT NULL, api_port INT DEFAULT 8728, username VARCHAR(100) NOT NULL, password_encrypted TEXT NOT NULL, -- 使用应用密钥加密 is_active BOOLEAN DEFAULT TRUE, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ); -- 设备类型表 CREATE TABLE device_types ( id SERIAL PRIMARY KEY, name VARCHAR(100) UNIQUE NOT NULL, is_manageable BOOLEAN DEFAULT FALSE, -- 是否可管理（是否有端口） port_count INT DEFAULT 0, -- 默认端口数量 icon_url TEXT, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ); -- 设备表 CREATE TABLE devices ( id SERIAL PRIMARY KEY, user_id INT REFERENCES users(id) ON DELETE CASCADE, -- 设备属于特定用户 device_type_id INT REFERENCES device_types(id), router_id INT REFERENCES routers(id), -- 关联到监控它的路由器 name VARCHAR(255) NOT NULL, latitude DECIMAL(10, 8) NOT NULL, longitude DECIMAL(11, 8) NOT NULL, status VARCHAR(10) DEFAULT 'UNKNOWN', -- 'UP', 'DOWN', 'UNKNOWN' last_checked_at TIMESTAMP, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ); -- 端口表 (仅对可管理设备有意义) CREATE TABLE ports ( id SERIAL PRIMARY KEY, device_id INT REFERENCES devices(id) ON DELETE CASCADE, port_number INT NOT NULL, ip_address INET, -- 分配给此端口的 IP is_connected BOOLEAN DEFAULT FALSE, UNIQUE(device_id, port_number) ); -- 连接表 (设备之间的连接) CREATE TABLE connections ( id SERIAL PRIMARY KEY, source_port_id INT REFERENCES ports(id) ON DELETE CASCADE, destination_port_id INT REFERENCES ports(id) ON DELETE CASCADE, connection_ip INET, -- 连接本身的 IP created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, UNIQUE(source_port_id, destination_port_id) ); -- 设备状态日志表 CREATE TABLE device_logs ( id SERIAL PRIMARY KEY, device_id INT REFERENCES devices(id) ON DELETE CASCADE, status VARCHAR(10) NOT NULL, -- 'UP' 或 'DOWN' changed_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ); -- 用户操作审计日志表 CREATE TABLE audit_logs ( id SERIAL PRIMARY KEY, user_id INT REFERENCES users(id) ON DELETE SET NULL, action VARCHAR(255) NOT NULL, -- 例如 'ADD_DEVICE', 'REMOVE_CONNECTION' entity_type VARCHAR(50), -- 'device', 'connection', 'port_forward' entity_id INT, details JSONB, -- 存储操作前后的数据快照 created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ); -- 用户余额变动记录表 CREATE TABLE user_balance_transactions ( id SERIAL PRIMARY KEY, user_id INT REFERENCES users(id) ON DELETE CASCADE, amount DECIMAL(12, 2) NOT NULL, transaction_type VARCHAR(20) NOT NULL, -- 'DEBIT', 'CREDIT' description TEXT, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ); -- 端口转发规则表 (用于远程访问) CREATE TABLE port_forwards ( id SERIAL PRIMARY KEY, device_id INT REFERENCES devices(id) ON DELETE CASCADE, router_id INT REFERENCES routers(id) ON DELETE CASCADE, src_port INT NOT NULL, dst_port INT NOT NULL, is_active BOOLEAN DEFAULT TRUE, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, UNIQUE(router_id, src_port) ); ``` ### 2. 认证与授权 **技术栈建议:** 使用 **Laravel (PHP)** 或 **Node.js (Express/NestJS)** 作为后端框架，它们内置了强大的认证和授权机制。 **核心实现逻辑:** - **会话管理:** 使用 JWT (JSON Web Tokens) 或基于 Session 的认证。JWT 更适合 API 驱动的 SPA 应用。 - **角色中间件:** 创建中间件来检查用户角色。例如 `adminMiddleware` 和 `userMiddleware`。 - **权限控制:** 在控制器中，根据用户角色和资源所有权进行细粒度控制。例如，用户只能修改自己的设备。 **示例 (Node.js/Express 伪代码):** ```javascript // 认证中间件 const authenticate = (req, res, next) => { const token = req.headers.authorization?.split(' ')[1]; if (!token) return res.status(401).json({ error: '未认证' }); try { const decoded = jwt.verify(token, process.env.JWT_SECRET); req.user = decoded; next(); } catch (err) { return res.status(401).json({ error: '无效的令牌' }); } }; // 授权中间件 (角色检查) const authorize = (...roles) => { return (req, res, next) => { if (!roles.includes(req.user.role)) { return res.status(403).json({ error: '权限不足' }); } next(); }; }; // 路由示例 app.post('/api/users', authenticate, authorize('Admin'), createUser); app.get('/api/devices', authenticate, getMyDevices); // 用户只能获取自己的设备 ``` ### 3. 用户与余额管理 **核心功能:** - **CRUD 用户:** 管理员可以创建、读取、更新、删除用户。 - **余额管理:** 用户有 `balance` 字段。管理员可以手动调整余额。 - **订阅计费:** 这是一个后台任务（Cron Job），每月自动运行。 **计费逻辑 (Cron Job 伪代码):** ```javascript // 每月1日运行 async function monthlyBilling() { const users = await User.findAll(); for (const user of users) { const activeDevices = await Device.count({ where: { user_id: user.id } }); const cost = activeDevices * 250; // 每台设备每月250元 if (user.balance >= cost) { user.balance -= cost; await user.save(); await BalanceTransaction.create({ user_id: user.id, amount: -cost, type: 'DEBIT', description: `月度设备订阅费 (${activeDevices} 台设备)` }); } else { // 余额不足，可以禁用设备或发送通知 await Device.update({ is_active: false }, { where: { user_id: user.id } }); // 发送通知邮件/短信 } } } ``` **防止余额不足时添加设备:** 在添加设备的 API 端点中，检查用户余额是否大于等于 250。如果不足，返回错误。 ### 4. 设备类型管理 (CRUD) 这是一个简单的 CRUD 模块。管理员可以创建、编辑、删除设备类型。设备类型定义了设备是否可管理以及默认端口数。 ### 5. 设备管理 (CRUD) **添加设备流程:** 1. 用户点击地图，获取经纬度坐标。 2. 弹出表单，填写设备名称、选择设备类型。 3. 如果设备类型是“可管理”的，则动态生成端口输入框（IP 地址）。 4. 提交时，后端验证余额，然后创建设备及其端口。 **API 端点示例:** - `POST /api/devices` - 创建设备 - `GET /api/devices` - 获取用户自己的设备列表 - `GET /api/devices/:id` - 获取设备详情 - `PUT /api/devices/:id` - 更新设备 - `DELETE /api/devices/:id` - 删除设备 ### 6. 连接管理 **连接逻辑:** - 用户选择源设备的一个端口和目标设备的一个端口。 - 系统检查两个端口是否都可用（`is_connected = false`）。 - 创建连接记录，并更新两个端口的状态为已连接。 - 可以为连接分配一个 IP 地址。 **移动连接:** 允许用户更改连接的源或目标端口。这需要更新 `connections` 表中的外键，并更新新旧端口的状态。 ### 7. 与 Mikrotik Netwatch API 集成 **核心服务类:** ```javascript // 使用 RouterOS API 客户端库 (例如 node-routeros) const RouterOSClient = require('node-routeros').RouterOSClient; class MikrotikService { constructor(routerConfig) { this.client = new RouterOSClient({ host: routerConfig.host, port: routerConfig.api_port, user: routerConfig.username, password: decrypt(routerConfig.password_encrypted) }); } async connect() { await this.client.connect(); } async disconnect() { await this.client.close(); } // 获取 Netwatch 状态 async getNetwatchStatus() { await this.connect(); const result = await this.client.write('/tool/netwatch/print'); await this.disconnect(); return result; } // 添加 Netwatch 规则 async addNetwatchRule(ipAddress, comment) { await this.connect(); const result = await this.client.write('/tool/netwatch/add', [ `=host=${ipAddress}`, `=comment=${comment}`, '=interval=10s', '=timeout=5s' ]); await this.disconnect(); return result; } // 添加端口转发规则 async addPortForward(srcPort, dstPort, dstAddress) { await this.connect(); const result = await this.client.write('/ip/firewall/nat/add', [ '=chain=dstnat', `=protocol=tcp`, `=dst-port=${srcPort}`, `=action=dst-nat`, `=to-addresses=${dstAddress}`, `=to-ports=${dstPort}` ]); await this.disconnect(); return result; } // 移除端口转发规则 async removePortForward(ruleId) { await this.connect(); const result = await this.client.write('/ip/firewall/nat/remove', [`=.id=${ruleId}`]); await this.disconnect(); return result; } } ``` **监控调度器:** 使用 `node-cron` 或 `Bull` 队列定期（例如每 10 秒）检查所有设备的 Netwatch 状态。当状态发生变化时，更新数据库并记录日志。 ### 8. 监控仪表盘 **前端技术栈:** React / Vue.js + Leaflet.js / Mapbox GL JS。 **功能:** - **地图展示:** 使用 Leaflet 或 Mapbox 在地图上显示设备标记。 - **状态图标:** 根据设备状态（UP/DOWN）使用不同颜色的图标（例如绿色/红色）。 - **视图样式:** 提供标准地图、卫星地图、暗色模式等切换。 - **状态历史:** 点击设备标记，弹出窗口显示该设备的状态变化历史（从 `device_logs` 表读取）。 ### 9. 远程设备访问 **实现逻辑:** 1. 用户点击设备的“远程”按钮。 2. 后端生成一个随机的源端口（例如 10000-60000 之间）。 3. 后端调用 Mikrotik API 添加端口转发规则，将源端口转发到设备的某个内部端口（例如 22 或 3389）。 4. 将规则信息保存到 `port_forwards` 表。 5. 前端显示连接信息（例如 `router_ip:src_port`）。 **移除远程访问:** 用户点击“断开”按钮，后端调用 Mikrotik API 删除对应的 NAT 规则。 ### 10. 多路由器实现 - `routers` 表已经包含了 `user_id` 字段，因此每个用户可以拥有多个路由器。 - 在添加设备时，用户可以选择将设备关联到哪个路由器进行监控。 - 在监控调度器中，需要遍历所有用户的所有路由器，并为每个路由器创建独立的 Mikrotik 服务实例。 ### 11. 交互式地图 - 使用 **Leaflet.js** 或 **Mapbox GL JS**。 - 在地图上绘制设备标记和连接线。 - 支持点击地图添加设备（弹窗表单）。 - 支持拖拽设备标记来更新位置。 ### 12. 日志与审计追踪 - **设备状态日志:** 在监控调度器中，当设备状态改变时，插入 `device_logs` 记录。 - **用户操作日志:** 在关键的 API 端点（添加/删除设备、连接、端口转发）中，插入 `audit_logs` 记录。 ### 13. 安全与最佳实践 - **输入验证:** 使用 Joi 或 Express Validator 验证所有 API 请求体。 - **SQL 注入防护:** 使用 ORM (Sequelize, TypeORM, Eloquent) 的参数化查询。 - **XSS 防护:** 在前端使用框架自带的转义功能，在后端设置合适的 CSP 头。 - **CSRF 防护:** 对于基于 Session 的认证，使用 CSRF Token。对于 JWT，确保 Token 存储在安全的地方（HttpOnly Cookie）。 - **Mikrotik API 安全:** 使用强密码，并通过加密存储密码。建议使用 API 密钥或限制 API 访问的 IP 地址。 --- **总结:** 这个计划提供了一个完整、可扩展的架构。您可以根据这个蓝图，选择合适的技术栈（例如 Laravel + Vue.js 或 Node.js + React）进行开发。开发过程中，请务必遵循安全最佳实践，并确保代码的模块化和可维护性。祝您开发顺利！

Mikrotik Netwatch 网络监控网页应用提示词

提示词内容收藏

用法

参考资料

讨论