Scala中for推导式组合Future的整体重试问题（SoftwareMill Retry）

完全可以给整个for推导式的流程添加重试，不需要为每个单独的Future单独处理。你遇到的问题大概率是重试逻辑的作用范围没覆盖到整个推导式的完整执行链。

问题分析 #

你当前的写法可能只把重试包在了单个Future调用上，或者推导式的组合逻辑没被正确纳入重试的闭包中。比如如果只是给function2()单独加重试，那当整个推导式里前面的function1()已经成功执行后，function2()失败时只会重试它自己；但如果要整个流程重试，需要把整个for推导式的代码块作为一个整体交给重试函数。

正确实现方式 #

以SoftwareMill Retry库为例，你需要把整个for推导式包装成一个返回Future[Either[Error, Result]]的函数，然后将这个函数传入重试逻辑。

示例代码大致如下：

import scala.concurrent.Future
import com.softwaremill.retry._
import scala.concurrent.ExecutionContext.Implicits.global

// 假设你的两个函数定义
def function1(): Future[Either[String, Int]] = Future.successful(Right(1))
def function2(input: Int): Future[Either[String, String]] = Future.successful(Right(s"result-$input"))

// 把整个for推导式封装成一个可重试的任务
val retryableTask: () => Future[Either[String, String]] = () => {
  for {
    res1 <- function1()
    res2 <- res1 match {
      case Right(v) => function2(v)
      case Left(e) => Future.successful(Left(e))
    }
  } yield res2
}

// 定义重试策略（比如最多重试3次，只在返回Left时触发）
val retryStrategy = RetryPolicies.upTo(3)
  .when { case Left(_) => true; case _ => false }

// 执行带重试的任务
val finalResult: Future[Either[String, String]] = retry(retryStrategy)(retryableTask())

关键注意点 #

• 必须确保整个流程的所有步骤都被包含在重试的闭包内，这样每次重试都会从头执行function1()到function2()的完整逻辑。
• 重试触发条件要准确：比如判断结果是否为Left，确保只有当整个流程失败时才会触发重试。
• 如果你的function1()是有副作用的操作（比如写数据库），要考虑重试带来的重复执行问题，这种场景下可能需要调整策略，或者对部分步骤做幂等处理。

为什么你的测试中function2只执行了一次？ #

大概率是你之前的代码只给function2()单独加了重试，或者整个推导式没有被正确包裹进重试逻辑。比如如果写法是：

// 错误写法：仅单独重试function2，而非整个流程
for {
  res1 <- function1()
  res2 <- res1 match {
    case Right(v) => retry(retryStrategy)(function2(v))
    case Left(e) => Future.successful(Left(e))
  }
} yield res2

这种情况下，只有function2()会被重试，但如果function1()第一次执行成功后，后续重试只会重复调用function2()，而不会重新执行function1()。但如果是整个流程重试，每次失败都会从头执行function1()和function2()。

内容的提问来源于stack exchange，提问作者Kyle