This is the multi-page printable view of this section. Click here to print.

Return to the regular view of this page.

弹性快速入门

开始使用 Dapr 弹性组件

1: 快速入门：服务到组件的弹性
2: 快速入门：服务到服务弹性

1 - 快速入门：服务到组件的弹性

通过状态管理 API 快速上手 Dapr 的弹性能力

通过模拟系统故障来观察 Dapr 的弹性能力。在本快速入门中，你将：

运行一个微服务应用程序，该应用程序通过 Dapr 的状态管理 API 持续持久化和检索状态。
通过模拟系统故障来触发弹性策略。
解决故障后，微服务应用程序将恢复运行。

在继续快速入门之前，请选择你偏好的特定语言的 Dapr SDK。

前置条件

对于此示例，你需要：

Docker Desktop

第 1 步：设置环境

克隆 Quickstarts 仓库中提供的示例。

git clone https://github.com/dapr/quickstarts.git

在终端窗口中，导航到 order-processor 目录。

cd ../state_management/python/sdk/order-processor

安装依赖项

pip3 install -r requirements.txt

第 2 步：运行应用程序

运行 order-processor 服务以及 Dapr 边车。Dapr 边车随后会加载位于资源目录中的弹性规范：

apiVersion: dapr.io/v1alpha1
kind: Resiliency
metadata:
  name: myresiliency
scopes:
  - order-processor

spec:
  policies:
    retries:
      retryForever:
        policy: constant
        duration: 5s
        maxRetries: -1

    circuitBreakers:
      simpleCB:
        maxRequests: 1
        timeout: 5s
        trip: consecutiveFailures >= 5

  targets:
    components:
      statestore:
        outbound:
          retry: retryForever
          circuitBreaker: simpleCB

dapr run --app-id order-processor --resources-path ../../../resources/ -- python3

应用程序启动后，order-processor 服务会向 statestore.yaml 组件中定义的 statestore Redis 实例写入和读取 orderId 键值对。

== APP == Saving Order:  { orderId: '1' }
== APP == Getting Order:  { orderId: '1' }
== APP == Saving Order:  { orderId: '2' }
== APP == Getting Order:  { orderId: '2' }
== APP == Saving Order:  { orderId: '3' }
== APP == Getting Order:  { orderId: '3' }
== APP == Saving Order:  { orderId: '4' }
== APP == Getting Order:  { orderId: '4' }

第 3 步：引入故障

通过停止在开发机器上执行 dapr init 时初始化的 Redis 容器实例来模拟故障。实例停止后，order-processor 服务的写入和读取操作将开始失败。

由于 resiliency.yaml 规范将 statestore 定义为组件目标，因此所有失败的请求都将应用重试和熔断器策略：

  targets:
    components:
      statestore:
        outbound:
          retry: retryForever
          circuitBreaker: simpleCB

在新的终端窗口中，运行以下命令来停止 Redis：

docker stop dapr_redis

Redis 停止后，请求将开始失败，并应用名为 retryForever 的重试策略。下面的输出显示了 order-processor 服务的日志：

INFO[0006] Error processing operation component[statestore] output. Retrying...

根据 retryForever 策略，对于每个失败的请求，将以 5 秒的间隔无限期地继续重试。

retryForever:
  policy: constant
  maxInterval: 5s
  maxRetries: -1

一旦 5 次连续重试失败，熔断器策略 simpleCB 被触发，熔断器打开，停止所有请求：

INFO[0026] Circuit breaker "simpleCB-statestore" changed state from closed to open

circuitBreakers:
  simpleCB:
  maxRequests: 1
  timeout: 5s 
  trip: consecutiveFailures >= 5

5 秒后，熔断器将切换到半开状态，允许一个请求通过以验证故障是否已解决。如果请求继续失败，电路将跳回打开状态。

INFO[0031] Circuit breaker "simpleCB-statestore" changed state from open to half-open  
INFO[0031] Circuit breaker "simpleCB-statestore" changed state from half-open to open 
INFO[0036] Circuit breaker "simpleCB-statestore" changed state from open to half-open  
INFO[0036] Circuit breaker "simpleCB-statestore" changed state from half-open to closed

只要 Redis 容器停止，这种半开/打开行为就会持续下去。

第 3 步：移除故障

当你在机器上重新启动 Redis 容器后，应用程序将无缝恢复，从中断的地方继续执行。

docker start dapr_redis

INFO[0036] Recovered processing operation component[statestore] output.  
== APP == Saving Order:  { orderId: '5' }
== APP == Getting Order:  { orderId: '5' }
== APP == Saving Order:  { orderId: '6' }
== APP == Getting Order:  { orderId: '6' }
== APP == Saving Order:  { orderId: '7' }
== APP == Getting Order:  { orderId: '7' }
== APP == Saving Order:  { orderId: '8' }
== APP == Getting Order:  { orderId: '8' }
== APP == Saving Order:  { orderId: '9' }
== APP == Getting Order:  { orderId: '9' }

前置条件

对于此示例，你需要：

Docker Desktop

第 1 步：设置环境

克隆 Quickstarts 仓库中提供的示例。

git clone https://github.com/dapr/quickstarts.git

在终端窗口中，导航到 order-processor 目录。

cd ../state_management/javascript/sdk/order-processor

安装依赖项

npm install

第 2 步：运行应用程序

运行 order-processor 服务以及 Dapr 边车。Dapr 边车随后会加载位于资源目录中的弹性规范：

apiVersion: dapr.io/v1alpha1
kind: Resiliency
metadata:
  name: myresiliency
scopes:
  - checkout

spec:
  policies:
    retries:
      retryForever:
        policy: constant
        maxInterval: 5s
        maxRetries: -1 

    circuitBreakers:
      simpleCB:
        maxRequests: 1
        timeout: 5s 
        trip: consecutiveFailures >= 5

  targets:
    apps:
      order-processor:
        retry: retryForever
        circuitBreaker: simpleCB

dapr run --app-id order-processor --resources-path ../../../resources/ -- npm start

应用程序启动后，order-processor 服务会向 statestore.yaml 组件中定义的 statestore Redis 实例写入和读取 orderId 键值对。

