scala 2.10，akka-camel tcp 套接字通信

Question

我正在寻找一些简单而简短的示例，如何连接并与 tcp 套接字进行交互(双向)。换句话说，如何编写 scala 2.10 应用程序(使用 akka-camel 或 netty 库)与 tcp 进程(套接字)进行通信。

我在互联网上找到了很多文献，但一切都很旧(寻找 Scala 2.10)和/或已弃用。

提前致谢!

Answer 1

嗯，我正在寻找这样的东西:

1.服务器:

import akka.actor._
import akka.camel.{ Consumer, CamelMessage }

class Ser extends Consumer {
  def endpointUri = "mina2:tcp://localhost:9002"
  def receive = {
    case message: CamelMessage => {
     //log
     println("looging, question:" + message)
     sender ! "server response to request: " + message.bodyAs[String] + ", is NO"
     }
   case _ => println("I got something else!??!!")
  }
}

object server extends App {

val system = ActorSystem("some")
val spust = system.actorOf(Props[Ser])
}

2. 客户:

 import akka.actor._
 import akka.camel._
 import akka.pattern.ask
 import scala.concurrent.duration._
 import akka.util.Timeout
 import scala.concurrent.Await

 class Producer1 extends Actor with Producer {
   def endpointUri = "mina2:tcp://localhost:9002"
  }

 object Client extends App {

 implicit val timeout = Timeout(10 seconds)
 val system2 = ActorSystem("some-system")
 val producer = system2.actorOf(Props[Producer1])
 val future = producer.ask("Hello, can I go to cinema?")

 val result = Await.result(future, timeout.duration)
 println("Is future over?="+future.isCompleted+";;result="+result)

 println("Ende!!!")
 system2.shutdown
 println("system2 ended:"+system2.isTerminated)

我知道这是在 http://doc.akka.io/docs/akka/2.1.0/scala/camel.html 中编写和详细描述的所有内容。 .但是，如果您是新手，则需要通读并多次阅读，以构建非常简单的客户端-服务器应用程序。我认为某种“激励示例”会非常受欢迎。