Как отправлять сообщения между удаленными участниками Akka? - PullRequest
Новая
       15

Как отправлять сообщения между удаленными участниками Akka?

2 голосов
/ 21 октября 2011

Я хочу создать очень простое приложение для чата, которое должно работать без какого-либо центрального сервера с использованием удаленных участников Akka.

Я в основном хочу запустить один экземпляр приложения с IP-адресомA. Затем я хочу запустить экземпляр приложения с IP-адресом A и , сообщая ему, что удаленный экземпляр находится по IP-адресу B.

Как мне это настроить?Документация Akka обычно охватывает только случаи использования клиент / сервер, и даже основные вещи оставили меня в полном замешательстве, например, где использовать Actor.actorOf против Actor.register против Actor.remote.

Мой код в настоящее время выглядит следующим образом: 

import collection.mutable.{ArrayBuffer, HashSet}
import akka.actor.Actor

sealed trait Event    
/** Join tells the peer that there is a new peer and 
  * requests a list of known peers and messages. */
case class Join(user: String, ipAddress: String) extends Event
/** Join tells the peer that there is a new peer. */
case class Register(user: String, ipAddress: String) extends Event
case class Leave(user: String, ipAddress: String) extends Event    
case object GetChatLog extends Event
case object GetPeers extends Event
case class ChatLog(log: Seq[Message]) extends Event
case class Peers(peers: Seq[Peer]) extends Event
case class Message(sender: String, time: Long, message: String) extends Event

class ChatPeer(val name: String, ipAddress: String) extends Actor {
  val chat = Actor.remote.actorFor("chat:service", ipAddress, 2552) //This is not what I want...
  val messages = ArrayBuffer[Message]()
  val peers = HashSet[Peer]()

  def join = {
    (chat ? Join(name, ipAddress)).as[(Seq[Peer], Seq[Message])]
  }

  def register = chat ! Register(name, ipAddress)

  def leave = chat ! Leave(name, ipAddress)

  def send(message: String) = {
    val msg = Message(name, System.currentTimeMillis(), message)
    messages += msg
    chat ! msg
  }

  def getMessages = (chat ? GetChatLog).as[ChatLog]
    .getOrElse(throw new Exception("Couldn't get the chat log from ChatServer"))

  def getPeers = (chat ? GetPeers).as[Peers]
    .getOrElse(throw new Exception("Couldn't get the peers from ChatServer"))


  def receive = {
    case msg@Message(from, time, message) =>
      println(msg)
      messages += msg

    case GetChatLog =>
      self reply messages

    case GetPeers =>
      self reply peers

    case Join =>
      peers += Peer(name, ipAddress)
      self reply ((peers, messages))

    case Register(user, ipAddress) =>
      peers += Peer(user, ipAddress)

    case Leave(user, ipAddress) =>
      peers -= Peer(user, ipAddress)

  }
}

case class Peer(name: String, ipAddress: String)

1 Ответ

3 голосов
/ 21 октября 2011

Не уверен, что я понимаю, что вы хотите от вашего примера кода.

Я думаю, что если вы хотите создать версию без выделенного сервера, то в основном оба партнера должны будут запустить и зарегистрировать удаленный сервер 

remote.start("localhost", somePort).register("chat-main", actorOf[ChatMain])

, а затем попробуйте подключиться к серверу другого партнера 

val otherActor = remote.actorFor("chat-main", otherHost, somePeer)

По сути, вам придется настроить равноправные серверы и одновременно. Остальная часть настройки - это логика согласования и чата, но технически она не намного сложнее, чем этот простой пример на сайте Akka.

...