You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

4.1 KiB

Raw Blame History Unescape Escape

Sentinel Dubbo Consumer Example

项目说明

本项目演示如何使用 Sentinel starter 完成 Dubbo 应用的限流管理。

Sentinel 是阿里巴巴开源的分布式系统的流量防卫组件，Sentinel 把流量作为切入点，从流量控制，熔断降级，系统负载保护等多个维度保护服务的稳定性。

Dubbo是一款高性能Java RPC框架，有对应的SpringBoot工程。

本项目需要配合sentinel-dubbo-provider-example模块一起完成演示，并且需要先启动sentinel-dubbo-provider-example。

本项目专注于Sentinel与Dubbo的整合，关于Sentinel的更多特性可以查看sentinel-example。

示例

如何接入

在启动示例进行演示之前，我们先了解一下 Dubbo 如何接入 Sentinel。 注意本章节只是为了便于您理解接入方式，本示例代码中已经完成接入工作，您无需再进行修改。

首先，修改 pom.xml 文件，引入 Sentinel starter 和 Dubbo starter。

 <dependency>
     <groupId>org.springframework.cloud</groupId>
     <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
 </dependency>

 <dependency>
     <groupId>com.alibaba.boot</groupId>
     <artifactId>dubbo-spring-boot-starter</artifactId>
 </dependency>

配置限流规则

Sentinel提供了sentinel-dubbo-adapter模块用来支持Dubbo服务调用的限流降级。sentinel-starter默认也集成了该功能。

sentinel-dubbo-adapter内部的Dubbo Filter会根据资源名进行限流降级处理。只需要配置规则即可：

 FlowRule flowRule = new FlowRule();
 flowRule.setResource(
         "org.springframework.cloud.alibaba.cloud.examples.FooService:hello(java.lang.String)");
 flowRule.setCount(10);
 flowRule.setGrade(RuleConstant.FLOW_GRADE_QPS);
 flowRule.setLimitApp("default");
 FlowRuleManager.loadRules(Collections.singletonList(flowRule));

规则定义

sentinel-dubbo-api模块中定义了FooService服务，内容如下：

package org.springframework.cloud.alibaba.cloud.examples.FooService;
public interface FooService {
    String hello(String name);
}

该服务在Sentinel下对应的资源名是 org.springframework.cloud.alibaba.cloud.examples.dubbo.FooService:hello(java.lang.String) 。

定义该资源名对应的限流规则：

FlowRule flowRule = new FlowRule();
flowRule.setResource("dubboResource");
flowRule.setCount(10);
flowRule.setGrade(RuleConstant.FLOW_GRADE_QPS);
flowRule.setLimitApp("default");
FlowRuleManager.loadRules(Collections.singletonList(flowRule));

服务调用

根据sentinel-dubbo-provider-example中发布的定义，使用Dubbo的@Reference注解注入服务对应的Bean。

@Reference(version = "${foo.service.version}", application = "${dubbo.application.id}",
        url = "dubbo://localhost:12345", timeout = 30000)
private FooService fooService;

由于设置的qps是10。调用15次查看是否被限流：

FooServiceConsumer service = applicationContext.getBean(FooServiceConsumer.class);

for (int i = 0; i < 15; i++) {
    try {
        String message = service.hello("Jim");
        System.out.println((i + 1) + " -> Success: " + message);
    }
    catch (SentinelRpcException ex) {
        System.out.println("Blocked");
    }
    catch (Exception ex) {
        ex.printStackTrace();
    }
}

应用启动

支持 IDE 直接启动和编译打包后启动。

IDE直接启动：找到主类 SentinelDubboConsumerApp，执行 main 方法启动应用。
打包编译后启动：首先执行 mvn clean package 将工程编译打包，然后执行 java -jar sentinel-dubbo-consumer-example.jar启动应用。

4.1 KiB Raw Blame History Unescape Escape