发送TCP/IP消息的AKKA actor

Question

是否可以通过TCP/IP向AKKA actor发送消息？

例如，编写一个客户端：

mySocket = new Socket("theactor", 75);
os = new DataOutputStream(smtpSocket.getOutputStream());
os.writeBytes("HELLO");    

那怎样向AKKA演员发送消息呢？

谢谢。

- dublintech

Answer 1

详细说一下Viktor的回答，最简单的示例是：

import akka.actor._
import ActorDSL._
import java.net.InetSocketAddress

object Server extends App {
  implicit val sys = ActorSystem("telnet")

  actor(new Act with ActorLogging {
    IOManager(context.system) listen new InetSocketAddress(1234)
    become {
      case IO.NewClient(server) ⇒
        server.accept()
      case IO.Read(handle, bytes) ⇒
        log.info("got {} from {}", bytes.decodeString("utf-8"), handle)
    }
  })
}

然后在另一个终端中启动telnet localhost 1234，开始输入，您将看到每行显示一个演员日志消息。

- Roland Kuhn

Answer 2

是的，也不完全是。您需要使用Akka IO模块或Akka Camel模块（使用netty或mina组件）：

http://doc.akka.io/docs/akka/snapshot/scala/io.html

http://doc.akka.io/docs/akka/snapshot/java/camel.html

- Viktor Klang

Answer 3

如果您正在尝试通过IP向远程Actor发送消息，为什么不尝试使用Akka Remote Actor系统呢？"在这里阅读"

- ezuweHiwatari