diff --git a/backend/iot-device/src/main/java/com/iot/device/event/DeviceCommandListener.java b/backend/iot-device/src/main/java/com/iot/device/event/DeviceCommandListener.java index 76b87d1..0e2c980 100644 --- a/backend/iot-device/src/main/java/com/iot/device/event/DeviceCommandListener.java +++ b/backend/iot-device/src/main/java/com/iot/device/event/DeviceCommandListener.java @@ -1,5 +1,6 @@ package com.iot.device.event; +import com.iot.common.exception.BusinessException; import com.iot.device.config.RabbitConfig; import com.iot.device.entity.Device; import com.iot.device.mapper.DeviceMapper; @@ -12,6 +13,7 @@ import org.springframework.stereotype.Component; import java.util.ArrayList; import java.util.List; import java.util.Map; +import java.util.concurrent.ConcurrentHashMap; /** * 设备控制指令监听器 @@ -23,6 +25,12 @@ import java.util.Map; @RequiredArgsConstructor public class DeviceCommandListener { + /** 日志抑制窗口:同一 key 在该窗口内只详细记录一次,其余静默累计 */ + private static final long LOG_SUPPRESS_WINDOW_MS = 60_000L; + + /** key -> {窗口起始时间, 窗口内被抑制次数, 上一窗口被抑制次数} */ + private final Map logThrottle = new ConcurrentHashMap<>(); + private final DeviceMapper deviceMapper; private final TuyaCloudService tuyaCloudService; @@ -90,8 +98,52 @@ public class DeviceCommandListener { } else { log.info("平台[{}]控制指令暂未适配: deviceId={}", platform, deviceId); } + } catch (BusinessException be) { + // 业务可预期异常(如用户尚未绑定涂鸦账号):属于账号/数据状态问题而非系统故障, + // 不打印堆栈,并按 60 秒窗口抑制,避免定时场景高频触发时刷爆错误日志 + logThrottled("biz:" + message.get("deviceId"), true, "设备控制指令业务异常", be); } catch (Exception e) { - log.error("执行设备控制指令失败: {}", message, e); + logThrottled("err:" + message.get("deviceId"), false, "执行设备控制指令失败", e); + } + } + + /** + * 受控日志输出:同一 key 在 60 秒窗口内只详细记录一次,其余静默累计; + * 下一个窗口首次记录时,汇总上一窗口被抑制的次数。 + * + * @param business true=业务可预期异常(WARN 单行,不打堆栈);false=系统异常(ERROR + 堆栈) + */ + private void logThrottled(String key, boolean business, String message, Throwable t) { + long now = System.currentTimeMillis(); + long[] slot = logThrottle.compute(key, (k, v) -> { + if (v == null) { + return new long[]{now, 0, 0}; + } + if (now - v[0] >= LOG_SUPPRESS_WINDOW_MS) { + // 新窗口开启:继承上一窗口被抑制的次数,用于汇总输出 + return new long[]{now, 0, v[1]}; + } + v[1]++; + return v; + }); + if (slot[1] != 0) { + // 本窗口内已详细记录过一次,静默累计即可 + return; + } + long suppressed = slot[2]; + slot[2] = 0; + if (business) { + if (suppressed > 0) { + log.warn("{}: {}(上一周期同类异常已抑制 {} 次)", message, t.getMessage(), suppressed); + } else { + log.warn("{}: {}", message, t.getMessage()); + } + } else { + if (suppressed > 0) { + log.error("{}(上一周期同类异常已抑制 {} 次): {}", message, suppressed, t.getMessage(), t); + } else { + log.error("{}: {}", message, t.getMessage(), t); + } } } }