5

我正在使用 zeromq 构建 REQ/REP 服务，REP 部分在 Scala 中并使用 Akka 演员。

这里是演员

class ReplyActor extends Actor {

  println("Listening..")

  def receive = {
    case m: ZMQMessage =>
      sender ! ZMQMessage(Seq(Frame("world")))
    case _ =>
      sender ! ZMQMessage(Seq(Frame("didn't understand?")))
  }

}

我的主要功能

object Replyer extends App {
  val system = ActorSystem("zmq")
  val serverSocket = ZeroMQExtension(system).newRepSocket(
    Array(
      Bind("tcp://127.0.0.1:1234"),
      Listener(system.actorOf(Props[ReplyActor]))
    )
  )
}

我的 REQ 代码在 python 中

import zmq
import time
context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect("tcp://127.0.0.1:1234")

startTime = time.time() 
for i in range(10):
    msg = "msg %s" % i
    socket.send("hello")
    msg_in = socket.recv()

print 'That took ', time.time()-startTime, 'seconds'

10 条消息大约需要 1 秒，所以我的问题是为什么这么慢？如果我在 python 中构建 REP，它真的很快，所以我指责 Akka zeromq 绑定。

额外信息：我正在使用 Scala 2.9.2 和最新的 Akka 2.0.3（但也尝试使用 2.0.2）

4

0 回答 0