KingChan
/
liteFlow
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改Component类加载的代码

This commit is contained in:
paul.xiong 2017-10-18 19:27:19 +08:00
parent 8f7f4b070f
commit 3ca86f0511
1 changed files with 64 additions and 77 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

141
src/main/java/com/thebeastshop/liteflow/parser/FlowParser.java
View File

@ -10,22 +10,17 @@
package com.thebeastshop.liteflow.parser;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import org.apache.commons.lang3.ClassUtils;
import org.apache.commons.lang3.StringUtils;
import org.dom4j.Document;
import org.dom4j.Element;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.poolik.classfinder.ClassFinder;
import com.poolik.classfinder.filter.Subclass;
import com.poolik.classfinder.info.ClassInfo;
import com.thebeastshop.liteflow.core.Component;
import com.thebeastshop.liteflow.entity.config.Chain;
import com.thebeastshop.liteflow.entity.config.Condition;
@ -38,85 +33,77 @@ import com.thebeastshop.liteflow.util.IOUtil;
@SuppressWarnings("unchecked")
public class FlowParser {
private static final Logger LOG = LoggerFactory.getLogger(FlowParser.class);
private static final String ENCODING_FORMAT = "UTF-8";
public static void parseLocal(String rulePath) throws Exception{
public static void parseLocal(String rulePath) throws Exception {
String ruleContent = IOUtil.read(rulePath, ENCODING_FORMAT);
parse(ruleContent);
}
public static void parse(String content) throws Exception{
public static void parse(String content) throws Exception {
Document document = Dom4JReader.getFormatDocument(content);
parse(document);
}
public static void parse(Document document) throws Exception{
Element rootElement = document.getRootElement();
//find所有的组件实现类并实例化
Map<String, Component> compInstanceMap = new HashMap<String, Component>();
ClassFinder finder = new ClassFinder().addClasspath();
Collection<ClassInfo> classList = finder.findClasses(Subclass.of(Component.class));
Component component = null;
for(ClassInfo classInfo : classList){
LOG.info("component [{}] has been registered to flow parse manager",classInfo.getClassName());
component = (Component)ClassUtils.getClass(classInfo.getClassName()).newInstance();
compInstanceMap.put(classInfo.getClassName(), component);
}
//解析node节点
List<Element> nodeList = rootElement.element("nodes").elements("node");
String id = null;
String clazz = null;
Node node = null;
Map<String, Node> nodeMap = new HashMap<String, Node>();
for(Element e : nodeList){
node = new Node();
id = e.attributeValue("id");
clazz = e.attributeValue("class");
node.setId(id);
node.setClazz(clazz);
if(!compInstanceMap.containsKey(clazz)){
LOG.error("couldn't find [{}] in registered component map",clazz);
}
component = compInstanceMap.get(clazz);
component.setNodeId(id);
node.setInstance(component);
nodeMap.put(id, node);
}
//解析chain节点
String chainName = null;
String condArrayStr = null;
String[] condArray = null;
List<Node> chainNodeList = null;
List<Condition> conditionList = null;
List<Element> chainList = rootElement.elements("chain");
for(Element e : chainList){
chainName = e.attributeValue("name");
conditionList = new ArrayList<Condition>();
for (Iterator<Element> it = e.elementIterator(); it.hasNext();) {
Element condE = it.next();
condArrayStr = condE.attributeValue("value");
if(StringUtils.isBlank(condArrayStr)){
continue;
}
chainNodeList = new ArrayList<Node>();
condArray = condArrayStr.split(",");
for (int i = 0; i < condArray.length; i++) {
chainNodeList.add(nodeMap.get(condArray[i]));
}
if(condE.getName().equals("then")){
conditionList.add(new ThenCondition(chainNodeList));
}else if(condE.getName().equals("when")){
conditionList.add(new WhenCondition(chainNodeList));
}
public static void parse(Document document) throws Exception {
try {
Element rootElement = document.getRootElement();
// 解析node节点
List<Element> nodeList = rootElement.element("nodes").elements("node");
String id = null;
String clazz = null;
Node node = null;
Component component = null;
Map<String, Node> nodeMap = new HashMap<String, Node>();
for (Element e : nodeList) {
node = new Node();
id = e.attributeValue("id");
clazz = e.attributeValue("class");
node.setId(id);
node.setClazz(clazz);
component = (Component) Class.forName(clazz).newInstance();
component.setNodeId(id);
node.setInstance(component);
nodeMap.put(id, node);
}
FlowBus.addChain(chainName, new Chain(conditionList));
}
}
// 解析chain节点
String chainName = null;
String condArrayStr = null;
String[] condArray = null;
List<Node> chainNodeList = null;
List<Condition> conditionList = null;
List<Element> chainList = rootElement.elements("chain");
for (Element e : chainList) {
chainName = e.attributeValue("name");
conditionList = new ArrayList<Condition>();
for (Iterator<Element> it = e.elementIterator(); it.hasNext();) {
Element condE = it.next();
condArrayStr = condE.attributeValue("value");
if (StringUtils.isBlank(condArrayStr)) {
continue;
}
chainNodeList = new ArrayList<Node>();
condArray = condArrayStr.split(",");
for (int i = 0; i < condArray.length; i++) {
chainNodeList.add(nodeMap.get(condArray[i]));
}
if (condE.getName().equals("then")) {
conditionList.add(new ThenCondition(chainNodeList));
} else if (condE.getName().equals("when")) {
conditionList.add(new WhenCondition(chainNodeList));
}
}
FlowBus.addChain(chainName, new Chain(conditionList));
}
} catch (Exception e) {
LOG.error("FlowParser解析异常: {}", e);
}
}
}