spring获取注册的bean并注册到自定义工厂中管理

背景

        在开发的时候，对于同一个对象的按照某个字段的不同有很多的处理方式。想着开发一个类似于工厂模式，由上层工厂统一分配。

        由于是基于springboot开发，所以有很多自动注入的对象，如果由工厂统一创建new对象的方式，那new出来的对象无法获取自动注入的对象的。所以需要通过从springboot中获取对象方法。获取到自动注入的对象。

实现

抽象类：

public interface AbstractService {/*** 事件处理器，各个处理器需要实现这个方法* @return 处理结果*/public BaseRes<String> dealEvent(Object obj){};}

管理类：

public class HandlerManager{private static Map<String, List<Class<? extends AbstractService>>> executeService = new HashMap<>();/*** 注册处理器* @param command 命令* @param abstractServices 服务*/public static void register(String command, Class<? extends AbstractService> clazz){List<NorthEventService> abstractServices = executeService.get(command);if(CollectionUtils.isEmpty(abstractServices)){abstractServices = new ArrayList<>();abstractServices.put(command, obj);}northEventServices.add(clazz);}/*** 处理器选择入口，通过传入命令和参数来实现* @param command* @return*/public List<BaseRes<String>> dealByCommand(String command, Object obj){List<Class<? extends AbstractService>> abstractServiceClazzs = executeService.get(command);if(CllectionUtils.isEmpty(abstractServiceClazzs)){defaultDealEvent(command, obj);retrun BaseRep.error();}List<BaseRes<String>> responses = new ArrayList<>();for(Class<? extends AbstractService> clazz : abstractServices){AbstractService abstractService = SpringContextUtil.getBean(clazz);if(abstractService == null) {LOGGER.info("指令[{}]的处理器没有注册到容器中");try {//利用这种方式构建的对象如果，类中使用了自动注入的会失败abstractService = clazz.newInstance();} catch (Exception e) {LOGGER.error("反射构建处理器失败", e);throw new RuntimeException(e);}}BaseRes<String> baseResponse = abstractService.dealEvent(obj);responses.add(baseResponse);}return responses;}/*** 默认的处理方式*/private BaseRes<String> defaultDeal(String command, Object obj){LOGGER.error("没有指定命令[{}]的事件的处理器, 参数:{}", command, JSON.toJSONString(obj));}
}

实现类：

        通过初始化后，自动向工厂管理类注册自己，SpringContextConfig.getBean()获取自己在spring中注册的类。这样才能让@Autowired的属性被初始化。

@Component
public class MyService implements AbstractService{@Autowiredprivate TestService testService;@Autowiredprivate TestService1 testService1;@PostConstructprivate void afterInstance(){LOGGER.info("自定义事件处理器注册:{}", MyService.class.getName());//这里不能使用new MyService的方式。否则 @Autowired 注解的属性无法初始化//这里通过 pringContextConfig.getBean() 从容器中获取自动注入的对象HandlerManager.register(”MY-TEST-COMMAND“, MyService.class);}@Overridepublic BaseRes<String> dealEvent(Object obj) {return null;}
}

       注意：在使用@PostConstruct的时候需要加上注解@Component，这也是SpringContextConfig.getBaen()能获取到spring中自身注册的对象的必要条件。

        其他的实现类操作方式，这样我们的事件只需要通过AbstractService的dealByCommand()方法就能得到处理方法。