You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

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

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.07.04 13:22:05