SpringBoot+Drools使用数据库

阅读数:224 评论数:0

分类

python/Java

正文

POM依赖

        <dependency>
            <groupId>org.kie</groupId>
            <artifactId>kie-api</artifactId>
        </dependency>
        <dependency>
            <groupId>org.drools</groupId>
            <artifactId>drools-core</artifactId>
        </dependency>
        <dependency>
            <groupId>org.drools</groupId>
            <artifactId>drools-compiler</artifactId>
        </dependency>

建表

CREATE TABLE `drools_rule` (
  `rule_id` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
  `rule_uuid` varchar(64) DEFAULT NULL COMMENT '业务主键',
  `rule_content` longtext COMMENT '规则',
  PRIMARY KEY (`rule_id`)
) ENGINE=InnoDB AUTO_INCREMENT=22 DEFAULT CHARSET=utf8;

droolService

@Slf4j
@Service
public class DroolServiceImpl implements IDroolsService {

    @Autowired
    private RedisUtil redisUtil;
    @Autowired
    private TbRuleMapper tbRuleMapper;

    @Override
    public void reload() {
        Boolean needReload = redisUtil.exists("droolsNeedLoad");
        if(needReload){
            KieServices kieServices = KieServices.Factory.get();
            KieFileSystem kfs = kieServices.newKieFileSystem();
            TbRule tbRule = tbRuleMapper.findEffectiveRule();
            if(tbRule!=null&& StringUtils.isNotBlank(tbRule.getRuleContent())){
                kfs.write("src/main/resources/rules/temp.drl",tbRule.getRuleContent().getBytes());
                KieBuilder kieBuilder = kieServices.newKieBuilder(kfs).buildAll();
                Results results = kieBuilder.getResults();
                if(results.hasMessages(Message.Level.ERROR)){
                    System.out.println(results.getMessages());
                    return;
                }
                KieUtil.setKieContainer(kieServices.newKieContainer(kieServices.getRepository().getDefaultReleaseId()));
                log.info("drools规则重新加载成功");
            }
        }
        redisUtil.del("droolsNeedLoad");
    }


}

KieUtil

public class KieUtil {
    private static KieContainer kieContainer;
    private static KieSession kieSession;

    public static KieContainer getKieContainer(){
        return kieContainer;
    }

    public static void setKieContainer(KieContainer kieContainer){
        KieUtil.kieContainer = kieContainer;
        kieSession = KieUtil.kieContainer.newKieSession();
    }

    public static KieSession getKieSession(){
        return kieSession;
    }

    public static void setKieSession(KieSession kieSession){
        KieUtil.kieSession = kieSession;
    }
}

使用

            iDroolsService.reload();
            KieSession kieSession = KieUtil.getKieSession();
            kieSession.insert(entity);
            kieSession.fireAllRules();