add annotation

Author: kimmking

07rpc/rpc01/rpcfx-core/pom.xml

@@ -24,6 +24,12 @@
 			<version>1.2.70</version>
 		</dependency>
 
+		<dependency>
+			<groupId>org.projectlombok</groupId>
+			<artifactId>lombok</artifactId>
+			<version>1.18.16</version>
+		</dependency>
+
 		<dependency>
 			<groupId>com.squareup.okhttp3</groupId>
 			<artifactId>okhttp</artifactId>

07rpc/rpc01/rpcfx-demo-provider/src/main/java/io/kimmking/rpcfx/demo/provider/ServiceProviderDesc.java renamed to 07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/api/ServiceProviderDesc.java

@@ -1,4 +1,4 @@
-package io.kimmking.rpcfx.demo.provider;
+package io.kimmking.rpcfx.api;
 
 public class ServiceProviderDesc {
 

07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/api/annotation/RpcfxClassPathBeanDefinitionScanner.java

@@ -0,0 +1,47 @@
+package io.kimmking.rpcfx.api.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.Set;
+
+import static org.springframework.context.annotation.AnnotationConfigUtils.registerAnnotationConfigProcessors;
+
+public class RpcfxClassPathBeanDefinitionScanner extends ClassPathBeanDefinitionScanner {
+
+
+    public RpcfxClassPathBeanDefinitionScanner(BeanDefinitionRegistry registry, boolean useDefaultFilters, Environment environment,
+                                               ResourceLoader resourceLoader) {
+
+        super(registry, useDefaultFilters);
+
+        setEnvironment(environment);
+
+        setResourceLoader(resourceLoader);
+
+        registerAnnotationConfigProcessors(registry);
+
+    }
+
+    public RpcfxClassPathBeanDefinitionScanner(BeanDefinitionRegistry registry, Environment environment,
+                                               ResourceLoader resourceLoader) {
+
+        this(registry, false, environment, resourceLoader);
+
+    }
+
+    @Override
+    public Set<BeanDefinitionHolder> doScan(String... basePackages) {
+        return super.doScan(basePackages);
+    }
+
+    @Override
+    public boolean checkCandidate(String beanName, BeanDefinition beanDefinition) throws IllegalStateException {
+        return super.checkCandidate(beanName, beanDefinition);
+    }
+
+}

07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/api/annotation/RpcfxComponentScan.java

@@ -0,0 +1,42 @@
+package io.kimmking.rpcfx.api.annotation;
+
+import org.springframework.context.annotation.Import;
+
+import java.lang.annotation.*;
+
+@Target(ElementType.TYPE)
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+@Import(RpcfxComponentScanRegistrar.class)
+public @interface RpcfxComponentScan {
+
+    /**
+     * Alias for the {@link #basePackages()} attribute. Allows for more concise annotation
+     * declarations e.g.: {@code @DubboComponentScan("org.my.pkg")} instead of
+     * {@code @DubboComponentScan(basePackages="org.my.pkg")}.
+     *
+     * @return the base packages to scan
+     */
+    String[] value() default {};
+
+    /**
+     * Base packages to scan for annotated @Service classes. {@link #value()} is an
+     * alias for (and mutually exclusive with) this attribute.
+     * <p>
+     * Use {@link #basePackageClasses()} for a type-safe alternative to String-based
+     * package names.
+     *
+     * @return the base packages to scan
+     */
+    String[] basePackages() default {};
+
+    /**
+     * Type-safe alternative to {@link #basePackages()} for specifying the packages to
+     * scan for annotated @Service classes. The package of each class specified will be
+     * scanned.
+     *
+     * @return classes from the base packages to scan
+     */
+    Class<?>[] basePackageClasses() default {};
+
+}

07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/api/annotation/RpcfxComponentScanRegistrar.java

@@ -0,0 +1,60 @@
+package io.kimmking.rpcfx.api.annotation;
+
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.beans.factory.support.AbstractBeanDefinition;
+import org.springframework.beans.factory.support.BeanDefinitionBuilder;
+import org.springframework.beans.factory.support.BeanDefinitionReaderUtils;
+import org.springframework.beans.factory.support.BeanDefinitionRegistry;
+import org.springframework.context.annotation.ImportBeanDefinitionRegistrar;
+import org.springframework.core.annotation.AnnotationAttributes;
+import org.springframework.core.type.AnnotationMetadata;
+import org.springframework.util.ClassUtils;
+
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.LinkedHashSet;
+import java.util.Set;
+
+import static org.springframework.beans.factory.support.BeanDefinitionBuilder.rootBeanDefinition;
+
+public class RpcfxComponentScanRegistrar implements ImportBeanDefinitionRegistrar {
+
+    @Override
+    public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry) {
+
+        Set<String> packagesToScan = getPackagesToScan(importingClassMetadata);
+
+        registerServiceAnnotationBeanPostProcessor(packagesToScan, registry);
+
+        //registerCommonBeans(registry);
+    }
+
+    private void registerServiceAnnotationBeanPostProcessor(Set<String> packagesToScan, BeanDefinitionRegistry registry) {
+
+        BeanDefinitionBuilder builder = rootBeanDefinition(ServiceAnnotationBeanPostProcessor.class);
+        builder.addConstructorArgValue(packagesToScan);
+        builder.setRole(BeanDefinition.ROLE_INFRASTRUCTURE);
+        AbstractBeanDefinition beanDefinition = builder.getBeanDefinition();
+        BeanDefinitionReaderUtils.registerWithGeneratedName(beanDefinition, registry);
+
+    }
+
+    private Set<String> getPackagesToScan(AnnotationMetadata metadata) {
+        AnnotationAttributes attributes = AnnotationAttributes.fromMap(
+                metadata.getAnnotationAttributes(RpcfxComponentScan.class.getName()));
+        String[] basePackages = attributes.getStringArray("basePackages");
+        Class<?>[] basePackageClasses = attributes.getClassArray("basePackageClasses");
+        String[] value = attributes.getStringArray("value");
+        // Appends value array attributes
+        Set<String> packagesToScan = new LinkedHashSet<String>(Arrays.asList(value));
+        packagesToScan.addAll(Arrays.asList(basePackages));
+        for (Class<?> basePackageClass : basePackageClasses) {
+            packagesToScan.add(ClassUtils.getPackageName(basePackageClass));
+        }
+        if (packagesToScan.isEmpty()) {
+            return Collections.singleton(ClassUtils.getPackageName(metadata.getClassName()));
+        }
+        return packagesToScan;
+    }
+
+}