== APP == Saving Order:  { orderId: '1' }
== APP == Getting Order:  { orderId: '1' }
== APP == Saving Order:  { orderId: '2' }
== APP == Getting Order:  { orderId: '2' }
== APP == Saving Order:  { orderId: '3' }
== APP == Getting Order:  { orderId: '3' }
== APP == Saving Order:  { orderId: '4' }
== APP == Getting Order:  { orderId: '4' }

第 3 步：引入故障

通过停止在开发机器上执行 dapr init 时初始化的 Redis 容器实例来模拟故障。实例停止后，order-processor 服务的写入和读取操作将开始失败。

由于 resiliency.yaml 规范将 statestore 定义为组件目标，因此所有失败的请求都将应用重试和熔断器策略：

  targets:
    components:
      statestore:
        outbound:
          retry: retryForever
          circuitBreaker: simpleCB

在新的终端窗口中，运行以下命令来停止 Redis：

docker stop dapr_redis

Redis 停止后，请求将开始失败，并应用名为 retryForever 的重试策略。下面的输出显示了 order-processor 服务的日志：

INFO[0006] Error processing operation component[statestore] output. Retrying...

根据 retryForever 策略，对于每个失败的请求，将以 5 秒的间隔无限期地继续重试。

retryForever:
  policy: constant
  maxInterval: 5s
  maxRetries: -1

一旦 5 次连续重试失败，熔断器策略 simpleCB 被触发，熔断器打开，停止所有请求：

INFO[0026] Circuit breaker "simpleCB-statestore" changed state from closed to open

circuitBreakers:
  simpleCB:
  maxRequests: 1
  timeout: 5s 
  trip: consecutiveFailures >= 5

5 秒后，熔断器将切换到半开状态，允许一个请求通过以验证故障是否已解决。如果请求继续失败，电路将跳回打开状态。

INFO[0031] Circuit breaker "simpleCB-statestore" changed state from open to half-open  
INFO[0031] Circuit breaker "simpleCB-statestore" changed state from half-open to open 
INFO[0036] Circuit breaker "simpleCB-statestore" changed state from open to half-open  
INFO[0036] Circuit breaker "simpleCB-statestore" changed state from half-open to closed

只要 Redis 容器停止，这种半开/打开行为就会持续下去。

第 3 步：移除故障

当你在机器上重新启动 Redis 容器后，应用程序将无缝恢复，从中断的地方继续执行。

docker start dapr_redis

INFO[0036] Recovered processing operation component[statestore] output.  
== APP == Saving Order:  { orderId: '5' }
== APP == Getting Order:  { orderId: '5' }
== APP == Saving Order:  { orderId: '6' }
== APP == Getting Order:  { orderId: '6' }
== APP == Saving Order:  { orderId: '7' }
== APP == Getting Order:  { orderId: '7' }
== APP == Saving Order:  { orderId: '8' }
== APP == Getting Order:  { orderId: '8' }
== APP == Saving Order:  { orderId: '9' }
== APP == Getting Order:  { orderId: '9' }

前置条件

对于此示例，你需要：

Docker Desktop

第 1 步：设置环境

克隆 Quickstarts 仓库中提供的示例。

git clone https://github.com/dapr/quickstarts.git

在终端窗口中，导航到 order-processor 目录。

cd ../state_management/csharp/sdk/order-processor

安装依赖项

dotnet restore
dotnet build

第 2 步：运行应用程序

运行 order-processor 服务以及 Dapr 边车。Dapr 边车随后会加载位于资源目录中的弹性规范：

apiVersion: dapr.io/v1alpha1
kind: Resiliency
metadata:
  name: myresiliency
scopes:
  - checkout

spec:
  policies:
    retries:
      retryForever:
        policy: constant
        maxInterval: 5s
        maxRetries: -1 

    circuitBreakers:
      simpleCB:
        maxRequests: 1
        timeout: 5s 
        trip: consecutiveFailures >= 5

  targets:
    apps:
      order-processor:
        retry: retryForever
        circuitBreaker: simpleCB

dapr run --app-id order-processor --resources-path ../../../resources/ -- dotnet run

应用程序启动后，order-processor 服务会向 statestore.yaml 组件中定义的 statestore Redis 实例写入和读取 orderId 键值对。

== APP == Saving Order:  { orderId: '1' }
== APP == Getting Order:  { orderId: '1' }
== APP == Saving Order:  { orderId: '2' }
== APP == Getting Order:  { orderId: '2' }
== APP == Saving Order:  { orderId: '3' }
== APP == Getting Order:  { orderId: '3' }
== APP == Saving Order:  { orderId: '4' }
== APP == Getting Order:  { orderId: '4' }

第 3 步：引入故障

通过停止在开发机器上执行 dapr init 时初始化的 Redis 容器实例来模拟故障。实例停止后，order-processor 服务的写入和读取操作将开始失败。

由于 resiliency.yaml 规范将 statestore 定义为组件目标，因此所有失败的请求都将应用重试和熔断器策略：

  targets:
    components:
      statestore:
        outbound:
          retry: retryForever
          circuitBreaker: simpleCB

在新的终端窗口中，运行以下命令来停止 Redis：

docker stop dapr_redis

Redis 停止后，请求将开始失败，并应用名为 retryForever 的重试策略。下面的输出显示了 order-processor 服务的日志：

INFO[0006] Error processing operation component[statestore] output. Retrying...

根据 retryForever 策略，对于每个失败的请求，将以 5 秒的间隔无限期地继续重试。

retryForever:
  policy: constant
  maxInterval: 5s
  maxRetries: -1

一旦 5 次连续重试失败，熔断器策略 simpleCB 被触发，熔断器打开，停止所有请求：

INFO[0026] Circuit breaker "simpleCB-statestore" changed state from closed to open

circuitBreakers:
  simpleCB:
  maxRequests: 1
  timeout: 5s 
  trip: consecutiveFailures >= 5

5 秒后，熔断器将切换到半开状态，允许一个请求通过以验证故障是否已解决。如果请求继续失败，电路将跳回打开状态。

INFO[0031] Circuit breaker "simpleCB-statestore" changed state from open to half-open  
INFO[0031] Circuit breaker "simpleCB-statestore" changed state from half-open to open 
INFO[0036] Circuit breaker "simpleCB-statestore" changed state from open to half-open  
INFO[0036] Circuit breaker "simpleCB-statestore" changed state from half-open to closed

