多节点测试

    示例项目

    你可以查看「」项目，以了解实践中的情况。

    多节点测试概念

    当我们讨论 Akka 中的多节点测试时，我们指的是在不同的 JVM 中的多个 Actor 系统上运行协调测试的过程。多节点测试套件由三个主要部分组成。

    • ，它协调和控制被测节点。
    • Multi Node Spec，它是一个方便的包装器，用于启动TestConductor并让所有节点连接到它。
    • ，它可以在多个 JVM 中（可能在多台机器上）启动测试。

    多节点测试的基础是TestConductor。它是一个插入网络堆栈的 Akka 扩展，用于协调参与测试的节点，并提供以下几个功能：

    • 节点地址查找：查找到另一个测试节点的完整路径（不需要在测试节点之间共享配置）
    • 节点屏障协调：在指定屏障处等待其他节点。
    • 网络故障注入：限制流量、丢弃数据包、拔出和重新插入节点。

    下面是TestConductor的示意图概述：

    TestConductor服务器负责协调屏障并向TestConductor客户端发送命令，例如限制与其他客户端之间的网络流量。有关可能操作的更多信息，请参阅akka.remote.testconductor.Conductor API文档。

    Multi Node Spec

    Multi Node Spec由两部分组成。MultiNodeConfig负责公共配置、枚举和命名测试节点；MultiNodeSpec包含许多方便函数，用于使测试节点相互作用。有关可能操作的更多信息，请参阅akka.remote.testkit.MultiNodeSpec API文档。

    这些是可用的属性：

    • multinode.max-nodes，测试可以拥有的最大节点数。
    • multinode.host，此节点的主机名或 IP，必须可以使用InetAddress.getByName解析。
    • multinode.port，此节点的端口号，默认为0，将使用随机端口。
    • multinode.server-host，服务器节点的主机名或 IP，必须可以使用InetAddress.getByName解析。
    • multinode.server-port，服务器节点的端口号，默认为4711。
    • multinode.index，按照为测试定义的角色序列对此节点的索引，索引0是特殊的，该计算机将是服务器，所有故障注入和节流都必须从此节点完成。

    SbtMultiJvm 插件

    SbtMultiJvm插件已经更新，可以通过自动生成相关的multinode.*属性来运行多节点测试。这意味着你可以在一台机器上运行多节点测试，而无需任何特殊配置，方法是将它们作为普通的多 JVM 测试运行。然后，通过使用插件中的多节点添加，可以在多台计算机上运行这些测试，而无需进行任何更改。

    该插件还具有许多新的multi-node-* sbt 任务和设置，以支持在多台计算机上运行测试。将必要的测试类和依赖项打包，以便通过「」分发到一个jar文件中，该文件的格式为<projectName>_<scalaVersion>-<projectVersion>-multi-jvm-assembly.jar。

    • 注释：为了能够在多台机器上分发和启动测试，假设主机和目标系统都是具有ssh和rsync可用性的类似 POSIX 的系统。

    这些是可用的sbt多节点设置：

    • multiNodeHosts，提供一个用于运行测试的主机序列，在表单user@host:java中，host是唯一需要的部分。将覆盖文件中的设置。
    • multiNodeHostsFileName，用于在主机中读取以用于运行测试的文件。每行一个，格式同上。默认为基本项目目录中的multi-node-test.hosts。
    • multiNodeTargetDirName，为目标计算机上的目录命名，在其中复制jar文件。默认为ssh用户的基本目录中用于rsync jar 文件的multi-node-test。
    • multiNodeJavaName，目标机器上的默认 Java 可执行文件的名称，默认为java。

    下面是一些如何定义主机的示例：

    • localhost，使用默认java在本地主机上定位当前用户。
    • user1@host1，用户user1在主机host1使用默认java。
    • ，用户user2在主机host2上使用java 7。
    • host3:/usr/lib/jvm/java-6-openjdk-amd64/bin/java，使用java 6在主机host3上的当前用户。

    要在sbt内部以多节点模式（即分发jar文件并远程启动测试）运行所有多节点测试，请使用multiNodeTest任务：

    1. multiNodeTest

    要在多 JVM 模式（即本地计算机上的所有 JVM）下运行所有的 JVM，请执行以下操作：

    1. multiNodeTestOnly your.MultiNodeTest

    要在多 JVM 模式下运行单个测试，请执行以下操作：

    可以列出多个测试名称以运行多个特定测试。sbt中的制表符使完成测试名称变得容易。

    多节点测试示例

    首先，我们需要一些脚手架（scaffolding）来将MultiNodeSpec与你最喜欢的测试框架连接起来。让我们定义一个使用ScalaTest启动和停止MultiNodeSpec的特征STMultiNodeSpec。

    1. package akka.remote.testkit
    2. import scala.language.implicitConversions
    4. import org.scalatest.{ BeforeAndAfterAll, WordSpecLike }
    5. import org.scalatest.Matchers
    7. /**
    8.  * Hooks up MultiNodeSpec with ScalaTest
    9.  */
    10. trait STMultiNodeSpec extends MultiNodeSpecCallbacks with WordSpecLike with Matchers with BeforeAndAfterAll {
    11.   self: MultiNodeSpec =>
    13.   override def beforeAll() = multiNodeSpecBeforeAll()
    15.   override def afterAll() = multiNodeSpecAfterAll()
    17.   // Might not be needed anymore if we find a nice way to tag all logging from a node
    18.   override implicit def convertToWordSpecStringWrapper(s: String): WordSpecStringWrapper =
    19.     new WordSpecStringWrapper(s"$s (on node '${self.myself.name}', $getClass)")
    20. }

    然后我们需要定义一个配置。让我们使用两个节点"node1"和"node2"，并将其称为MultiNodeSampleConfig。

    最后到节点测试代码。它启动两个节点，并演示一个屏障和一个远程 Actor 消息发送/接收。

    1. package akka.remote.sample
    3. import akka.actor.{ Actor, Props }
    4. import akka.remote.testkit.MultiNodeSpec
    5. import akka.testkit.ImplicitSender
    7. class MultiNodeSampleSpecMultiJvmNode1 extends MultiNodeSample
    10. object MultiNodeSample {
    11.   class Ponger extends Actor {
    12.     def receive = {
    13.       case "ping" => sender() ! "pong"
    14.     }
    15.   }
    16. }
    17. class MultiNodeSample extends MultiNodeSpec(MultiNodeSampleConfig) with STMultiNodeSpec with ImplicitSender {
    19.   import MultiNodeSample._
    20.   import MultiNodeSampleConfig._
    22.   def initialParticipants = roles.size
    24.   "A MultiNodeSample" must {
    26.     "wait for all nodes to enter a barrier" in {
    27.       enterBarrier("startup")
    28.     }
    30.     "send to and receive from a remote node" in {
    31.       runOn(node1) {
    32.         enterBarrier("deployed")
    33.         val ponger = system.actorSelection(node(node2) / "user" / "ponger")
    34.         ponger ! "ping"
    35.         import scala.concurrent.duration._
    36.         expectMsg(10.seconds, "pong")
    37.       }
    39.       runOn(node2) {
    40.         system.actorOf(Props[Ponger], "ponger")
    41.         enterBarrier("deployed")
    42.       }
    44.       enterBarrier("finished")
    45.     }
    46.   }
    47. }

    自己运行这个示例的最简单方法是下载准备好的「」以及教程，此示例的源代码可以在「Akka Samples Repository」中找到。

    要记住的事情

    在编写多节点测试时，需要记住一些事情，否则你的测试可能会以令人惊讶的方式运行。

    • 不要关闭第一个节点。第一个节点是控制器，如果它关闭，测试将中断。
    • 要使用blackhole、passThrough和throttle，你必须通过在MultiNodeConfig中指定testTransport(on = true)来激活故障注入器和节流器传输适配器。
    • 节流、关闭和其他故障注入只能从第一个节点完成，这也是控制器。
    • 关闭节点后，不要使用node(address)请求节点的地址。在关闭节点之前获取地址。

    英文原文链接：Multi Node Testing.