();
+ }
+ nodeMap.put(nodeId, node);
+ }
+
+ public static Node getNode(String nodeId) {
+ return nodeMap.get(nodeId);
+ }
}
diff --git a/src/main/java/com/thebeastshop/liteflow/parser/LocalXmlFlowParser.java b/src/main/java/com/thebeastshop/liteflow/parser/LocalXmlFlowParser.java
new file mode 100644
index 000000000..a8a929bf0
--- /dev/null
+++ b/src/main/java/com/thebeastshop/liteflow/parser/LocalXmlFlowParser.java
@@ -0,0 +1,22 @@
+/**
+ * Title: liteFlow
+ * Description: 轻量级的组件式流程框架
+ * Copyright: Copyright (c) 2017
+ * @author Bryan.Zhang
+ * @email weenyc31@163.com
+ * @Date 2017-7-28
+ * @version 1.0
+ */
+package com.thebeastshop.liteflow.parser;
+
+import com.thebeastshop.liteflow.util.IOUtil;
+
+public class LocalXmlFlowParser extends XmlFlowParser{
+
+ private final String ENCODING_FORMAT = "UTF-8";
+
+ public void parseMain(String rulePath) throws Exception {
+ String ruleContent = IOUtil.read(rulePath, ENCODING_FORMAT);
+ parse(ruleContent);
+ }
+}
diff --git a/src/main/java/com/thebeastshop/liteflow/parser/RegexEntity.java b/src/main/java/com/thebeastshop/liteflow/parser/RegexEntity.java
new file mode 100644
index 000000000..55ffd84ee
--- /dev/null
+++ b/src/main/java/com/thebeastshop/liteflow/parser/RegexEntity.java
@@ -0,0 +1,32 @@
+package com.thebeastshop.liteflow.parser;
+
+import java.util.Arrays;
+
+public class RegexEntity {
+
+ private String condNode;
+
+ private String[] realNodeArray;
+
+ public String getCondNode() {
+ return condNode;
+ }
+
+ public void setCondNode(String condNode) {
+ this.condNode = condNode;
+ }
+
+ public String[] getRealNodeArray() {
+ return realNodeArray;
+ }
+
+ public void setRealNodeArray(String[] realNodeArray) {
+ this.realNodeArray = realNodeArray;
+ }
+
+ @Override
+ public String toString() {
+ return "RegexEntity [condNode=" + condNode + ", realNodeArray="
+ + Arrays.toString(realNodeArray) + "]";
+ }
+}
diff --git a/src/main/java/com/thebeastshop/liteflow/parser/FlowParser.java b/src/main/java/com/thebeastshop/liteflow/parser/XmlFlowParser.java
similarity index 67%
rename from src/main/java/com/thebeastshop/liteflow/parser/FlowParser.java
rename to src/main/java/com/thebeastshop/liteflow/parser/XmlFlowParser.java
index 6537e376c..ef84df3aa 100644
--- a/src/main/java/com/thebeastshop/liteflow/parser/FlowParser.java
+++ b/src/main/java/com/thebeastshop/liteflow/parser/XmlFlowParser.java
@@ -1,20 +1,8 @@
-/**
- * Title: liteFlow
- * Description: 轻量级的组件式流程框架
- * Copyright: Copyright (c) 2017
- * @author Bryan.Zhang
- * @email weenyc31@163.com
- * @Date 2017-7-28
- * @version 1.0
- */
package com.thebeastshop.liteflow.parser;
import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
-import java.util.Map;
import java.util.Map.Entry;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
@@ -34,28 +22,20 @@ import com.thebeastshop.liteflow.entity.config.WhenCondition;
import com.thebeastshop.liteflow.flow.FlowBus;
import com.thebeastshop.liteflow.spring.ComponentScaner;
import com.thebeastshop.liteflow.util.Dom4JReader;
-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 abstract class XmlFlowParser {
- private static Map nodeMap = new HashMap();
-
- 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 {
+ private final Logger LOG = LoggerFactory.getLogger(XmlFlowParser.class);
+
+ public abstract void parseMain(String path) throws Exception;
+
+ public void parse(String content) throws Exception {
Document document = Dom4JReader.getFormatDocument(content);
parse(document);
}
- public static void parse(Document document) throws Exception {
+ @SuppressWarnings("unchecked")
+ public void parse(Document document) throws Exception {
try {
Element rootElement = document.getRootElement();
@@ -79,11 +59,11 @@ public class FlowParser {
}
component.setNodeId(id);
node.setInstance(component);
- nodeMap.put(id, node);
+ FlowBus.addNode(id, node);
}
}else{
for(Entry componentEntry : ComponentScaner.nodeComponentMap.entrySet()){
- nodeMap.put(componentEntry.getKey(), new Node(componentEntry.getKey(), componentEntry.getValue().getClass().getName(), componentEntry.getValue()));
+ FlowBus.addNode(componentEntry.getKey(), new Node(componentEntry.getKey(), componentEntry.getValue().getClass().getName(), componentEntry.getValue()));
}
}
@@ -110,11 +90,11 @@ public class FlowParser {
Node node = null;
for (int i = 0; i < condArray.length; i++) {
regexEntity = parseNodeStr(condArray[i].trim());
- node = nodeMap.get(regexEntity.getCondNode());
+ node = FlowBus.getNode(regexEntity.getCondNode());
chainNodeList.add(node);
if(regexEntity.getRealNodeArray() != null){
for(String key : regexEntity.getRealNodeArray()){
- Node condNode = nodeMap.get(key);
+ Node condNode = FlowBus.getNode(key);
if(condNode != null){
node.setCondNode(condNode.getId(), condNode);
}
@@ -135,39 +115,6 @@ public class FlowParser {
}
- public static Node getNode(String nodeId){
- return nodeMap.get(nodeId);
- }
-
- private static class RegexEntity{
-
- private String condNode;
-
- private String[] realNodeArray;
-
- public String getCondNode() {
- return condNode;
- }
-
- public void setCondNode(String condNode) {
- this.condNode = condNode;
- }
-
- public String[] getRealNodeArray() {
- return realNodeArray;
- }
-
- public void setRealNodeArray(String[] realNodeArray) {
- this.realNodeArray = realNodeArray;
- }
-
- @Override
- public String toString() {
- return "RegexEntity [condNode=" + condNode + ", realNodeArray="
- + Arrays.toString(realNodeArray) + "]";
- }
- }
-
public static RegexEntity parseNodeStr(String str) {
List list = new ArrayList();
Pattern p = Pattern.compile("[^\\)\\(]+");
@@ -186,8 +133,4 @@ public class FlowParser {
}
return regexEntity;
}
-
- public static void main(String[] args) {
- System.out.println(parseNodeStr("aaaa ( xxxx | yyyy | vvvv )"));
- }
}
diff --git a/src/main/java/com/thebeastshop/liteflow/parser/ZookeeperXmlFlowParser.java b/src/main/java/com/thebeastshop/liteflow/parser/ZookeeperXmlFlowParser.java
new file mode 100644
index 000000000..047aca383
--- /dev/null
+++ b/src/main/java/com/thebeastshop/liteflow/parser/ZookeeperXmlFlowParser.java
@@ -0,0 +1,63 @@
+package com.thebeastshop.liteflow.parser;
+
+import java.text.MessageFormat;
+
+import org.apache.commons.lang3.StringUtils;
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.framework.recipes.cache.NodeCache;
+import org.apache.curator.framework.recipes.cache.NodeCacheListener;
+import org.apache.curator.retry.RetryNTimes;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import com.thebeastshop.liteflow.exception.ParseException;
+
+public class ZookeeperXmlFlowParser extends XmlFlowParser{
+
+ private static final Logger LOG = LoggerFactory.getLogger(ZookeeperXmlFlowParser.class);
+
+ private String nodePath = "/lite-flow/flow";
+
+ public ZookeeperXmlFlowParser() {
+
+ }
+
+ public ZookeeperXmlFlowParser(String node) {
+ nodePath = node;
+ }
+
+ @Override
+ public void parseMain(String path) throws Exception {
+ CuratorFramework client = CuratorFrameworkFactory.newClient(
+ path,
+ new RetryNTimes(10, 5000)
+ );
+ client.start();
+
+ if (client.checkExists().forPath(nodePath) == null) {
+ client.create().creatingParentsIfNeeded().forPath(nodePath, "".getBytes());
+ }
+
+ String content = new String(client.getData().forPath(nodePath));
+
+
+ if(StringUtils.isBlank(content)) {
+ String error = MessageFormat.format("the node[{0}] value is empty", nodePath);
+ throw new ParseException(error);
+ }
+ parse(content);
+
+
+ final NodeCache cache = new NodeCache(client,nodePath);
+ cache.start();
+
+ cache.getListenable().addListener(new NodeCacheListener() {
+ @Override
+ public void nodeChanged() throws Exception {
+ String content = new String(cache.getCurrentData().getData());
+ LOG.info("stating load flow config....");
+ parse(content);
+ }
+ });
+ }
+}
diff --git a/src/main/java/com/thebeastshop/liteflow/util/LOGOPrinter.java b/src/main/java/com/thebeastshop/liteflow/util/LOGOPrinter.java
index 7c7e470bd..1bc27212f 100644
--- a/src/main/java/com/thebeastshop/liteflow/util/LOGOPrinter.java
+++ b/src/main/java/com/thebeastshop/liteflow/util/LOGOPrinter.java
@@ -15,7 +15,7 @@ public class LOGOPrinter {
str.append(" | | | | | | | _| _____| |_ | | | | | \\ \\ /\\ / / \n");
str.append(" | |___ | | | | | |__|_____| _| | |__| |_| |\\ V V / \n");
str.append(" |_____|___| |_| |_____| |_| |_____\\___/ \\_/\\_/ \n\n");
- str.append(" 做最轻量级，最吊炸天的微流程框架\n");
+ str.append(" 做最轻量级，最实用的微流程框架\n");
str.append(" To be the most lightweight and the most practical micro-process framework\n");
str.append("================================================================================================\n");
LOG.info(str.toString());
diff --git a/src/test/java/com/thebeastshop/liteflow/test/TestWithSpringMain.java b/src/test/java/com/thebeastshop/liteflow/test/TestWithSpringMain.java
index a5e7f777e..61897ce48 100644
--- a/src/test/java/com/thebeastshop/liteflow/test/TestWithSpringMain.java
+++ b/src/test/java/com/thebeastshop/liteflow/test/TestWithSpringMain.java
@@ -19,7 +19,7 @@ import com.thebeastshop.liteflow.entity.data.Slot;
@ContextConfiguration(locations = { "classpath:spring-test.xml" })
public class TestWithSpringMain {
- @Resource
+ @Resource(name="flowExecutor")
private FlowExecutor flowExecutor;
@Test
@@ -50,4 +50,17 @@ public class TestWithSpringMain {
}
}
+
+ @Test
+ public void test3() throws Exception {
+ try {
+ while(true) {
+ Slot slot = flowExecutor.execute("chain3", "it's a request");
+ Thread.sleep(2000);
+ }
+ }catch(Exception e) {
+ e.printStackTrace();
+ }
+
+ }
}
diff --git a/src/test/java/com/thebeastshop/liteflow/test/curator/CuratorTest.java b/src/test/java/com/thebeastshop/liteflow/test/curator/CuratorTest.java
new file mode 100644
index 000000000..3d6989dcc
--- /dev/null
+++ b/src/test/java/com/thebeastshop/liteflow/test/curator/CuratorTest.java
@@ -0,0 +1,135 @@
+package com.thebeastshop.liteflow.test.curator;
+
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.framework.recipes.cache.NodeCache;
+import org.apache.curator.framework.recipes.cache.NodeCacheListener;
+import org.apache.curator.framework.recipes.cache.PathChildrenCache;
+import org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent;
+import org.apache.curator.framework.recipes.cache.PathChildrenCacheListener;
+import org.apache.curator.retry.RetryNTimes;
+
+public class CuratorTest {
+
+ /** Zookeeper info */
+ private static final String ZK_ADDRESS = "123.206.92.144:2181,123.206.92.144:2182,123.206.92.144:2183";
+ private static final String ZK_PATH = "/zktest/a1/aa1";
+
+ public static void main(String[] args) throws Exception {
+ // 1.Connect to zk
+ CuratorFramework client = CuratorFrameworkFactory.newClient(
+ ZK_ADDRESS,
+ new RetryNTimes(10, 5000)
+ );
+ client.start();
+
+ checkNode(client);
+
+// childNodeListen(client);
+
+// removeNodeData(client);
+
+// createNode(client);
+
+// nodeListen(client);
+//
+// modifyNodeData(client);
+
+ System.in.read();
+
+// getNodeData(client);
+//
+//
+
+ }
+
+ private static void checkNode(CuratorFramework client) throws Exception {
+ System.out.println(client.checkExists().forPath("/test"));
+ }
+
+ private static void createNode(CuratorFramework client) throws Exception {
+ String data1 = "nice to meet you";
+ print("create", ZK_PATH, data1);
+ client.create().
+ creatingParentsIfNeeded().
+ forPath(ZK_PATH, data1.getBytes());
+ }
+
+ private static void getNodeData(CuratorFramework client) throws Exception {
+ print("ls", "/");
+ print(client.getChildren().forPath("/"));
+ print("get", ZK_PATH);
+ print(client.getData().forPath(ZK_PATH));
+ }
+
+ private static void modifyNodeData(CuratorFramework client) throws Exception {
+ String data2 = "world for u";
+ print("set", ZK_PATH, data2);
+ client.setData().forPath(ZK_PATH, data2.getBytes());
+ print("get", ZK_PATH);
+ print(client.getData().forPath(ZK_PATH));
+ }
+
+ private static void removeNodeData(CuratorFramework client) throws Exception {
+ print("delete", "/zktest/dddd");
+ client.delete().forPath("/zktest/dddd");
+ print("ls", "/");
+ print(client.getChildren().forPath("/"));
+ }
+
+ private static void nodeListen(CuratorFramework client) throws Exception {
+ final NodeCache cache = new NodeCache(client,ZK_PATH);
+ cache.start();
+
+ cache.getListenable().addListener(new NodeCacheListener() {
+
+ @Override
+ public void nodeChanged() throws Exception {
+ byte[] res = cache.getCurrentData().getData();
+ System.out.println("data: " + new String(res));
+ }
+ });
+ }
+
+ private static void childNodeListen(CuratorFramework client) throws Exception {
+ final PathChildrenCache cache = new PathChildrenCache(client,"/zktest",true);
+ cache.start();
+
+ cache.getListenable().addListener(new PathChildrenCacheListener() {
+
+ @Override
+ public void childEvent(CuratorFramework curator, PathChildrenCacheEvent event) throws Exception {
+ switch (event.getType()) {
+ case CHILD_ADDED:
+ System.out.println("add:" + event.getData().getPath() + ":" + new String(event.getData().getData()));
+ break;
+ case CHILD_UPDATED:
+ System.out.println("update:" + event.getData().getPath() + ":" + new String(event.getData().getData()));
+ break;
+ case CHILD_REMOVED:
+ System.out.println("remove:" + event.getData().getPath() + ":" + new String(event.getData().getData()));
+ break;
+ default:
+ break;
+ }
+ }
+ });
+ }
+
+
+ private static void print(String... cmds) {
+ StringBuilder text = new StringBuilder("$ ");
+ for (String cmd : cmds) {
+ text.append(cmd).append(" ");
+ }
+ System.out.println(text.toString());
+ }
+
+ private static void print(Object result) {
+ System.out.println(
+ result instanceof byte[]
+ ? new String((byte[]) result)
+ : result);
+ }
+
+}
diff --git a/src/test/java/com/thebeastshop/liteflow/test/curator/CuratorTest2.java b/src/test/java/com/thebeastshop/liteflow/test/curator/CuratorTest2.java
new file mode 100644
index 000000000..232ecace1
--- /dev/null
+++ b/src/test/java/com/thebeastshop/liteflow/test/curator/CuratorTest2.java
@@ -0,0 +1,121 @@
+package com.thebeastshop.liteflow.test.curator;
+
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.framework.recipes.cache.NodeCache;
+import org.apache.curator.framework.recipes.cache.NodeCacheListener;
+import org.apache.curator.framework.recipes.cache.PathChildrenCache;
+import org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent;
+import org.apache.curator.framework.recipes.cache.PathChildrenCacheListener;
+import org.apache.curator.retry.RetryNTimes;
+
+public class CuratorTest2 {
+
+ /** Zookeeper info */
+ private static final String ZK_ADDRESS = "114.55.174.189:2181";
+ private static final String ZK_PATH = "/zktest/ffff";
+
+ public static void main(String[] args) throws Exception {
+ // 1.Connect to zk
+ CuratorFramework client = CuratorFrameworkFactory.newClient(
+ ZK_ADDRESS,
+ new RetryNTimes(10, 5000)
+ );
+ client.start();
+
+// removeNodeData(client);
+
+// createNode(client);
+
+// nodeListen(client);
+//
+ modifyNodeData(client);
+
+ }
+
+ private static void createNode(CuratorFramework client) throws Exception {
+ String data1 = "hello";
+ print("create", ZK_PATH, data1);
+ client.create().
+ creatingParentsIfNeeded().
+ forPath(ZK_PATH, data1.getBytes());
+ }
+
+ private static void getNodeData(CuratorFramework client) throws Exception {
+ print("ls", "/");
+ print(client.getChildren().forPath("/"));
+ print("get", ZK_PATH);
+ print(client.getData().forPath(ZK_PATH));
+ }
+
+ private static void modifyNodeData(CuratorFramework client) throws Exception {
+ String data2 = "world for u";
+ print("set", ZK_PATH, data2);
+ client.setData().forPath(ZK_PATH, data2.getBytes());
+ print("get", ZK_PATH);
+ print(client.getData().forPath(ZK_PATH));
+ }
+
+ private static void removeNodeData(CuratorFramework client) throws Exception {
+ print("delete", "/zktest/dddd");
+ client.delete().forPath("/zktest/dddd");
+ print("ls", "/");
+ print(client.getChildren().forPath("/"));
+ }
+
+ private static void nodeListen(CuratorFramework client) throws Exception {
+ final NodeCache cache = new NodeCache(client,ZK_PATH);
+ cache.start();
+
+ cache.getListenable().addListener(new NodeCacheListener() {
+
+ @Override
+ public void nodeChanged() throws Exception {
+ byte[] res = cache.getCurrentData().getData();
+ System.out.println("data: " + new String(res));
+ }
+ });
+ }
+
+ private static void childNodeListen(CuratorFramework client) throws Exception {
+ final PathChildrenCache cache = new PathChildrenCache(client,"/zktest",true);
+ cache.start();
+
+ cache.getListenable().addListener(new PathChildrenCacheListener() {
+
+ @Override
+ public void childEvent(CuratorFramework curator, PathChildrenCacheEvent event) throws Exception {
+ switch (event.getType()) {
+ case CHILD_ADDED:
+ System.out.println("add:" + event.getData().getPath() + ":" + new String(event.getData().getData()));
+ break;
+ case CHILD_UPDATED:
+ System.out.println("update:" + event.getData().getPath() + ":" + new String(event.getData().getData()));
+ break;
+ case CHILD_REMOVED:
+ System.out.println("remove:" + event.getData().getPath() + ":" + new String(event.getData().getData()));
+ break;
+ default:
+ break;
+ }
+ }
+ });
+ }
+
+
+ private static void print(String... cmds) {
+ StringBuilder text = new StringBuilder("$ ");
+ for (String cmd : cmds) {
+ text.append(cmd).append(" ");
+ }
+ System.out.println(text.toString());
+ }
+
+ private static void print(Object result) {
+ System.out.println(
+ result instanceof byte[]
+ ? new String((byte[]) result)
+ : result);
+ }
+
+}
diff --git a/src/test/java/com/thebeastshop/liteflow/test/regex/RegexTest.java b/src/test/java/com/thebeastshop/liteflow/test/regex/RegexTest.java
new file mode 100644
index 000000000..c1efeebd9
--- /dev/null
+++ b/src/test/java/com/thebeastshop/liteflow/test/regex/RegexTest.java
@@ -0,0 +1,23 @@
+package com.thebeastshop.liteflow.test.regex;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+public class RegexTest {
+
+ public static void main(String[] args) {
+ String str = "192.168.1.1:2181,192.168.1.2:2182,192.168.1.3:2183";
+ List list = new ArrayList();
+ Pattern p = Pattern.compile("[\\w\\d][\\w\\d\\.]+\\:(\\d)+(\\,[\\w\\d][\\w\\d\\.]+\\:(\\d)+)*");
+ Matcher m = p.matcher(str);
+ while(m.find()){
+ list.add(m.group());
+ }
+ System.out.println(list.size());
+ System.out.println(list);
+
+ }
+
+}
diff --git a/src/test/resources/spring-test.xml b/src/test/resources/spring-test.xml
index 685098480..71ba484c4 100644
--- a/src/test/resources/spring-test.xml
+++ b/src/test/resources/spring-test.xml
@@ -10,11 +10,21 @@
-
+
+
+
+
+
+
+ 123.206.92.144:2181,123.206.92.144:2182,123.206.92.144:2183
+
+
+
\ No newline at end of file