只要 Redis 容器停止，这种半开/打开行为就会持续下去。

第 3 步：移除故障

当你在机器上重新启动 Redis 容器后，应用程序将无缝恢复，从中断的地方继续执行。

docker start dapr_redis

INFO[0036] Recovered processing operation component[statestore] output.  
== APP == Saving Order:  { orderId: '5' }
== APP == Getting Order:  { orderId: '5' }
== APP == Saving Order:  { orderId: '6' }
== APP == Getting Order:  { orderId: '6' }
== APP == Saving Order:  { orderId: '7' }
== APP == Getting Order:  { orderId: '7' }
== APP == Saving Order:  { orderId: '8' }
== APP == Getting Order:  { orderId: '8' }
== APP == Saving Order:  { orderId: '9' }
== APP == Getting Order:  { orderId: '9' }

前置条件

对于此示例，你需要：

Dapr CLI 和已初始化的环境。
Java JDK 17（或更高版本）：
- Oracle JDK，或
- OpenJDK
Apache Maven，版本 3.x。

Docker Desktop

第 1 步：设置环境

克隆 Quickstarts 仓库中提供的示例。

git clone https://github.com/dapr/quickstarts.git

在终端窗口中，导航到 order-processor 目录。

cd ../state_management/java/sdk/order-processor

安装依赖项

mvn clean install

第 2 步：运行应用程序

运行 order-processor 服务以及 Dapr 边车。Dapr 边车随后会加载位于资源目录中的弹性规范：

apiVersion: dapr.io/v1alpha1
kind: Resiliency
metadata:
  name: myresiliency
scopes:
  - checkout

spec:
  policies:
    retries:
      retryForever:
        policy: constant
        maxInterval: 5s
        maxRetries: -1 

    circuitBreakers:
      simpleCB:
        maxRequests: 1
        timeout: 5s 
        trip: consecutiveFailures >= 5

  targets:
    apps:
      order-processor:
        retry: retryForever
        circuitBreaker: simpleCB

dapr run --app-id order-processor --resources-path ../../../resources/ -- java -jar target/OrderProcessingService-0.0.1-SNAPSHOT.jar

应用程序启动后，order-processor 服务会向 statestore.yaml 组件中定义的 statestore Redis 实例写入和读取 orderId 键值对。

== APP == Saving Order:  { orderId: '1' }
== APP == Getting Order:  { orderId: '1' }
== APP == Saving Order:  { orderId: '2' }
== APP == Getting Order:  { orderId: '2' }
== APP == Saving Order:  { orderId: '3' }
== APP == Getting Order:  { orderId: '3' }
== APP == Saving Order:  { orderId: '4' }
== APP == Getting Order:  { orderId: '4' }

第 3 步：引入故障

通过停止在开发机器上执行 dapr init 时初始化的 Redis 容器实例来模拟故障。实例停止后，order-processor 服务的写入和读取操作将开始失败。

由于 resiliency.yaml 规范将 statestore 定义为组件目标，因此所有失败的请求都将应用重试和熔断器策略：

  targets:
    components:
      statestore:
        outbound:
          retry: retryForever
          circuitBreaker: simpleCB

在新的终端窗口中，运行以下命令来停止 Redis：

docker stop dapr_redis

Redis 停止后，请求将开始失败，并应用名为 retryForever 的重试策略。下面的输出显示了 order-processor 服务的日志：

INFO[0006] Error processing operation component[statestore] output. Retrying...

根据 retryForever 策略，对于每个失败的请求，将以 5 秒的间隔无限期地继续重试。

retryForever:
  policy: constant
  maxInterval: 5s
  maxRetries: -1

一旦 5 次连续重试失败，熔断器策略 simpleCB 被触发，熔断器打开，停止所有请求：

INFO[0026] Circuit breaker "simpleCB-statestore" changed state from closed to open

circuitBreakers:
  simpleCB:
  maxRequests: 1
  timeout: 5s 
  trip: consecutiveFailures >= 5

5 秒后，熔断器将切换到半开状态，允许一个请求通过以验证故障是否已解决。如果请求继续失败，电路将跳回打开状态。

INFO[0031] Circuit breaker "simpleCB-statestore" changed state from open to half-open  
INFO[0031] Circuit breaker "simpleCB-statestore" changed state from half-open to open 
INFO[0036] Circuit breaker "simpleCB-statestore" changed state from open to half-open  
INFO[0036] Circuit breaker "simpleCB-statestore" changed state from half-open to closed

只要 Redis 容器停止，这种半开/打开行为就会持续下去。

第 3 步：移除故障

当你在机器上重新启动 Redis 容器后，应用程序将无缝恢复，从中断的地方继续执行。

docker start dapr_redis

INFO[0036] Recovered processing operation component[statestore] output.  
== APP == Saving Order:  { orderId: '5' }
== APP == Getting Order:  { orderId: '5' }
== APP == Saving Order:  { orderId: '6' }
== APP == Getting Order:  { orderId: '6' }
== APP == Saving Order:  { orderId: '7' }
== APP == Getting Order:  { orderId: '7' }
== APP == Saving Order:  { orderId: '8' }
== APP == Getting Order:  { orderId: '8' }
== APP == Saving Order:  { orderId: '9' }
== APP == Getting Order:  { orderId: '9' }

前置条件

对于此示例，你需要：

Docker Desktop

第 1 步：设置环境

克隆 Quickstarts 仓库中提供的示例。

git clone https://github.com/dapr/quickstarts.git

在终端窗口中，导航到 order-processor 目录。

cd ../state_management/go/sdk/order-processor

安装依赖项

go build .

第 2 步：运行应用程序

运行 order-processor 服务以及 Dapr 边车。Dapr 边车随后会加载位于资源目录中的弹性规范：

apiVersion: dapr.io/v1alpha1
kind: Resiliency
metadata:
  name: myresiliency
scopes:
  - checkout

spec:
  policies:
    retries:
      retryForever:
        policy: constant
        maxInterval: 5s
        maxRetries: -1 

    circuitBreakers:
      simpleCB:
        maxRequests: 1
        timeout: 5s 
        trip: consecutiveFailures >= 5

  targets:
    apps:
      order-processor:
        retry: retryForever
        circuitBreaker: simpleCB

