错误获取线程“ main”中的Akka流代码异常java.lang.NoClassDefFoundError:scala / Function1 $ class

莫哈末 中学:

我在运行akka流代码时遇到以下Java错误:**线程“ main”中的异常java.lang.NoClassDefFoundError:akka.stream.Supervision $$ anon $ 1中的scala / Function1 $ class。(Supervision.scala :57)在akka.stream.Supervision $。(Supervision.scala:57)在akka.stream.Supervision $。(Supervision.scala)在akka.stream.ActorMaterializerSettings $ .apply(ActorMaterializer.scala:268)在akka。流.ActorMaterializerSettings $ .apply(ActorMaterializer.scala:258)在akka.stream.act.Materializer $$ anonfun $ 1.apply(ActorMaterializer.scala:42)在akka.stream.ActorMaterializer $$ anonfun $ 1.apply(ActorMaterializerscal。 )在akka.stream.actorMaterializer $ .apply(在akka.stream.ActorMaterializer $ .create(ActorMaterializer.scala:111)在scak.Option.getOrElse(Option.scala:121)在akka.stream演员材质化器。在com.accenture.akka.stream.Sample1.main(Sample1.java:15)处创建(ActorMaterializer.scala)原因:java.lang.ClassNotFoundException:scala.Function1 $ class在java.net.URLClassLoader.findClass(URLClassLoader。 java:381)at java.lang.ClassLoader.loadClass(ClassLoader.java:424)at sun.misc.Launcher $ AppClassLoader.loadClass(Launcher.java:349)at java.lang.ClassLoader.loadClass(ClassLoader.java:357) )...另外12个** Java代码:

import java.io.IOException;
import java.util.Arrays;

import akka.NotUsed;
import akka.actor.ActorSystem;
import akka.stream.ActorMaterializer;
import akka.stream.javadsl.Source;
public class Sample1 {
  public static void main(String[] args) throws IOException {
    final ActorSystem system = ActorSystem.create("Sys");
    final ActorMaterializer materializer = ActorMaterializer.create(system);

    final String text =
      "Lorem Ipsum is simply dummy text of the printing and typesetting industry. " +
      "Lorem Ipsum has been the industry's standard dummy text ever since the 1500s, " +
      "when an unknown printer took a galley of type and scrambled it to make a type " +
      "specimen book.";

    Source.from(Arrays.asList(text.split("\\s"))).
      // transform
      map(e -> e.toUpperCase()).
      // print to console
      runForeach(System.out::println, materializer).
      handle((done, failure) -> {
        system.terminate();
        return NotUsed.getInstance();
      });
  }

}

Maven代码:

<project xmlns="http://maven.apache.org/POM/4.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.accenture.akka</groupId>
    <artifactId>AkkaDemo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <build>
        <sourceDirectory>src</sourceDirectory>
        <plugins>
            <plugin>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.8.0</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>
    <dependencies>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <scope>test</scope>
        </dependency>


        <!-- akka dependency -->
        <dependency>
            <groupId>com.typesafe.akka</groupId>
            <artifactId>akka-actor_2.12</artifactId>
            <version>2.5.11</version>
        </dependency>
        <dependency>
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka_2.11</artifactId>
            <version>1.1.0</version>
        </dependency>
        <dependency>
            <groupId>com.typesafe.akka</groupId>
            <artifactId>akka-stream_2.11</artifactId>
            <version>2.5.2</version>
        </dependency>
        <dependency>
            <groupId>com.typesafe.akka</groupId>
            <artifactId>akka-stream-testkit_2.11</artifactId>
            <version>2.5.2</version>
        </dependency>
        <dependency>
            <groupId>org.scala-lang</groupId>
            <artifactId>scala-library</artifactId>
            <version>2.12.0</version>
        </dependency>
    </dependencies>
</project>

请告诉我们我在做什么错

蒂姆·摩尔(Tim Moore):

您的依赖项混合了为不同的Scala版本编译的库。通常,Scala不保证次要版本之间的二进制兼容性,这就是依赖项包含工件ID _2.11包含_2.12在工件ID中的原因。您需要选择一个并持续使用它。在这种情况下,由于要包含scala-library版本2.12.0,因此应使用以结尾的工件_2.12同样重要的是不要混合使用不同版本的Akka库,因此对于所有Akka依赖项都应使用2.5.11。我也建议将akka-stream-testkit依赖项分配给test作用域,如junit这是一个更正的示例:

    <dependency>
        <groupId>com.typesafe.akka</groupId>
        <artifactId>akka-actor_2.12</artifactId>
        <version>2.5.11</version>
    </dependency>
    <dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka_2.12</artifactId>
        <version>1.1.0</version>
    </dependency>
    <dependency>
        <groupId>com.typesafe.akka</groupId>
        <artifactId>akka-stream_2.12</artifactId>
        <version>2.5.11</version>
    </dependency>
    <dependency>
        <groupId>com.typesafe.akka</groupId>
        <artifactId>akka-stream-testkit_2.12</artifactId>
        <version>2.5.11</version>
        <scope>test</scope>
    </dependency>

