标签：rules spring boot biz easy centraldogma
easy-rules-centraldogma-spring-boot-starter 是直接利用了centraldogma进行easy-rules 配置规则管理
可以方便的多版本以及实时更新问题，利用centraldogma强大的git 能力，可以方便的进行rule 的版本管
理，同时centraldogma还支持一种方便的镜像能力，可以方便的进行gitrepo-> centraldogma 的定时同步
同时实现按需的近实时规则更新，而且centraldogma的ha 以及集成还是很方便的，以下是基于centraldogma
的easy-rules spring boot starer 使用
环境准备
- centraldogma 环境
version: "3"
services:
app:
image: line/centraldogma
ports:
- "36462:36462"
注意需要初始创建demo 项目，以及demo repo，同时添加easy-rules 的一个规则配置，后边有说明
- 引入starter
需要自己构建，还没有发布私服,参考链接
pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.5.3</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.dalong</groupId>
<artifactId>batchapp</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>batchapp</name>
<description>mybatch app</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>com.github.rongfengliang</groupId>
<artifactId>easy-rules-centraldogma-spring-boot-starter</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>com.linecorp.centraldogma</groupId>
<artifactId>centraldogma-client-spring-boot-starter</artifactId>
<version>0.51.1</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<version>2.5.3</version>
</plugin>
</plugins>
</build>
</project>
配置
application.yml
easyrules:
skipOnFirstAppliedRule: false
skipOnFirstNonTriggeredRule: false
priorityThreshold: 1000000
project: demo
repo: demo
contentType: json
confName: /rules2.json
centraldogma:
hosts:
- "127.0.0.1:36462" // 如需认证的，可以按照参考链接配置
server:
port: 9000
centraldogma demo repo /rules2.json 文件内容(rulesId 是结合业务使用的规则使用的spel 格式)
[
{
"rulesId": "demoapp",
"rulesContent": [
{
"name": "1",
"description": "1ssssss",
"priority": 1,
"compositeRuleType": "UnitRuleGroup",
"composingRules": [
{
"name": "2",
"description": "2",
"condition": "#biz.age >18", // fact 数据age > 18 会进行action
"priority": 2,
"actions": [
"@myService.setInfo(#biz)" // 具体action 会age 的数据重新赋值
]
}
]
}
]
},
{
"rulesId": "demoapp222",
"rulesContent": [
{
"name": "1",
"description": "1ssssss",
"priority": 1,
"compositeRuleType": "UnitRuleGroup",
"composingRules": [
{
"name": "2",
"description": "2",
"condition": "#biz.age >18",
"priority": 2,
"actions": [
"@myService.setInfo(#biz)",
"T(com.dalong.easyrulesv4.UserServiceImpl).doAction4(#biz)"
]
}
]
}
]
}
]
代码集成（一个简单的rest api)
@RestController
public class RuleApi {
@RequestMapping(value = "/myrule", method = RequestMethod.POST)
public Object info(@RequestBody User user) throws Exception {
SpringBeanUtil.centralDogmaRules().forEach(new BiConsumer<String, Rules>() {
@Override
public void accept(String s, Rules rules) {
System.out.println(s);
rules.forEach(new Consumer<Rule>() {
@Override
public void accept(Rule rule) {
System.out.println(rule.getDescription());
}
});
}
});
Rules rules = SpringBeanUtil.centralDogmaRules().get("demoapp");
Facts facts = new Facts();
// 生成一个唯一id，方便基于数据id规则流程查询
user.setUniqueId(UUID.randomUUID().toString());
facts.put("biz",user);
SpringBeanUtil.getBean("rulesEngine", RulesEngine.class).fire(rules,facts);
User userResult= facts.get("biz");
System.out.println("result from final ruls"+userResult.toString());
return userResult;
}
}
规则依赖的spring bean
@Component("myService")
public class MyService {
public User setInfo(User biz){
System.out.println("call bean method");
System.out.println(biz.toString());
biz.setAge(33333);
return biz;
}
}
运行效果
easy-rules-centraldogma-spring-boot-starter 相关配置参数说明
具体的参考github 实际上说明了，以下简单说明下
配置参数是也easy-rules engine 配置是一致的
<wiz_code_mirror>easyrules:
skipOnFirstAppliedRule: false
skipOnFirstNonTriggeredRule: false
priorityThreshold: 1000000
project: demo
repo: demo
contentType: json // 当前只支持json格式的，后续扩展其他的
confName: /rules2.json
centraldogma:
hosts:
- "127.0.0.1:36462"
server:
port: 9000
调用说明
因为easy-rules 的特性，facts不是线程安全的，而且ruleengine 也不是的，所以需要使用原型bean 进行数据处理，所以
包装了一个通用的utils 可以参考上边rest api 部分的代码，同时关于centraldogma安全以及ha 部分可以参考官方文档，或
者我写的文章
参考资料
https://line.github.io/centraldogma/
https://www.cnblogs.com/rongfengliang/p/15168860.html
https://www.cnblogs.com/rongfengliang/p/15135247.html
https://github.com/rongfengliang/easy-rules-centraldogma-spring-boot-starter
标签：rules,spring,boot,biz,easy,centraldogma 来源： https://www.cnblogs.com/rongfengliang/p/15170535.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。