dapr run --app-id order-processor --resources-path ../../../resources -- go run .

应用程序启动后，order-processor 服务会向 statestore.yaml 组件中定义的 statestore Redis 实例写入和读取 orderId 键值对。

== APP == Saving Order:  { orderId: '1' }
== APP == Getting Order:  { orderId: '1' }
== APP == Saving Order:  { orderId: '2' }
== APP == Getting Order:  { orderId: '2' }
== APP == Saving Order:  { orderId: '3' }
== APP == Getting Order:  { orderId: '3' }
== APP == Saving Order:  { orderId: '4' }
== APP == Getting Order:  { orderId: '4' }

第 3 步：引入故障

通过停止在开发机器上执行 dapr init 时初始化的 Redis 容器实例来模拟故障。实例停止后，order-processor 服务的写入和读取操作将开始失败。

由于 resiliency.yaml 规范将 statestore 定义为组件目标，因此所有失败的请求都将应用重试和熔断器策略：

  targets:
    components:
      statestore:
        outbound:
          retry: retryForever
          circuitBreaker: simpleCB

在新的终端窗口中，运行以下命令来停止 Redis：

docker stop dapr_redis

Redis 停止后，请求将开始失败，并应用名为 retryForever 的重试策略。下面的输出显示了 order-processor 服务的日志：

INFO[0006] Error processing operation component[statestore] output. Retrying...

根据 retryForever 策略，对于每个失败的请求，将以 5 秒的间隔无限期地继续重试。

retryForever:
  policy: constant
  maxInterval: 5s
  maxRetries: -1

一旦 5 次连续重试失败，熔断器策略 simpleCB 被触发，熔断器打开，停止所有请求：

INFO[0026] Circuit breaker "simpleCB-statestore" changed state from closed to open

circuitBreakers:
  simpleCB:
  maxRequests: 1
  timeout: 5s 
  trip: consecutiveFailures >= 5

5 秒后，熔断器将切换到半开状态，允许一个请求通过以验证故障是否已解决。如果请求继续失败，电路将跳回打开状态。

INFO[0031] Circuit breaker "simpleCB-statestore" changed state from open to half-open  
INFO[0031] Circuit breaker "simpleCB-statestore" changed state from half-open to open 
INFO[0036] Circuit breaker "simpleCB-statestore" changed state from open to half-open  
INFO[0036] Circuit breaker "simpleCB-statestore" changed state from half-open to closed

只要 Redis 容器停止，这种半开/打开行为就会持续下去。

第 3 步：移除故障

当你在机器上重新启动 Redis 容器后，应用程序将无缝恢复，从中断的地方继续执行。

docker start dapr_redis

INFO[0036] Recovered processing operation component[statestore] output.  
== APP == Saving Order:  { orderId: '5' }
== APP == Getting Order:  { orderId: '5' }
== APP == Saving Order:  { orderId: '6' }
== APP == Getting Order:  { orderId: '6' }
== APP == Saving Order:  { orderId: '7' }
== APP == Getting Order:  { orderId: '7' }
== APP == Saving Order:  { orderId: '8' }
== APP == Getting Order:  { orderId: '8' }
== APP == Saving Order:  { orderId: '9' }
== APP == Getting Order:  { orderId: '9' }

请告诉我们你的想法！

我们正在不断努力改进我们的快速入门示例，并重视你的反馈。你觉得这个快速入门有帮助吗？你有改进建议吗？

在我们的 discord 频道中加入讨论。

后续步骤

了解有关弹性功能的更多信息，以及它如何与 Dapr 的构建块 API 配合使用。

探索 Dapr 教程 >>

2 - 快速入门：服务到服务弹性

通过服务调用 API 开始使用 Dapr 的弹性功能

通过模拟系统故障来观察 Dapr 弹性功能。在本快速入门中，您将：

运行两个微服务应用程序：checkout 和 order-processor。checkout 将持续向 order-processor 发起 Dapr 服务调用请求。
通过模拟系统故障来触发弹性规范。
移除故障，使微服务应用程序能够恢复。

Diagram showing the resiliency applied to Dapr APIs

在继续快速入门之前，选择您偏好的特定语言的 Dapr SDK。

前置条件

对于此示例，您需要：

Docker Desktop

步骤 1：设置环境

克隆 Quickstarts 仓库中提供的示例。

git clone https://github.com/dapr/quickstarts.git

步骤 2：运行 `order-processor` 服务

在终端窗口中，从快速入门目录的根目录导航到 order-processor 目录。

cd service_invocation/python/http/order-processor

安装依赖：

pip3 install -r requirements.txt

运行 order-processor 服务以及 Dapr 边车。

dapr run --app-port 8001 --app-id order-processor --resources-path ../../../resources/ --app-protocol http --dapr-http-port 3501 -- python3 app.py

步骤 3：运行 `checkout` 服务应用程序

在新的终端窗口中，从快速入门目录的根目录导航到 checkout 目录。

cd service_invocation/python/http/checkout

安装依赖：

pip3 install -r requirements.txt

运行 checkout 服务以及 Dapr 边车。

dapr run --app-id checkout --resources-path ../../../resources/ --app-protocol http --dapr-http-port 3500 -- python3 app.py

然后 Dapr 边车将加载位于 resources 目录中的弹性规范：

apiVersion: dapr.io/v1alpha1
kind: Resiliency
metadata:
  name: myresiliency
scopes:
  - checkout

spec:
  policies:
    retries:
      retryForever:
        policy: constant
        maxInterval: 5s
        maxRetries: -1 

    circuitBreakers:
      simpleCB:
        maxRequests: 1
        timeout: 5s 
        trip: consecutiveFailures >= 5

  targets:
    apps:
      order-processor:
        retry: retryForever
        circuitBreaker: simpleCB

步骤 4：查看服务调用输出

当两个服务和边车都在运行时，注意订单是如何使用 Dapr 服务调用从 checkout 服务传递到 order-processor 服务的。

checkout 服务输出：

== APP == Order passed: {"orderId": 1}
== APP == Order passed: {"orderId": 2}
== APP == Order passed: {"orderId": 3}
== APP == Order passed: {"orderId": 4}

order-processor 服务输出：