请注意,scala-libary无需更改其他依赖关系就可以安全地更新的补丁程序版本当前,Scala 2.12的最新版本是2.12.11。使用最新版本将确保您具有所有错误修复:

    <dependency>
        <groupId>org.scala-lang</groupId>
        <artifactId>scala-library</artifactId>
        <version>2.12.11</version>
    </dependency>

同样,Akka 2.5的最新版本是2.5.31。我建议您使用它而不是2.5.11。

我还建议定义Maven属性akka.version并将其scala.binary.version作为Maven属性,以使您可以轻松地在一处更改它们。

将所有建议汇总在一起:

<project xmlns="http://maven.apache.org/POM/4.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.accenture.akka</groupId>
    <artifactId>AkkaDemo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <build>
        <sourceDirectory>src</sourceDirectory>
        <plugins>
            <plugin>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.8.0</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>
    <dependencies>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <scope>test</scope>
        </dependency>


        <!-- akka dependency -->
        <dependency>
            <groupId>com.typesafe.akka</groupId>
            <artifactId>akka-actor_${scala.binary.version}</artifactId>
            <version>${akka.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka_${scala.binary.version}</artifactId>
            <version>1.1.0</version>
        </dependency>
        <dependency>
            <groupId>com.typesafe.akka</groupId>
            <artifactId>akka-stream_${scala.binary.version}</artifactId>
            <version>${akka.version}</version>
        </dependency>
        <dependency>
            <groupId>com.typesafe.akka</groupId>
            <artifactId>akka-stream-testkit_${scala.binary.version}</artifactId>
            <version>${akka.version}</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.scala-lang</groupId>
            <artifactId>scala-library</artifactId>
            <version>2.12.11</version>
        </dependency>
    </dependencies>
    <properties>
        <akka.version>2.5.31</akka.version>
        <scala.binary.version>2.12</scala.binary.version>
    </properties>
</project>

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

线程“main”中的异常 java.lang.NoClassDefFoundError: scala/collection/mutable/SynchronizedBuffer$class

当我在ScalaIDE中运行代码时,为什么会出现`java.lang.NoClassDefFoundError:scala / Function1`?

错误yarn.ApplicationMaster:用户类引发异常:java.lang.NoClassDefFoundError:scala / Function0 $ class

java.lang.NoClassDefFoundError:scala / Product $ class

java错误:线程“ main”中的异常java.lang.NoClassDefFoundError

线程“主”中的异常java.lang.NoClassDefFoundError:scala / Cloneable

蜂巢错误:线程“主”中的异常java.lang.NoClassDefFoundError:scala / collection / Iterable

在Scala中扩展Function1

线程“主”中的异常java.lang.NoClassDefFoundError:Main $ 1 Java?

Scala Akka Microkernel中的线程“ main”中的异常java.lang.InstantiationException

testng中的线程“ main”中的异常java.lang.NoClassDefFoundError

为什么线程“ main”中的异常java.lang.NoClassDefFoundError :?

线程“main”中的异常 - java.lang.NoClassDefFoundError

线程“main”中的 NetBeans 异常 java.lang.NoClassDefFoundError

如何修复此Scala jar错误“线程“主”中的异常java.lang.NoClassDefFoundError:org / apache / spark / sql / types / DataType”

Spring Boot jar 启动错误:线程“main”中的异常 java.lang.NoClassDefFoundError

线程“ main”中的异常java.lang.NoClassDefFoundError:错误的名称-命令提示符

线程“main”中的异常java.lang.NoClassDefFoundError:解决方案(错误名称:解决方案)

从scala repl查看<function1>中的内容

获取错误“线程“主”中的异常java.lang.ExceptionInInitializerError”

我需要此错误的帮助:线程“ main”中的异常java.lang.NoClassDefFoundError:org / apache / commons / csv / CSVFormat

实例化休眠配置会引发错误:线程“main”中的异常 java.lang.NoClassDefFoundError: javax/xml/bind/JAXBException

java-线程“ main”中的异常java.lang.NoClassDefFoundError:io / kubernetes / client / openapi / ApiException

Cucumber - Java - 线程“main”中的异常 java.lang.NoClassDefFoundError: io/cucumber/plugin/ConcurrentEventListener

ssj-2.5.jar库中的线程“ main”中的异常java.lang.NoClassDefFoundError

Scala Flink在将案例类用于自定义的DeserializationSchema后获得java.lang.NoClassDefFoundError:scala / Product $ class

用蚂蚁构建jar:线程“ main”中的异常java.lang.NoClassDefFoundError

线程“main”中的异常 java.lang.NoClassDefFoundError: com/google/gson/JsonParseExceptiong

线程“main”中的 Gradle 异常 java.lang.NoClassDefFoundError: org/slf4j/LoggerFactory