TestProbe缺少Akka消息 [英] TestProbe missing akka message

问题描述

我正在尝试测试连接到tcp上另一个遥控器的简单角色。这是我的演员

I'm trying to test a simple actor which is connecting to another remote on tcp. Here is my actor

/**
  * Created by chris on 6/6/16.
  */
class Client(listener : ActorRef, actorSystem: ActorSystem) extends Actor with BitcoinSLogger {

  /**
    * The manager is an actor that handles the underlying low level I/O resources (selectors, channels)
    * and instantiates workers for specific tasks, such as listening to incoming connections.
    */
  def manager = IO(Tcp)(actorSystem)


  def receive  = {

    case Tcp.Connect(remote,_,_,_,_) => manager ! Tcp.Connect(remote)
    case Tcp.CommandFailed(_: Tcp.Connect) =>
      logger.debug("Connection failed")
      listener ! "connect failed"
      context stop self

    case c @ Tcp.Connected(remote, local) =>
      logger.debug("Tcp connection to: " + remote)
      logger.debug("Local: " + local)
      listener ! c
      val connection = sender()
      connection ! Tcp.Register(self)
      context become {
        case data: ByteString =>
          connection ! Tcp.Write(data)
        case Tcp.CommandFailed(w: Tcp.Write) =>
          // O/S buffer was full
          listener ! "write failed"
        case Tcp.Received(data) =>
          listener ! data
        case "close" =>
          connection ! Tcp.Close
        case _: Tcp.ConnectionClosed =>
          listener ! "connection closed"
          context stop self
      }
  }
  def sendMessage(msg : NetworkRequest, peer : NetworkIpAddress) : Future[NetworkResponse] = ???

}


object Client {
  //private case class ClientImpl(remote: InetSocketAddress, listener: ActorRef, actorSystem : ActorSystem) extends Client

  def apply(listener : ActorRef, actorSystem : ActorSystem) : Props = {
    Props(classOf[Client], listener, actorSystem)
  }

}

这是我的测试用例

class ClientTest extends TestKit(ActorSystem("ClientTest")) with FlatSpecLike with MustMatchers with BeforeAndAfterAll {

      "Client" must "connect to a node on the bitcoin network" in {

        val probe = TestProbe()
        val hostName = "testnet-seed.bitcoin.schildbach.de"
        val socket = new InetSocketAddress(hostName, TestNet3.port)
        val peerMessageHandler = PeerMessageHandler(system)
        val client = system.actorOf(Client(peerMessageHandler, system))
        probe.send(client, Tcp.Connect(socket))
        probe.expectMsgType[Tcp.Connected](10.seconds)
      }



  override def afterAll: Unit = {
    TestKit.shutdownActorSystem(system)
  }
}

最后，我可以说连接成功了，因为我的日志消息被击中：

finally, I can tell the connection is successful because my log messages are being hit:

2016-06-08 09：58：21,548-[DEBUG]-来自类

中的org.bitcoins.spvnode.networking.Client ClientTest-akka.actor.default-dispatcher-4 Tcp连接至：
testnet-seed.bitcoin.schildbach.de:18333

2016-06-08 09:58:21,548 - [DEBUG] - from class org.bitcoins.spvnode.networking.Client in ClientTest-akka.actor.default-dispatcher-4 Tcp connection to: testnet-seed.bitcoin.schildbach.de:18333

2016-06-08 09：58：21,550-[调试]-来自
ClientTest-akka.actor中的类
org.bitcoins.spvnode.networking.Client。 default-dispatcher-4本地：
/192.168.1.107:43782

2016-06-08 09:58:21,550 - [DEBUG] - from class org.bitcoins.spvnode.networking.Client in ClientTest-akka.actor.default-dispatcher-4 Local: /192.168.1.107:43782

但是我的测试用例由于此错误而失败

however my test case is failing with this error

[info] ClientTest:
[info] Client
[info] - must connect to a node on the bitcoin network *** FAILED ***
[info]   java.lang.AssertionError: assertion failed: timeout (10 seconds) during expectMsgClass waiting for class akka.io.Tcp$Connected
[info]   at scala.Predef$.assert(Predef.scala:170)
[info]   at akka.testkit.TestKitBase$class.expectMsgClass_internal(TestKit.scala:435)
[info]   at akka.testkit.TestKitBase$class.expectMsgType(TestKit.scala:417)
[info]   at akka.testkit.TestKit.expectMsgType(TestKit.scala:737)
[info]   at org.bitcoins.spvnode.networking.ClientTest$$anonfun$1.apply$mcV$sp(ClientTest.scala:25)
[info]   at org.bitcoins.spvnode.networking.ClientTest$$anonfun$1.apply(ClientTest.scala:17)
[info]   at org.bitcoins.spvnode.networking.ClientTest$$anonfun$1.apply(ClientTest.scala:17)
[info]   at org.scalatest.Transformer$$anonfun$apply$1.apply$mcV$sp(Transformer.scala:22)
[info]   at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85)
[info]   at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
[info]   ...

似乎我缺少一些简单的东西，但我无法弄清楚到底是什么。

Seems like I am missing something simple, but I can't figure out exactly what it is.

推荐答案

要回答我自己的问题，我只是探究了试听 Client actor的监听器的想法。本身。

To answer my own question, I just made probe the listener isntead of trying to listen on the Client actor itself.

  "Client" must "connect to a node on the bitcoin network" in {
    val probe = TestProbe()
    val hostName = "testnet-seed.bitcoin.schildbach.de"
    val socket = new InetSocketAddress(hostName, TestNet3.port)
    val peerMessageHandler = PeerMessageHandler(system)
    val client = TestActorRef(Client(probe.ref,system))
    //probe.send(client, Tcp.Connect(socket))
    client ! Tcp.Connect(socket)
    probe.expectMsgType[Tcp.Connected](10.seconds)
  }

这篇关于TestProbe缺少Akka消息的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！