== APP == Order received: {"orderId": 1}
== APP == Order received: {"orderId": 2}
== APP == Order received: {"orderId": 3}
== APP == Order received: {"orderId": 4}

步骤 5：引入故障

通过停止 order-processor 服务来模拟故障。一旦实例停止，来自 checkout 服务的服务调用操作将开始失败。

由于 resiliency.yaml 规范将 order-processor 服务定义为弹性目标，所有失败的请求都将应用重试和断路器策略：

  targets:
    apps:
      order-processor:
        retry: retryForever
        circuitBreaker: simpleCB

在 order-processor 窗口中，停止服务：

CMD + C

CTRL + C

一旦第一个请求失败，将应用名为 retryForever 的重试策略：

INFO[0005] Error processing operation endpoint[order-processor, order-processor:orders]. Retrying...

对于每个失败的请求，重试将以 5 秒的间隔无限期继续。

retryForever:
  policy: constant
  maxInterval: 5s
  maxRetries: -1

一旦 5 次连续重试失败，断路器策略 simpleCB 将被触发，断路器打开，停止所有请求：

INFO[0025] Circuit breaker "order-processor:orders" changed state from closed to open

circuitBreakers:
  simpleCB:
  maxRequests: 1
  timeout: 5s 
  trip: consecutiveFailures >= 5

超过 5 秒后，断路器将切换到半开状态，允许一个请求通过以验证故障是否已解决。如果请求继续失败，电路将跳闸回到打开状态。

INFO[0030] Circuit breaker "order-processor:orders" changed state from open to half-open  
INFO[0030] Circuit breaker "order-processor:orders" changed state from half-open to open   
INFO[0030] Circuit breaker "order-processor:orders" changed state from open to half-open  
INFO[0030] Circuit breaker "order-processor:orders" changed state from half-open to open

只要 order-processor 服务停止，这种半开/打开行为就会持续下去。

步骤 6：移除故障

重新启动 order-processor 服务后，应用程序将无缝恢复，从中断的地方继续接受订单请求。

在 order-processor 服务终端中，重新启动应用程序：

dapr run --app-port 8001 --app-id order-processor --app-protocol http --dapr-http-port 3501 -- python3 app.py

checkout 服务输出：

== APP == Order passed: {"orderId": 5}
== APP == Order passed: {"orderId": 6}
== APP == Order passed: {"orderId": 7}
== APP == Order passed: {"orderId": 8}
== APP == Order passed: {"orderId": 9}
== APP == Order passed: {"orderId": 10}

order-processor 服务输出：

== APP == Order received: {"orderId": 5}
== APP == Order received: {"orderId": 6}
== APP == Order received: {"orderId": 7}
== APP == Order received: {"orderId": 8}
== APP == Order received: {"orderId": 9}
== APP == Order received: {"orderId": 10}

前置条件

对于此示例，您需要：

Docker Desktop

步骤 1：设置环境

克隆 Quickstarts 仓库中提供的示例。

git clone https://github.com/dapr/quickstarts.git

步骤 2：运行 `order-processor` 服务

在终端窗口中，从快速入门目录的根目录导航到 order-processor 目录。

cd service_invocation/javascript/http/order-processor

安装依赖：

npm install

运行 order-processor 服务以及 Dapr 边车。

dapr run --app-port 5001 --app-id order-processor --resources-path ../../../resources/ --app-protocol http --dapr-http-port 3501 -- npm start

步骤 3：运行 `checkout` 服务应用程序

在新的终端窗口中，从快速入门目录的根目录导航到 checkout 目录。

cd service_invocation/javascript/http/checkout

安装依赖：

npm install

运行 checkout 服务以及 Dapr 边车。

dapr run --app-id checkout --resources-path ../../../resources/ --app-protocol http --dapr-http-port 3500 -- npm start

然后 Dapr 边车将加载位于 resources 目录中的弹性规范：

apiVersion: dapr.io/v1alpha1
kind: Resiliency
metadata:
  name: myresiliency
scopes:
  - checkout

spec:
  policies:
    retries:
      retryForever:
        policy: constant
        maxInterval: 5s
        maxRetries: -1 

    circuitBreakers:
      simpleCB:
        maxRequests: 1
        timeout: 5s 
        trip: consecutiveFailures >= 5

  targets:
    apps:
      order-processor:
        retry: retryForever
        circuitBreaker: simpleCB

步骤 4：查看服务调用输出

当两个服务和边车都在运行时，注意订单是如何使用 Dapr 服务调用从 checkout 服务传递到 order-processor 服务的。

checkout 服务输出：

== APP == Order passed: {"orderId": 1}
== APP == Order passed: {"orderId": 2}
== APP == Order passed: {"orderId": 3}
== APP == Order passed: {"orderId": 4}

order-processor 服务输出：

== APP == Order received: {"orderId": 1}
== APP == Order received: {"orderId": 2}
== APP == Order received: {"orderId": 3}
== APP == Order received: {"orderId": 4}

步骤 5：引入故障

通过停止 order-processor 服务来模拟故障。一旦实例停止，来自 checkout 服务的服务调用操作将开始失败。

由于 resiliency.yaml 规范将 order-processor 服务定义为弹性目标，所有失败的请求都将应用重试和断路器策略：

  targets:
    apps:
      order-processor:
        retry: retryForever
        circuitBreaker: simpleCB

在 order-processor 窗口中，停止服务：

CMD + C

CTRL + C

一旦第一个请求失败，将应用名为 retryForever 的重试策略：

INFO[0005] Error processing operation endpoint[order-processor, order-processor:orders]. Retrying...

对于每个失败的请求，重试将以 5 秒的间隔无限期继续。

retryForever:
  policy: constant
  maxInterval: 5s
  maxRetries: -1

一旦 5 次连续重试失败，断路器策略 simpleCB 将被触发，断路器打开，停止所有请求：

INFO[0025] Circuit breaker "order-processor:orders" changed state from closed to open

circuitBreakers:
  simpleCB:
  maxRequests: 1
  timeout: 5s 
  trip: consecutiveFailures >= 5

超过 5 秒后，断路器将切换到半开状态，允许一个请求通过以验证故障是否已解决。如果请求继续失败，电路将跳闸回到打开状态。

