在嵌入式Jetty中集成Jersey REST服务与Weld CDI的指南

plugins {
    id 'application'
    id 'java'
    id 'eclipse'
}

repositories {
    mavenCentral()
}

dependencies {
    // 日志框架
    implementation 'org.slf4j:slf4j-api:2.0.4'
    implementation 'ch.qos.logback:logback-classic:1.4.5'

    // Jetty 服务器核心与Servlet支持
    implementation 'org.eclipse.jetty:jetty-servlet:11.0.12'
    // Jetty CDI集成模块，关键所在
    implementation 'org.eclipse.jetty:jetty-cdi:11.0.12'

    // Weld Servlet环境核心，提供CDI Servlet生命周期监听器
    implementation 'org.jboss.weld.servlet:weld-servlet-core:4.0.3.Final'

    // Jersey RESTful框架核心与Servlet容器集成
    implementation 'org.glassfish.jersey.containers:jersey-container-servlet-core:3.0.4'
    // Jersey CDI 2.0 SE集成模块，与Weld 4.x版本兼容
    implementation 'org.glassfish.jersey.media:jersey-cdi2-se:3.0.4'
    // Jersey JSON处理支持
    implementation 'org.glassfish.jersey.media:jersey-media-json-jackson:3.0.4'

    // 测试依赖
    testImplementation 'org.junit.jupiter:junit-jupiter:5.7.2'
}

application {
    mainClass = 'it.gym.StartApp'
}

tasks.named('test') {
    useJUnitPlatform()
}

package it.gym;

import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.servlet.ServletContextHandler;
import org.eclipse.jetty.servlet.ServletHolder;
import org.glassfish.jersey.servlet.ServletContainer;
import org.jboss.weld.environment.se.Weld;
import org.jboss.weld.environment.se.WeldContainer;

// 导入正确的CDI集成类
import org.eclipse.jetty.cdi.CdiServletContainerInitializer;
import org.eclipse.jetty.cdi.CdiDecoratingListener;
import org.jboss.weld.environment.servlet.EnhancedListener;

public class StartApp {

    public static void main(String[] args) {
        // 1. 初始化Weld SE容器 (虽然Weld Servlet会接管，但初始化SE容器可以确保BeanManager可用)
        Weld weld = new Weld();
        WeldContainer container = weld.initialize(); // 此处初始化Weld SE容器

        final Server server = new Server(9000);
        final ServletContextHandler context = new ServletContextHandler(
                ServletContextHandler.SESSIONS);
        context.setContextPath("/");

        // 2. 配置Jetty与Weld CDI的集成
        // 设置CDI集成模式为装饰器监听器模式
        context.setInitParameter(
                CdiServletContainerInitializer.CDI_INTEGRATION_ATTRIBUTE,
                CdiDecoratingListener.MODE);
        // 添加Jetty CDI容器初始化器
        context.addServletContainerInitializer(new CdiServletContainerInitializer());
        // 添加Weld增强型监听器，确保Weld在Servlet上下文中的正确生命周期管理
        context.addServletContainerInitializer(new EnhancedListener());

        // 3. 配置Jersey Servlet
        final ServletHolder servletHolder = new ServletHolder(
                ServletContainer.class);
        servletHolder.setInitOrder(1);
        // 指定Jersey扫描JAX-RS资源类的包路径
        servletHolder.setInitParameter(
                "jersey.config.server.provider.packages",
                "it.gym"); // 替换为您的资源类所在的基础包

        context.addServlet(servletHolder, "/rest/*"); // 将Jersey Servlet映射到/rest/*路径

        server.setHandler(context);

        try {
            server.start();
            server.join();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 确保Weld容器在应用关闭时也关闭
            weld.shutdown();
        }
    }
}

package it.gym.rest;

import java.util.List;

import it.gym.dao.GymDAO;
import jakarta.enterprise.context.RequestScoped;
import jakarta.inject.Inject;
import jakarta.ws.rs.GET;
import jakarta.ws.rs.Path;
import jakarta.ws.rs.core.Response;
import jakarta.ws.rs.core.Response.Status;

@Path("/")
@RequestScoped // 标记为请求作用域的CDI Bean
public class GymEndpoint {

    @Inject // 注入GymDAO实例
    private GymDAO gymDAO;

    @GET
    @Path("/test")
    public Response test() {
        List<String> entity = gymDAO.getDevices();
        return Response.status(Status.OK).entity(entity).build();
    }
}

package it.gym.dao;

import java.util.ArrayList;
import java.util.List;

import jakarta.enterprise.context.RequestScoped;

@RequestScoped // 标记为请求作用域的CDI Bean
public class GymDAO {

    public GymDAO() {
        // 构造函数，Weld会负责其生命周期
    }

    public List<String> getDevices() {
        // 模拟数据访问
        List<String> devices = new ArrayList<>();
        devices.add("Device A");
        devices.add("Device B");
        return devices;
    }
}