[dubbo] branch 3.0 updated: add cache for scan result. (#8049)

[albumenj]

This is an automated email from the ASF dual-hosted git repository.

albumenj pushed a commit to branch 3.0
in repository https://gitbox.apache.org/repos/asf/dubbo.git


The following commit(s) were added to refs/heads/3.0 by this push:
     new 96680dd  add cache for scan result. (#8049)
96680dd is described below

commit 96680ddb4a74324ecd449393b9a2a0b3526cb3a3
Author: pazi <35765732+zhangjiezh...@users.noreply.github.com>
AuthorDate: Mon Jun 21 10:21:15 2021 +0800

    add cache for scan result. (#8049)
    
    * add cache for scan result. (#7477)
    
    * remove unused method and delete Unused import. (#8049)
    
    * delete checkCandidate method.
    
    * Please remove redundant comments.
    
    Co-authored-by: zhang.jie <zhang...@rivamed.cn>
---
 .../DubboClassPathBeanDefinitionScanner.java       | 25 ++++++++++++++--------
 1 file changed, 16 insertions(+), 9 deletions(-)

diff --git 
a/dubbo-config/dubbo-config-spring/src/main/java/org/apache/dubbo/config/spring/context/annotation/DubboClassPathBeanDefinitionScanner.java
 
b/dubbo-config/dubbo-config-spring/src/main/java/org/apache/dubbo/config/spring/context/annotation/DubboClassPathBeanDefinitionScanner.java
index 1ed2f32..fc8953b 100644
--- 
a/dubbo-config/dubbo-config-spring/src/main/java/org/apache/dubbo/config/spring/context/annotation/DubboClassPathBeanDefinitionScanner.java
+++ 
b/dubbo-config/dubbo-config-spring/src/main/java/org/apache/dubbo/config/spring/context/annotation/DubboClassPathBeanDefinitionScanner.java
@@ -17,13 +17,15 @@
 package org.apache.dubbo.config.spring.context.annotation;
 
 import org.springframework.beans.factory.config.BeanDefinition;
-import org.springframework.beans.factory.config.BeanDefinitionHolder;
 import org.springframework.beans.factory.support.BeanDefinitionRegistry;
 import org.springframework.context.annotation.ClassPathBeanDefinitionScanner;
 import org.springframework.core.env.Environment;
 import org.springframework.core.io.ResourceLoader;
 
+import java.util.Objects;
 import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentMap;
 
 import static 
org.springframework.context.annotation.AnnotationConfigUtils.registerAnnotationConfigProcessors;
 
@@ -36,6 +38,11 @@ import static 
org.springframework.context.annotation.AnnotationConfigUtils.regis
  */
 public class DubboClassPathBeanDefinitionScanner extends 
ClassPathBeanDefinitionScanner {
 
+    /**
+     * key is package to scan, value is BeanDefinition
+     */
+    private final ConcurrentMap<String, Set<BeanDefinition>> beanDefinitionMap 
= new ConcurrentHashMap<>();
+
 
     public DubboClassPathBeanDefinitionScanner(BeanDefinitionRegistry 
registry, boolean useDefaultFilters, Environment environment,
                                                ResourceLoader resourceLoader) {
@@ -58,13 +65,13 @@ public class DubboClassPathBeanDefinitionScanner extends 
ClassPathBeanDefinition
     }
 
     @Override
-    public Set<BeanDefinitionHolder> doScan(String... basePackages) {
-        return super.doScan(basePackages);
+    public Set<BeanDefinition> findCandidateComponents(String basePackage) {
+        Set<BeanDefinition> beanDefinitions = 
beanDefinitionMap.get(basePackage);
+        // if beanDefinitions size is null => scan
+        if (Objects.isNull(beanDefinitions)) {
+            beanDefinitions = super.findCandidateComponents(basePackage);
+            beanDefinitionMap.put(basePackage, beanDefinitions);
+        }
+        return beanDefinitions;
     }
-
-    @Override
-    public boolean checkCandidate(String beanName, BeanDefinition 
beanDefinition) throws IllegalStateException {
-        return super.checkCandidate(beanName, beanDefinition);
-    }
-
 }