INFO[0030] Circuit breaker "order-processor:orders" changed state from open to half-open  
INFO[0030] Circuit breaker "order-processor:orders" changed state from half-open to open   
INFO[0030] Circuit breaker "order-processor:orders" changed state from open to half-open  
INFO[0030] Circuit breaker "order-processor:orders" changed state from half-open to open

只要 Redis 容器停止，这种半开/打开行为就会持续下去。

步骤 6：移除故障

重新启动 order-processor 服务后，应用程序将无缝恢复，从中断的地方继续。

在 order-processor 服务终端中，重新启动应用程序：

dapr run --app-port 5001 --app-id order-processor --resources-path ../../../resources/ --app-protocol http --dapr-http-port 3501 -- npm start

checkout 服务输出：

== APP == Order passed: {"orderId": 5}
== APP == Order passed: {"orderId": 6}
== APP == Order passed: {"orderId": 7}
== APP == Order passed: {"orderId": 8}
== APP == Order passed: {"orderId": 9}
== APP == Order passed: {"orderId": 10}

order-processor 服务输出：

== APP == Order received: {"orderId": 5}
== APP == Order received: {"orderId": 6}
== APP == Order received: {"orderId": 7}
== APP == Order received: {"orderId": 8}
== APP == Order received: {"orderId": 9}
== APP == Order received: {"orderId": 10}

前置条件

对于此示例，您需要：

Docker Desktop

步骤 1：设置环境

克隆 Quickstarts 仓库中提供的示例。

git clone https://github.com/dapr/quickstarts.git

步骤 2：运行 `order-processor` 服务

在终端窗口中，从快速入门目录的根目录导航到 order-processor 目录。

cd service_invocation/csharp/http/order-processor

安装依赖：

dotnet restore
dotnet build

运行 order-processor 服务以及 Dapr 边车。

dapr run --app-port 7001 --app-id order-processor --resources-path ../../../resources/ --app-protocol http --dapr-http-port 3501 -- dotnet run

步骤 3：运行 `checkout` 服务应用程序

在新的终端窗口中，从快速入门目录的根目录导航到 checkout 目录。

cd service_invocation/csharp/http/checkout

安装依赖：

dotnet restore
dotnet build

运行 checkout 服务以及 Dapr 边车。

dapr run --app-id checkout --resources-path ../../../resources/ --app-protocol http --dapr-http-port 3500 -- dotnet run

然后 Dapr 边车将加载位于 resources 目录中的弹性规范：

apiVersion: dapr.io/v1alpha1
kind: Resiliency
metadata:
  name: myresiliency
scopes:
  - checkout

spec:
  policies:
    retries:
      retryForever:
        policy: constant
        maxInterval: 5s
        maxRetries: -1 

    circuitBreakers:
      simpleCB:
        maxRequests: 1
        timeout: 5s 
        trip: consecutiveFailures >= 5

  targets:
    apps:
      order-processor:
        retry: retryForever
        circuitBreaker: simpleCB

步骤 4：查看服务调用输出

当两个服务和边车都在运行时，注意订单是如何使用 Dapr 服务调用从 checkout 服务传递到 order-processor 服务的。

checkout 服务输出：

== APP == Order passed: {"orderId": 1}
== APP == Order passed: {"orderId": 2}
== APP == Order passed: {"orderId": 3}
== APP == Order passed: {"orderId": 4}

order-processor 服务输出：

== APP == Order received: {"orderId": 1}
== APP == Order received: {"orderId": 2}
== APP == Order received: {"orderId": 3}
== APP == Order received: {"orderId": 4}

步骤 5：引入故障

通过停止 order-processor 服务来模拟故障。一旦实例停止，来自 checkout 服务的服务调用操作将开始失败。

由于 resiliency.yaml 规范将 order-processor 服务定义为弹性目标，所有失败的请求都将应用重试和断路器策略：

  targets:
    apps:
      order-processor:
        retry: retryForever
        circuitBreaker: simpleCB

在 order-processor 窗口中，停止服务：

CMD + C

CTRL + C

一旦第一个请求失败，将应用名为 retryForever 的重试策略：

INFO[0005] Error processing operation endpoint[order-processor, order-processor:orders]. Retrying...

对于每个失败的请求，重试将以 5 秒的间隔无限期继续。

retryForever:
  policy: constant
  maxInterval: 5s
  maxRetries: -1

一旦 5 次连续重试失败，断路器策略 simpleCB 将被触发，断路器打开，停止所有请求：

INFO[0025] Circuit breaker "order-processor:orders" changed state from closed to open

circuitBreakers:
  simpleCB:
  maxRequests: 1
  timeout: 5s 
  trip: consecutiveFailures >= 5

超过 5 秒后，断路器将切换到半开状态，允许一个请求通过以验证故障是否已解决。如果请求继续失败，电路将跳闸回到打开状态。

INFO[0030] Circuit breaker "order-processor:orders" changed state from open to half-open  
INFO[0030] Circuit breaker "order-processor:orders" changed state from half-open to open   
INFO[0030] Circuit breaker "order-processor:orders" changed state from open to half-open  
INFO[0030] Circuit breaker "order-processor:orders" changed state from half-open to open

只要 Redis 容器停止，这种半开/打开行为就会持续下去。

步骤 6：移除故障

重新启动 order-processor 服务后，应用程序将无缝恢复，从中断的地方继续。

在 order-processor 服务终端中，重新启动应用程序：

dapr run --app-port 7001 --app-id order-processor --app-protocol http --dapr-http-port 3501 -- dotnet run

checkout 服务输出：

== APP == Order passed: {"orderId": 5}
== APP == Order passed: {"orderId": 6}
== APP == Order passed: {"orderId": 7}
== APP == Order passed: {"orderId": 8}
== APP == Order passed: {"orderId": 9}
== APP == Order passed: {"orderId": 10}

order-processor 服务输出：

== APP == Order received: {"orderId": 5}
== APP == Order received: {"orderId": 6}
== APP == Order received: {"orderId": 7}
== APP == Order received: {"orderId": 8}
== APP == Order received: {"orderId": 9}
== APP == Order received: {"orderId": 10}

前置条件

对于此示例，您需要：

Dapr CLI 和已初始化的环境。
Java JDK 17（或更高版本）：
- Oracle JDK，或
- OpenJDK
Apache Maven，版本 3.x。

