1.新增示例 2.升级开发版本

Author: lvyahui8

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>io.github.lvyahui8</groupId>
     <artifactId>spring-boot-data-aggregator</artifactId>
-    <version>1.0.1</version>
+    <version>1.0.2-SNAPHOST</version>
     <modules>
         <module>spring-boot-data-aggregator-core</module>
         <module>spring-boot-data-aggregator-autoconfigure</module>

spring-boot-data-aggregator-autoconfigure/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>spring-boot-data-aggregator</artifactId>
         <groupId>io.github.lvyahui8</groupId>
-        <version>1.0.1</version>
+        <version>1.0.2-SNAPHOST</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

spring-boot-data-aggregator-core/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>spring-boot-data-aggregator</artifactId>
         <groupId>io.github.lvyahui8</groupId>
-        <version>1.0.1</version>
+        <version>1.0.2-SNAPHOST</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

spring-boot-data-aggregator-example/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>spring-boot-data-aggregator</artifactId>
         <groupId>io.github.lvyahui8</groupId>
-        <version>1.0.1</version>
+        <version>1.0.2-SNAPHOST</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

spring-boot-data-aggregator-example/src/main/java/io/github/lvyahui8/spring/example/aggregate/UserAggregate.java

@@ -1,7 +1,5 @@
 package io.github.lvyahui8.spring.example.aggregate;
 
-import io.github.lvyahui8.spring.annotation.DataConsumer;
-import io.github.lvyahui8.spring.annotation.DataProvider;
 import io.github.lvyahui8.spring.annotation.DataConsumer;
 import io.github.lvyahui8.spring.annotation.DataProvider;
 import io.github.lvyahui8.spring.example.model.Post;
@@ -23,4 +21,13 @@ public User userWithPosts(
         user.setPosts(posts);
         return user;
     }
+
+    @DataProvider(id="userFullData")
+    public User userFullData(@DataConsumer(id = "user") User user,
+                             @DataConsumer(id = "posts") List<Post> posts,
+                             @DataConsumer(id = "followers") List<User> followers) {
+        user.setFollowers(followers);
+        user.setPosts(posts);
+        return user;
+    }
 }

spring-boot-data-aggregator-example/src/main/java/io/github/lvyahui8/spring/example/facade/UserQueryFacade.java

@@ -0,0 +1,76 @@
+package io.github.lvyahui8.spring.example.facade;
+
+import io.github.lvyahui8.spring.aggregate.facade.DataBeanAggregateQueryFacade;
+import io.github.lvyahui8.spring.example.model.Post;
+import io.github.lvyahui8.spring.example.model.User;
+import io.github.lvyahui8.spring.example.service.FollowService;
+import io.github.lvyahui8.spring.example.service.PostService;
+import io.github.lvyahui8.spring.example.service.UserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.lang.reflect.InvocationTargetException;
+import java.util.Collections;
+import java.util.List;
+import java.util.concurrent.*;
+
+/**
+ * @author lvyahui ([email protected],[email protected])
+ * @since 2019/6/11 21:46
+ */
+@Component
+public class UserQueryFacade {
+    @Autowired
+    private FollowService followService;
+    @Autowired
+    private PostService postService;
+    @Autowired
+    private UserService userService;
+
+    @Autowired
+    private DataBeanAggregateQueryFacade dataBeanAggregateQueryFacade;
+
+    public User getUserData(Long userId) {
+        User user = userService.get(userId);
+        user.setPosts(postService.getPosts(userId));
+        user.setFollowers(followService.getFollowers(userId));
+        return user;
+    }
+
+    public User getUserDataByParallel(Long userId) throws InterruptedException, ExecutionException {
+        ExecutorService executorService = Executors.newFixedThreadPool(3);
+        CountDownLatch countDownLatch = new CountDownLatch(3);
+        Future<User> userFuture = executorService.submit(() -> {
+            try{
+                return userService.get(userId);
+            }finally {
+                countDownLatch.countDown();
+            }
+        });
+        Future<List<Post>> postsFuture = executorService.submit(() -> {
+            try{
+                return postService.getPosts(userId);
+            }finally {
+                countDownLatch.countDown();
+            }
+        });
+        Future<List<User>> followersFuture = executorService.submit(() -> {
+            try{
+                return followService.getFollowers(userId);
+            }finally {
+                countDownLatch.countDown();
+            }
+        });
+        countDownLatch.await();
+        User user = userFuture.get();
+        user.setFollowers(followersFuture.get());
+        user.setPosts(postsFuture.get());
+        return user;
+    }
+
+    public User getUserFinal(Long userId) throws InterruptedException,
+            IllegalAccessException, InvocationTargetException {
+        return dataBeanAggregateQueryFacade.get("userFullData",
+                Collections.singletonMap("userId", userId), User.class);
+    }
+}

spring-boot-data-aggregator-example/src/main/java/io/github/lvyahui8/spring/example/model/User.java

@@ -14,4 +14,5 @@ public class User {
     private String username;
     private String email;
     List<Post> posts ;
+    List<User> followers;
 }

spring-boot-data-aggregator-example/src/main/java/io/github/lvyahui8/spring/example/service/FollowService.java

@@ -0,0 +1,13 @@
+package io.github.lvyahui8.spring.example.service;
+
+import io.github.lvyahui8.spring.example.model.User;
+
+import java.util.List;
+
+/**
+ * @author lvyahui ([email protected],[email protected])
+ * @since 2019/6/11 21:31
+ */
+public interface FollowService {
+    List<User> getFollowers(Long userId);
+}

spring-boot-data-aggregator-example/src/main/java/io/github/lvyahui8/spring/example/service/impl/FollowServiceImpl.java

@@ -0,0 +1,33 @@
+package io.github.lvyahui8.spring.example.service.impl;
+
+import io.github.lvyahui8.spring.annotation.DataProvider;
+import io.github.lvyahui8.spring.annotation.InvokeParameter;
+import io.github.lvyahui8.spring.example.model.User;
+import io.github.lvyahui8.spring.example.service.FollowService;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author lvyahui ([email protected],[email protected])
+ * @since 2019/6/11 21:32
+ */
+@Service
+public class FollowServiceImpl implements FollowService {
+    @DataProvider(id = "followers")
+    @Override
+    public List<User> getFollowers(@InvokeParameter("userId") Long userId) {
+        try { Thread.sleep(1000L); } catch (InterruptedException e) {}
+        int size = 10;
+        List<User> users = new ArrayList<>(size);
+        for(int i = 0 ; i < size; i++) {
+            User user = new User();
+            user.setUsername("name"+i);
+            user.setEmail("email"+i+"@fox.com");
+            user.setId((long) i);
+            users.add(user);
+        };
+        return users;
+    }
+}

spring-boot-data-aggregator-starter/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>spring-boot-data-aggregator</artifactId>
         <groupId>io.github.lvyahui8</groupId>
-        <version>1.0.1</version>
+        <version>1.0.2-SNAPHOST</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>