Play 2とRemote Akka Clusterを使ったシリアル化の実装
-
12-12-2019 - |
質問
私はリモートAKKAクラスタシステムに接続されているプレイフレームワーク2があり、両方のシステムはJavaにあります。 私はクラスに包まれているデータストラントがあり、私はシリアライズ可能な実装を実装しました ラッパークラスで。 私はリモート計算のためのデータストラートを使いたいですが、リモートAKKAシステムにラッパークラスを送信しようとするときはいつでもエラーが発生します。 以下はコードスニペットです。
これはラッパークラスです
package controllers;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.Map;
public class Coordinates implements Serializable{
String className = null;
Map <String,ArrayList<Object>> jMap = null;
boolean train = false;
public Coordinates() { train = true;}
public Coordinates (String className)
{
this.className = className;
}
public Coordinates (Map <String,ArrayList<Object>> jMap , boolean b)
{
this.jsonMap = jMap;
train = b;
}
}
.
これはオブジェクトを送信するアクタークラスです。
package controllers;
import akka.actor.ActorRef;
import akka.actor.UntypedActor;
public class LocalActor extends UntypedActor {
ActorRef masterActor;
@Override
public void onReceive(Object arg) throws Exception {
if(arg instanceof Coordinates)
{ Coordinates msg = (Coordinates) arg ;
masterActor.tell(msg , getSelf());
}
}
public void preStart()
{
masterActor = getContext().actorFor("akka://MasterNode@127.0.0.1:2552/user/masterActor");
}
}
.
これはAKKA俳優がクラスを受け取ることです。
package Rubine_Cluster;
import java.io.Serializable;
import akka.actor.*;
public class MasterActor extends UntypedActor implements Serializable{
public MasterActor(){System.out.println(" the masteractor has been started ");}
@Override
public void onReceive(Object message) throws Exception {
System.out.print(" this is from before me to you "+message.toString());
if(message instanceof Coordinates)
{ Coordinates msg = (Coordinates) message;
try { System.out.print(" this is from message " + msg.jsonMap.toString());
getSender().tell( 1234 , getSelf());
} catch (Exception e) {
getSender().tell(new akka.actor.Status.Failure(e), getSelf());
throw e;
}
}
else{ unhandled(message);}
}
}
.
私のEclipse IDEからのエラーメッセージです
[INFO] [10/02/2012 02:58:35.606] [main] [ActorSystem(MasterNode)] REMOTE: RemoteServerStarted@akka://MasterNode@127.0.0.1:2552
Master Node is called
the masteractor has been started
[INFO] [10/02/2012 02:59:28.223] [MasterNode-7] [ActorSystem(MasterNode)] REMOTE: RemoteClientStarted@akka://LocalNode@127.0.0.1:63305
[ERROR] [10/02/2012 02:59:28.334] [MasterNode-7] [ActorSystem(MasterNode)] REMOTE: RemoteServerError@akka://MasterNode@127.0.0.1:2552] Error[java.lang.ClassNotFoundException:controllers.Coordinates
at java.net.URLClassLoader$1.run(Unknown Source)
at java.net.URLClassLoader$1.run(Unknown Source)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(Unknown Source)
at java.lang.ClassLoader.loadClass(Unknown Source)
at sun.misc.Launcher$AppClassLoader.loadClass(Unknown Source)
at java.lang.ClassLoader.loadClass(Unknown Source)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Unknown Source)
at java.io.ObjectInputStream.resolveClass(Unknown Source)
at akka.util.ClassLoaderObjectInputStream.resolveClass(ClassLoaderObjectInputStream.scala:12)
at java.io.ObjectInputStream.readNonProxyDesc(Unknown Source)
at java.io.ObjectInputStream.readClassDesc(Unknown Source)
at java.io.ObjectInputStream.readOrdinaryObject(Unknown Source)
at java.io.ObjectInputStream.readObject0(Unknown Source)
at java.io.ObjectInputStream.readObject(Unknown Source)
at akka.serialization.JavaSerializer$$anonfun$1.apply(Serializer.scala:121)
at scala.util.DynamicVariable.withValue(DynamicVariable.scala:57)
at akka.serialization.JavaSerializer.fromBinary(Serializer.scala:121)
at akka.serialization.Serialization.deserialize(Serialization.scala:73)
at akka.remote.MessageSerializer$.deserialize(MessageSerializer.scala:22)
at akka.remote.RemoteMessage.payload(RemoteTransport.scala:210)
at akka.remote.RemoteMarshallingOps$class.receiveMessage(RemoteTransport.scala:276)
at akka.remote.netty.NettyRemoteTransport.receiveMessage(NettyRemoteSupport.scala:30)
at akka.remote.netty.RemoteServerHandler.messageReceived(Server.scala:182)
at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:75)
at akka.remote.netty.RemoteServerHandler.handleUpstream(Server.scala:154)
at org.jboss.netty.channel.StaticChannelPipeline.sendUpstream(StaticChannelPipeline.java:366)
at org.jboss.netty.channel.StaticChannelPipeline$StaticChannelHandlerContext.sendUpstream(StaticChannelPipeline.java:528)
at org.jboss.netty.handler.execution.ChannelUpstreamEventRunnable.run(ChannelUpstreamEventRunnable.java:44)
at org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor$ChildExecutor.run(OrderedMemoryAwareThreadPoolExecutor.java:312)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)
]
.
ALOはリモートAKKAシステムの座標クラスを実装しています。 どんな提案や助けが高く評価されます。 ありがとう
解決
座標クラスを2回実装する必要はありません。モデルクラス(座標など)を含むモジュールがあるはずです。この最初の1つに従って、他の2つのAkkaプロジェクトをプロジェクトにしてください。
この種のプロジェクト/モジュール依存関係を持つべきです:
module containing Coordinate class (Maven Project)
|
---- Local Actor (Play project)
|
---- Remote Actor (Maven Project)
. 他のヒント
明らかにあなたのマスター俳優にはControllers.Coordinatesがクラスパスに含まれていません。別の答えはコードの再利用を示唆していますが、それは根本的な原因ではありません。場合によっては意味がありません(ローカルとマスターで異なる操作がある可能性があります)。あなたのマスター俳優はどのように建てられていますか?クラスパスはどのようなものですか?マスタープロジェクトにクラスを追加するだけで、大丈夫です。
所属していません StackOverflow