ClassNotFoundException使用带有本地类和Debezium引擎的QuarkusClassLoader

Question

ClassLoader classLoader = QuarkusClassLoader.getSystemClassLoader();
String str = "com.mycompany.service.SomeClass";
try {
  Class<? extends SomeClass> someClass =
      (Class<? extends SomeClass>) classLoader.loadClass(str);
} catch (Throwable e) {
  e.printStackTrace();
}

我试图弄清楚为什么我得到了java.lang.ClassNotFoundException当我尝试加载com.mycompany.service.某个类。这个类是在项目中本地定义的，当我启动我的Quarkus应用程序（mvn编译Quarkus： dev）时，我得到了这个错误。如果我使用另一个类加载器（即this.getClass（）. getClassLoader（）），这个错误不会发生。它似乎只发生在QuarkusClassLoader

编辑：我认为问题最终与Debezium引擎初始化有关。调用以下行时引发了该异常：

// Create the engine with this configuration ...
engine =
    DebeziumEngine.create(Json.class)
        .using(props)
        .notifying(this::handleDbChangeEvent)
        .build();

看看我的回答我是怎么解决的

Answer 1

我通过传递线程解决了这个问题。currentThread（）。引擎初始化中的getContextClassLoader（）。

engine =
    DebeziumEngine.create(Json.class)
        // Have to pass the current class loader to avoid ClassNotFoundException
        .using(Thread.currentThread().getContextClassLoader())
        .using(props)
        .notifying(this::handleDbChangeEvent)
        .build();

Answer 2

使用Classloader.getSystemClassLoader当然不是正确的做法，因为在开发模式下（更一般地说，你很少会想在Java代码中这样做），Quarkus dot不是一个扁平的类加载器结构，而是一个分层的结构。

有关开发模式下的类加载如何工作的更多详细信息，请参阅https://quarkus.io/guides/class-loading-reference。

您可以使用以下方法强制jar的所有类由系统类加载器而不是Quarkus类加载器加载：

夸克斯。类加载。父第一工件=stax:stax api

在这里，您基本上配置了应该由系统类加载器加载的jar的groupId和artifactId