Akka2使用探索1（Remoting）

 

akka从1.2升级到现在的2.0.2后有了很大的改变。现在摸索一下如何使用。

 

Remoting可以方便地用于服务器之间通信。akka1.2可以使用clientActor.sendRequestReply将消息发送到服务器端，并且同步获取服务器端的返回消息。但是akka2已经不能这么用了,akka2使用tell方法给另一个Actor发消息。

tell有两个重载方法：

/**
* Sends the specified message to the sender, i.e. fire-and-forget semantics.<p/>
* <pre>
* actor.tell(message);
* </pre>
*/
final def tell(msg: Any): Unit = this.!(msg)(null: ActorRef)

只发送，不管其他，也不接收相应。actor.tell(msg)----给actor发送msg消息

 

/**
* Java API. <p/>
* Sends the specified message to the sender, i.e. fire-and-forget
* semantics, including the sender reference if possible (not supported on
* all senders).<p/>
* <pre>
* actor.tell(message, context);
* </pre>
*/
final def tell(msg: Any, sender: ActorRef): Unit = this.!(msg)(sender)

只发送消息，并告诉对方你可以给我指定的sender回复消息。actor.tell(msg,sender)----给actor发送msg消息,actor处理时可以给sender回复消息。

所以akka2中actor是对等的。有消息来回发送的akka应用最好部署在对等互通的网络环境中。如果一个应用部署在内网，一个部署在外网，那么内网的actor给外网发消息没问题，但是外网的actor想给内网的actor回复消息就不行了。

 

另外，因为remoting的host最好指定成具体的ip或域名或hostname，不要指定成”0.0.0.0”，这样才方便定位远程actor。host和port在配置文件中指定。

注意区别Deploy，Deploy是指将本地Actor发布到远程akka Server上，withDeploy的参数RemoteScope指的是远程Server的ip、端口、sysName。并不是启动本地Server。

serverActor = system.actorOf(new Props(Server.class).withDeploy(new Deploy(new RemoteScope(new Address("akka", Server.AkkaSystemName, "127.0.0.1", 8888);))), "simple");

客户端可以直接用serverActor发消息，也可以通过路径查找，用actorFor(akka://${远程sysName}@${远程akka服务地址}/remote/${被发布的sysName}@${被发布的akka的地址（ip、端口）}/user/${actorOf第二个参数指定的路径})发消息。注意消息是在服务端收到。

 

现在来看看具体的例子：

 

首先引用typesafe的仓库：

<repository>
<id>typesafe-releases</id>
<url>http://repo.typesafe.com/typesafe/releases</url>
</repository>

 

加入依赖包：<akka.version>2.0.2</akka.version>

<dependency>
<groupId>com.typesafe.akka</groupId>
<artifactId>akka-actor</artifactId>
<version>${akka.version}</version>
</dependency>
<dependency>
<groupId>com.typesafe.akka</groupId>
<artifactId>akka-remote</artifactId>
<version>${akka.version}</version>
</dependency>
<dependency>
<groupId>com.typesafe.akka</groupId>
<artifactId>akka-kernel</artifactId>
<version>${akka.version}</version>
</dependency>

 

首先定义ServerActor：

import akka.remote.RemoteScope
import akka.actor.*
import com.typesafe.config.ConfigFactory
class Server extends UntypedActor {
static final String AkkaSystemName = "xw"
LoggingAdapter log = Logging.getLogger(getContext().system(), this);

@Override
void onReceive(Object message) {
log.debug("server收到消息----${message}----self:${getSelf()},sender:${getSender()}")
getSender().tell(message)//给客户端actor发送消息
}

}

然后定义服务端应用，来启动ServerActor

import akka.kernel.Bootable
import akka.actor.ActorSystem
import akka.actor.Props
import akka.actor.ActorRef
import akka.actor.Address
import akka.actor.Deploy
import akka.remote.RemoteScope
import com.typesafe.config.ConfigFactory

class ServerApp implements Bootable {
ActorSystem system
ActorRef serverActor

ServerApp() {
system = ActorSystem.create(Server.AkkaSystemName, ConfigFactory.load().getConfig("server"))
Address addr = new Address("akka", Server.AkkaSystemName, "10.68.15.16", 8888);
serverActor = system.actorOf(new Props(Server.class), "server");

// serverActor = system.actorOf(new Props(Server.class).withDeploy(new Deploy(new RemoteScope(addr))), "simple");
}

void startup() {

}

void shutdown() {
system.shutdown()
}

}
指定它加载“server”配置。需要在classpath下的application.conf中添加：

server {
akka {
//loglevel = "DEBUG"
actor {

provider = "akka.remote.RemoteActorRefProvider"//这里指定使用RemoteActor

}
remote {
transport = "akka.remote.netty.NettyRemoteTransport"
netty {
hostname = "10.68.15.16"//"0.0.0.0"//指定系统绑定的host
port = 8888//指定系统绑定的端口
}
}
}
}
现在只需要new ServerApp()将服务启动即可。

 

客户端很简单：

ActorSystem.create(Server.AkkaSystemName, ConfigFactory.load().getConfig("client")).actorFor("akka://xw@10.68.15.16:8888/user/server").tell("hello,I'm client")

客户端也需要加载配置文件：

client {
akka {

actor {
provider = "akka.remote.RemoteActorRefProvider"

}

}
}

这里需要注意：

1、必须指定provider为RemoteActorXXX

2、客户端只发不收消息时，ActorSystem的name没有要求。需要收消息时，如果和服务端相同则可能出问题。遇到问题时改下ActorSystem的那么试一下。

 

经过试验，如果服务端启多个ActorSystem和akka端口是没问题的。akka1.2中同一个进程不能启多个akka端口。

评论

1 楼 蜗居之家 2016-05-18  

akka2.0的如何实现1.2的功能 onReceive中接收另一个actor返回的数据 把数据返回给上级调用