ScalaInAction测试——静态测试

测试积点老人

前言

首先，我们需要了解如何测试发送和接受消息，包括发送然后不管的模式以及发送之后等待回复的交互式模式。
使用的是 Scala 的测试框架 [ScalaTest]。这个框架被设计成可读性性很高。
使用这个工具可以生成可读性很强的测试报告。当然 Akka 也为我们提供了测试工具 akka-test，如果没有这个工具，
我们将面临相比与正常对象更加困难的测试环境。主要有下面四个原因：

• 无法准确把握消息到达时间，因为消息是异步发送的
• 并发，Actors 之间是并发多线程的，需要考虑更多的问题，如锁、障碍等
• 无状态 Actor是无法直接访问对象的，只能通过 ActorRef
• 集成测试。如果需要集成测试多个 Actor 就需要在它们直接做拦截，这也是不明确如何去实现的
  

下面主要从两个方面演示如何利用 akka-testkit + ScalaTest 作测试：

• Single threaded unit testing
• Multi-threaded unit testing
  

环境搭建

安装 jdk + sbt + scala， build.sbt 中加入如下内容：

1. name := "testdriven" #名字随意取，项目名称
   
2. 
   
3. version := "0.1-SNAPSHOT"
   
4. 
   
5. organization := "com.manning" #公司域名倒过来写，最后可以加入部门简称
   
6. 
   
7. scalaVersion := "2.11.7"
   
8. 
   
9. libraryDependencies ++= {
   
10.   val akkaVersion       = "2.3.12"
    
11.   Seq(
    
12.     "com.typesafe.akka"       %%  "akka-actor"   % akkaVersion, #注意两个 %% 号的用法基本类
    
13.     "com.typesafe.akka"       %%  "akka-slf4j"   % akkaVersion, #日志类
    
14.     "com.typesafe.akka"       %%  "akka-testkit" % akkaVersion   % "test", #最后一个 %指定使用范围
    
15.     "org.scalatest"           %%  "scalatest"    % "2.2.4"       % "test"
    
16.   )
    
17. }

复制代码

静态测试示例1

1. package packagename
   
2. import org.scalatest.WordSpecLike
   
3. import org.scalatest.MustMatchers
   
4. import akka.testkit.{ TestActorRef, TestKit }
   
5. import akka.actor._
   
6. 
   
7. package silenttest {
   
8. 
   
9. class SilentActorTest extends TestKit(ActorSystem("testsystem"))
   
10.     with WordSpecLike
    
11.     with MustMatchers
    
12.     with StopSystemAfterAll {
    
13. 
    
14.     "A Silent Actor" must {
    
15. 
    
16.       "change internal state when it receives a message, single" in {
    
17.         import SilentActor._
    
18. 
    
19.         //  利用TestActorRef 直接生成可以访问实际 Actor 对象的 Actor
    
20.         val silentActor = TestActorRef[SilentActor]
    
21.         silentActor ! SilentMessage("whisper")
    
22.         //  静态的测试方法，直接访问actor的内部对象
    
23.         silentActor.underlyingActor.state must (contain("whisper"))
    
24.       }
    
25.       //<end id="ch02-silentactor-test02"/>
    
26.     }
    
27.   }
    
28. 
    
29. 
    
30.   object SilentActor {
    
31.     case class SilentMessage(data: String)
    
32.     case class GetState(receiver: ActorRef)
    
33.   }
    
34. 
    
35.   class SilentActor extends Actor {
    
36.     import SilentActor._
    
37.     var internalState = Vector[String]()
    
38. 
    
39.     def receive = {
    
40.       case SilentMessage(data) =>
    
41.         internalState = internalState :+ data
    
42.     }
    
43. 
    
44.     def state = internalState
    
45.   }
    
46. }
    
47. 
    
48. //通用类，目的是及时关闭所有Actor
    
49. package common {
    
50.   import akka.testkit.TestKit
    
51.   import org.scalatest.{Suite, BeforeAndAfterAll}
    
52. 
    
53.   trait StopSystemAfterAll extends BeforeAndAfterAll{
    
54. 
    
55.     //注意这种混入手法
    
56.     this: TestKit with Suite =>
    
57.     override protected def afterAll(): Unit = {
    
58.       super.afterAll()
    
59.       system.shutdown()
    
60.     }
    
61.   }
    
62. }
    

复制代码

静态测试示例2

1. package silentactor03 {
   
2. 
   
3.   class SilentActorTest extends TestKit(ActorSystem("testsystem"))
   
4.     with WordSpecLike
   
5.     with MustMatchers
   
6.     with StopSystemAfterAll {
   
7. 
   
8.     "A Silent Actor" must {
   
9. 
   
10.       "change internal state when it receives a message, multi" in {
    
11.         import SilentActor._
    
12. 
    
13.         val silentActor = system.actorOf(Props[SilentActor], "s3")
    
14.         silentActor ! SilentMessage("whisper1")
    
15.         silentActor ! SilentMessage("whisper2")
    
16.         //通过发送消息获取内部状态
    
17.         silentActor ! GetState(testActor)
    
18.         expectMsg(Vector("whisper1", "whisper2"))
    
19.       }
    
20. 
    
21.     }
    
22. 
    
23.   }
    
24. 
    
25. 
    
26.   object SilentActor {
    
27.     case class SilentMessage(data: String)
    
28.     case class GetState(receiver: ActorRef)
    
29.   }
    
30. 
    
31.   class SilentActor extends Actor {
    
32.     import SilentActor._
    
33.     var internalState = Vector[String]()
    
34. 
    
35.     def receive = {
    
36.       case SilentMessage(data) =>
    
37.         internalState = internalState :+ data
    
38.       case GetState(receiver) => receiver ! internalState
    
39.     }
    
40.   }
    
41. }

复制代码