Docker Desktop

步骤 1：设置环境

克隆 Quickstarts 仓库中提供的示例。

git clone https://github.com/dapr/quickstarts.git

步骤 2：运行 `order-processor` 服务

在终端窗口中，从快速入门目录的根目录导航到 order-processor 目录。

cd service_invocation/java/http/order-processor

安装依赖：

mvn clean install

运行 order-processor 服务以及 Dapr 边车。

dapr run --app-id order-processor --resources-path ../../../resources/ --app-port 9001 --app-protocol http --dapr-http-port 3501 -- java -jar target/OrderProcessingService-0.0.1-SNAPSHOT.jar

步骤 3：运行 `checkout` 服务应用程序

在新的终端窗口中，从快速入门目录的根目录导航到 checkout 目录。

cd service_invocation/java/http/checkout

安装依赖：

mvn clean install

运行 checkout 服务以及 Dapr 边车。

dapr run --app-id checkout --resources-path ../../../resources/ --app-protocol http --dapr-http-port 3500 -- java -jar target/CheckoutService-0.0.1-SNAPSHOT.jar

然后 Dapr 边车将加载位于 resources 目录中的弹性规范：

apiVersion: dapr.io/v1alpha1
kind: Resiliency
metadata:
  name: myresiliency
scopes:
  - checkout

spec:
  policies:
    retries:
      retryForever:
        policy: constant
        maxInterval: 5s
        maxRetries: -1 

    circuitBreakers:
      simpleCB:
        maxRequests: 1
        timeout: 5s 
        trip: consecutiveFailures >= 5

  targets:
    apps:
      order-processor:
        retry: retryForever
        circuitBreaker: simpleCB

步骤 4：查看服务调用输出

当两个服务和边车都在运行时，注意订单是如何使用 Dapr 服务调用从 checkout 服务传递到 order-processor 服务的。

checkout 服务输出：

== APP == Order passed: {"orderId": 1}
== APP == Order passed: {"orderId": 2}
== APP == Order passed: {"orderId": 3}
== APP == Order passed: {"orderId": 4}

order-processor 服务输出：

== APP == Order received: {"orderId": 1}
== APP == Order received: {"orderId": 2}
== APP == Order received: {"orderId": 3}
== APP == Order received: {"orderId": 4}

步骤 5：引入故障

通过停止 order-processor 服务来模拟故障。一旦实例停止，来自 checkout 服务的服务调用操作将开始失败。

由于 resiliency.yaml 规范将 order-processor 服务定义为弹性目标，所有失败的请求都将应用重试和断路器策略：

  targets:
    apps:
      order-processor:
        retry: retryForever
        circuitBreaker: simpleCB

在 order-processor 窗口中，停止服务：

CMD + C

CTRL + C

一旦第一个请求失败，将应用名为 retryForever 的重试策略：

INFO[0005] Error processing operation endpoint[order-processor, order-processor:orders]. Retrying...

对于每个失败的请求，重试将以 5 秒的间隔无限期继续。

retryForever:
  policy: constant
  maxInterval: 5s
  maxRetries: -1

一旦 5 次连续重试失败，断路器策略 simpleCB 将被触发，断路器打开，停止所有请求：

INFO[0025] Circuit breaker "order-processor:orders" changed state from closed to open

circuitBreakers:
  simpleCB:
  maxRequests: 1
  timeout: 5s 
  trip: consecutiveFailures >= 5

超过 5 秒后，断路器将切换到半开状态，允许一个请求通过以验证故障是否已解决。如果请求继续失败，电路将跳闸回到打开状态。

INFO[0030] Circuit breaker "order-processor:orders" changed state from open to half-open  
INFO[0030] Circuit breaker "order-processor:orders" changed state from half-open to open   
INFO[0030] Circuit breaker "order-processor:orders" changed state from open to half-open  
INFO[0030] Circuit breaker "order-processor:orders" changed state from half-open to open

只要 Redis 容器停止，这种半开/打开行为就会持续下去。

步骤 6：移除故障

重新启动 order-processor 服务后，应用程序将无缝恢复，从中断的地方继续。

在 order-processor 服务终端中，重新启动应用程序：

dapr run --app-id order-processor --resources-path ../../../resources/ --app-port 9001 --app-protocol http --dapr-http-port 3501 -- java -jar target/OrderProcessingService-0.0.1-SNAPSHOT.jar

checkout 服务输出：

== APP == Order passed: {"orderId": 5}
== APP == Order passed: {"orderId": 6}
== APP == Order passed: {"orderId": 7}
== APP == Order passed: {"orderId": 8}
== APP == Order passed: {"orderId": 9}
== APP == Order passed: {"orderId": 10}

order-processor 服务输出：

== APP == Order received: {"orderId": 5}
== APP == Order received: {"orderId": 6}
== APP == Order received: {"orderId": 7}
== APP == Order received: {"orderId": 8}
== APP == Order received: {"orderId": 9}
== APP == Order received: {"orderId": 10}

前置条件

对于此示例，您需要：

Docker Desktop

步骤 1：设置环境

克隆 Quickstarts 仓库中提供的示例。

git clone https://github.com/dapr/quickstarts.git

步骤 2：运行 `order-processor` 服务

在终端窗口中，从快速入门目录的根目录导航到 order-processor 目录。

cd service_invocation/go/http/order-processor

安装依赖：

go build .

运行 order-processor 服务以及 Dapr 边车。

dapr run --app-port 6001 --app-id order-processor --resources-path ../../../resources/ --app-protocol http --dapr-http-port 3501 -- go run .

步骤 3：运行 `checkout` 服务应用程序

在新的终端窗口中，从快速入门目录的根目录导航到 checkout 目录。

cd service_invocation/go/http/checkout

安装依赖：

go build .

运行 checkout 服务以及 Dapr 边车。

dapr run --app-id checkout --resources-path ../../../resources/ --app-protocol http --dapr-http-port 3500 -- go run .

然后 Dapr 边车将加载位于 resources 目录中的弹性规范：

apiVersion: dapr.io/v1alpha1
kind: Resiliency
metadata:
  name: myresiliency
scopes:
  - checkout

