我正在 Java 專案中實作 Drools，以下依賴項的第 6 版：
<dependency>
<groupId>org.drools</groupId>
<artifactId>drools-core</artifactId>
<version>6.0.1.Final</version>
</dependency>
<dependency>
<groupId>org.drools</groupId>
<artifactId>drools-compiler</artifactId>
<version>6.0.1.Final</version>
</dependency>
我打算通過呼叫使用 spring 4.3.0.RELEASE 構建的 REST API 來呼叫規則。在我的配置類中，我從資料庫加載 drools 腳本：
@Configuration
@EnableWebMvc
@EnableAsync
@ComponentScan(basePackages = "com.bla.bla.api.app")
@ImportResource({ "classpath:datasources-context.xml" })
public class AppConfig {
private static final Log log = LogFactory.getLog(AppConfig.class);
public @Autowired IServiceDao serviceDao;
然后將規則作為帶@Repository注釋的類中的串列存盤在全域變數中：
@Repository
public class ServiceDao implements IServiceDao
在上面的 ServiceDao 中有一個方法，在 post 構造階段呼叫：
@PostConstruct
private void init() throws IOException {
log.debug("Initializing ruleevaluation API Context");
// Initializing rules:
serviceDao.initializeRules();
}
，從資料庫重新加載規則并初始化 drools 環境：
public void initializeRules() {
// 1. Load Rules:
log.debug("Initiating Rules...");
rules.clear();
rules = loadRules();
// 2. Initialize Drools Environment:
try {
initializeDrools();
} catch (DroolsParserException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
方法 'initializeDrools()' 實作如下：
private void initializeDrools() throws DroolsParserException, IOException {
PackageBuilder packageBuilder = new PackageBuilder();
RuleBase ruleBase = RuleBaseFactory.newRuleBase();
// This script will contain all the rules combined in one Drools script:
String completeRulesDroolsScript = "";
// Initialize script with object imports:
completeRulesDroolsScript = ""
"import com.bla.model.svc.RuleRequest \r\n"
"import com.bla.model.svc.RuleResponse \r\n\n\n";
if (rules != null) {
if (rules.size() > 0) {
for (RuleObject ruleObject : rules) {
// Add each individual Drools rule expression to the complete Drools script:
completeRulesDroolsScript = ruleObject.getExpression();
completeRulesDroolsScript = completeRulesDroolsScript .concat("\n\n\n");
}
}
}
try {
packageBuilder.addPackageFromDrl(new
StringReader(completeRulesDroolsScript));
org.drools.core.rule.Package rulesPackage = packageBuilder.getPackage();
ruleBase.addPackage(rulesPackage);
this.setWorkingMemory(ruleBase.newStatefulSession());
}
catch(Exception e) {
log.error("!!! Could not Initialize Drools Engine !!!");
}
}
接下來是 REST 方法，在一個單獨的控制器類中：
@RestController
public class RuleEvaluationController
它只是從 ServiceDao 類呼叫后端服務：
@PostMapping(value = "/evaluateRule")
public ResponseEntity<RuleEvaluationResponse> evaluateRuleData(
@RequestBody RuleEvaluationRequest ruleEvaluationRequest) {
RuleEvaluationResponse ruleEvaluationResponse = new RuleEvaluationResponse();
try {
// 1. get the parameters list:
log.debug(ruleEvaluationRequest.toString());
RuleEvaluationResponse response = serviceDao
.evaluateRule(ruleEvaluationRequest);
log.debug("response = " response.getEntry());
return new ResponseEntity<RuleEvaluationResponse>(response,
HttpStatus.OK);
} catch (Exception e) {
log.error("!!!!! Exception Occurred:" e.getMessage());
// set request id, and date in millis:
ruleevaluationResponse.setRequestId(UUID.randomUUID().toString());
ruleevaluationResponse.setDate(System.currentTimeMillis());
ruleevaluationResponse.setErrorCode(Constants.FAILURE);
ruleevaluationResponse.setErrorDescription(e.getMessage());
return new ResponseEntity<RuleEvaluationResponse>(ruleevaluationResponse,
HttpStatus.OK);
}
}
其中serviceDao.evaluateRule 只是插入請求和回應物件，然后觸發規則：
public RuleEvaluationResponse evaluateRule(RuleEvaluationRequest request) {
RuleEvaluationResponse response = new RuleEvaluationResponse();
this.getWorkingMemory().insert(response);
this.getWorkingMemory().insert(request);
this.getWorkingMemory().fireAllRules();
log.debug("Response = " response.getEntry());
return response;
}
起初這一切正常，我成功評估了規則并獲得了預期的回應。然而，在 4 或 5 次 REST 呼叫之后，下一次 REST 呼叫將永遠持續下去并且永遠不會回傳回應，并且過了一段時間我會收到記憶體不足錯誤。
誰能告訴我我在這里錯過了什么？任何提示和建議都非常感謝。如果以上資訊不足，請隨時詢問更多詳細資訊。
謝謝
uj5u.com熱心網友回復：
您沒有提供所有代碼，所以也許您在其他地方進行了清理，但看起來您正在插入和呼叫.fireAllRules()而不是清理。我的代碼與 KieSession 一起使用，看起來或多或少是這樣的：
kSession = container.newKieSession("name");
kSession.insert(...);
kSession.insert(...);
kSession.insert(...);
kSession.fireAllRules();
Object[] objects = kSession.getObjects();
kSession.dispose();
您可能需要更改代碼。https://docs.jboss.org/drools/release/6.0.1.Final/drools-docs/html_single/#d0e3555
檔案中描述的有狀態會話需要在第一次fireAllRules()呼叫后洗掉物件。因此，您要么每次創建無狀態會話并處理它，要么使用有狀態會話并在插入新物件之前洗掉舊物件。
我可能會選擇無狀態（因為我已經這樣做了；）
[...]
try {
packageBuilder.addPackageFromDrl(new
StringReader(completeRulesDroolsScript));
org.drools.core.rule.Package rulesPackage =
packageBuilder.getPackage();
ruleBase.addPackage(rulesPackage);
this.setWorkingMemory(ruleBase.newStatefulSession());
}
[...]
我假設所有繁重的作業（決議 DRL 等）都在newStatefulSession()呼叫之前發生，并且創建會話并不“昂貴”。
uj5u.com熱心網友回復：
感謝您提供的提示和建議，它們有助于找到解決方案。
我解決了這個問題如下：
首先，我遷移到版本 6 的新語法。. ，使用 KieSession。
首先我初始化了 Kie 組件，如下所示：
// Define Kie Service from the Drools factory:
KieServices ks = KieServices.Factory.get();
// Define Drools Kie Repository to house the rules:
KieRepository kr = ks.getRepository();
// By default, a Kie File System is defined. In this case rules are NOT being
// read from the *.drl file, but instead fetched from Database.
KieFileSystem kfs = ks.newKieFileSystem();
// Write rules into the Kie file system. Specified file is irrelevant and can be
// empty, since we are not reading from *.drl file.
kfs.write("src/main/resources/com/rule/tempRules.drl", completeAccountingRulesDroolsScript);
// Define rule builder of the rules in file system object:
KieBuilder kb = ks.newKieBuilder(kfs);
// Build all rules in the script.kieModule is automatically deployed to
// KieRepository if successfully built.
kb.buildAll();
// Define new session container. This container is global and will be available
// for all subsequent rule invocations:
kContainer = ks.newKieContainer(kr.getDefaultReleaseId());
在我的 REST 呼叫中，我將代碼替換為以下內容：
kSession = kContainer.newKieSession();
kSession.insert(response);
kSession.insert(request);
kSession.fireAllRules();
Collection<? extends Object> objects = kSession.getObjects();
kSession.dispose();
現在變數 kContainer 是一個僅在啟動時初始化的全域變數。在每次 REST 呼叫結束時，我都會處理會話。以后的呼叫將為每個呼叫創建一個 kie 會話。如果這是最好的方法，可以使用您的輸入。
@user3075118 @ 冷凍豌豆的羅迪
謝謝你的提示，這是解決問題的人。
轉載請註明出處，本文鏈接：https://www.uj5u.com/shujuku/345451.html