Dapr 1.7.0 版本全解析Resiliency 容错策略、可观测性增强与安装部署升级指南【免费下载链接】daprDapr is a portable runtime for building distributed applications across cloud and edge, combining event-driven architecture with workflow orchestration.项目地址: https://gitcode.com/GitHub_Trending/da/dapr本文以 Dapr 1.7.0 官方发布说明为主线深入解析本版本最核心的三大主题——面向全部 Dapr API 的弹性容错策略Timeout / Retry / Circuit Breaker、组件级指标与 API 调用日志等可观测性增强以及自托管离线安装、Kubernetes Unix Domain Socket 等部署能力升级同时结合当前仓库源码给出完整的配置示例、升级步骤与破坏性变更说明。读完本文你将掌握 Dapr 1.7.0 的完整特性清单、Resiliency 规格的编写方法与底层执行原理并能独立完成自托管与 Kubernetes 环境的平滑升级。版本概览Dapr 1.7.0 带来了什么Dapr 1.7.0 是分布式应用运行时 Dapr 的里程碑式版本围绕构建具备故障自愈能力的分布式应用这一核心目标展开。本版本的关键变化可以概括为Resiliency 弹性策略落地在既有重试能力基础上正式加入超时Timeouts、重试Retries与熔断Circuit breakers三种策略并可统一应用到服务调用Apps、组件Components与 Actor 三种目标上覆盖全部 Dapr API 调用路径可观测性增强为 pub/sub、bindings、state store 等组件补充了大量组件级指标并新增 Dapr API 调用日志开关便于诊断应用与 sidecar 之间的通信组件生态扩容5 个组件从 RC 转正为 stable新增 3 个 state storeCockroachDB、NATS JetStream、Oracle Databasestate store 总数达到 23 个组件总数达到 97 个41 bindings、1 configuration、8 HTTP middleware、3 name resolution、13 pub/sub、8 secret stores、23 state stores多项功能转正Actor 重入Actor reentrancy、gRPC 代理gRPC proxying、自动状态加密Automatic state store encryption由 preview 转为 stable部署能力升级CLI 支持 Kubernetes namespace、证书轮换命令dapr mtls renew-certificate、私有镜像仓库与离线airgap安装preview以及 Kubernetes 上的 Unix Domain Socket 支持。Resiliency面向所有 Dapr API 的容错策略为什么需要弹性策略分布式应用通常由数十甚至上百个服务实例构成这些服务高度依赖数据库、缓存、pub/sub、secret store 等基础设施。依赖越多故障概率越高——实例可能因硬件故障、数据库慢查询、请求过载、应用重启或扩缩容而失败或无响应。具备容错能力检测、缓解、响应故障的应用能够恢复到可用状态并实现自愈同时防止级联故障蔓延到基础设施层。Dapr 通过Resiliency spec弹性规格来定义和应用容错策略。该规格与组件规格存放在相同位置sidecar 启动时加载并据此决定如何将弹性策略应用到 Dapr API 调用上。三种策略与三类目标Resiliency 规格支持三种经典弹性模式策略作用Timeouts超时为操作设置最大等待时间防止调用无限期挂起Retries重试在操作失败后按策略进行重试可基于错误类型/状态码决定是否重试Circuit breakers熔断在连续失败达到阈值后打开熔断器暂时切断对该目标的调用避免雪崩这些策略可以一致地应用到三类目标上Apps通过服务调用service invocation访问的应用Componentsstate store、pub/sub、bindings 等组件ActorsActor 运行时。完整配置示例仓库 pkg/resiliency/testdata/resiliency.yaml 提供了一份完整的示例规格覆盖了三种策略与三类目标apiVersion: dapr.io/v1alpha1 kind: Resiliency metadata: name: resiliency spec: policies: # Timeouts are simple named durations. timeouts: general: 5s important: 60s largeResponse: 10s # Retries are named templates and are instantiated for life of the operation. retries: serviceRetry: policy: constant duration: 5s maxRetries: 10 actorRetry: policy: constant duration: 5s maxRetries: 10 stateRetry: policy: constant duration: 5s maxRetries: 10 pubsubRetry: policy: constant duration: 5s maxRetries: 10 retryForever: policy: exponential maxInterval: 15s maxRetries: -1 # Retry indefinitely noRetry: policy: constant maxRetries: 0 # No retries withMatch: policy: constant duration: 5s maxRetries: 3 matching: httpStatusCodes: 500 # Circuit breakers are automatically instantiated per component, service # endpoint, and application route using these settings as a template. # Circuit breakers maintain counters that can live as long as the Dapr sidecar. circuitBreakers: serviceCB: maxRequests: 1 interval: 8s timeout: 45s trip: consecutiveFailures 8 stateCB: maxRequests: 1 interval: 8s timeout: 45s trip: consecutiveFailures 8 actorCB: maxRequests: 1 interval: 8s timeout: 45s trip: consecutiveFailures 8 pubsubCB: maxRequests: 1 interval: 8s timeout: 45s trip: consecutiveFailures 8 # This section specifies default policies for: # * service invocation # * requests to components # * events sent to routes targets: apps: appB: timeout: general retry: serviceRetry # Circuit breakers for services are scoped per endpoint (e.g. hostname port). # When a breaker is tripped, that route is removed from load balancing for the # configured timeout duration. circuitBreaker: serviceCB actors: myActorType: timeout: general retry: actorRetry # Circuit breakers for actors are scoped by type, id, or both. # When a breaker is tripped, that type or id is removed from the placement table # for the configured timeout duration. circuitBreaker: actorCB circuitBreakerScope: both circuitBreakerCacheSize: 5000 components: # For state stores, policies apply to saving and retrieving state. statestore1: outbound: timeout: general retry: stateRetry # Circuit breakers for components are scoped per component configuration/instance # (e.g. redis1). When this breaker is tripped, all interaction to that component # is prevented for the configured timeout duration. circuitBreaker: stateCB pubsub2: outbound: retry: pubsubRetry circuitBreaker: pubsubCB inbound: timeout: general retry: pubsubRetry circuitBreaker: pubsubCB需要特别注意的配置要点Retry 策略支持constant固定间隔与exponential指数退避两种模式maxRetries: -1表示无限重试maxRetries: 0表示不重试Retry 条件匹配matching支持按 HTTP 状态码如500也支持范围如500-504决定是否重试——这正是发布说明中根据错误类型配置重试FIXED #3826的能力落地Circuit breaker通过 CEL 表达式trip定义触发条件如consecutiveFailures 8熔断器按目标自动实例化——服务按 endpoint 粒度、Actor 按 type/id 粒度circuitBreakerScope可取type、id、both、组件按组件实例粒度组件目标区分 inbound / outboundinbound 用于处理进入的事件如 pub/sub 投递到订阅路由outbound 用于发起调用如写 state store、发布消息。源码级解析策略如何被加载与执行从源码结构看Resiliency 的实现位于 pkg/resiliency 包加载与执行链路清晰可循加载LoadLocalResiliency自托管模式从本地组件目录读取 YAML与LoadKubernetesResiliencyKubernetes 模式通过 operator 的ListResiliencygRPC 接口拉取负责加载规格二者都会过滤非kind: Resiliency的文件FromConfigurations将配置解码为运行时对象并先注入一组内置策略见 pkg/resiliency/resiliency.go。内置默认策略addBuiltInPolicies预置了DaprBuiltInServiceRetries服务调用constant 策略最多 3 次、间隔 1s、DaprBuiltInActorRetries、DaprBuiltInActorReminderRetries、DaprBuiltInActorNotFoundRetries、DaprBuiltInInitializationRetries等默认重试覆盖 Dapr 原有的内置重试场景用户定义的策略若与内置重试同名且重试次数低于 3会被强制重置为 3 以保持最低容错保障见 pkg/resiliency/resiliency.go。执行PolicyDefinition将三类策略组合为一个执行单元NewRunner生成包装函数按超时 → 熔断 → 重试的次序包裹业务操作见 pkg/resiliency/policy.go。超时通过context.WithTimeout与带缓冲 channel 实现超时后会触发addTimeoutActivatedMetric指标熔断基于 sony/gobreaker 实现熔断器状态变化时上报cb_state指标重试使用 backoff 机制若错误携带 HTTP/gRPC 状态码且不在matching白名单中则通过backoff.Permanent立即终止重试。熔断参数CircuitBreaker结构见 pkg/resiliency/breaker/circuitbreaker.go支持maxRequests半开状态下允许通过的请求数默认 1、intervalclosed 状态下清空内部计数的周期默认 0 即不清空、timeoutopen 状态持续时长默认 60s、tripCEL 表达式默认consecutiveFailures 5还可用requests、totalFailures等计数。状态码匹配retry.go中的ParseRetryConditionMatch将matching.httpStatusCodes/matching.gRPCStatusCodes解析为区间列表HTTP 合法范围 100-599gRPC 合法范围 0-16运行期据此判断某次失败是否值得重试见 pkg/resiliency/retry.go。可观测性组件级指标与 API 调用日志新增组件指标为提升运维可见性本版本为组件新增了大量指标覆盖 pub/sub、bindings、state stores 等类型例如使用组件时的延迟以及组件被调用的次数。仓库文档 docs/development/dapr-metrics.md 中记录了这些指标的定义核心组件指标包括pub/subdapr_component_pubsub_ingress_latencies消费应用事件处理延迟、dapr_component_pubsub_ingress_count从 pub/sub 组件到达的入站消息数、dapr_component_pubsub_egress_count发布到组件的出站消息数、dapr_component_pubsub_egress_latenciespub/sub 组件响应延迟bindingsdapr_component_input_binding_count入站事件数、dapr_component_input_binding_latencies、dapr_component_output_binding_count输出绑定操作数、dapr_component_output_binding_latenciesstate storedapr_component_state_count状态组件操作数、dapr_component_state_latencies状态组件响应延迟configuration / secretdapr_component_configuration_count、dapr_component_configuration_latencies、dapr_component_secret_count、dapr_component_secret_latenciesjobsdapr_component_job_success_count、dapr_component_job_failure_count、dapr_component_job_latencies。与此同时Resiliency 也配套了可观测性指标见 docs/development/dapr-metrics.mddapr_resiliency_loaded已加载的弹性策略数量dapr_resiliency_count弹性策略被执行的总次数dapr_resiliency_activations_total策略在失败或状态变化后被激活的次数dapr_resiliency_cb_state熔断器当前状态unknown/closed/half-open/open四个系列当前状态为 1其余为 0。Dapr API 调用日志Dapr 运行时本就会将组件加载清单等运行时信息输出到标准输出便于诊断。本版本新增了应用与 Dapr sidecar 之间 API 调用的日志开关对应 ADDED #4119开启后可以在输出日志中看到 gRPC 与 HTTP 两种协议的 API 调用记录为定位应用侧问题提供了直接依据。组件生态更新5 个组件转正为 stable上一版本仍为 stable release candidate 的以下组件本版本正式转正为stableMQTT pub/subRabbitMQ pub/subAzure Blob Storage bindingAzure CosmosDB bindingAzure Service Bus Queues binding3 个全新 state store 组件本版本新增 3 个 state storestate store 总数达到 23 个CockroachDB state store组件NATS JetStream state store组件基于 JetStream KVOracle Database state store组件也支持 OCI Autonomous Database。同时预览版 Query API支持扩展到 PostgreSQL、CockroachDB 与 Redis state store在既有支持之上新增对应测试配置可见于 tests/config 目录。既有组件的更新与修复influxdb binding新增对query操作的支持大量组件修复重点包括MongoDB state store 修复自 1.5.0 起的 Actor reminder 数据序列化问题1.5.2/1.6.1 热修复同源Redis state store 修复数值查询问题、Query API 移除 JSON 查询语法中 key 名冗余的value前缀PostgreSQL state store 实现 Query API 并修复 ETag 设置问题MySQL、PostgreSQL、SQL Server、Azure CosmosDB state store 的 transaction API 均修复为按操作顺序执行AWS DynamoDB state store 新增 TTL 支持Hashicorp Vault secret store 支持 version、engine path 与parseAsMap选项NATS JetStream pub/sub 新增通配符订阅与 NKey 认证Pulsar pub/sub 升级客户端至 0.8.0 并新增 token 认证、disableBatching选项Kafka binding 新增版本配置Azure EventHubs binding 新增 Azure AD 支持等。从 Preview 转 Stable 的功能以下功能已至少经过两个版本的验证并收集了社区反馈与修复本版本正式转为 stableActor 重入Actor reentrancy允许 Actor 在同一调用链中重入自身避免死锁gRPC 代理gRPC proxyingsidecar 直接代理 gRPC 流量到目标应用降低序列化开销自动状态存储加密Automatic state store encryption在 state 层自动加解密本版本新增对128-bit、192-bit、256-bitAES 密钥尺寸的显式支持对应 PR #4373加密实现可参见 pkg/encryption 目录。CLI 与安装方式更新Kubernetes namespace 支持dapr components、dapr configurations与dapr list三个 CLI 命令现在支持指定 Kubernetes namespace 过滤输出结果。更简便的证书轮换为应对集群中根证书过期与续期问题本版本引入dapr mtls renew-certificate命令用于轮换和重新生成根证书与应用证书。同时任何使用-kKubernetes选项的 CLI 命令在根证书剩余有效期不足 30 天时都会输出警告信息。自托管模式的新安装方式Preview私有与替代镜像仓库自托管模式下CLIinit命令现在可以指定任意私有仓库拉取安装 Dapr 所需的容器镜像也可以在公共 Docker Hub 与 GitHub 容器仓库之间选择对应--image-registry选项与相关环境变量方便将镜像放入可信仓库或在镜像限流时切换拉取来源离线 / airgap 安装Dapr 现在支持使用预下载的制品进行离线安装Docker 环境或精简环境均可。每个版本构建出Dapr Installer Bundle制品包配合 CLIinit命令即可在完全无网络的环境中完成安装。性能Kubernetes 上的 Unix Domain Sockets本版本在自托管基础上为Kubernetes引入了Unix Domain SocketUDS支持用于调用 Dapr sidecar 时提升吞吐量并降低延迟。启用方式是在 Pod 上添加注解dapr.io/unix-domain-socket-path该注解定义于 pkg/injector/annotations/annotations.go并由注入器 patcher 在 pkg/injector/patcher/sidecar.go 中读取后写入 sidecar 容器配置。注意该特性仅适用于 LinuxWindows 上不可用。升级到 Dapr 1.7.0本版本包含少量破坏性变更升级前请先阅读对应小节。本地机器 / 自托管升级先使用当前已安装的 CLI 卸载 Dapr。注意这会删除默认的$HOME/.dapr目录、二进制文件以及dapr_redis、dapr_placement、dapr_zipkin全部容器Linux 用户若 docker 命令需要 sudo则需加 sudodapr uninstall --all安装最新 CLI 后执行dapr init --runtime-version1.7.0等待更新完成用以下命令确认 Dapr 已更新到 1.7.0$ dapr --version CLI version: 1.7.0 Runtime version: 1.7.0Kubernetes从旧版本升级可以使用 Helm 3 或 Dapr CLI 进行零停机升级。使用 CLI 升级dapr upgrade --runtime-version 1.7.0 -k启用高可用模式升级dapr upgrade --runtime-version 1.7.0 --enable-hatrue -k等待操作完成并用dapr status -k检查状态。使用 Helm 升级helm repo add dapr https://dapr.github.io/helm-charts/ helm repo update helm upgrade dapr dapr/dapr --version 1.7.0 --namespacedapr-system --wait注意升级完成后务必重启你的 deployments以便 sidecar 注入器为 Pod 注入新版本的 Dapr sidecar。Kubernetes全新安装使用 Helm 3 安装helm repo add dapr https://dapr.github.io/helm-charts/ helm repo update kubectl create namespace dapr-system helm install dapr dapr/dapr --version 1.7.0 --namespacedapr-system --wait也可以使用最新版 CLIdapr init --runtime-version1.7.0 -k安装后验证确认控制平面各 Pod 运行且健康$ dapr status -k NAME NAMESPACE HEALTHY STATUS REPLICAS VERSION AGE CREATED dapr-dashboard dapr-system True Running 1 0.10.0 15s 2022-03-29 13:07.39 dapr-sidecar-injector dapr-system True Running 1 1.7.0 15s 2022-03-29 13:07.39 dapr-sentry dapr-system True Running 1 1.7.0 15s 2022-03-29 13:07.39 dapr-operator dapr-system True Running 1 1.7.0 15s 2022-03-29 13:07.39 dapr-placement dapr-system True Running 1 1.7.0 15s 2022-03-29 13:07.39安装完成后对既有 deployments 执行滚动重启以接入新版本 sidecarkubectl rollout restart deploy/deployment-nameBreaking Changes 与弃用通知破坏性变更State Management Query API预览key 名称中的value字段被移除。这是该预览功能基于社区反馈的持续调整使用 Query API 的 JSON 查询语法时需要注意 key 命名变化MongoDB state store包含 v1.6.1 发布说明中描述的破坏性变更以修复数据序列化问题——MongoDB state store 从 JSON 值输出中移除了 bson 产物bson二进制字段标记方法调用中的/若你在方法调用中使用/本版本会受影响——Dapr 现在会自动解码 URL 中的%2f对应 FIXED #4008调用路径语义发生变化Java SDK移除了已废弃的 builder 类对应 REMOVED #601。弃用通知从 Dapr 1.9 开始HTTP 调用若未显式提供content-type头将不再默认使用text/plain。建议用户通过新的 preview 特性开关提前开启该行为评估这一变化对现有应用的影响本版本同时修复了 Dapr 默认设置text/plain内容类型的问题 #4472并允许在未指定 content-type 时禁用该默认行为 #4469。结语Dapr 1.7.0 通过 Resiliency 规格将超时、重试与熔断统一收敛到同一套声明式配置中覆盖服务调用、组件与 Actor 全部调用路径配合组件级指标与 API 调用日志使分布式应用的故障自愈与可观测性能力迈上了新台阶自托管离线安装、Kubernetes UDS、证书轮换等部署与运维增强则进一步降低了生产环境的使用门槛。对于希望深入了解实现细节的读者建议继续阅读仓库中的 pkg/resiliency 源码、测试用例以及 docs/development/dapr-metrics.md 指标文档。【免费下载链接】daprDapr is a portable runtime for building distributed applications across cloud and edge, combining event-driven architecture with workflow orchestration.项目地址: https://gitcode.com/GitHub_Trending/da/dapr创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考 Dapr 1.7.0 版本全解析：Resiliency 容错策略、可观测性增强与安装部署升级指南
Dapr 1.7.0 版本全解析Resiliency 容错策略、可观测性增强与安装部署升级指南【免费下载链接】daprDapr is a portable runtime for building distributed applications across cloud and edge, combining event-driven architecture with workflow orchestration.项目地址: https://gitcode.com/GitHub_Trending/da/dapr本文以 Dapr 1.7.0 官方发布说明为主线深入解析本版本最核心的三大主题——面向全部 Dapr API 的弹性容错策略Timeout / Retry / Circuit Breaker、组件级指标与 API 调用日志等可观测性增强以及自托管离线安装、Kubernetes Unix Domain Socket 等部署能力升级同时结合当前仓库源码给出完整的配置示例、升级步骤与破坏性变更说明。读完本文你将掌握 Dapr 1.7.0 的完整特性清单、Resiliency 规格的编写方法与底层执行原理并能独立完成自托管与 Kubernetes 环境的平滑升级。版本概览Dapr 1.7.0 带来了什么Dapr 1.7.0 是分布式应用运行时 Dapr 的里程碑式版本围绕构建具备故障自愈能力的分布式应用这一核心目标展开。本版本的关键变化可以概括为Resiliency 弹性策略落地在既有重试能力基础上正式加入超时Timeouts、重试Retries与熔断Circuit breakers三种策略并可统一应用到服务调用Apps、组件Components与 Actor 三种目标上覆盖全部 Dapr API 调用路径可观测性增强为 pub/sub、bindings、state store 等组件补充了大量组件级指标并新增 Dapr API 调用日志开关便于诊断应用与 sidecar 之间的通信组件生态扩容5 个组件从 RC 转正为 stable新增 3 个 state storeCockroachDB、NATS JetStream、Oracle Databasestate store 总数达到 23 个组件总数达到 97 个41 bindings、1 configuration、8 HTTP middleware、3 name resolution、13 pub/sub、8 secret stores、23 state stores多项功能转正Actor 重入Actor reentrancy、gRPC 代理gRPC proxying、自动状态加密Automatic state store encryption由 preview 转为 stable部署能力升级CLI 支持 Kubernetes namespace、证书轮换命令dapr mtls renew-certificate、私有镜像仓库与离线airgap安装preview以及 Kubernetes 上的 Unix Domain Socket 支持。Resiliency面向所有 Dapr API 的容错策略为什么需要弹性策略分布式应用通常由数十甚至上百个服务实例构成这些服务高度依赖数据库、缓存、pub/sub、secret store 等基础设施。依赖越多故障概率越高——实例可能因硬件故障、数据库慢查询、请求过载、应用重启或扩缩容而失败或无响应。具备容错能力检测、缓解、响应故障的应用能够恢复到可用状态并实现自愈同时防止级联故障蔓延到基础设施层。Dapr 通过Resiliency spec弹性规格来定义和应用容错策略。该规格与组件规格存放在相同位置sidecar 启动时加载并据此决定如何将弹性策略应用到 Dapr API 调用上。三种策略与三类目标Resiliency 规格支持三种经典弹性模式策略作用Timeouts超时为操作设置最大等待时间防止调用无限期挂起Retries重试在操作失败后按策略进行重试可基于错误类型/状态码决定是否重试Circuit breakers熔断在连续失败达到阈值后打开熔断器暂时切断对该目标的调用避免雪崩这些策略可以一致地应用到三类目标上Apps通过服务调用service invocation访问的应用Componentsstate store、pub/sub、bindings 等组件ActorsActor 运行时。完整配置示例仓库 pkg/resiliency/testdata/resiliency.yaml 提供了一份完整的示例规格覆盖了三种策略与三类目标apiVersion: dapr.io/v1alpha1 kind: Resiliency metadata: name: resiliency spec: policies: # Timeouts are simple named durations. timeouts: general: 5s important: 60s largeResponse: 10s # Retries are named templates and are instantiated for life of the operation. retries: serviceRetry: policy: constant duration: 5s maxRetries: 10 actorRetry: policy: constant duration: 5s maxRetries: 10 stateRetry: policy: constant duration: 5s maxRetries: 10 pubsubRetry: policy: constant duration: 5s maxRetries: 10 retryForever: policy: exponential maxInterval: 15s maxRetries: -1 # Retry indefinitely noRetry: policy: constant maxRetries: 0 # No retries withMatch: policy: constant duration: 5s maxRetries: 3 matching: httpStatusCodes: 500 # Circuit breakers are automatically instantiated per component, service # endpoint, and application route using these settings as a template. # Circuit breakers maintain counters that can live as long as the Dapr sidecar. circuitBreakers: serviceCB: maxRequests: 1 interval: 8s timeout: 45s trip: consecutiveFailures 8 stateCB: maxRequests: 1 interval: 8s timeout: 45s trip: consecutiveFailures 8 actorCB: maxRequests: 1 interval: 8s timeout: 45s trip: consecutiveFailures 8 pubsubCB: maxRequests: 1 interval: 8s timeout: 45s trip: consecutiveFailures 8 # This section specifies default policies for: # * service invocation # * requests to components # * events sent to routes targets: apps: appB: timeout: general retry: serviceRetry # Circuit breakers for services are scoped per endpoint (e.g. hostname port). # When a breaker is tripped, that route is removed from load balancing for the # configured timeout duration. circuitBreaker: serviceCB actors: myActorType: timeout: general retry: actorRetry # Circuit breakers for actors are scoped by type, id, or both. # When a breaker is tripped, that type or id is removed from the placement table # for the configured timeout duration. circuitBreaker: actorCB circuitBreakerScope: both circuitBreakerCacheSize: 5000 components: # For state stores, policies apply to saving and retrieving state. statestore1: outbound: timeout: general retry: stateRetry # Circuit breakers for components are scoped per component configuration/instance # (e.g. redis1). When this breaker is tripped, all interaction to that component # is prevented for the configured timeout duration. circuitBreaker: stateCB pubsub2: outbound: retry: pubsubRetry circuitBreaker: pubsubCB inbound: timeout: general retry: pubsubRetry circuitBreaker: pubsubCB需要特别注意的配置要点Retry 策略支持constant固定间隔与exponential指数退避两种模式maxRetries: -1表示无限重试maxRetries: 0表示不重试Retry 条件匹配matching支持按 HTTP 状态码如500也支持范围如500-504决定是否重试——这正是发布说明中根据错误类型配置重试FIXED #3826的能力落地Circuit breaker通过 CEL 表达式trip定义触发条件如consecutiveFailures 8熔断器按目标自动实例化——服务按 endpoint 粒度、Actor 按 type/id 粒度circuitBreakerScope可取type、id、both、组件按组件实例粒度组件目标区分 inbound / outboundinbound 用于处理进入的事件如 pub/sub 投递到订阅路由outbound 用于发起调用如写 state store、发布消息。源码级解析策略如何被加载与执行从源码结构看Resiliency 的实现位于 pkg/resiliency 包加载与执行链路清晰可循加载LoadLocalResiliency自托管模式从本地组件目录读取 YAML与LoadKubernetesResiliencyKubernetes 模式通过 operator 的ListResiliencygRPC 接口拉取负责加载规格二者都会过滤非kind: Resiliency的文件FromConfigurations将配置解码为运行时对象并先注入一组内置策略见 pkg/resiliency/resiliency.go。内置默认策略addBuiltInPolicies预置了DaprBuiltInServiceRetries服务调用constant 策略最多 3 次、间隔 1s、DaprBuiltInActorRetries、DaprBuiltInActorReminderRetries、DaprBuiltInActorNotFoundRetries、DaprBuiltInInitializationRetries等默认重试覆盖 Dapr 原有的内置重试场景用户定义的策略若与内置重试同名且重试次数低于 3会被强制重置为 3 以保持最低容错保障见 pkg/resiliency/resiliency.go。执行PolicyDefinition将三类策略组合为一个执行单元NewRunner生成包装函数按超时 → 熔断 → 重试的次序包裹业务操作见 pkg/resiliency/policy.go。超时通过context.WithTimeout与带缓冲 channel 实现超时后会触发addTimeoutActivatedMetric指标熔断基于 sony/gobreaker 实现熔断器状态变化时上报cb_state指标重试使用 backoff 机制若错误携带 HTTP/gRPC 状态码且不在matching白名单中则通过backoff.Permanent立即终止重试。熔断参数CircuitBreaker结构见 pkg/resiliency/breaker/circuitbreaker.go支持maxRequests半开状态下允许通过的请求数默认 1、intervalclosed 状态下清空内部计数的周期默认 0 即不清空、timeoutopen 状态持续时长默认 60s、tripCEL 表达式默认consecutiveFailures 5还可用requests、totalFailures等计数。状态码匹配retry.go中的ParseRetryConditionMatch将matching.httpStatusCodes/matching.gRPCStatusCodes解析为区间列表HTTP 合法范围 100-599gRPC 合法范围 0-16运行期据此判断某次失败是否值得重试见 pkg/resiliency/retry.go。可观测性组件级指标与 API 调用日志新增组件指标为提升运维可见性本版本为组件新增了大量指标覆盖 pub/sub、bindings、state stores 等类型例如使用组件时的延迟以及组件被调用的次数。仓库文档 docs/development/dapr-metrics.md 中记录了这些指标的定义核心组件指标包括pub/subdapr_component_pubsub_ingress_latencies消费应用事件处理延迟、dapr_component_pubsub_ingress_count从 pub/sub 组件到达的入站消息数、dapr_component_pubsub_egress_count发布到组件的出站消息数、dapr_component_pubsub_egress_latenciespub/sub 组件响应延迟bindingsdapr_component_input_binding_count入站事件数、dapr_component_input_binding_latencies、dapr_component_output_binding_count输出绑定操作数、dapr_component_output_binding_latenciesstate storedapr_component_state_count状态组件操作数、dapr_component_state_latencies状态组件响应延迟configuration / secretdapr_component_configuration_count、dapr_component_configuration_latencies、dapr_component_secret_count、dapr_component_secret_latenciesjobsdapr_component_job_success_count、dapr_component_job_failure_count、dapr_component_job_latencies。与此同时Resiliency 也配套了可观测性指标见 docs/development/dapr-metrics.mddapr_resiliency_loaded已加载的弹性策略数量dapr_resiliency_count弹性策略被执行的总次数dapr_resiliency_activations_total策略在失败或状态变化后被激活的次数dapr_resiliency_cb_state熔断器当前状态unknown/closed/half-open/open四个系列当前状态为 1其余为 0。Dapr API 调用日志Dapr 运行时本就会将组件加载清单等运行时信息输出到标准输出便于诊断。本版本新增了应用与 Dapr sidecar 之间 API 调用的日志开关对应 ADDED #4119开启后可以在输出日志中看到 gRPC 与 HTTP 两种协议的 API 调用记录为定位应用侧问题提供了直接依据。组件生态更新5 个组件转正为 stable上一版本仍为 stable release candidate 的以下组件本版本正式转正为stableMQTT pub/subRabbitMQ pub/subAzure Blob Storage bindingAzure CosmosDB bindingAzure Service Bus Queues binding3 个全新 state store 组件本版本新增 3 个 state storestate store 总数达到 23 个CockroachDB state store组件NATS JetStream state store组件基于 JetStream KVOracle Database state store组件也支持 OCI Autonomous Database。同时预览版 Query API支持扩展到 PostgreSQL、CockroachDB 与 Redis state store在既有支持之上新增对应测试配置可见于 tests/config 目录。既有组件的更新与修复influxdb binding新增对query操作的支持大量组件修复重点包括MongoDB state store 修复自 1.5.0 起的 Actor reminder 数据序列化问题1.5.2/1.6.1 热修复同源Redis state store 修复数值查询问题、Query API 移除 JSON 查询语法中 key 名冗余的value前缀PostgreSQL state store 实现 Query API 并修复 ETag 设置问题MySQL、PostgreSQL、SQL Server、Azure CosmosDB state store 的 transaction API 均修复为按操作顺序执行AWS DynamoDB state store 新增 TTL 支持Hashicorp Vault secret store 支持 version、engine path 与parseAsMap选项NATS JetStream pub/sub 新增通配符订阅与 NKey 认证Pulsar pub/sub 升级客户端至 0.8.0 并新增 token 认证、disableBatching选项Kafka binding 新增版本配置Azure EventHubs binding 新增 Azure AD 支持等。从 Preview 转 Stable 的功能以下功能已至少经过两个版本的验证并收集了社区反馈与修复本版本正式转为 stableActor 重入Actor reentrancy允许 Actor 在同一调用链中重入自身避免死锁gRPC 代理gRPC proxyingsidecar 直接代理 gRPC 流量到目标应用降低序列化开销自动状态存储加密Automatic state store encryption在 state 层自动加解密本版本新增对128-bit、192-bit、256-bitAES 密钥尺寸的显式支持对应 PR #4373加密实现可参见 pkg/encryption 目录。CLI 与安装方式更新Kubernetes namespace 支持dapr components、dapr configurations与dapr list三个 CLI 命令现在支持指定 Kubernetes namespace 过滤输出结果。更简便的证书轮换为应对集群中根证书过期与续期问题本版本引入dapr mtls renew-certificate命令用于轮换和重新生成根证书与应用证书。同时任何使用-kKubernetes选项的 CLI 命令在根证书剩余有效期不足 30 天时都会输出警告信息。自托管模式的新安装方式Preview私有与替代镜像仓库自托管模式下CLIinit命令现在可以指定任意私有仓库拉取安装 Dapr 所需的容器镜像也可以在公共 Docker Hub 与 GitHub 容器仓库之间选择对应--image-registry选项与相关环境变量方便将镜像放入可信仓库或在镜像限流时切换拉取来源离线 / airgap 安装Dapr 现在支持使用预下载的制品进行离线安装Docker 环境或精简环境均可。每个版本构建出Dapr Installer Bundle制品包配合 CLIinit命令即可在完全无网络的环境中完成安装。性能Kubernetes 上的 Unix Domain Sockets本版本在自托管基础上为Kubernetes引入了Unix Domain SocketUDS支持用于调用 Dapr sidecar 时提升吞吐量并降低延迟。启用方式是在 Pod 上添加注解dapr.io/unix-domain-socket-path该注解定义于 pkg/injector/annotations/annotations.go并由注入器 patcher 在 pkg/injector/patcher/sidecar.go 中读取后写入 sidecar 容器配置。注意该特性仅适用于 LinuxWindows 上不可用。升级到 Dapr 1.7.0本版本包含少量破坏性变更升级前请先阅读对应小节。本地机器 / 自托管升级先使用当前已安装的 CLI 卸载 Dapr。注意这会删除默认的$HOME/.dapr目录、二进制文件以及dapr_redis、dapr_placement、dapr_zipkin全部容器Linux 用户若 docker 命令需要 sudo则需加 sudodapr uninstall --all安装最新 CLI 后执行dapr init --runtime-version1.7.0等待更新完成用以下命令确认 Dapr 已更新到 1.7.0$ dapr --version CLI version: 1.7.0 Runtime version: 1.7.0Kubernetes从旧版本升级可以使用 Helm 3 或 Dapr CLI 进行零停机升级。使用 CLI 升级dapr upgrade --runtime-version 1.7.0 -k启用高可用模式升级dapr upgrade --runtime-version 1.7.0 --enable-hatrue -k等待操作完成并用dapr status -k检查状态。使用 Helm 升级helm repo add dapr https://dapr.github.io/helm-charts/ helm repo update helm upgrade dapr dapr/dapr --version 1.7.0 --namespacedapr-system --wait注意升级完成后务必重启你的 deployments以便 sidecar 注入器为 Pod 注入新版本的 Dapr sidecar。Kubernetes全新安装使用 Helm 3 安装helm repo add dapr https://dapr.github.io/helm-charts/ helm repo update kubectl create namespace dapr-system helm install dapr dapr/dapr --version 1.7.0 --namespacedapr-system --wait也可以使用最新版 CLIdapr init --runtime-version1.7.0 -k安装后验证确认控制平面各 Pod 运行且健康$ dapr status -k NAME NAMESPACE HEALTHY STATUS REPLICAS VERSION AGE CREATED dapr-dashboard dapr-system True Running 1 0.10.0 15s 2022-03-29 13:07.39 dapr-sidecar-injector dapr-system True Running 1 1.7.0 15s 2022-03-29 13:07.39 dapr-sentry dapr-system True Running 1 1.7.0 15s 2022-03-29 13:07.39 dapr-operator dapr-system True Running 1 1.7.0 15s 2022-03-29 13:07.39 dapr-placement dapr-system True Running 1 1.7.0 15s 2022-03-29 13:07.39安装完成后对既有 deployments 执行滚动重启以接入新版本 sidecarkubectl rollout restart deploy/deployment-nameBreaking Changes 与弃用通知破坏性变更State Management Query API预览key 名称中的value字段被移除。这是该预览功能基于社区反馈的持续调整使用 Query API 的 JSON 查询语法时需要注意 key 命名变化MongoDB state store包含 v1.6.1 发布说明中描述的破坏性变更以修复数据序列化问题——MongoDB state store 从 JSON 值输出中移除了 bson 产物bson二进制字段标记方法调用中的/若你在方法调用中使用/本版本会受影响——Dapr 现在会自动解码 URL 中的%2f对应 FIXED #4008调用路径语义发生变化Java SDK移除了已废弃的 builder 类对应 REMOVED #601。弃用通知从 Dapr 1.9 开始HTTP 调用若未显式提供content-type头将不再默认使用text/plain。建议用户通过新的 preview 特性开关提前开启该行为评估这一变化对现有应用的影响本版本同时修复了 Dapr 默认设置text/plain内容类型的问题 #4472并允许在未指定 content-type 时禁用该默认行为 #4469。结语Dapr 1.7.0 通过 Resiliency 规格将超时、重试与熔断统一收敛到同一套声明式配置中覆盖服务调用、组件与 Actor 全部调用路径配合组件级指标与 API 调用日志使分布式应用的故障自愈与可观测性能力迈上了新台阶自托管离线安装、Kubernetes UDS、证书轮换等部署与运维增强则进一步降低了生产环境的使用门槛。对于希望深入了解实现细节的读者建议继续阅读仓库中的 pkg/resiliency 源码、测试用例以及 docs/development/dapr-metrics.md 指标文档。【免费下载链接】daprDapr is a portable runtime for building distributed applications across cloud and edge, combining event-driven architecture with workflow orchestration.项目地址: https://gitcode.com/GitHub_Trending/da/dapr创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考