向单例KieContainer添加新规则，同时保留现有规则。

huangapple
go评论117阅读模式
英文:

Add new rules to singleton KieContainer by preserving existing rules

问题

配置类：

  1. @Configuration
  2. public class DynamicDroolsConfig {
  4.     private KieServices kieServices;
  6.     @Autowired
  7.     private IPersistentSessionService iPersistentSessionService;
  9.     @PostConstruct
  10.     private void init() {
  11.         this.initDataSource();
  12.         this.kieServices = KieServices.Factory.get();
  13.     }
  15.     @Bean
  16.     public KieSession getPersistentKieSession() {
  17.         List<SessioninfoEntity> sessioninfoEntities = iPersistentSessionService.getStoredSessionDetails();
  19.         if (sessioninfoEntities.size() == 0) {
  20.             return newSession();
  21.         } else if (sessioninfoEntities.size() == 1) {
  22.             return persistedSession(sessioninfoEntities.get(0));
  23.         } else {
  24.             // todo other things
  25.             return null;
  26.         }
  27.     }
  29.     @Bean
  30.     public KieServices getKieServices() {
  31.         return this.kieServices;
  32.     }
  34.     @Bean
  35.     public KieContainer getKieContainer() {
  36.         getFileSystem();
  37.         KieRepository kieRepository = kieServices.getRepository();
  38.         kieRepository.addKieModule(kieRepository::getDefaultReleaseId);
  39.         KieBuilder kb = kieServices.newKieBuilder(getFileSystem()).buildAll();
  40.         KieModule kieModule = kb.getKieModule();
  41.         return kieServices.newKieContainer(kieModule.getReleaseId());
  42.     }
  44.     @Bean
  45.     public KieFileSystem getFileSystem() {
  46.         KieFileSystem kieFileSystem = kieServices.newKieFileSystem();
  47.         return kieFileSystem;
  48.     }
  50.     public Environment getEnv() {
  51.         Environment env = kieServices.newEnvironment();
  52.         env.set(EnvironmentName.ENTITY_MANAGER_FACTORY, Persistence.createEntityManagerFactory("org.drools.persistence.jpa"));
  53.         env.set(EnvironmentName.TRANSACTION_MANAGER, TransactionManagerServices.getTransactionManager());
  54.         return env;
  55.     }
  57.     private void initDataSource() {
  58.         PoolingDataSource ds = new PoolingDataSource();
  59.         ds.setUniqueName("jdbc/BitronixJTADataSource");
  60.         ds.setClassName("com.mysql.cj.jdbc.MysqlXADataSource");
  61.         ds.setMaxPoolSize(3);
  62.         ds.setAllowLocalTransactions(true);
  63.         ds.getDriverProperties().put("user", "root");
  64.         ds.getDriverProperties().put("password", "1234");
  65.         ds.getDriverProperties().put("URL", "jdbc:mysql://localhost:3306/drool_demo");
  66.         ds.init();
  67.     }
  69.     private KieSession newSession() {
  70.         return kieServices.getStoreServices().newKieSession(getKieContainer().getKieBase(), null, getEnv());
  71.     }
  73.     private KieSession persistedSession(SessioninfoEntity sessioninfoEntity) {
  74.         return kieServices.getStoreServices().loadKieSession(sessioninfoEntity.getId(), getKieContainer().getKieBase(), null, getEnv());
  75.     }
  76. }

容器 releaseId 更新方法：

  1. @Service
  2. public class DroolsUtilityImpl implements IDroolsUtility {
  4.     @Autowired
  5.     private KieFileSystem fileSystem;
  6.     @Autowired
  7.     private KieServices services;
  8.     @Autowired
  9.     private KieContainer container;
  11.     @Override
  12.     public void updateContainer(String rules) {
  14.         fileSystem.write("src/main/resources/rules/rule.drl", rules);
  15.         KieBuilder kb = services.newKieBuilder(fileSystem).buildAll();
  16.         KieModule kieModule = kb.getKieModule();
  17.         container.updateToVersion(kieModule.getReleaseId());
  18.     }
  20.     @Override
  21.     public void viewContainerRules() {
  23.         KieBase kieBase = container.getKieBase();
  24.         for (KiePackage kp : kieBase.getKiePackages()) {
  25.             for (Rule rule : kp.getRules()) {
  26.                 System.out.println(rule.getName());
  27.             }
  28.         }
  29.     }
  30. }
英文:

I am trying to add new rules to a singleton KieContainer having session persistence, in a Spring Boot project. I have implemented the programmatic approach for addition of new rules to the KieContainer but the existing rules are getting replaced everytime I update the ReleaseID of the KieContainer. What I want is to preserve the existing rules that is present in the Drools Session and add new rules to that. The updateContainer() function from my utility class is how I am making changes to the KieContainer. Any suggestions mostly welcomed. My implementation is as follows:

