问题描述
我正在构建一个 maven 项目来使用 akka 集群。我将我的类从一个项目目录移到另一个目录（在 Eclipse 中）。在最初的应用程序中，应用程序可以工作，现在我转移到一个新的 Maven 项目（总是在 eclipse 中）它不起作用。如何让我的应用程序在两个项目中都能正常运行？
这是我得到的控制台堆栈：
Start cluster on port(s) [2551,2552,0]
[DEBUG] [07/27/2021 17:29:45.013] [main] [EventStream] StandardOutLogger started
17:29:45.289 [cluster-akka.actor.default-dispatcher-5] INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
[DEBUG] [07/27/2021 17:29:45.295] [main] [EventStream(akka://cluster)] logger log1-Slf4jLogger started
[DEBUG] [07/27/2021 17:29:45.299] [main] [EventStream(akka://cluster)] Default Loggers started
17:29:45.299 [cluster-akka.actor.default-dispatcher-5] DEBUG akka.event.EventStream - logger log1-Slf4jLogger started
17:29:45.303 [cluster-akka.actor.default-dispatcher-5] DEBUG akka.event.EventStream - Default Loggers started
17:29:45.536 [cluster-akka.actor.default-dispatcher-5] DEBUG akka.io.TcpListener - Successfully bound to /127.0.0.1:2551
17:29:45.630 [cluster-akka.actor.default-dispatcher-5] INFO akka.remote.artery.tcp.ArteryTcpTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster@127.0.0.1:2551] with UID [4291962385969910618]
17:29:45.655 [cluster-akka.actor.default-dispatcher-5] INFO akka.cluster.Cluster - Cluster Node [akka://cluster@127.0.0.1:2551] - Starting up,Akka version [2.6.0] ...
17:29:45.868 [cluster-akka.actor.default-dispatcher-5] INFO akka.cluster.Cluster - Cluster Node [akka://cluster@127.0.0.1:2551] - Registered cluster JMX MBean [akka:type=Cluster,port=2551]
17:29:45.868 [cluster-akka.actor.default-dispatcher-5] INFO akka.cluster.Cluster - Cluster Node [akka://cluster@127.0.0.1:2551] - Started up successfully
17:29:45.931 [cluster-akka.actor.default-dispatcher-11] INFO akka.cluster.Cluster - Cluster Node [akka://cluster@127.0.0.1:2551] - No downing-provider-class configured,manual cluster downing required,see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
17:29:46.049 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.remote.artery.Association - Starting outbound control stream to [akka://cluster@127.0.0.1:2552]
17:29:46.080 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.serialization.Serialization(akka://cluster) - Replacing JavaSerializer with disabledJavaSerializer,due to `akka.actor.allow-java-serialization = off`.
17:29:46.139 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.remote.artery.Association - Starting outbound message stream to [akka://cluster@127.0.0.1:2552]
Exception in thread "main" 17:29:46.363 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.actor.CoordinatedShutdown - Running CoordinatedShutdown with reason [ActorSystemTerminateReason]
17:29:46.363 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.actor.CoordinatedShutdown - Performing phase [before-service-unbind] with [0] tasks
java.lang.classNotFoundException: cluster.FstSerializer
at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:606)
at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:168)
at java.base/java.lang.classLoader.loadClass(ClassLoader.java:522)
at java.base/java.lang.class.forName0(Native Method)
at java.base/java.lang.class.forName(Class.java:468)
at akka.actor.ReflectiveDynamicAccess.$anonfun$getClassFor$1(ReflectiveDynamicAccess.scala:29)
at scala.util.Try$.apply(Try.scala:212)
at akka.actor.ReflectiveDynamicAccess.getClassFor(ReflectiveDynamicAccess.scala:28)
at akka.actor.ReflectiveDynamicAccess.createInstanceFor(ReflectiveDynamicAccess.scala:47)
at akka.serialization.Serialization.serializerOf(Serialization.scala:390)
at akka.serialization.Serialization.$anonfun$serializers$2(Serialization.scala:424)
at scala.collection.Iterator$$anon$9.next(Iterator.scala:554)
at scala.collection.immutable.HashMapBuilder.addAll(HashMap.scala:2299)
at scala.collection.immutable.HashMap$.from(HashMap.scala:2123)
at scala.collection.immutable.HashMap$.from(HashMap.scala:2099)
at scala.collection.MapOps$WithFilter.map(Map.scala:351)
at akka.serialization.Serialization.<init>(Serialization.scala:424)
at akka.serialization.SerializationExtension$.createExtension(SerializationExtension.scala:16)
at akka.serialization.SerializationExtension$.createExtension(SerializationExtension.scala:13)
at akka.actor.ActorSystemImpl.registerExtension(ActorSystem.scala:1146)
at akka.actor.ActorSystemImpl.$anonfun$loadExtensions$1(ActorSystem.scala:1184)
at scala.collection.IterableOnceOps.foreach(IterableOnce.scala:576)
at scala.collection.IterableOnceOps.foreach$(IterableOnce.scala:574)
at scala.collection.AbstractIterable.foreach(Iterable.scala:904)
at akka.actor.ActorSystemImpl.loadExtensions$1(ActorSystem.scala:1180)
at akka.actor.ActorSystemImpl.loadExtensions(ActorSystem.scala:1196)
at akka.actor.ActorSystemImpl.liftedTree2$1(ActorSystem.scala:1041)
at akka.actor.ActorSystemImpl._start$lzycompute(ActorSystem.scala:1029)
at akka.actor.ActorSystemImpl._start(ActorSystem.scala:1029)
at akka.actor.ActorSystemImpl.start(ActorSystem.scala:1051)
at akka.actor.ActorSystem$.apply(ActorSystem.scala:282)
at akka.actor.ActorSystem$.apply(ActorSystem.scala:326)
at akka.actor.ActorSystem$.apply(ActorSystem.scala:300)
at akka.actor.ActorSystem$.create(ActorSystem.scala:223)
at akka.actor.ActorSystem.create(ActorSystem.scala)
at main.Application.lambda$0(Application.java:51)
at java.base/java.util.Arrays$ArrayList.forEach(Arrays.java:4203)
at main.Application.startupClusterNodes(Application.java:50)
at main.Application.main(Application.java:31)
17:29:46.371 [cluster-akka.actor.default-dispatcher-11] ERROR akka.remote.artery.Encoder - Failed to serialize message [akka.remote.artery.OutboundHandshake$HandshakeReq].
java.lang.classNotFoundException: cluster.FstSerializer
at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:606)
at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:168)
at java.base/java.lang.classLoader.loadClass(ClassLoader.java:522)
at java.base/java.lang.class.forName0(Native Method)
at java.base/java.lang.class.forName(Class.java:468)
at akka.actor.ReflectiveDynamicAccess.$anonfun$getClassFor$1(ReflectiveDynamicAccess.scala:29)
at scala.util.Try$.apply(Try.scala:212)
at akka.actor.ReflectiveDynamicAccess.getClassFor(ReflectiveDynamicAccess.scala:28)
at akka.actor.ReflectiveDynamicAccess.createInstanceFor(ReflectiveDynamicAccess.scala:47)
at akka.serialization.Serialization.serializerOf(Serialization.scala:390)
at akka.serialization.Serialization.$anonfun$serializers$2(Serialization.scala:424)
at scala.collection.Iterator$$anon$9.next(Iterator.scala:554)
at scala.collection.immutable.HashMapBuilder.addAll(HashMap.scala:2299)
at scala.collection.immutable.HashMap$.from(HashMap.scala:2123)
at scala.collection.immutable.HashMap$.from(HashMap.scala:2099)
at scala.collection.MapOps$WithFilter.map(Map.scala:351)
at akka.serialization.Serialization.<init>(Serialization.scala:424)
at akka.serialization.SerializationExtension$.createExtension(SerializationExtension.scala:16)
at akka.serialization.SerializationExtension$.createExtension(SerializationExtension.scala:13)
at akka.actor.ActorSystemImpl.registerExtension(ActorSystem.scala:1146)
at akka.actor.ActorSystemImpl.$anonfun$loadExtensions$1(ActorSystem.scala:1184)
at scala.collection.IterableOnceOps.foreach(IterableOnce.scala:576)
at scala.collection.IterableOnceOps.foreach$(IterableOnce.scala:574)
at scala.collection.AbstractIterable.foreach(Iterable.scala:904)
at akka.actor.ActorSystemImpl.loadExtensions$1(ActorSystem.scala:1180)
at akka.actor.ActorSystemImpl.loadExtensions(ActorSystem.scala:1196)
at akka.actor.ActorSystemImpl.liftedTree2$1(ActorSystem.scala:1041)
at akka.actor.ActorSystemImpl._start$lzycompute(ActorSystem.scala:1029)
at akka.actor.ActorSystemImpl._start(ActorSystem.scala:1029)
at akka.actor.ActorSystemImpl.start(ActorSystem.scala:1051)
at akka.actor.ActorSystem$.apply(ActorSystem.scala:282)
at akka.actor.ActorSystem$.apply(ActorSystem.scala:326)
at akka.actor.ActorSystem$.apply(ActorSystem.scala:300)
at akka.actor.ActorSystem$.create(ActorSystem.scala:223)
at akka.actor.ActorSystem.create(ActorSystem.scala)
at main.Application.lambda$0(Application.java:51)
at java.base/java.util.Arrays$ArrayList.forEach(Arrays.java:4203)
at main.Application.startupClusterNodes(Application.java:50)
at main.Application.main(Application.java:31)
17:29:46.372 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.actor.CoordinatedShutdown - Performing phase [service-unbind] with [0] tasks
17:29:46.372 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.actor.CoordinatedShutdown - Performing phase [service-requests-done] with [0] tasks
17:29:46.373 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.actor.CoordinatedShutdown - Performing phase [service-stop] with [0] tasks
17:29:46.373 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.actor.CoordinatedShutdown - Performing phase [before-cluster-shutdown] with [0] tasks
17:29:46.373 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.actor.CoordinatedShutdown - Performing phase [cluster-sharding-shutdown-region] with [0] tasks
17:29:46.373 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.actor.CoordinatedShutdown - Performing phase [cluster-leave] with [1] tasks.
17:29:46.374 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.actor.CoordinatedShutdown - Performing task [leave] in CoordinatedShutdown phase [cluster-leave]
17:29:46.374 [cluster-akka.actor.default-dispatcher-5] ERROR akka.remote.artery.Encoder - Failed to serialize message [akka.remote.artery.OutboundHandshake$HandshakeReq].
java.lang.classNotFoundException: cluster.FstSerializer
at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:606)
at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:168)
at java.base/java.lang.classLoader.loadClass(ClassLoader.java:522)
at java.base/java.lang.class.forName0(Native Method)
at java.base/java.lang.class.forName(Class.java:468)
at akka.actor.ReflectiveDynamicAccess.$anonfun$getClassFor$1(ReflectiveDynamicAccess.scala:29)
at scala.util.Try$.apply(Try.scala:212)
at akka.actor.ReflectiveDynamicAccess.getClassFor(ReflectiveDynamicAccess.scala:28)
at akka.actor.ReflectiveDynamicAccess.createInstanceFor(ReflectiveDynamicAccess.scala:47)
at akka.serialization.Serialization.serializerOf(Serialization.scala:390)
at akka.serialization.Serialization.$anonfun$serializers$2(Serialization.scala:424)
at scala.collection.Iterator$$anon$9.next(Iterator.scala:554)
at scala.collection.immutable.HashMapBuilder.addAll(HashMap.scala:2299)
at scala.collection.immutable.HashMap$.from(HashMap.scala:2123)
at scala.collection.immutable.HashMap$.from(HashMap.scala:2099)
at scala.collection.MapOps$WithFilter.map(Map.scala:351)
at akka.serialization.Serialization.<init>(Serialization.scala:424)
at akka.serialization.SerializationExtension$.createExtension(SerializationExtension.scala:16)
at akka.serialization.SerializationExtension$.createExtension(SerializationExtension.scala:13)
at akka.actor.ActorSystemImpl.registerExtension(ActorSystem.scala:1146)
at akka.actor.ActorSystemImpl.$anonfun$loadExtensions$1(ActorSystem.scala:1184)
at scala.collection.IterableOnceOps.foreach(IterableOnce.scala:576)
at scala.collection.IterableOnceOps.foreach$(IterableOnce.scala:574)
at scala.collection.AbstractIterable.foreach(Iterable.scala:904)
at akka.actor.ActorSystemImpl.loadExtensions$1(ActorSystem.scala:1180)
at akka.actor.ActorSystemImpl.loadExtensions(ActorSystem.scala:1196)
at akka.actor.ActorSystemImpl.liftedTree2$1(ActorSystem.scala:1041)
at akka.actor.ActorSystemImpl._start$lzycompute(ActorSystem.scala:1029)
at akka.actor.ActorSystemImpl._start(ActorSystem.scala:1029)
at akka.actor.ActorSystemImpl.start(ActorSystem.scala:1051)
at akka.actor.ActorSystem$.apply(ActorSystem.scala:282)
at akka.actor.ActorSystem$.apply(ActorSystem.scala:326)
at akka.actor.ActorSystem$.apply(ActorSystem.scala:300)
at akka.actor.ActorSystem$.create(ActorSystem.scala:223)
at akka.actor.ActorSystem.create(ActorSystem.scala)
at main.Application.lambda$0(Application.java:51)
at java.base/java.util.Arrays$ArrayList.forEach(Arrays.java:4203)
at main.Application.startupClusterNodes(Application.java:50)
at main.Application.main(Application.java:31)
17:29:46.380 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.actor.CoordinatedShutdown - Performing phase [cluster-exiting] with [1] tasks.
17:29:46.381 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.actor.CoordinatedShutdown - Performing task [wait-exiting] in CoordinatedShutdown phase [cluster-exiting]
17:29:46.381 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.actor.CoordinatedShutdown - Performing phase [cluster-exiting-done] with [1] tasks.
17:29:46.381 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.actor.CoordinatedShutdown - Performing task [exiting-completed] in CoordinatedShutdown phase [cluster-exiting-done]
17:29:46.381 [cluster-akka.actor.default-dispatcher-11] INFO akka.cluster.Cluster - Cluster Node [akka://cluster@127.0.0.1:2551] - Exiting completed
17:29:46.387 [cluster-akka.actor.default-dispatcher-11] INFO akka.cluster.Cluster - Cluster Node [akka://cluster@127.0.0.1:2551] - Shutting down...
17:29:46.388 [cluster-akka.actor.default-dispatcher-11] INFO akka.cluster.Cluster - Cluster Node [akka://cluster@127.0.0.1:2551] - Successfully shut down
17:29:46.390 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.actor.CoordinatedShutdown - Performing phase [cluster-shutdown] with [1] tasks.
17:29:46.394 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.actor.CoordinatedShutdown - Performing task [wait-shutdown] in CoordinatedShutdown phase [cluster-shutdown]
17:29:46.406 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.actor.CoordinatedShutdown - Performing phase [before-actor-system-terminate] with [0] tasks
17:29:46.407 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.actor.CoordinatedShutdown - Performing phase [actor-system-terminate] with [1] tasks.
17:29:46.408 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.actor.CoordinatedShutdown - Performing task [terminate-system] in CoordinatedShutdown phase [actor-system-terminate]
17:29:46.412 [cluster-akka.actor.default-dispatcher-11] INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
17:29:46.414 [cluster-akka.actor.default-dispatcher-11] INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
17:29:46.418 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.remote.artery.tcp.ArteryTcpTransport - Shutting down [akka://cluster@127.0.0.1:2551#4291962385969910618]
17:29:46.447 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.stream.Materializer - [outbound connection to [akka://cluster@127.0.0.1:2552],control stream] Upstream finished.
17:29:46.450 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.stream.Materializer - [outbound connection to [akka://cluster@127.0.0.1:2552],message stream] Upstream finished.
17:29:46.472 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.io.TcpListener - Unbinding endpoint /127.0.0.1:2551
17:29:46.476 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.io.TcpListener - Unbound endpoint /127.0.0.1:2551,stopping listener
17:29:46.492 [cluster-akka.actor.default-dispatcher-11] INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[DEBUG] [07/27/2021 17:29:46.495] [cluster-akka.actor.internal-dispatcher-2] [EventStream] shutting down: StandardOutLogger
17:29:46.496 [cluster-akka.actor.default-dispatcher-11] DEBUG akka.event.EventStream - shutting down: StandardOutLogger
[DEBUG] [07/27/2021 17:29:46.499] [cluster-akka.actor.internal-dispatcher-2] [EventStream] all default loggers stopped
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）