diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java b/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java index fbd3e2b66..3ba948380 100644 --- a/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java @@ -117,6 +117,8 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter { // 优化:增加消息处理耗时监控,用于排查性能问题 long elapsed = System.currentTimeMillis() - startTime; + // 从 AttributeKey 获取 frameType,避免作用域问题 + String frameType = ctx.channel().attr(LAST_FRAME_TYPE).get(); // 心跳帧(0x03)处理超过50ms警告,其他帧超过200ms警告 int warnThreshold = "0x03".equals(frameType) ? 50 : 200; if (elapsed > warnThreshold) {