From 6fef3bc7ae8380ec4ebb9406ad28015d5d8499a1 Mon Sep 17 00:00:00 2001 From: Guoqs <123@jsowell.com> Date: Thu, 21 Nov 2024 17:23:19 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BB=9F=E8=AE=A1=E6=96=B9=E6=B3=95=E8=80=97?= =?UTF-8?q?=E6=97=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/jsowell/framework/aspectj/CostTimeAspect.java | 4 +++- .../netty/handler/yunkuaichong/AbstractYkcHandler.java | 3 +++ .../netty/handler/yunkuaichong/LoginRequestHandler.java | 1 + 3 files changed, 7 insertions(+), 1 deletion(-) diff --git a/jsowell-framework/src/main/java/com/jsowell/framework/aspectj/CostTimeAspect.java b/jsowell-framework/src/main/java/com/jsowell/framework/aspectj/CostTimeAspect.java index 4851327d4..225038e9b 100644 --- a/jsowell-framework/src/main/java/com/jsowell/framework/aspectj/CostTimeAspect.java +++ b/jsowell-framework/src/main/java/com/jsowell/framework/aspectj/CostTimeAspect.java @@ -4,9 +4,11 @@ import lombok.extern.slf4j.Slf4j; import org.aspectj.lang.ProceedingJoinPoint; import org.aspectj.lang.annotation.Around; import org.aspectj.lang.annotation.Aspect; +import org.springframework.core.annotation.Order; import org.springframework.stereotype.Component; @Aspect +@Order(1) @Component// 使用spring容器进行管理 @Slf4j public class CostTimeAspect { @@ -29,7 +31,7 @@ public class CostTimeAspect { String methodName = joinPoint.getSignature().getName(); // 获取类名称 String className = joinPoint.getSignature().getDeclaringTypeName(); - log.info("统计方法耗时, 类:[{}], 方法:[{}], 耗时时间为:[{}]", className, methodName, (System.currentTimeMillis() - beginTime) / 1000 + "秒"); + log.info("统计方法耗时, 类:[{}], 方法:[{}], 耗时时间为:[{}ms]", className, methodName, (System.currentTimeMillis() - beginTime)); } catch (Throwable throwable) { throwable.printStackTrace(); } diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/AbstractYkcHandler.java b/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/AbstractYkcHandler.java index 6045d4df2..ab3aedf52 100644 --- a/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/AbstractYkcHandler.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/AbstractYkcHandler.java @@ -1,6 +1,7 @@ package com.jsowell.netty.handler.yunkuaichong; import com.google.common.primitives.Bytes; +import com.jsowell.common.annotation.CostTime; import com.jsowell.common.constant.CacheConstants; import com.jsowell.common.core.domain.ykc.YKCDataProtocol; import com.jsowell.common.core.domain.ykc.YKCFrameTypeCode; @@ -32,6 +33,7 @@ public abstract class AbstractYkcHandler implements InitializingBean { // throw new UnsupportedOperationException(); // } + public byte[] supplyProcess(YKCDataProtocol ykcDataProtocol, ChannelHandlerContext channel) { throw new UnsupportedOperationException(); } @@ -91,6 +93,7 @@ public abstract class AbstractYkcHandler implements InitializingBean { * 阻止重复帧 * @return true 重复 */ + @CostTime protected boolean verifyTheDuplicateRequest(YKCDataProtocol ykcDataProtocol, ChannelHandlerContext ctx) { // 获取序列号域 int serialNumber = BytesUtil.bytesToIntLittle(ykcDataProtocol.getSerialNumber()); diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/LoginRequestHandler.java b/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/LoginRequestHandler.java index 58a57c36c..567826722 100644 --- a/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/LoginRequestHandler.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/LoginRequestHandler.java @@ -115,6 +115,7 @@ public class LoginRequestHandler extends AbstractYkcHandler { String business = BytesUtil.bcd2Str(businessTypeByteArr); } + @Override public byte[] supplyProcess(YKCDataProtocol ykcDataProtocol, ChannelHandlerContext ctx) { if (verifyTheDuplicateRequest(ykcDataProtocol, ctx)) {