public interface IBaseHandler {
    /**
     * 獲取處理器類型
     * @return 處理器類型
     */
    int getType();

    /**
     * 處理業(yè)務(wù)
     * @param t 業(yè)務(wù)數(shù)據(jù)
     * @param <T> 業(yè)務(wù)數(shù)據(jù)類型
     */
    <T> void handler(T t);
}

    @Autowired
    private List<IBaseHandler> handlers;
     /**
     * 處理業(yè)務(wù)
     * @param type 業(yè)務(wù)類型
     * @param data 業(yè)務(wù)數(shù)據(jù)
     * @param <T> 業(yè)務(wù)數(shù)據(jù)類型
     */
    public <T> void handle(int type, T data) {
        handlers.stream().filter(handler -> handler.getType() == type).findAny().orElseThrow(() -> {
            // 獲取不到業(yè)務(wù)類對(duì)象時(shí)打印日志并拋出異常
            log.error("Failed to get handler, type:{}", type);
            throw new NoSuchElementException("No such handler");
        }).handler(data);
    }

@Slf4j
public class HandlerManager {
    /**
     * 按照type映射的處理器map
     */
    private static Map<Integer, IBaseHandler> typeHandlerMap = new HashMap<>();
    /**
     * 按照類型映射的處理器map
     */
    private static Map<Class<IBaseHandler>, IBaseHandler> clazzHandlerMap = new HashMap<>();

    /**
     * 初始化方法，項(xiàng)目啟動(dòng)時(shí)調(diào)用該方法來(lái)初始化map
     * @param applicationContext spring 上下文對(duì)象
     */
    public static void init(ApplicationContext applicationContext) {
        List<IBaseHandler> handlers = new ArrayList<>();
        applicationContext.getBeansOfType(IBaseHandler.class).forEach((name, obj) -> handlers.add(obj));
        // 為了方便，兩次循環(huán)構(gòu)建map，一次循環(huán)也可以解決，不過(guò)人為定義的handler數(shù)量不多，一次循環(huán)性能提升不大
        typeHandlerMap = handlers.stream().collect(Collectors.toMap(IBaseHandler::getType, obj -> obj));
        clazzHandlerMap = handlers.stream().collect(Collectors.toMap(obj -> (Class<IBaseHandler>) obj.getClass(), obj -> obj));
    }

    public IBaseHandler getHandlerByType(int type) {
        return Optional.ofNullable(typeHandlerMap.get(type)).orElseThrow(() -> {
            // 獲取不到處理器打印日志并拋出異常
            log.info("Failed to get handler, type:{}", type);
            throw new NoSuchElementException("No such  handler error");
        });
    }

    public IBaseHandler getHandlerByClass(Class<IBaseHandler> clazz) {
        return Optional.ofNullable(clazzHandlerMap.get(clazz)).orElseThrow(() -> {
            // 獲取不到處理器打印日志并拋出異常
            log.info("Failed to get handler, clazz:{}", clazz);
            throw new NoSuchElementException("No such  handler error");
        });
    }


}

/**
 * 項(xiàng)目初始化類
 * 繼承ApplicationContextAware,實(shí)現(xiàn)setApplicationContext，可獲取ApplicationContext來(lái)獲取上下文
 */
@Component
public class ApplicationInit implements ApplicationContextAware {

    @Autowired
    private List<IBaseHandler> handlers;

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        // 調(diào)用處理器工具類初始化方法
        HandlerManager.init(applicationContext);
    }
}