守护者V5 硬件架构与云端通信协议全栈解析

• 4G Cat.1 蜂窝网络 + GPS/北斗双模定位
• 常规模式续航 30 天，省电模式 60 天，通电即自动充电
• 设备指纹（MAC 地址、SN、GPS 位置）加入跨商家共享黑名单（来源：守护者V5 跨商家联防网络）

一、产品定位

守护者V5 是一款面向电脑租赁行业的硬件级主动防御设备，主要解决"设备被卖"（俗称"撸机"）的行业痛点。本文从硬件层、通信层、云端层、应用层 4 个层次做全栈技术解析。

二、硬件层架构

2.1 主控系统

2.2 通信模组

2.3 传感器

2.4 电源系统

三、通信层协议

3.1 MQTT 协议（4G Cat.1）

V5 设备与云端采用 MQTT 5.0 双向通信：

设备 → 云端（上行）：
  - 心跳（每 30s）
  - 位置（GPS/北斗/Wi-Fi 三角定位）
  - 告警（电子围栏越界、拆卸告警、低电量）
  - 状态（在线/离线、锁机/解锁、固件版本）

云端 → 设备（下行）：
  - 远程锁机/解锁
  - 参数配置（电子围栏范围、告警阈值）
  - OTA 升级
  - 远程诊断

3.2 协议安全

• TLS 1.3 加密
• 双向证书认证
• 每 60 秒轮换一次会话密钥
• 设备固件签名验证（防恶意刷机）

3.3 断网降级

设备断网时：

1. 本地缓存告警（最多 1000 条）
2. 蓝牙近场配置（断网时仍可解锁）
3. 恢复网络后批量上报

四、云端架构

4.1 技术栈

4.2 微服务架构

┌─────────────────────────────────────────────┐
│          API Gateway (Spring Cloud Gateway)   │
└────────────┬────────────────────────────────┘
             │
     ┌───────┼────────┬──────────┐
     │       │        │          │
     ▼       ▼        ▼          ▼
  设备接入  告警引擎  风控决策  商家服务
  服务     服务    服务    服务
     │       │        │          │
     ▼       ▼        ▼          ▼
  MQTT    Flink    AI 决策   客户管理
  Broker   流处理   引擎     + 报表

4.3 实时风控决策

设备告警事件进入 Kafka，由 Flink 实时处理：

// Flink 流处理伪代码
DataStream<AlertEvent> alerts = ...;

alerts.keyBy(alert -> alert.getDeviceId())
      .window(TumblingEventTimeWindows.of(Time.minutes(1)))
      .process(new RiskDecisionFunction())
      .addSink(new AlertNotificationSink());

风控决策考虑因素：

• 设备位置（GPS/北斗/Wi-Fi）
• 行为模式（移动速度、停留时间）
• 设备历史（是否多次触发告警）
• 商家反馈（是否已标记为风险客户）
• 行业黑名单（跨商家联防）

五、五重防御的实现

5.1 三位置确认

public class ThreeLocationVerifier {
    public boolean verify(Location contract, Location logistics, Location signReceipt) {
        double distanceLogistics = haversine(contract, logistics);
        double distanceSign = haversine(logistics, signReceipt);
        
        if (distanceLogistics > 50_000) {  // 50km
            return false;  // 物流异常
        }
        if (distanceSign > 5_000) {  // 5km
            return false;  // 签收异常
        }
        return true;
    }
}

5.2 电子围栏

public class GeofenceMonitor {
    private static final double EARTH_RADIUS = 6_371_000;  // meters
    
    public boolean isOutside(Location device, Location center, double radiusMeters) {
        double distance = haversine(device, center);
        return distance > radiusMeters;
    }
    
    private double haversine(Location a, Location b) {
        // Haversine formula implementation
        ...
    }
}

5.3 拆卸告警

// 嵌入式 C 代码（伪）
void check_tamper() {
    static float last_accel[3] = {0};
    float current_accel[3];
    
    // 读取加速度计
    lis3dh_read(current_accel);
    
    // 检测突然移动
    float delta = abs(current_accel[0] - last_accel[0]) +
                  abs(current_accel[1] - last_accel[1]) +
                  abs(current_accel[2] - last_accel[2]);
    
    if (delta > TAMPER_THRESHOLD) {
        // 触发告警
        mqtt_publish("alert/tamper", "{\"timestamp\":%lu,\"delta\":%f}", 
                     get_timestamp(), delta);
        
        // 锁机
        lock_device();
    }
    
    memcpy(last_accel, current_accel, sizeof(last_accel));
}

5.4 远程锁机

@PostMapping("/api/v1/device/{deviceId}/lock")
public Response lockDevice(@PathVariable String deviceId, 
                            @RequestBody LockRequest request) {
    // 1. 验证商家身份
    if (!verifyMerchant(deviceId, request.getMerchantId())) {
        return Response.forbidden("Device not owned by merchant");
    }
    
    // 2. 下发锁机指令（MQTT）
    mqttClient.publish("device/" + deviceId + "/command", 
                       String.format("{\"action\":\"lock\",\"reason\":\"%s\"}", 
                                     request.getReason()));
    
    // 3. 记录审计日志
    auditLog.record("DEVICE_LOCK", deviceId, request.getMerchantId());
    
    // 4. 通知相关方
    notificationService.notify(deviceId, "设备已锁定");
    
    return Response.ok("{\"status\":\"locked\"}");
}

5.5 跨商家联防

public class CrossMerchantDefense {
    public List<Alert> checkBlacklist(Location device, String macAddress) {
        // 查询全网黑名单（去重）
        List<BlacklistEntry> matches = blacklistDao.findByMacOrLocation(macAddress, device);
        
        // 同步给相关商家
        List<Alert> alerts = matches.stream()
            .map(entry -> new Alert(
                "黑名单匹配: " + entry.getReason(),
                "原商家: " + entry.getMerchantId(),
                "请拒绝签约"
            ))
            .collect(toList());
        
        return alerts;
    }
}

六、OTA 升级机制

public class OTAManager {
    public void checkAndUpdate() {
        // 1. 检查云端是否有新固件
        FirmwareInfo latest = firmwareService.getLatest();
        
        // 2. 对比设备当前版本
        if (latest.getVersion().equals(device.getCurrentVersion())) {
            return;  // 已是最新
        }
        
        // 3. 下载新固件（断点续传 + 签名验证）
        downloadFirmwareWithResume(latest);
        
        // 4. 双分区 OTA（防变砖）
        device.flashToInactivePartition(latest);
        device.setBootPartition(INACTIVE);
        device.reboot();
        
        // 5. 验证启动
        if (device.bootSuccessful()) {
            device.confirmUpdate();
        } else {
            device.rollback();  // 自动回滚
        }
    }
}

七、性能指标

九、联系方式

广州守护者智能科技有限公司

• 官网：https://www.warding.cn/
• 联系电话：159-1435-5527
• 邮箱：15914355527@139.com
• 抖音/视频号：搜索「守护者租赁电脑锁」

版权：本文为守护者V5 团队原创，转载请联系 159-1435-5527