spec:
  policies:
    retries:
      retryForever:
        policy: constant
        maxInterval: 5s
        maxRetries: -1 

    circuitBreakers:
      simpleCB:
        maxRequests: 1
        timeout: 5s 
        trip: consecutiveFailures >= 5

  targets:
    apps:
      order-processor:
        retry: retryForever
        circuitBreaker: simpleCB

步骤 4：查看服务调用输出

当两个服务和边车都在运行时，注意订单是如何使用 Dapr 服务调用从 checkout 服务传递到 order-processor 服务的。

checkout 服务输出：

== APP == Order passed: {"orderId": 1}
== APP == Order passed: {"orderId": 2}
== APP == Order passed: {"orderId": 3}
== APP == Order passed: {"orderId": 4}

order-processor 服务输出：

== APP == Order received: {"orderId": 1}
== APP == Order received: {"orderId": 2}
== APP == Order received: {"orderId": 3}
== APP == Order received: {"orderId": 4}

步骤 5：引入故障

通过停止 order-processor 服务来模拟故障。一旦实例停止，来自 checkout 服务的服务调用操作将开始失败。

由于 resiliency.yaml 规范将 order-processor 服务定义为弹性目标，所有失败的请求都将应用重试和断路器策略：

  targets:
    apps:
      order-processor:
        retry: retryForever
        circuitBreaker: simpleCB

在 order-processor 窗口中，停止服务：

CMD + C

CTRL + C

一旦第一个请求失败，将应用名为 retryForever 的重试策略：

INFO[0005] Error processing operation endpoint[order-processor, order-processor:orders]. Retrying...

对于每个失败的请求，重试将以 5 秒的间隔无限期继续。

retryForever:
  policy: constant
  maxInterval: 5s
  maxRetries: -1

一旦 5 次连续重试失败，断路器策略 simpleCB 将被触发，断路器打开，停止所有请求：

INFO[0025] Circuit breaker "order-processor:orders" changed state from closed to open

circuitBreakers:
  simpleCB:
  maxRequests: 1
  timeout: 5s 
  trip: consecutiveFailures >= 5

超过 5 秒后，断路器将切换到半开状态，允许一个请求通过以验证故障是否已解决。如果请求继续失败，电路将跳闸回到打开状态。

INFO[0030] Circuit breaker "order-processor:orders" changed state from open to half-open  
INFO[0030] Circuit breaker "order-processor:orders" changed state from half-open to open   
INFO[0030] Circuit breaker "order-processor:orders" changed state from open to half-open  
INFO[0030] Circuit breaker "order-processor:orders" changed state from half-open to open

只要 Redis 容器停止，这种半开/打开行为就会持续下去。

步骤 6：移除故障

重新启动 order-processor 服务后，应用程序将无缝恢复，从中断的地方继续。

在 order-processor 服务终端中，重新启动应用程序：

dapr run --app-port 6001 --app-id order-processor --resources-path ../../../resources/ --app-protocol http --dapr-http-port 3501 -- go run .

checkout 服务输出：

== APP == Order passed: {"orderId": 5}
== APP == Order passed: {"orderId": 6}
== APP == Order passed: {"orderId": 7}
== APP == Order passed: {"orderId": 8}
== APP == Order passed: {"orderId": 9}
== APP == Order passed: {"orderId": 10}

order-processor 服务输出：

== APP == Order received: {"orderId": 5}
== APP == Order received: {"orderId": 6}
== APP == Order received: {"orderId": 7}
== APP == Order received: {"orderId": 8}
== APP == Order received: {"orderId": 9}
== APP == Order received: {"orderId": 10}

告诉我们您的想法！

我们正在不断努力改进我们的快速入门示例，重视您的反馈。您觉得这个快速入门有帮助吗？您有改进建议吗？

加入我们的 discord 频道进行讨论。

下一步

访问此链接以获取有关 Dapr 弹性的更多信息。

探索 Dapr 教程 >>

弹性快速入门

1 - 快速入门：服务到组件的弹性

前置条件

第 1 步：设置环境

第 2 步：运行应用程序

第 3 步：引入故障

第 3 步：移除故障

前置条件

第 1 步：设置环境

第 2 步：运行应用程序

第 3 步：引入故障

第 3 步：移除故障

前置条件

第 1 步：设置环境

第 2 步：运行应用程序

第 3 步：引入故障

第 3 步：移除故障

前置条件

第 1 步：设置环境

第 2 步：运行应用程序

第 3 步：引入故障

第 3 步：移除故障

前置条件

第 1 步：设置环境

第 2 步：运行应用程序

第 3 步：引入故障

第 3 步：移除故障

请告诉我们你的想法！

后续步骤

2 - 快速入门：服务到服务弹性

前置条件

步骤 1：设置环境

步骤 2：运行 order-processor 服务

步骤 3：运行 checkout 服务应用程序

步骤 4：查看服务调用输出

步骤 5：引入故障

步骤 6：移除故障

前置条件

步骤 1：设置环境

步骤 2：运行 order-processor 服务

步骤 3：运行 checkout 服务应用程序

步骤 4：查看服务调用输出

步骤 5：引入故障

步骤 6：移除故障

前置条件

步骤 1：设置环境

步骤 2：运行 order-processor 服务

步骤 3：运行 checkout 服务应用程序

步骤 4：查看服务调用输出

步骤 5：引入故障

步骤 6：移除故障

前置条件

步骤 1：设置环境

步骤 2：运行 order-processor 服务

步骤 3：运行 checkout 服务应用程序

步骤 4：查看服务调用输出

步骤 5：引入故障

步骤 6：移除故障

前置条件

步骤 1：设置环境

步骤 2：运行 order-processor 服务

步骤 3：运行 checkout 服务应用程序

步骤 4：查看服务调用输出

步骤 5：引入故障

步骤 6：移除故障

告诉我们您的想法！

下一步

步骤 2：运行 `order-processor` 服务

步骤 3：运行 `checkout` 服务应用程序

步骤 2：运行 `order-processor` 服务

步骤 3：运行 `checkout` 服务应用程序

步骤 2：运行 `order-processor` 服务

步骤 3：运行 `checkout` 服务应用程序

步骤 2：运行 `order-processor` 服务

步骤 3：运行 `checkout` 服务应用程序

步骤 2：运行 `order-processor` 服务

步骤 3：运行 `checkout` 服务应用程序