mirror of
https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git
synced 2026-05-10 13:00:02 +08:00
统计方法耗时
This commit is contained in:
@@ -1,6 +1,6 @@
|
|||||||
package com.jsowell.netty.factory;
|
package com.jsowell.netty.factory;
|
||||||
|
|
||||||
import com.jsowell.netty.handler.yunkuaichongV2.AbstractYkcHandlerV2;
|
import com.jsowell.netty.strategy.ykc.AbstractYkcStrategy;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
@@ -15,14 +15,14 @@ import java.util.Map;
|
|||||||
public class YKCOperateFactoryV2 {
|
public class YKCOperateFactoryV2 {
|
||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
private Map<String, AbstractYkcHandlerV2> strategyMap;
|
private Map<String, AbstractYkcStrategy> strategyMap;
|
||||||
|
|
||||||
private static Map<String, String> operationMap = new HashMap<>();
|
private static Map<String, String> operationMap = new HashMap<>();
|
||||||
|
|
||||||
static {
|
static {
|
||||||
//初始化实现类
|
//初始化实现类
|
||||||
operationMap.put("0x01", "loginRequestHandlerV2");
|
operationMap.put("0x01", "loginRequestStrategy");
|
||||||
operationMap.put("0x05", "billingTemplateValidateRequestHandlerV2");
|
operationMap.put("0x05", "billingTemplateValidateRequestStrategy");
|
||||||
// more operators
|
// more operators
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -41,7 +41,7 @@ public class YKCOperateFactoryV2 {
|
|||||||
/**
|
/**
|
||||||
* 获取
|
* 获取
|
||||||
*/
|
*/
|
||||||
public AbstractYkcHandlerV2 getInvokeStrategy(String frameType) {
|
public AbstractYkcStrategy getInvokeStrategy(String frameType) {
|
||||||
String s = operationMap.get(frameType);
|
String s = operationMap.get(frameType);
|
||||||
return strategyMap.get(s);
|
return strategyMap.get(s);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,7 +1,6 @@
|
|||||||
package com.jsowell.netty.handler.yunkuaichongV2;
|
package com.jsowell.netty.strategy.ykc;
|
||||||
|
|
||||||
import com.google.common.primitives.Bytes;
|
import com.google.common.primitives.Bytes;
|
||||||
import com.jsowell.common.annotation.CostTime;
|
|
||||||
import com.jsowell.common.constant.CacheConstants;
|
import com.jsowell.common.constant.CacheConstants;
|
||||||
import com.jsowell.common.core.domain.ykc.YKCDataProtocol;
|
import com.jsowell.common.core.domain.ykc.YKCDataProtocol;
|
||||||
import com.jsowell.common.core.domain.ykc.YKCFrameTypeCode;
|
import com.jsowell.common.core.domain.ykc.YKCFrameTypeCode;
|
||||||
@@ -16,7 +15,7 @@ import io.netty.channel.ChannelHandlerContext;
|
|||||||
/**
|
/**
|
||||||
* 模板方法模式
|
* 模板方法模式
|
||||||
*/
|
*/
|
||||||
public interface AbstractYkcHandlerV2 {
|
public interface AbstractYkcStrategy {
|
||||||
|
|
||||||
String REQUEST_PREFIX = "Request_";
|
String REQUEST_PREFIX = "Request_";
|
||||||
|
|
||||||
@@ -1,4 +1,4 @@
|
|||||||
package com.jsowell.netty.handler.yunkuaichongV2;
|
package com.jsowell.netty.strategy.ykc;
|
||||||
|
|
||||||
import com.google.common.primitives.Bytes;
|
import com.google.common.primitives.Bytes;
|
||||||
import com.jsowell.common.annotation.CostTime;
|
import com.jsowell.common.annotation.CostTime;
|
||||||
@@ -22,7 +22,7 @@ import org.springframework.stereotype.Service;
|
|||||||
*/
|
*/
|
||||||
@Slf4j
|
@Slf4j
|
||||||
@Service
|
@Service
|
||||||
public class BillingTemplateValidateRequestHandlerV2 implements AbstractYkcHandlerV2 {
|
public class BillingTemplateValidateRequestStrategy implements AbstractYkcStrategy {
|
||||||
|
|
||||||
private final String type = YKCUtils.frameType2Str(YKCFrameTypeCode.BILLING_TEMPLATE_VALIDATE_CODE.getBytes());
|
private final String type = YKCUtils.frameType2Str(YKCFrameTypeCode.BILLING_TEMPLATE_VALIDATE_CODE.getBytes());
|
||||||
|
|
||||||
@@ -1,4 +1,4 @@
|
|||||||
package com.jsowell.netty.handler.yunkuaichongV2;
|
package com.jsowell.netty.strategy.ykc;
|
||||||
|
|
||||||
import com.alibaba.fastjson2.JSON;
|
import com.alibaba.fastjson2.JSON;
|
||||||
import com.google.common.collect.Lists;
|
import com.google.common.collect.Lists;
|
||||||
@@ -33,7 +33,7 @@ import java.util.concurrent.CompletableFuture;
|
|||||||
|
|
||||||
@Slf4j
|
@Slf4j
|
||||||
@Service
|
@Service
|
||||||
public class LoginRequestHandlerV2 implements AbstractYkcHandlerV2 {
|
public class LoginRequestStrategy implements AbstractYkcStrategy {
|
||||||
private final String type = YKCUtils.frameType2Str(YKCFrameTypeCode.LOGIN_CODE.getBytes());
|
private final String type = YKCUtils.frameType2Str(YKCFrameTypeCode.LOGIN_CODE.getBytes());
|
||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
Reference in New Issue
Block a user