Scala Specs2中自动收集集成测试Spec实现全局环境管控

一、全局依赖统一启停实现 #

用Specs2的BeforeAfterAll特质实现全局生命周期管理，写一个聚合用的根Specification，所有启停逻辑集中在这里：

import org.specs2.Specification
import org.specs2.specification.BeforeAfterAll
import play.api.inject.guice.GuiceApplicationBuilder
import org.apache.kafka.streams.integration.utils.EmbeddedKafkaCluster
import com.github.tomakehurst.wiremock.WireMockServer

class IntegrationSuite extends Specification with BeforeAfterAll {
  // 声明全局依赖实例
  private var app: play.api.Application = _
  private var kafkaCluster: EmbeddedKafkaCluster = _
  private var wireMock: WireMockServer = _

  override def beforeAll(): Unit = {
    // 启动Guice应用
    app = new GuiceApplicationBuilder().build()
    app.start()

    // 启动EmbeddedKafka（示例配置，按需调整节点数、端口等）
    kafkaCluster = new EmbeddedKafkaCluster(1)
    kafkaCluster.start()

    // 启动WireMock，建议用动态端口避免冲突
    wireMock = new WireMockServer(8080)
    wireMock.start()
  }

  override def afterAll(): Unit = {
    // 按启动逆序关闭依赖，防止资源泄露
    if (wireMock != null) wireMock.stop()
    if (kafkaCluster != null) kafkaCluster.stop()
    if (app != null) app.stop()
  }

  // 自动收集Spec的逻辑放在这里，下文实现
  override def is = ???
}

二、自动收集integrations目录下的Spec #

SpecificationFinder默认扫描范围不匹配导致返回空列表，需指定目标包路径（对应integrations目录的scala包结构），调整扫描逻辑如下：

import org.specs2.specification.SpecificationFinder
import org.specs2.mutable.Specification

// 在IntegrationSuite中实现自动收集逻辑
override def is = {
  // 指定集成测试所在的根包（比如integrations目录对应com.yourcompany.integrations）
  val targetPackage = "com.yourcompany.integrations"
  // 扫描包下所有继承Specs2 Specification的类
  val specs = SpecificationFinder
    .findSpecifications(
      packageName = targetPackage,
      classLoader = getClass.getClassLoader,
      filter = clazz => classOf[Specification].isAssignableFrom(clazz)
    )
    .map(_.is) // 提取每个Spec的测试片段

  // 聚合所有测试片段
  specs.foldLeft(Fragments.empty) { (acc, fragments) => acc.append(fragments) }
}

注意：所有集成测试Spec必须继承Specs2的Specification（或mutable.Specification），否则过滤器无法识别。

三、sbt测试任务复用配置 #

在build.sbt中单独配置集成测试任务，隔离单元测试与集成测试：

// 定义独立的集成测试配置
lazy val IntegrationTest = config("it") extend Test

lazy val root = (project in file("."))
  .configs(IntegrationTest)
  .settings(
    // 复用默认测试任务逻辑
    inConfig(IntegrationTest)(Defaults.testSettings),
    // 指定集成测试源目录为根目录下的integrations
    scalaSource in IntegrationTest := baseDirectory.value / "integrations",
    // 仅运行根聚合Spec，避免子Spec重复执行
    testOptions in IntegrationTest += Tests.Argument(TestFrameworks.Specs2, "only", "com.yourcompany.IntegrationSuite"),
    // 添加集成测试专属依赖
    libraryDependencies ++= Seq(
      "org.apache.kafka" % "kafka-streams-test-utils" % "2.8.1" % IntegrationTest,
      "com.github.tomakehurst" % "wiremock-jre8" % "2.35.0" % IntegrationTest,
      "org.specs2" %% "specs2-core" % "4.19.0" % IntegrationTest
    )
  )

执行sbt it:test即可运行所有集成测试，全局依赖仅启停一次。

常见问题排查 #

• SpecificationFinder返回空：检查包名是否与integrations目录的scala包结构一致，子Spec是否正确继承Specs2的Specification trait。
• 端口冲突：EmbeddedKafka、WireMock改用动态端口，通过实例方法获取端口后传递给测试代码。
• 资源泄露：确保afterAll中按逆序关闭所有依赖，避免残留进程。

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