From 33cab31829a876ac3ad486640b2f435573ac5796 Mon Sep 17 00:00:00 2001 From: 3y Date: Wed, 20 Apr 2022 19:45:50 +0800 Subject: [PATCH] UPDATE comment --- .../handler/enums/RateLimitStrategy.java | 2 +- .../austin/handler/handler/BaseHandler.java | 37 +++++++++---------- 2 files changed, 19 insertions(+), 20 deletions(-) diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/enums/RateLimitStrategy.java b/austin-handler/src/main/java/com/java3y/austin/handler/enums/RateLimitStrategy.java index 0ada834..80ac3f1 100644 --- a/austin-handler/src/main/java/com/java3y/austin/handler/enums/RateLimitStrategy.java +++ b/austin-handler/src/main/java/com/java3y/austin/handler/enums/RateLimitStrategy.java @@ -16,7 +16,7 @@ public enum RateLimitStrategy { REQUEST_RATE_LIMIT(10, "根据真实请求数限流"), - SEND_USER_NUM_RATE_LIMIT(20, "根据发送用户数请求数限流"), + SEND_USER_NUM_RATE_LIMIT(20, "根据发送用户数限流"), ; private Integer code; diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/handler/BaseHandler.java b/austin-handler/src/main/java/com/java3y/austin/handler/handler/BaseHandler.java index 8c21086..236d1f8 100644 --- a/austin-handler/src/main/java/com/java3y/austin/handler/handler/BaseHandler.java +++ b/austin-handler/src/main/java/com/java3y/austin/handler/handler/BaseHandler.java @@ -17,6 +17,12 @@ import javax.annotation.PostConstruct; * 发送各个渠道的handler */ public abstract class BaseHandler implements Handler { + @Autowired + private HandlerHolder handlerHolder; + @Autowired + private LogUtils logUtils; + @Autowired + private FlowControlService flowControlService; /** * 标识渠道的Code @@ -30,14 +36,6 @@ public abstract class BaseHandler implements Handler { */ protected FlowControlParam flowControlParam; - - @Autowired - private HandlerHolder handlerHolder; - @Autowired - private LogUtils logUtils; - @Autowired - private FlowControlService flowControlService; - /** * 初始化渠道与Handler的映射关系 */ @@ -46,17 +44,6 @@ public abstract class BaseHandler implements Handler { handlerHolder.putHandler(channelCode, this); } - @Override - public void doHandler(TaskInfo taskInfo) { - flowControl(taskInfo); - if (handler(taskInfo)) { - logUtils.print(AnchorInfo.builder().state(AnchorState.SEND_SUCCESS.getCode()).businessId(taskInfo.getBusinessId()).ids(taskInfo.getReceiver()).build()); - return; - } - logUtils.print(AnchorInfo.builder().state(AnchorState.SEND_FAIL.getCode()).businessId(taskInfo.getBusinessId()).ids(taskInfo.getReceiver()).build()); - } - - /** * 流量控制 * @@ -68,6 +55,18 @@ public abstract class BaseHandler implements Handler { flowControlService.flowControl(taskInfo, flowControlParam); } } + @Override + public void doHandler(TaskInfo taskInfo) { + flowControl(taskInfo); + if (handler(taskInfo)) { + logUtils.print(AnchorInfo.builder().state(AnchorState.SEND_SUCCESS.getCode()).businessId(taskInfo.getBusinessId()).ids(taskInfo.getReceiver()).build()); + return; + } + logUtils.print(AnchorInfo.builder().state(AnchorState.SEND_FAIL.getCode()).businessId(taskInfo.getBusinessId()).ids(taskInfo.getReceiver()).build()); + } + + + /** * 统一处理的handler接口