Jetty、Jersey与Weld：构建嵌入式Java REST应用

plugins {
    id 'application'
    id 'java'
    id 'eclipse' // 可选，用于生成Eclipse项目文件
}

repositories {
    mavenCentral()
}

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

    // Jetty 嵌入式服务器
    implementation 'org.eclipse.jetty:jetty-servlet:11.0.12'
    implementation 'org.eclipse.jetty:jetty-cdi:11.0.12' // 关键：Jetty的CDI集成模块

    // Weld CDI 实现
    implementation 'org.jboss.weld.servlet:weld-servlet-core:4.0.3.Final' // Weld Servlet集成核心

    // Jersey JAX-RS 实现
    implementation 'org.glassfish.jersey.containers:jersey-container-servlet-core:3.0.4'
    implementation 'org.glassfish.jersey.media:jersey-cdi2-se:3.0.4' // 关键：Jersey与CDI的集成模块
    implementation 'org.glassfish.jersey.media:jersey-media-json-jackson:3.0.4' // JSON支持

    // 测试依赖 (可选)
    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.cdi.CdiDecoratingListener;
import org.eclipse.jetty.cdi.CdiServletContainerInitializer;
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.servlet.EnhancedListener;

public class StartApp {

    public static void main(String[] args) {
        // 1. 创建Jetty服务器实例，监听端口
        final Server server = new Server(9000);

        // 2. 创建ServletContextHandler，用于配置Servlet和上下文路径
        final ServletContextHandler context = new ServletContextHandler(ServletContextHandler.SESSIONS);
        context.setContextPath("/"); // 设置根上下文路径

        // 3. 关键步骤：正确集成Weld CDI与Jetty
        // 使用CdiServletContainerInitializer和EnhancedListener进行CDI集成
        // 这是Weld推荐的与Jetty 11+集成的方式，它能自动发现和管理CDI Bean
        context.setInitParameter(
                CdiServletContainerInitializer.CDI_INTEGRATION_ATTRIBUTE,
                CdiDecoratingListener.MODE);
        context.addServletContainerInitializer(new CdiServletContainerInitializer());
        context.addServletContainerInitializer(new EnhancedListener());

        // 4. 配置Jersey ServletContainer
        final ServletHolder servletHolder = new ServletHolder(ServletContainer.class);
        servletHolder.setInitOrder(1); // 确保Servlet在启动时初始化

        // 告知Jersey扫描哪些包来查找JAX-RS资源类
        servletHolder.setInitParameter(
                "jersey.config.server.provider.packages",
                "it.gym.rest"); // 替换为你的REST资源类所在的包

        // 5. 将Jersey Servlet添加到上下文，并设置URL映射
        context.addServlet(servletHolder, "/rest/*"); // 所有/rest/*的请求都由Jersey处理

        // 6. 设置Jetty服务器的处理器
        server.setHandler(context);

        // 7. 启动Jetty服务器
        try {
            server.start();
            server.join(); // 阻塞主线程，直到服务器停止
        } catch (Exception e) {
            e.printStackTrace();
            System.exit(1); // 启动失败时退出应用
        } finally {
            // 确保服务器在应用关闭时停止
            if (server.isRunning()) {
                try {
                    server.stop();
                } catch (Exception e) {
                    System.err.println("Error stopping Jetty server: " + e.getMessage());
                }
            }
        }
    }
}

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 // JAX-RS资源类默认是单例，但在此处声明为请求作用域，以便CDI管理其生命周期
public class GymEndpoint {

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

    @GET // 处理HTTP GET请求
    @Path("/test") // 映射到 /rest/test 路径
    public Response test() {
        List<String> entity = gymDAO.getDevices(); // 调用注入的DAO方法
        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; // 声明为请求作用域的CDI Bean

@RequestScoped
public class GymDAO {

    public GymDAO() {
        // 构造函数，CDI容器在创建实例时调用
    }

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

gradle run

http://localhost:9000/rest/test

["Device A", "Device B"]