Dubbo 框架内置的并发控制策略

Dubbo 框架内置的并发控制或者限流策略,通过限制从同一客户端到同一服务的并发请求数,防止恶意请求使服务器过载,确保服务的稳定性,并防止使用过多资源。

Dubbo 通过 Filter 拦截器机制,内置了并发控制策略实现。限制从同一客户端到同一服务的并发请求数,防止恶意请求使服务器过载,确保服务的稳定性,并防止使用过多资源。

  • 控制某些服务的最大并发请求数,确保其他服务的资源可用性。系统过载和确保系统稳定性。
  • 允许在需求增加时更平滑地扩展服务。
  • 确保服务在高峰使用时间保持可靠和稳定。

限流策略配置

限制服务器端并发执行数(服务粒度)

限制 com.foo.BarService 的每个方法,服务器端并发执行(或占用线程池线程数)不能超过 10 个

XML 方式:

<dubbo:service interface="com.foo.BarService" executes="10" />

注解方式:

@DubboService(executes=10)
private DemoServiceImpl implements DemoService{}

限制服务器端并发执行数(方法粒度)

限制 com.foo.BarServicesayHello 方法,服务器端并发执行(或占用线程池线程数)不能超过 10 个

XML 方式:

<dubbo:service interface="com.foo.BarService">
    <dubbo:method name="sayHello" executes="10" />
</dubbo:service>

注解方式:

@DubboService(executes=10, methods = {@Method(name="sayHello",executes=10)})
private DemoServiceImpl implements DemoService{}

限制消费端并发调用数(服务粒度)

限制 com.foo.BarService 的每个方法,每客户端并发执行(或占用连接的请求数)不能超过 10 个

XML 方式:

<dubbo:service interface="com.foo.BarService" actives="10" />

注解方式:

@DubboReference(actives=10)
private DemoService demoService;

限制消费端并发调用数(方法粒度)

限制 com.foo.BarServicesayHello 方法,每客户端并发执行(或占用连接的请求数)不能超过 10 个

XML 方式:

<dubbo:service interface="com.foo.BarService">
    <dubbo:method name="sayHello" actives="10" />
</dubbo:service>

注解方式:

@DubboReference(actives=10, methods = {@Method(name="sayHello",executes=10)})
private DemoService demoService;

如果提供端 @DubboService 和消费端 @DubboReference 都配了 actives,则消费端配置值优先级更高,参见:配置的覆盖策略

最小并发数负载均衡

配置服务的客户端的 loadbalance 属性为 leastactive,此 Loadbalance 会调用并发数最小的 Provider(Consumer端并发数)。

<dubbo:reference interface="com.foo.BarService" loadbalance="leastactive" />

<dubbo:service interface="com.foo.BarService" loadbalance="leastactive" />
最后修改 September 13, 2024: Refactor website structure (#2860) (1a4b998f54b)