动态从 Drool 引擎读取 .xlsx 文件，无需重新启动 spring 项目

Question

我正在尝试使用 drool 读取我的 excel 文件 我能够成功地从 s3 读取该文件，但是当我对该文件进行更改并用新文件替换现有文件时出现问题 我的规则引擎仍然读取旧文件值 谁能告诉我可以采取什么措施来解决此问题

Dto

package com.example.demo;
import lombok.Getter;
import lombok.Setter;
import lombok.ToString;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.stereotype.Component;

@Getter
@Setter
@ToString
@Component
@RefreshScope
public class DataDTO {
    String firstName;
    String lastName;
}

Drool 配置

   package com.example.demo.Config;
 import lombok.extern.slf4j.Slf4j;
 import org.drools.decisiontable.DecisionTableProviderImpl;
 import org.kie.api.KieServices;
 import org.kie.api.builder.*;
 import org.kie.api.io.Resource;
 import org.kie.api.runtime.KieContainer;
 import org.kie.api.runtime.KieSession;
 import org.kie.internal.io.ResourceFactory;
 import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;

 import java.io.IOException;

 @Configuration
 @Slf4j
 @RefreshScope
 public class DroolConfig {

     private KieServices kieServices = KieServices.Factory.get();

     public KieFileSystem getKieFileSystem() throws IOException {
         KieFileSystem kieFileSystem = kieServices.newKieFileSystem();
         Resource resource;
         log.info("File read form local resource folder");
         resource = ResourceFactory
             .newUrlResource("awsurl/123.xlsx");
         kieFileSystem.write(resource);
         DecisionTableProviderImpl decisionTableProvider
             = new DecisionTableProviderImpl();
         String leadBox = decisionTableProvider.loadFromResource(resource, null);
         log.info("Rules Loaded from LeadBoxFile:{}", leadBox);
         return kieFileSystem;
     }

     @Bean
     @RefreshScope
     public KieContainer getKieContainer() throws IOException {
         getKieRepository();
         KieBuilder abc = kieServices.newKieBuilder(getKieFileSystem());
         abc.buildAll();
         KieModule kieModule = abc.getKieModule();
         KieContainer kContainer = kieServices.newKieContainer(kieModule.getReleaseId());
         return kContainer;
     }

     private void getKieRepository() {
         final KieRepository kieRepository = kieServices.getRepository();
         kieRepository.addKieModule(new KieModule() {
             public ReleaseId getReleaseId() {
                 return kieRepository.getDefaultReleaseId();
             }
         });
     }

     @Bean
     public KieSession getKieSession() throws IOException {
         return getKieContainer().newKieSession();
     }
 }

控制器

package com.example.demo;

import com.example.demo.Config.DroolConfig;
import org.kie.api.runtime.KieContainer;
import org.kie.api.runtime.KieSession;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.io.IOException;

@RestController
@RequestMapping("/v2")
public class LoadData {
    @Autowired
    private KieSession kieSession;

    @Autowired
    private final KieContainer kieContainer;

    @Autowired
    DroolConfig droolConfig;

    public LoadData(KieSession kieSession, KieContainer kieContainer) {
        this.kieSession = kieSession;
        this.kieContainer = kieContainer;
    }

    @PostMapping("/printData")
    public String printData(@RequestBody DataDTO dataDTO) throws IOException {
        KieSession kieSession = kieContainer.newKieSession();
        kieSession.insert(dataDTO);
        kieSession.fireAllRules();
        kieSession.dispose();
        return dataDTO.getLastName();
    }

    @GetMapping("/loadDroolFile")
    public String getDroolData() throws IOException {
        droolConfig.getKieFileSystem();
        kieContainer.getKieSessionConfiguration();
        return "Done";
    }
}

每当我尝试点击 loadDroolFile 时，我都能够获取刷新的数据，但数据不会被注入，我仍然使用旧值从 drool 引擎获得结果