07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/api/annotation/RpcfxService.java

@@ -0,0 +1,65 @@
+package io.kimmking.rpcfx.api.annotation;
+
+import io.kimmking.rpcfx.api.Filter;
+
+import java.lang.annotation.*;
+
+@Documented
+@Retention(RetentionPolicy.RUNTIME)
+@Target({ElementType.TYPE})
+@Inherited
+public @interface RpcfxService {
+
+    /**
+     * Interface class name, default value is empty string
+     */
+    String interfaceName() default "";
+
+    /**
+     * Service version, default value is empty string
+     */
+    String version() default "";
+
+    /**
+     * Service group, default value is empty string
+     */
+    String group() default "";
+
+    /**
+     * Service mock name, use interface name + Mock if not set
+     */
+    String mock() default "";
+
+    /**
+     * Timeout value for service invocation, default value is 0
+     */
+
+    int timeout() default 0;
+
+    /**
+     * Filters for service invocation
+     *
+     * @see Filter
+     */
+    String[] filter() default {};
+
+    /**
+     * Service owner name
+     */
+    String owner() default "";
+
+    /**
+     * Application spring bean name
+     */
+    String application() default "";
+
+    /**
+     * Module spring bean name
+     */
+    String module() default "";
+
+    /**
+     * Service tag name
+     */
+    String tag() default "";
+}

07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/api/annotation/ServiceAnnotationBeanPostProcessor.java

@@ -0,0 +1,4 @@
+package io.kimmking.rpcfx.api.annotation;
+
+public class ServiceAnnotationBeanPostProcessor {
+}