// 貧血模型的典型實(shí)現(xiàn)
public class Order {
    @Autowired
    private PaymentService paymentService; // 違反單一職責(zé)原則
    
    public void pay() {
        paymentService.process(this);
    }
}

@Primary
publicclass SpringContext implements ApplicationContextAware, PriorityOrdered, ApplicationRunner {
    privatestatic ApplicationContext applicationContext;
    // 初始化完成的信號(hào)
    privatestaticfinal CountDownLatch INITIALIZATION_LATCH = new CountDownLatch(1);

    @Override
    public void run(ApplicationArguments args) throws Exception {
        // 通知等待的線程初始化已完成
        INITIALIZATION_LATCH.countDown();
    }

    public void setApplicationContext(ApplicationContext applicationContext) {
        SpringContext.applicationContext = applicationContext;
    }

    publicstatic <T> T getBean(Class<T> clazz) {
        return applicationContext.getBean(clazz);
    }

    // 獲取Bean，需等待應(yīng)用完全啟動(dòng)
    publicstatic <T> T getBeanSync(Class<T> clazz) {
        try {
            // 阻塞等待初始化完成，最多等待 1 分鐘
            if (!INITIALIZATION_LATCH.await(1, TimeUnit.MINUTES)) {
                thrownew IllegalStateException("應(yīng)用初始化超時(shí)");
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            thrownew RuntimeException("獲取Bean時(shí)線程被中斷", e);
        }
        return applicationContext.getBean(clazz);
    }

    @Override
    public int getOrder() {
        return PriorityOrdered.HIGHEST_PRECEDENCE;
    }

}

public class Order {
    private Long orderId;
    private BigDecimal amount;
    private OrderStatus status;

    // 保持領(lǐng)域模型的純潔性
    public void pay() {
        PaymentService paymentService = SpringContext.getBean(PaymentService.class);
        PaymentResult result = paymentService.execute(this);
        
        if (result.isSuccess()) {
            this.status = OrderStatus.PAID;
            DomainEventPublisher.publish(new OrderPaidEvent(this));
        }
    }
}

public class AsyncBeanAccessor {
    public static <T> Mono<T> getBeanReactive(Class<T> beanClass) {
        return Mono.fromCallable(() -> SpringContext.getBean(beanClass)).subscribeOn(Schedulers.boundedElastic());
    }
}

@Test
public void testOrderPayment() {
    // 配置Mock環(huán)境
    SpringContextMock.registerMock(PaymentService.class, mockService);
    
    Order order = new Order(/*...*/);
    order.completePayment();
    
    assertThat(order.getStatus()).isEqualTo(PAID);
}