闲鱼业务代码解耦利器SWAK是如何实现的（内含大量代码）

if(搜商品) {
    if(搜商品A版本) {
        doSomething1();
    }else if(搜商品B版本) {
        doSomething2();
    }
} else if(搜会玩) {
    doSomething3();
} else if(搜用户) {
    if(搜用户A版本) {
        doSomething4();
    }else if(搜用户B版本) {
        doSomething5();
    }
}

/**
 * 1.首先先定义一个接口
 */
@SwakInterface(desc = "组件解析") // 使用注解声明这是一个多实现接口
public interface IPage {
    SearchPage parse(Object data);
}

/**
 * 2.然后编写相应的实现，这个实现可以有很多个，用TAG进行标识
 */
@Component
@SwakTag(tags = {ComponentTypeTag.COMMON_SEARCH})
public class CommonSearchPage implements IPage {
    @Override
    public SearchPage parse(Object data) {
        return null;
    }
}

/**
 * 3.编写Swak路由的入口
 */
@Component
public class PageService {
    @Autowired
    private IPage iPage;

    @SwakSessionAop(tagGroupParserClass = PageTypeParser.class,
        instanceClass = String.class)
    public SearchPage getPage(String pageType, Object data) {
        return iPage.parse(data);
    }
}

/**
 * 4.编写相应的解析类
 */
public class PageTypeParser implements SwakTagGroupParser<String> {
    @Override
    public SwakTagGroup parse(String pageType) {
            // pageType = ComponentTypeTag.COMMON_SEARCH
        return new SwakTagGroup.Builder().buildByTags(pageType);
    }
}

    public Set<Class<?>> getSwakInterface() {
        Reflections reflections = new Reflections(new ConfigurationBuilder()
            .addUrls(ClasspathHelper.forPackage(this.packagePath))
            .setScanners(new TypeAnnotationsScanner(), new SubTypesScanner())
        );
        return reflections.getTypesAnnotatedWith(SwakInterface.class);
    }

@Configuration
public class ProxyBeanDefinitionRegister implements BeanDefinitionRegistryPostProcessor {

    @Override
    public void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry beanDefinitionRegistry) throws BeansException {
        Set<Class> typesAnnotatedWith = getSwakInterface();

        for (Class superClass : typesAnnotatedWith) {
            if (!superClass.isInterface()) {
                continue;
            }

            RootBeanDefinition beanDefinition = new RootBeanDefinition();
            beanDefinition.setBeanClass(SwakInterfaceProxyFactoryBean.class);

            beanDefinition.getPropertyValues().addPropertyValue("swakInterfaceClass", superClass);
            String beanName = superClass.getName();
            beanDefinition.setPrimary(true);
            beanDefinitionRegistry.registerBeanDefinition(beanName, beanDefinition);
        }
    }
}

public class SwakInterfaceProxyFactoryBean implements FactoryBean {
    @Override
    public Object getObject() {
        Enhancer enhancer = new Enhancer();
        enhancer.setSuperclass(this);
        this.clazz = clazz;
        // 这里一般不用new出来，可以把SwakInterfaceProxy也交给Spring进行托管，这里为了表述清晰用new指代一下
        enhancer.setCallback(new SwakInterfaceProxy());
        / 返回代理对象，返回的对象起始就是一个封装了"实体类"的代理类，是实现类的实例。
        return enhancer.create();
    }
}

@Component
@Aspect
public class SwakSessionInterceptor {

    @Pointcut("@annotation(com.taobao.idle.swak.core.aop.SwakSessionAop)")
    public void sessionAop() {
    }


    @Around("sessionAop()&&@annotation(swakSessionAop)")
    public Object execute(ProceedingJoinPoint jointPoint, SwakSessionAop swakSessionAop) {
          // 根据类型获取需要传入Parser的参数
        Class instanceClass = swakSessionAop.instanceClass();
          Object sessionInstance;
          for (Object object : args) {
            if (instanceClass.isAssignableFrom(object.getClass())) {
                sessionInstance = object;
            }
        }

          //通过Parser解析出相应的tagGroup
        Class parserClass = swakSessionAop.tagGroupParserClass();
        SwakTagGroupParser swakTagGroupParser = (SwakTagGroupParser)(parserClass.newInstance());
        SwakTagGroup tagGroup = swakTagGroupParser.parse(sessionInstance);

        try {
            //SwakSessionHolder就是一个储存tagGroup的地方，可以随意实现
            SwakSessionHolder.hold(tagGroup);
            Object object = jointPoint.proceed();
            return object;
        } finally {
            SwakSessionHolder.clear();
        }
    }
}

public class SwakInterfaceProxy implements MethodInterceptor {
    @Override
    public Object intercept(Object o, Method method, Object[] parameters, MethodProxy methodProxy) throws Throwable {
            String interfaceName = clazz.getName();
        SwakTagGroup tagGroup = SwakSessionHolder.getTagGroup();

        // 这里还可以根据tag的优先级配置调整执行顺序，这里就简单取一下
        List<String> tags = tagGroup.getTags();
        Object retResult = null;
        try {
            // 按照优先级依次执行
            for (String tag : tags) {
                // 根据TAG可以获取到实现类的实例
                // 可能第一次用，那么没有实例只有Class，拿Class去Spring容器里找对应的实例
                Object tagImplInstance = getInvokeInstance(tag);
                retResult = method.invoke(tagImplInstance, parameters);
            }
            return retResult;
        } catch (Throwable t) {
            throw t;
        }
    }
}