操作指南：控制应用程序的并发和速率限制

了解如何控制可以同时调用您的应用程序的请求数和事件数

在分布式计算中，通常您可能只希望允许给定数量的请求并发执行。使用 Dapr 的 app-max-concurrency，您可以控制同时调用您的应用程序的请求数和事件数。

默认的 app-max-concurrency 设置为 -1，表示不强制执行并发限制。

不同的方法

本指南重点介绍 app-max-concurrency，您也可以使用 middleware.http.ratelimit 中间件来限制每秒的请求速率。但是，了解这两种方法之间的区别很重要：

  • middleware.http.ratelimit：时间受限，限制每秒的请求数
  • app-max-concurrency：指定在任何时间点的最大并发请求（和事件）数

有关该方法的更多信息，请参阅速率限制中间件。

演示

观看此视频，了解如何控制并发和速率限制。

配置 app-max-concurrency

如果不使用 Dapr，您需要在应用程序中创建某种信号量，并负责获取和释放它。

使用 Dapr，您无需对应用程序进行任何代码更改。

选择您想要配置 app-max-concurrency 的方式。

要在本地开发计算机上使用 Dapr CLI 设置并发限制，请添加 app-max-concurrency 标志：

dapr run --app-max-concurrency 1 --app-port 5000 python ./app.py

上述示例有效地将您的应用程序转换为顺序处理服务。

要在 Kubernetes 中配置并发限制，请将以下注解添加到您的 pod：

apiVersion: apps/v1
kind: Deployment
metadata:
  name: nodesubscriber
  namespace: default
  labels:
    app: nodesubscriber
spec:
  replicas: 1
  selector:
    matchLabels:
      app: nodesubscriber
  template:
    metadata:
      labels:
        app: nodesubscriber
      annotations:
        dapr.io/enabled: "true"
        dapr.io/app-id: "nodesubscriber"
        dapr.io/app-port: "3000"
        dapr.io/app-max-concurrency: "1"
#...

限制

控制外部请求的并发性

对于来自 Dapr 的每个事件，包括发布订阅事件、来自其他服务的直接调用、绑定事件等，都可以保证速率限制。但是，Dapr 无法对从外部到您的应用程序的请求强制执行并发策略。

相关链接

参数和注解

后续步骤

限制 secret store 访问