本文主要是介绍规则引擎Drools+Nacos实现动态规则,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
一,背景
项目中有需要根据规则计算不同收费方费用的需求,后面还会有优惠券、满减、限时折扣之类的规则,同时需要配合不同运营活动动态配置,这些需求对计算的灵活性要求比较高。
Drools是比较常用的规则引擎,可以自己定义计算规则,简化项目代码中的逻辑。
Nacos是Spring Cloud中的常用的配置中心和注册中心,可以动态读取最新的配置。
二,实现
1,Maven引入
<dependency><groupId>org.drools</groupId><artifactId>drools-compiler</artifactId><version>7.74.1.Final</version>
</dependency>
<dependency><groupId>org.drools</groupId><artifactId>drools-core</artifactId><version>7.74.1.Final</version>
</dependency>
<dependency><groupId>org.drools</groupId><artifactId>drools-templates</artifactId><version>7.74.1.Final</version>
</dependency>
<dependency><groupId>org.kie</groupId><artifactId>kie-api</artifactId><version>7.74.1.Final</version>
</dependency>
<dependency><groupId>org.kie</groupId><artifactId>kie-spring</artifactId><version>7.74.1.Final</version>
</dependency>
2,Drools工具类
@Configuration
public class DroolsConfig {private final ExtensionConfig extensionConfig;public DroolsConfig(ExtensionConfig extensionConfig) {this.extensionConfig = extensionConfig;}public void getDroolsResult(FeePackageDTO feePackageDTO) {KieHelper kieHelper = new KieHelper();kieHelper.addContent(extensionConfig.getContent(), ResourceType.DRL);KieBase kieBase = kieHelper.build();KieSession kieSession = kieBase.newKieSession();kieSession.insert(feePackageDTO);kieSession.fireAllRules();kieSession.destroy();}
}
3,项目启动文件中Nacos配置
# 共享配置
extension-configs:- data-id: drools-rulegroup: DEFAULT_GROUPfile-extension: textrefresh: true
4,动态读取Nacos更新内容
@Configuration
@RefreshScope
@Slf4j
@Data
public class ExtensionConfig {private String content;public ExtensionConfig(NacosConfigManager configManager) {try {ConfigService configService = configManager.getConfigService();// 直接从Nacos Config Service获取text配置内容this.content = configService.getConfig("drools-rule", "default_group", 5000);} catch (Exception e) {log.error("获取drools配置异常", e);}}
}
5, Nacos中Drools规则配置
5.1, 规则: 配置里必须包含rule, when, then, end。
5.2,优先级: 每一条规则都有一个salience属性,这个属性可以决定规则的执行顺序。在内部匹配队里里面,优先级越高的规则,执行顺序越靠前。默认的优先级的值是0,优先级的值可以是正数,也可以是负数。
5.3,高级配置:
Drools用户手册翻译——第四章 Drools规则引擎(六)执行控制_drools如何执行不同group的规则-CSDN博客
https://www.cnblogs.com/huan1993/p/16284781.html
下面是在nacos中的配置: 格式是text, data-id是drools-rule(随意命名, 只要和项目启动文件里的data-id一致就可以)
package com.xxx.xxx.xxx.droolsimport com.xxx.xxx.xxx.drools.FeePackageDTO
import java.math.BigDecimal// 三方分润模式
rule "tripartite profit sharing"
when$feePackageDTO: FeePackageDTO(feeModeCode==1)
then// 商户总费率BigDecimal rate = new BigDecimal($feePackageDTO.getRate());$feePackageDTO.setPlatformRate(new BigDecimal($feePackageDTO.getPlatformRate()).multiply(rate).toString());$feePackageDTO.setChannelRate(new BigDecimal($feePackageDTO.getChannelRate()).multiply(rate).toString());$feePackageDTO.setProxyRate(rate.subtract(new BigDecimal($feePackageDTO.getChannelRate())).subtract(new BigDecimal($feePackageDTO.getPlatformRate())).toString());System.out.println("三方分润模式-银行分润比例:" + $feePackageDTO.getChannelRate());System.out.println("三方分润模式-代理商分润比例:" + $feePackageDTO.getProxyRate());System.out.println("三方分润模式-XXX分润比例:" + $feePackageDTO.getPlatformRate());
end
6,使用Drools计算费率
private void calcRateWithCostMode(TransFeeDTO transFeeDTO) {FeePackageDTO dto = new FeePackageDTO();dto.setFeeModeCode(transFeeDTO.getFeeMode().getCode());//drools引擎计算费率log.info("=====>Drools计算参数: {}", JSONUtil.toJsonStr(dto));droolsConfig.getDroolsResult(dto);transFeeDTO.setRate(dto.getRate());transFeeDTO.setChannelRate(dto.getChannelRate());transFeeDTO.setProxyRate(dto.getProxyRate());transFeeDTO.setPlatformRate(dto.getPlatformRate());log.info("=====>Drools计算出的费率: {}", JSONUtil.toJsonStr(transFeeDTO));
}
三,总结
通过Nacos读取动态配置,结合Drools,实现动态规则引擎,可以满足大部分场景的费用计算,需要对计算规则调整时,只需要在Nacos中修改规则就好了,不用修改项目代码,也不用重新部署项目。
这篇关于规则引擎Drools+Nacos实现动态规则的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!