Optimized code

Author: lvyahui8

spring-boot-data-aggregator-autoconfigure/src/main/java/io/github/lvyahui8/spring/enums/ExceptionProcessingMethod.java

@@ -16,5 +16,5 @@ public enum ExceptionProcessingMethod {
     /**
      * Abort execution
      */
-    SUSPEND;
+    SUSPEND
 }

spring-boot-data-aggregator-core/src/main/java/io/github/lvyahui8/spring/aggregate/consts/AggregatorConstant.java

@@ -7,4 +7,5 @@
 public interface AggregatorConstant
 {
     Object EMPTY_MODEL  = new Object();
+    int DEFAULT_INITIAL_CAPACITY = 8;
 }

spring-boot-data-aggregator-core/src/main/java/io/github/lvyahui8/spring/aggregate/facade/DataBeanAggregateQueryFacade.java

@@ -4,9 +4,27 @@
 import java.util.Map;
 
 /**
+ * The only API for this framework
+ *
  * @author lvyahui (lvyahui8@gmail.com,lvyahui8@126.com)
  * @since 2019/6/1 0:22
  */
 public interface DataBeanAggregateQueryFacade {
-    <T> T get(String id, Map<String,Object> invokeParams, Class<T> clazz) throws InterruptedException, IllegalAccessException, InvocationTargetException;
+    /**
+     * Used to query data. It has the following three functions
+     * 1. Automatic analysis dependence
+     * 2. Parallel access dependency
+     * 3. Automatic injection
+     *
+     * @param id Data id
+     * @param invokeParams Fixed parameters that need to be passed in the query process
+     * @param clazz Return value type bytecode object
+     * @param <T> Return value type
+     * @return Return value
+     * @throws InterruptedException  If the thread is interrupted, this exception will be thrown
+     * @throws IllegalAccessException Thrown if the data provider cannot be executed
+     * @throws InvocationTargetException If the data provider throws an unhandled exception, this exception will be thrown
+     */
+    <T> T get(String id, Map<String,Object> invokeParams, Class<T> clazz)
+            throws InterruptedException, IllegalAccessException, InvocationTargetException;
 }

spring-boot-data-aggregator-core/src/main/java/io/github/lvyahui8/spring/aggregate/facade/impl/DataBeanAggregateQueryFacadeImpl.java

@@ -1,5 +1,6 @@
 package io.github.lvyahui8.spring.aggregate.facade.impl;
 
+import io.github.lvyahui8.spring.aggregate.consts.AggregatorConstant;
 import io.github.lvyahui8.spring.aggregate.service.DataBeanAggregateQueryService;
 import io.github.lvyahui8.spring.aggregate.facade.DataBeanAggregateQueryFacade;
 import org.springframework.util.Assert;
@@ -15,7 +16,7 @@
  */
 public class DataBeanAggregateQueryFacadeImpl implements DataBeanAggregateQueryFacade {
 
-    private DataBeanAggregateQueryService dataBeanAggregateQueryService;
+    private final DataBeanAggregateQueryService dataBeanAggregateQueryService;
 
     public DataBeanAggregateQueryFacadeImpl(DataBeanAggregateQueryService dataBeanAggregateQueryService) {
         this.dataBeanAggregateQueryService = dataBeanAggregateQueryService;
@@ -28,6 +29,7 @@ public <T> T get(String id, Map<String,Object> invokeParams, Class<T> clazz) thr
         if(invokeParams == null) {
             invokeParams = Collections.emptyMap();
         }
-        return dataBeanAggregateQueryService.get(id,invokeParams,clazz,new ConcurrentHashMap<>());
+        return dataBeanAggregateQueryService.get(id,invokeParams,clazz,
+                new ConcurrentHashMap<>(AggregatorConstant.DEFAULT_INITIAL_CAPACITY));
     }
 }

spring-boot-data-aggregator-core/src/main/java/io/github/lvyahui8/spring/aggregate/model/InvokeSignature.java

@@ -22,8 +22,12 @@ public InvokeSignature(Method method, Object[] args) {
 
     @Override
     public boolean equals(Object o) {
-        if (this == o) return true;
-        if (o == null || getClass() != o.getClass()) return false;
+        if (this == o) {
+            return true;
+        }
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
         InvokeSignature that = (InvokeSignature) o;
         return Objects.deepEquals(method, that.method) &&
                 Arrays.deepEquals(args, that.args);

spring-boot-data-aggregator-core/src/main/java/io/github/lvyahui8/spring/aggregate/repository/impl/DataProviderRepositoryImpl.java

@@ -12,7 +12,7 @@
  */
 public class DataProviderRepositoryImpl implements DataProviderRepository {
 
-    private ConcurrentHashMap<String,DataProvideDefinition> providerMap = new ConcurrentHashMap<>();
+    private final ConcurrentHashMap<String,DataProvideDefinition> providerMap = new ConcurrentHashMap<>();
 
     @Override
     public void put(String id, DataProvideDefinition dataProvideDefinition) {

spring-boot-data-aggregator-core/src/main/java/io/github/lvyahui8/spring/aggregate/service/impl/DataBeanAggregateQueryServiceImpl.java

@@ -22,7 +22,7 @@
 @Slf4j
 public class DataBeanAggregateQueryServiceImpl implements DataBeanAggregateQueryService {
 
-    private DataProviderRepository repository;
+    private final DataProviderRepository repository;
 
     @Setter
     private ApplicationContext applicationContext;

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

@@ -20,6 +20,9 @@
 @SpringBootApplication
 @Slf4j
 public class ExampleApplication {
+
+    public static final int NUM = 100;
+
     public static void main(String[] args) throws Exception {
         ConfigurableApplicationContext context = SpringApplication.run(ExampleApplication.class);
         try{
@@ -43,7 +46,7 @@ public static void main(String[] args) throws Exception {
             log.info("------------------------------------------------------------------");
 
             {
-                for (int i = 0; i < 100; i ++) {
+                for (int i = 0; i < NUM; i ++) {
                     String s = queryFacade.get("categoryTitle", Collections.singletonMap("categoryId", 1L), String.class);
                     Assert.isTrue(org.apache.commons.lang3.StringUtils.isNotEmpty(s),"s  not null");
                 }

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

@@ -1,6 +1,5 @@
 package io.github.lvyahui8.spring.example.service;
 
-import io.github.lvyahui8.spring.example.model.Post;
 import io.github.lvyahui8.spring.example.model.Post;
 
 import java.util.List;
@@ -10,5 +9,10 @@
  * @since 2019/6/2 16:53
  */
 public interface PostService {
+    /**
+     * s
+     * @param userId
+     * @return
+     */
     List<Post> getPosts(Long userId);
 }

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

@@ -1,12 +1,16 @@
 package io.github.lvyahui8.spring.example.service;
 
-import io.github.lvyahui8.spring.example.model.User;
 import io.github.lvyahui8.spring.example.model.User;
 
 /**
  * @author lvyahui (lvyahui8@gmail.com,lvyahui8@126.com)
  * @since 2019/6/2 16:36
  */
 public interface UserService {
+    /**
+     * s
+     * @param id
+     * @return
+     */
     User get(Long id);
 }