Solon2 开发之容器，三、注入或手动获取 Bean

1、如何注入Bean？

先了解一下Bean生命周期的简化版：

1. 运行构建函数
2. 尝试字段注入（有时同步注入，没时订阅注入。不会有相互依赖而卡住的问题）
3. @Init 函数（是在容器初始化完成后才执行）
4. …
5. 释放（基本不会发生）

了解这个生命过程后，可以知道注入的内容，在构建函数里是不可用的：

@Service
public class DemoService{//通过bean type注入（注入是异步的，不能在构造函数里使用）@Injectprivate TrackService trackService;//通过bean name注入@Inject("userService")private UserService userService;public DemoService(){//注入的Bean，不能在构造函数里使用。在生命周期时，构建先于注入}@Initpublic void init(){//注入的Bean，需要进一步做初始化，请在处理}
}

引用已有 Bean 构建新的 Bean：

@Configuration
public class DemoConfig{//提示：@Bean 只能与 @Configuration 配合@Bean("ds3") public DataSource init(@Inject("ds1") DataSource ds1, @Inject("ds2") DataSource ds2){Map<String, DataSource> dsMap = new HashMap<>();dsMap.put("ds1", ds1);dsMap.put("ds2", ds2);DynamicDataSource tmp = new DynamicDataSource();tmp.setStrict(true);tmp.setTargetDataSources(dsMap);tmp.setDefaultTargetDataSource(ds1);return tmp;}
}

2、如何手动获取Bean？

• 同步获取

public class DemoService{private TrackService trackService;private UserService userService;public DemoService(){//同步方式，根据bean type获取Bean（如果此时不存在，则返回null。需要注意时机）trackService = Solon.context().getBean(TrackService.class);//同步方式，根据bean type获取Bean（如果此时不存在，自动生成一个Bean并注册+返回）trackService = Solon.context().getBeanOrNew(TrackService.class);//同步方式，根据bean name获取Bean（如果此时不存在，则返回null）userService = Solon.context().getBean("userService");}
}

• 异步获取（如果存在，会直接回调；如果没有，目标产生时会通知回调）

public class DemoService{private TrackService trackService;private UserService userService;public DemoService(){//异步订阅方式，根据bean type获取Bean（已存在或产生时，会通知回调；否则，一直不回调）Solon.context().getBeanAsync(TrackService.class, bean-> {trackService = bean;//bean 获取后，可以做些后续处理。。。});//异步订阅方式，根据bean name获取BeanSolon.context().getBeanAsync("userService", bean-> {userService = bean;});}
}

注入模式是必须要被扫描到的。有时候不方便扫描，或者不必扫描，那手动模式就是很大的一种自由。

3、获取一批有特征的Bean？

• 通过订阅接口

context.subBeansOfType(DataSource, bean->{//获取所有 DataSource Bean//一般由：@Component 产生 或者 @Configuration + @Bean 产生
});context.subWarpsOfType(DataSource, bw->{// bw.name() 获取 bean name // bw.get() 获取 bean//一般由：@Component 产生 或者 @Configuration + @Bean 产生
});

• 通过容器加载完成事件 beanOnloaded ，遍历已注册的 Bean

//在 beanOnloaded 事件进进行遍历，确保所有 Bean 已处理完成//a. 获取 name "share:" 开头的 bean  //context:AopContext
context.beanOnloaded((ctx) -> {ctx.beanForeach((k, v) -> {if (k.startsWith("share:")) {render.putVariable(k.split(":")[1], v.raw());}});
});//b. 获取 IJob 类型的 bean  //context:AopContext
context.beanOnloaded((ctx) -> {ctx.beanForeach((v) -> {if (v.raw() instanceof IJob) {JobManager.register(new JobEntity(v.name(), v.raw()));}});
});