Configuration class:

  1. @Configuration
  2. public class DynamicDroolsConfig {
  4.     private KieServices kieServices;
  6.     @Autowired
  7.     private IPersistentSessionService iPersistentSessionService;
  9.     @PostConstruct
  10.     private void init() {
  11.         this.initDataSource();
  12.         this.kieServices = KieServices.Factory.get();
  13.     }
  15.     @Bean
  16.     public KieSession getPersistentKieSession() {
  17.         List&lt;SessioninfoEntity&gt; sessioninfoEntities = iPersistentSessionService.getStoredSessionDetails();
  19.         if (sessioninfoEntities.size() == 0) {
  20.             return newSession();
  21.         } else if (sessioninfoEntities.size() == 1) {
  22.             return persistedSession(sessioninfoEntities.get(0));
  23.         } else {
  24.             // todo other things
  25.             return null;
  26.         }
  27.     }
  29.     @Bean
  30.     public KieServices getKieServices() {
  31.         return this.kieServices;
  32.     }
  34.     @Bean
  35.     public KieContainer getKieContainer() {
  36.         getFileSystem();
  37.         KieRepository kieRepository = kieServices.getRepository();
  38.         kieRepository.addKieModule(kieRepository::getDefaultReleaseId);
  39.         KieBuilder kb = kieServices.newKieBuilder(getFileSystem()).buildAll();
  40.         KieModule kieModule = kb.getKieModule();
  41.         return kieServices.newKieContainer(kieModule.getReleaseId());
  42.     }
  44.     @Bean
  45.     public KieFileSystem getFileSystem() {
  46.         KieFileSystem kieFileSystem = kieServices.newKieFileSystem();
  47.         return kieFileSystem;
  48.     }
  50.     public Environment getEnv() {
  51.         Environment env = kieServices.newEnvironment();
  52.         env.set(EnvironmentName.ENTITY_MANAGER_FACTORY, Persistence.createEntityManagerFactory(&quot;org.drools.persistence.jpa&quot;));
  53.         env.set(EnvironmentName.TRANSACTION_MANAGER, TransactionManagerServices.getTransactionManager());
  54.         return env;
  55.     }
  57.     private void initDataSource() {
  58.         PoolingDataSource ds = new PoolingDataSource();
  59.         ds.setUniqueName(&quot;jdbc/BitronixJTADataSource&quot;);
  60.         ds.setClassName(&quot;com.mysql.cj.jdbc.MysqlXADataSource&quot;);
  61.         ds.setMaxPoolSize(3);
  62.         ds.setAllowLocalTransactions(true);
  63.         ds.getDriverProperties().put(&quot;user&quot;, &quot;root&quot;);
  64.         ds.getDriverProperties().put(&quot;password&quot;, &quot;1234&quot;);
  65.         ds.getDriverProperties().put(&quot;URL&quot;, &quot;jdbc:mysql://localhost:3306/drool_demo&quot;);
  66.         ds.init();
  67.     }
  69.     private KieSession newSession() {
  70.         return kieServices.getStoreServices().newKieSession(getKieContainer().getKieBase(), null, getEnv());
  71.     }
  73.     private KieSession persistedSession(SessioninfoEntity sessioninfoEntity) {
  74.         return kieServices.getStoreServices().loadKieSession(sessioninfoEntity.getId(), getKieContainer().getKieBase(), null, getEnv());
  75.     }
  76. }

Container releaseId updation method:

  1. @Service
  2. public class DroolsUtilityImpl implements IDroolsUtility {
  4.     @Autowired
  5.     private KieFileSystem fileSystem;
  6.     @Autowired
  7.     private KieServices services;
  8.     @Autowired
  9.     private KieContainer container;
  11.     @Override
  12.     public void updateContainer(String rules) {
  14. //        System.out.println(&quot;drl:\n&quot; + rules);
  15.         fileSystem.write(&quot;src/main/resources/rules/rule.drl&quot;, rules);
  16.         KieBuilder kb = services.newKieBuilder(fileSystem).buildAll();
  17.         KieModule kieModule = kb.getKieModule();
  18.         container.updateToVersion(kieModule.getReleaseId());
  19.     }
  21.     @Override
  22.     public void viewContainerRules() {
  24.         KieBase kieBase = container.getKieBase();
  25.         for (KiePackage kp : kieBase.getKiePackages()) {
  26.             for (Rule rule : kp.getRules()) {
  27.                 System.out.println(rule.getName());
  28.             }
  29.         }
  30.     }
  31. }

答案1

得分: 1

我会尝试重新生成pom并增加发布编号。有点类似于这个例子：

  1.   KieServices ks = KieServices.Factory.get();
  2.   ReleaseId releaseId = ks.newReleaseId("org.kie", "hello-world", "1.0");
  3.   KieFileSystem kfs = ks.newKieFileSystem()
  4.       .generateAndWritePomXML(releaseId)
  5.       .write("src/main/resources/KBase1/org/pkg1/r1.drl", createDrl("R1"))
  6.       .write("src/main/resources/KBase1/org/pkg2/r2.drl", createDrl("R2"))
  7.       .writeKModuleXML(createKieProjectWithPackages(ks, "org.pkg1").toXML());
  8.   ks.newKieBuilder(kfs).buildAll();

摘自：
https://www.codota.com/web/assistant/code/rs/5c65b1cf1095a5000171b19f#L199

英文:

I would try to regenerate the pom and increase release Id. A bit like in this example :

  1.   KieServices ks = KieServices.Factory.get();
  2. ReleaseId releaseId = ks.newReleaseId(&quot;org.kie&quot;, &quot;hello-world&quot;, &quot;1.0&quot;);
  3. KieFileSystem kfs = ks.newKieFileSystem()
  4. .generateAndWritePomXML( releaseId )
  5. .write( &quot;src/main/resources/KBase1/org/pkg1/r1.drl&quot;, createDrl( &quot;R1&quot; ) )
  6. .write( &quot;src/main/resources/KBase1/org/pkg2/r2.drl&quot;, createDrl( &quot;R2&quot; ) )
  7. .writeKModuleXML( createKieProjectWithPackages( ks, &quot;org.pkg1&quot; ).toXML() );
  8. ks.newKieBuilder( kfs ).buildAll();

taken from
https://www.codota.com/web/assistant/code/rs/5c65b1cf1095a5000171b19f#L199

huangapple
  • 本文由 发表于 2020年10月21日 01:57:50
  • 转载请务必保留本文链接：https://go.coder-hub.com/64450848.html
  • drools
  • drools-guvnor
  • java
  • spring
  • spring-boot
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定