Springboot启动优化之业务数据异步加载

// BeanInitCostTimeBeanPostProcessor.java
@Slf4j@Componentpublic class BeanInitCostTimeBeanPostProcessor implements BeanPostProcessor {  private static final ConcurrentHashMap<String, Long> START_TIME = new ConcurrentHashMap<>();  @Override  public Object postProcessBeforeInitialization(Object bean, String beanName) {    START_TIME.put(beanName, System.currentTimeMillis());    return bean;  }  @Override  public Object postProcessAfterInitialization(Object bean, String beanName) {    if(Objects.nonNull(START_TIME.get(beanName))) {      log.info("beanName:{}, cost:{}", beanName, System.currentTimeMillis() - START_TIME.get(beanName));    }    return bean;  }}

// SleepBean.java
@Configurationpublic class SleepBean {  @Bean(initMethod = "initWithSleep")  public TestBean testLongTimeBean() {    return new TestBean();  }    public static class TestBean {    public void initWithSleep() throws InterruptedException {      Thread.sleep(10000);    }  }}

// AsyncTestLongTimeBean.java
@Slf4jpublic class AsyncTestLongTimeBean extends SleepBean.TestBean implements FactoryBean<TestBean> {  private AtomicBoolean started = new AtomicBoolean(false);  @Override  public TestBean getObject() throws Exception {    return this;  }  @Override  public Class> getObjectType() {    return SleepBean.TestBean.class;  }    @Override  public void initWithSleep() {    long start = System.currentTimeMillis();    new Thread(() ->  {      try {        super.initWithSleep();      } catch (InterruptedException e) {      }      // 保持操作的原子性      started.compareAndSet(false, true);      log.info("async bean init cost:{} ms", System.currentTimeMillis() - start);    }).start();  }  }
// SleepBean.java 修改@Configurationpublic class SleepBean {  @Bean(initMethod = "initWithSleep")  public TestBean testLongTimeBean() {    return new AsyncTestLongTimeBean();  }    public static class TestBean {    public void initWithSleep() throws InterruptedException {      Thread.sleep(10000);    }  }}