java.lang.NoClassDefFoundError: scala/Predef$any2stringadd$

java.lang.NoClassDefFoundError: scala/Predef$any2stringadd$

我正在使用 Java 的 Akka 分布式发布订阅,遵循文档this examples

但是每当我 运行 我的代码时,我都会得到一个 java.lang.NoClassDefFoundError: scala/Predef$any2stringadd$

它似乎无法归档 scala 库,但我可以在依赖项选项卡上看到 scala 库。我也为两个 Akka 依赖项使用相同的版本。

我对 pom.xml 的依赖:

<dependencies>
    <dependency>
        <groupId>org.twitter4j</groupId>
        <artifactId>twitter4j-core</artifactId>
        <version>[4.0,)</version>
    </dependency>
    <dependency>
        <groupId>org.twitter4j</groupId>
        <artifactId>twitter4j-stream</artifactId>
        <version>[4.0,)</version>
    </dependency>
    <dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka_2.10</artifactId>
        <version>0.8.2.2</version>
    </dependency>
    <dependency>
        <groupId>org.apache.zookeeper</groupId>
        <artifactId>zookeeper</artifactId>
        <version>3.4.6</version>
    </dependency>
    <dependency>
        <groupId>org.apache.storm</groupId>
        <artifactId>storm-core</artifactId>
        <version>0.10.0</version>
    </dependency>
    <dependency>
        <groupId>org.apache.storm</groupId>
        <artifactId>storm-kafka</artifactId>
        <version>0.10.0</version>
    </dependency>
    <dependency>
        <groupId>com.fasterxml.jackson.core</groupId>
        <artifactId>jackson-databind</artifactId>
        <version>2.6.4</version>
    </dependency>
    <dependency>
        <groupId>com.typesafe.akka</groupId>
        <artifactId>akka-actor_2.11</artifactId>
        <version>2.4.1</version>
    </dependency>
    <dependency>
        <groupId>com.typesafe.akka</groupId>
        <artifactId>akka-cluster-tools_2.11</artifactId>
        <version>2.4.1</version>
    </dependency>
</dependencies>

IntelliJ 显示:

这是导致异常的代码:

ActorSystem actorSystem = ActorSystemManager.INSTANCE.getActorSystem();
ActorRef actorSubscriber = actorSystem.actorOf(Props.create(TwitterSubscriber.class));

其中 ActorSystemManager 是传递给 actor 系统的单例。

public enum ActorSystemManager {
    INSTANCE;

    private final ActorSystem actorSystem;

    private ActorSystemManager() {
        actorSystem = ActorSystem.create("localized_tweets");
    }

    public ActorSystem getActorSystem() {
        return actorSystem;
    }
}

这里是完整的堆栈跟踪:

Connected to the target VM, address: '127.0.0.1:51608', transport: 'socket'
Exception in thread "main" java.lang.NoClassDefFoundError: scala/Predef$any2stringadd$
    at akka.actor.RootActorPath.<init>(ActorPath.scala:273)
    at akka.event.Logging$StandardOutLogger.<init>(Logging.scala:800)
    at akka.event.Logging$.<init>(Logging.scala:821)
    at akka.event.Logging$.<clinit>(Logging.scala)
    at akka.event.LoggingBus$class.setUpStdoutLogger(Logging.scala:74)
    at akka.event.LoggingBus$class.startStdoutLogger(Logging.scala:90)
    at akka.event.EventStream.startStdoutLogger(EventStream.scala:28)
    at akka.actor.ActorSystemImpl.<init>(ActorSystem.scala:613)
    at akka.actor.ActorSystem$.apply(ActorSystem.scala:143)
    at akka.actor.ActorSystem$.apply(ActorSystem.scala:110)
    at akka.actor.ActorSystem$.create(ActorSystem.scala:58)
    at akka.actor.ActorSystem.create(ActorSystem.scala)
    at com.dazito.twitter.akka.ActorSystemManager.<init>(ActorSystemManager.java:16)
    at com.dazito.twitter.akka.ActorSystemManager.<clinit>(ActorSystemManager.java:11)
    at com.dazito.twitter.Main.main(Main.java:36)
Caused by: java.lang.ClassNotFoundException: scala.Predef$any2stringadd$
    at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
    ... 15 more
Disconnected from the target VM, address: '127.0.0.1:51608', transport: 'socket'

关于如何解决此异常的任何帮助?

将您的 Scala 库更新到 2.11 版本。

您的依赖项存在冲突:kafka_2.10 需要 Scala 2.10,而 akka-actor_2.11 需要 Scala 2.11,并且这些库不是二进制兼容的。请改用 kafka_2.11。 (虽然你已经接受了另一个答案,但如果你不改变Kafka依赖,你可以运行进入更多类似的问题。)

Maven 帮不了你,因为它不知道库的 Scala 版本后缀约定,也没有特殊对待 scala-library。所以它无法注意到冲突。如果您有 Scala 依赖项,您可能甚至想对 Java 个项目使用 SBT;或使用

<properties><scala.version>2.11</scala.version></properties>
...
kafka_${scala.version}
...
akka-actor_${scala.version}