如何让 Drools 访问动态加载的 类?
How do I give Drools access to dynamically loaded classes?
我正在尝试使用 ClassLoader 在运行时从 .class 文件加载 classes,并在 Drools 规则 (Drools 7.52.0) 中使用它们。我正在使用这个自定义 ClassLoader,它从文件中读取并使用 ClassLoader.defineClass()
加载 class。它类似于 URLClassLoader:
package example;
import java.io.BufferedInputStream;
import java.io.ByteArrayOutputStream;
import java.io.FileInputStream;
import java.io.IOException;
public class DynamicClassLoader extends ClassLoader {
public DynamicClassLoader(ClassLoader parent) {
super(parent);
}
/**
* Define a class from a .class file and return it
* @param filepath path to a .class file
* @return new Class or null if error
*/
public Class<?> classFromFile(String filepath) {
try {
// Read .class file and write bytes to buffer
BufferedInputStream input = new BufferedInputStream(new FileInputStream(filepath));
// Write file contents to buffer
ByteArrayOutputStream buffer = new ByteArrayOutputStream();
int data = input.read();
while(data != -1){
buffer.write(data);
data = input.read();
}
byte[] classData = buffer.toByteArray(); // contents of .class file
input.close();
return defineClass(null, classData, 0, classData.length);
} catch (IOException | ClassFormatError e) {
e.printStackTrace();
}
return null;
}
}
我可以使用 ClassLoader 加载一个 class,构造一个实例,并访问它的方法。但是,即使我通过方法 KieServices.newKieBuilder
和 KieServices.newKieContainer
将 ClassLoader 传递给 Drools,Drools 也无法编译规则。这是我的 Main.java:
package example;
import java.io.IOException;
import org.kie.api.builder.model.KieBaseModel;
import org.kie.api.builder.model.KieModuleModel;
import org.kie.api.runtime.KieSession;
import org.kie.api.KieServices;
import org.kie.api.builder.KieBuilder;
import org.kie.api.builder.KieFileSystem;
import org.kie.api.builder.Message;
public class Main {
private static KieServices kServices = KieServices.Factory.get();
private static KieFileSystem kFileSys;
private static KieSession kSession;
private static DynamicClassLoader classLoader = new DynamicClassLoader(Main.class.getClassLoader());
public static void main(String[] args) throws IOException, ClassNotFoundException {
// Load Person class
classLoader.classFromFile("Person.class");
// Instantiate Person
Class<?> personClass = classLoader.loadClass("facts.Person");
Object person = null;
try {
// Instantiate person and access methods using reflection
person = personClass.getConstructor(String.class, Integer.class).newInstance("Alice", 49);
System.out.println(person.getClass() + ": name = " +
(String) personClass.getMethod("getName").invoke(person));
} catch (Exception e) {
System.out.println("Error instantiating person");
e.printStackTrace();
}
// Create a KieSession with a rule that uses the Person class
String drl = String.join("\n",
"import facts.Person;",
"rule \"person\"",
" when",
" $p : Person()",
" then",
" System.out.println($p.getName());",
"end"
);
initializeKieSession(drl);
kSession.insert(person);
kSession.fireAllRules();
}
/**
* Create a KieSession using the given ruleset
* @param drl a ruleset string in Drools Rule Language
*/
private static void initializeKieSession(String drl) {
// Create module model
KieModuleModel kModMod = kServices.newKieModuleModel();
KieBaseModel kBaseMod = kModMod.newKieBaseModel("KBase_std").setDefault(true);
kBaseMod.newKieSessionModel("KSession_std").setDefault(true);
// Create file system with module model
kFileSys = kServices.newKieFileSystem();
kFileSys.writeKModuleXML(kModMod.toXML());
// Write rules
kFileSys.write("src/main/resources/person.drl", drl);
KieBuilder kBuilder = kServices.newKieBuilder(kFileSys, classLoader).buildAll();
boolean errors = kBuilder.getResults().hasMessages(Message.Level.ERROR);
if (errors) {
for (Message message : kBuilder.getResults().getMessages())
System.out.println(message.getText());
}
// new KieSession
kSession = kServices.newKieContainer(
kServices.getRepository().getDefaultReleaseId(), classLoader).getKieBase().newKieSession();
}
}
编译此规则(使用KieBuilder.buildAll()
)给出错误
Rule Compilation error Only a type can be imported. facts.Person resolves to a package. facts.Person cannot be resolved to a type.
如果我不将 ClassLoader 传递给 KieBuilder,我会收到两个额外的错误:
Unable to resolve ObjectType 'Person'. $p cannot be resolved.
所以我的 ClassLoader 正在做一些事情,但没有让 Drools 完全访问它已加载的任何 classes。我怎样才能解决这个问题?我花了几天时间解决这个问题,但找不到任何帮助。
看起来任何加载的 class 文件的内容也需要在编译之前写入 KieFileSystem。
因此,要让 Drools 完全访问 class,需要以下内容:
ClassLoader classLoader;
// Use classLoader to load external classes
...
// Copy class definitions to the KieFileSystem
for (/*each loaded class*/) {
String filename = packageName + '/' + className + ".class";
kFileSys.write(filename, byteArrayOfClassFileContents);
}
// Pass classLoader to both newKieBuilder and newKieContainer
KieServices kServices = KieServices.Factory.get();
KieBuilder kBuilder = kServices.newKieBuilder(kFileSys, classLoader).buildAll();
KieContainer kContainer = kServices.newKieContainer(
kServices.getRepository().getDefaultReleaseId(), classLoader);
请注意,将 class 文件写入 KieFileSystem 根目录下的包内非常重要。例如,class foo.bar.Baz
的定义应该写成 "foo/bar/Baz.class"
我正在尝试使用 ClassLoader 在运行时从 .class 文件加载 classes,并在 Drools 规则 (Drools 7.52.0) 中使用它们。我正在使用这个自定义 ClassLoader,它从文件中读取并使用 ClassLoader.defineClass()
加载 class。它类似于 URLClassLoader:
package example;
import java.io.BufferedInputStream;
import java.io.ByteArrayOutputStream;
import java.io.FileInputStream;
import java.io.IOException;
public class DynamicClassLoader extends ClassLoader {
public DynamicClassLoader(ClassLoader parent) {
super(parent);
}
/**
* Define a class from a .class file and return it
* @param filepath path to a .class file
* @return new Class or null if error
*/
public Class<?> classFromFile(String filepath) {
try {
// Read .class file and write bytes to buffer
BufferedInputStream input = new BufferedInputStream(new FileInputStream(filepath));
// Write file contents to buffer
ByteArrayOutputStream buffer = new ByteArrayOutputStream();
int data = input.read();
while(data != -1){
buffer.write(data);
data = input.read();
}
byte[] classData = buffer.toByteArray(); // contents of .class file
input.close();
return defineClass(null, classData, 0, classData.length);
} catch (IOException | ClassFormatError e) {
e.printStackTrace();
}
return null;
}
}
我可以使用 ClassLoader 加载一个 class,构造一个实例,并访问它的方法。但是,即使我通过方法 KieServices.newKieBuilder
和 KieServices.newKieContainer
将 ClassLoader 传递给 Drools,Drools 也无法编译规则。这是我的 Main.java:
package example;
import java.io.IOException;
import org.kie.api.builder.model.KieBaseModel;
import org.kie.api.builder.model.KieModuleModel;
import org.kie.api.runtime.KieSession;
import org.kie.api.KieServices;
import org.kie.api.builder.KieBuilder;
import org.kie.api.builder.KieFileSystem;
import org.kie.api.builder.Message;
public class Main {
private static KieServices kServices = KieServices.Factory.get();
private static KieFileSystem kFileSys;
private static KieSession kSession;
private static DynamicClassLoader classLoader = new DynamicClassLoader(Main.class.getClassLoader());
public static void main(String[] args) throws IOException, ClassNotFoundException {
// Load Person class
classLoader.classFromFile("Person.class");
// Instantiate Person
Class<?> personClass = classLoader.loadClass("facts.Person");
Object person = null;
try {
// Instantiate person and access methods using reflection
person = personClass.getConstructor(String.class, Integer.class).newInstance("Alice", 49);
System.out.println(person.getClass() + ": name = " +
(String) personClass.getMethod("getName").invoke(person));
} catch (Exception e) {
System.out.println("Error instantiating person");
e.printStackTrace();
}
// Create a KieSession with a rule that uses the Person class
String drl = String.join("\n",
"import facts.Person;",
"rule \"person\"",
" when",
" $p : Person()",
" then",
" System.out.println($p.getName());",
"end"
);
initializeKieSession(drl);
kSession.insert(person);
kSession.fireAllRules();
}
/**
* Create a KieSession using the given ruleset
* @param drl a ruleset string in Drools Rule Language
*/
private static void initializeKieSession(String drl) {
// Create module model
KieModuleModel kModMod = kServices.newKieModuleModel();
KieBaseModel kBaseMod = kModMod.newKieBaseModel("KBase_std").setDefault(true);
kBaseMod.newKieSessionModel("KSession_std").setDefault(true);
// Create file system with module model
kFileSys = kServices.newKieFileSystem();
kFileSys.writeKModuleXML(kModMod.toXML());
// Write rules
kFileSys.write("src/main/resources/person.drl", drl);
KieBuilder kBuilder = kServices.newKieBuilder(kFileSys, classLoader).buildAll();
boolean errors = kBuilder.getResults().hasMessages(Message.Level.ERROR);
if (errors) {
for (Message message : kBuilder.getResults().getMessages())
System.out.println(message.getText());
}
// new KieSession
kSession = kServices.newKieContainer(
kServices.getRepository().getDefaultReleaseId(), classLoader).getKieBase().newKieSession();
}
}
编译此规则(使用KieBuilder.buildAll()
)给出错误
Rule Compilation error Only a type can be imported. facts.Person resolves to a package. facts.Person cannot be resolved to a type.
如果我不将 ClassLoader 传递给 KieBuilder,我会收到两个额外的错误:
Unable to resolve ObjectType 'Person'. $p cannot be resolved.
所以我的 ClassLoader 正在做一些事情,但没有让 Drools 完全访问它已加载的任何 classes。我怎样才能解决这个问题?我花了几天时间解决这个问题,但找不到任何帮助。
看起来任何加载的 class 文件的内容也需要在编译之前写入 KieFileSystem。
因此,要让 Drools 完全访问 class,需要以下内容:
ClassLoader classLoader;
// Use classLoader to load external classes
...
// Copy class definitions to the KieFileSystem
for (/*each loaded class*/) {
String filename = packageName + '/' + className + ".class";
kFileSys.write(filename, byteArrayOfClassFileContents);
}
// Pass classLoader to both newKieBuilder and newKieContainer
KieServices kServices = KieServices.Factory.get();
KieBuilder kBuilder = kServices.newKieBuilder(kFileSys, classLoader).buildAll();
KieContainer kContainer = kServices.newKieContainer(
kServices.getRepository().getDefaultReleaseId(), classLoader);
请注意,将 class 文件写入 KieFileSystem 根目录下的包内非常重要。例如,class foo.bar.Baz
的定义应该写成 "foo/bar/Baz.class"