Quarkus 1.2.1中如何实现CDI Bean即时初始化(无@StartUp)
解决Quarkus 1.2.1中无@Startup注解时初始化SQS监听器Bean的方案
针对你使用Quarkus 1.2.1 + Jakarta CDI 2.0.2的场景,由于CDI 2.0尚未引入@Startup注解,这里提供三种可行的方案来让你的SQS监听器Bean在应用启动时立即初始化:
方法1:使用Quarkus自带的@Startup注解
Quarkus本身提供了专属的@io.quarkus.runtime.Startup注解,专门用于标记需要启动时初始化的Bean,无需依赖CDI的注解。直接给你的CustomListener类添加该注解即可:
import io.quarkus.runtime.Startup; import javax.enterprise.context.ApplicationScoped; import javax.inject.Inject; import javax.inject.Named; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @ApplicationScoped @Named("customListener") @Startup // 添加Quarkus启动注解 public class CustomListener implements MessageListener { private static final Logger LOGGER = LoggerFactory.getLogger(CustomListener.class); private final CustomService customService; @Inject public CustomListener( @Named("customService") CustomService customService) { this.customService = customService; } @Override public void onMessage(Message message) { final SQSTextMessage sqsMessage = (SQSTextMessage) message; // 业务逻辑处理 } }
方法2:通过CDI事件观察者触发初始化
如果不想使用Quarkus专属注解,可以利用CDI的事件监听机制,在应用启动时手动获取Bean实例完成初始化:
创建一个启动初始化类:
import javax.enterprise.context.ApplicationScoped; import javax.enterprise.event.Observes; import javax.inject.Inject; import javax.inject.Named; import io.quarkus.runtime.StartupEvent; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @ApplicationScoped public class StartupInitializer { private static final Logger LOGGER = LoggerFactory.getLogger(StartupInitializer.class); @Inject @Named("customListener") CustomListener customListener; // 监听Quarkus启动事件 public void onAppStartup(@Observes StartupEvent event) { // 注入的customListener会在此处被实例化 LOGGER.info("CustomListener已完成启动时初始化"); } }
方法3:通过配置文件指定初始化Bean
在项目的application.properties中添加配置,直接指定需要启动时初始化的Bean全类名:
# 替换为你的CustomListener实际包路径 quarkus.arc.init-at-startup=com.yourpackage.CustomListener
如果有多个Bean需要启动时初始化,用逗号分隔类名即可。
内容的提问来源于stack exchange,提问作者Catalonec
相关产品推荐
相关产品推荐

