使用spring动态获取接口的不同实现类

public Object saveANews() {

     //1、获取A接口新闻列表

     //2、和缓存对比，存数据到数据库

}

public Object saveBNews() {

     //1、获取B新闻列表

     //2、和缓存对比，存数据到数据库

}

//业务接口实现方法

public Object saveNews(NewsUtilService service) {

     //1、获取接口新闻列表

     List<NewsVO> list = service.queryNews();

     //2、和缓存对比，存数据到数据库

}

//定义新闻数据接口

public interface NewsUtilService {

     List<NewsVO> queryNews();

}

//接口的两个实现类

@Service

public class ANewsDataServiceImpl implements NewsUtilService {

     @Autowired

     private NewsDataMapper newsDataMapper;

     @Override

     public List<NewsVO> queryNews(){

         //对接数据

     }

}

@Service

public class BNewsDataServiceImpl implements NewsUtilService {

     @Override

     public List<NewsVO> queryNews(){

         //对接数据

     }

}

//定义工厂类

@Service

public class NewsUtilServiceFactory {  

     /**

      *

      * Method Name:  getNewsUtilService

      * @param source

      * @return

      */

     public NewsUtilService getNewsUtilService(String source){

         switch (source){

             case "a" :

                 return new ANewsDataServiceImpl();

             case "b" :

                 return new BNewsDataServiceImpl();

             default :

                 return null ;

         }

     }

}

//控制层调用

@RestController

public class NewsDataController {

     @Resource

     private NewsDataService newsDataService;

     @Resource

     private NewsUtilServiceFactory factory;

     public Object getNewsData(){

         String[] sources = { "a" , "b" };

             for ( int i = 0 ; i < sources.length; i++) {

                 NewsUtilService newsUtilService = factory.getNewsUtilService(sources[i]);

                 newsDataService.saveNews(newsUtilService);

             }

     }

}

//定义工厂类

@Service

public class NewsUtilServiceFactory {  

     @Autowired

     private ANewsDataServiceImpl aNewsDataServiceImpl;

     @Autowired

     private BNewsDataServiceImpl bNewsDataServiceImpl;

     public NewsUtilService getNewsUtilService(String source){

         switch (source){

             case "a" :

                 return aNewsDataServiceImpl;

             case "b" :

                 return bNewsDataServiceImpl;

             default :

                 return null ;

         }

     }

}

@Service

public class NewsUtilServiceFactory {  

     @Autowired

     private ApplicationContext applicationContext; 

     public NewsUtilService getNewsUtilService(String source){

         switch (source){

             case "web" :

                 return applicationContext.getBean(WebNewsDataServiceImpl. class );

             case "oa" :

                 return applicationContext.getBean(OANewDataServiceImpl. class );

             default :

                 return null ;

         }

     }

}

package com.yang.config;

import com.yang.workOrder.service.IRootService;

import org.springframework.beans.BeansException;

import org.springframework.context.ApplicationContext;

import org.springframework.context.ApplicationContextAware;

import org.springframework.stereotype.Component;

import java.util.Map;

/**

  * explain：获取应用上下文并获取相应的接口实现类

  *

  * @author yang

  * @date 2021/1/5

  */

@Component

public class ServiceLocator implements ApplicationContextAware {

     /**

      * 用于保存接口实现类名及对应的类

      */

     private Map<String, IRootService> map;

     /**

      * 获取应用上下文并获取相应的接口实现类

      * @param applicationContext

      * @throws BeansException

      */

     @Override

     public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {

         //根据接口类型返回相应的所有bean

         map = applicationContext.getBeansOfType(IRootService. class );

     }

     /**

      * 获取所有实现集合

      * @return

      */

     public Map<String, IRootService> getMap() {

         return map;

     }

     /**

      * 获取对应服务

      * @param key

      * @return

      */

     public IRootService getService(String key) {

         return map.get(key);

     }

}

package com.yang.workOrder.service;

import com.alibaba.fastjson.JSONObject;

import com.yang.workOrder.entity.WorkOrder;

/**

  * explain：基础流程操作服务接口

  *

  * @author yang

  * @date 2021/1/5

  */

public interface IRootService {

     /**

      * 开始流程

      * @param workOrder

      * @return

      */

     boolean startProcess(WorkOrder workOrder);

}

package com.yang.workOrder.service.impl;

import com.alibaba.fastjson.JSONObject;

import com.yang.workOrder.entity.WorkOrder;

import com.yang.workOrder.service.IRootService;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.stereotype.Service;

/**

  * explain：A_001流程审批实现类

  *

  * @author yang

  * @date 2021/1/5

  */

@Service ( "A_001" )

public class RootA001ServiceImpl implements IRootService {

     private static final Logger LOGGER = LoggerFactory.getLogger(RootA001ServiceImpl. class );

     @Override

     public boolean startProcess(WorkOrder workOrder) {

         return false ;

     }

}

package com.yang.workOrder.service.impl;

import com.alibaba.fastjson.JSONObject;

import com.yang.workOrder.entity.WorkOrder;

import com.yang.workOrder.service.IRootService;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.stereotype.Service;

/**

  * explain：A_002流程审批实现类

  *

  * @author yang

  * @date 2021/1/5

  */

@Service ( "A_002" )

public class RootA002ServiceImpl implements IRootService {

     private static final Logger LOGGER = LoggerFactory.getLogger(RootA002ServiceImpl. class );

     @Override

     public boolean startProcess(WorkOrder workOrder) {

         return false ;

     }

}