Commit b1f08c6

committed

v2 version devlop

1 parent ade2326 commit b1f08c6Copy full SHA for b1f08c6

File tree

+65

-0

lines changed

spring-boot-data-aggregator-core/src/main/java/io/github/lvyahui8/spring/aggregate2

+65

-0

lines changed

Lines changed: 25 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,25 @@`
	`1`	`+package io.github.lvyahui8.spring.aggregate2;`
	`2`	`+`
	`3`	`+import io.github.lvyahui8.spring.aggregate.model.DataProvideDefinition;`
	`4`	`+import io.github.lvyahui8.spring.aggregate.service.DataBeanAggregateService;`
	`5`	`+`
	`6`	`+import java.lang.reflect.InvocationTargetException;`
	`7`	`+import java.util.Map;`
	`8`	`+`
	`9`	`+/**`
	`10`	`+ * @author feego lvyahui8@gmail.com`
	`11`	`+ * @date 2022年4月2日`
	`12`	`+ */`
	`13`	`+public class AggregateServiceV2 implements DataBeanAggregateService {`
	`14`	`+ @Override`
	`15`	`+ public <T> T get(String id, Map<String, Object> invokeParams, Class<T> resultType) throws InterruptedException, InvocationTargetException, IllegalAccessException {`
	`16`	`+ final Context context = new Context();`
	`17`	`+ context.paramMap = invokeParams;`
	`18`	`+ return null;`
	`19`	`+ }`
	`20`	`+`
	`21`	`+ @Override`
	`22`	`+ public <T> T get(DataProvideDefinition provider, Map<String, Object> invokeParams, Class<T> resultType) throws InterruptedException, InvocationTargetException, IllegalAccessException {`
	`23`	`+ return null;`
	`24`	`+ }`
	`25`	`+}`

Lines changed: 12 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,12 @@`
	`1`	`+package io.github.lvyahui8.spring.aggregate2;`
	`2`	`+`
	`3`	`+import java.util.Map;`
	`4`	`+`
	`5`	`+/**`
	`6`	`+ * @author feego lvyahui8@gmail.com`
	`7`	`+ * @date 2022年4月1日`
	`8`	`+ */`
	`9`	`+public class Context {`
	`10`	`+ Map<String,Object> resultMap;`
	`11`	`+ Map<String,Object> paramMap;`
	`12`	`+}`

Lines changed: 15 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,15 @@`
	`1`	`+package io.github.lvyahui8.spring.aggregate2;`
	`2`	`+`
	`3`	`+import java.lang.reflect.Method;`
	`4`	`+import java.util.Map;`
	`5`	`+`
	`6`	`+/**`
	`7`	`+ * @author feego lvyahui8@gmail.com`
	`8`	`+ * @date 2022年4月1日`
	`9`	`+ */`
	`10`	`+public class ResourceNode {`
	`11`	`+ Object target;`
	`12`	`+ Method method;`
	`13`	`+`
	`14`	`+ Map<String,ResourceNode> dependents;`
	`15`	`+}`

Lines changed: 9 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,9 @@`
	`1`	`+package io.github.lvyahui8.spring.aggregate2;`
	`2`	`+`
	`3`	`+/**`
	`4`	`+ * @author feego lvyahui8@gmail.com`
	`5`	`+ * @date 2022年4月1日`
	`6`	`+ */`
	`7`	`+public class ResourceTree {`
	`8`	`+ ResourceNode treeRoot;`
	`9`	`+}`

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,4 @@`
	`1`	`+## v2版原理`
	`2`	`+`
	`3`	`+并行汇聚,本质是对一颗树进行类似fork&join的操作。`
	`4`	`+`

Comments

(0)