0
点赞
收藏
分享

微信扫一扫

opencv-33 图像平滑处理-中值滤波cv2.medianBlur()

奔跑的酆 2023-08-04 阅读 64

1、添加依赖

  • 该版本匹配springboot 2.3.x和2.4.x
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
<version>2021.1</version>
</dependency>

2、SentinelConfig配置限流规则

@Configuration
public class SentinelConfig {

@Bean
public SentinelResourceAspect sentinelResourceAspect() {
return new SentinelResourceAspect();
}

@PostConstruct
private void initRules() {
//=============================规则1=========================
FlowRule rule1 = new FlowRule();
rule1.setResource("rule1");//规则名称
rule1.setGrade(RuleConstant.FLOW_GRADE_QPS);//如果设置0则按照线程数限流,如果设置1则按照QPS(每秒查询率)限流
rule1.setCount(100); // 每秒调用最大次数为 100 次
rule1.setControlBehavior(0);//0快速失败,1预警,2排队等候
rule1.setMaxQueueingTimeMs(1000);//排队超时阈值

//=============================规则2=========================
FlowRule rule2 = new FlowRule();
rule2.setResource("rule2");
rule2.setGrade(RuleConstant.FLOW_GRADE_QPS);
rule2.setCount(10); // 每秒调用最大次数为 10 次

List<FlowRule> rules = new ArrayList<>();
rules.add(rule1);
rules.add(rule2);
FlowRuleManager.loadRules(rules);
}
}

3、API限流

@SentinelResource(value = "rule1", blockHandler = "poll", blockHandlerClass = SentinelHandler.class)
@ApiOperation("批量拉取消息")
@PostMapping("/poll")
public BaseResult poll(@RequestBody @Valid PollMessageRequest request){
return BaseResult.success(kafkaService.poll(request));
}

4、配置handler

  • handler里的方法必须用public static修饰
  • handler里的方法的返回值类型必须和原方法保持一致,参数是在原参数后边加一个BlockException
public class SentinelHandler {

public static BaseResult poll(PollMessageRequest request, BlockException e) {
throw new BusinessException("请勿频繁操作");
}
}
举报

相关推荐

0 条评论