如何在Java Servlet中异步执行.exe程序并返回进程标识Token？

刚好做过类似的需求，给你一套落地的实现思路和代码，亲测能用：

核心逻辑拆解 #

• 用Servlet的**异步上下文（AsyncContext）**避免请求线程被阻塞，启动.exe后立刻给客户端返回Token，不用等进程跑完
• 生成唯一Token和每个启动的进程绑定，用线程安全的容器存起来，方便后续查询
• 额外做一个查询接口，让客户端能通过Token查进程是否完成

具体代码实现 #

1. 全局进程跟踪工具类 #

先整个工具类，专门管Token和进程的映射，保证多线程下安全：

import java.util.Map;
import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;

public class ProcessTracker {
    // 用ConcurrentHashMap保证线程安全，存储Token与Process的对应关系
    private static final Map<String, Process> PROCESS_REGISTRY = new ConcurrentHashMap<>();

    // 注册进程并生成唯一Token
    public static String bindProcessToToken(Process process) {
        // 生成不带横杠的UUID作为Token，简洁好传递
        String uniqueToken = UUID.randomUUID().toString().replace("-", "");
        PROCESS_REGISTRY.put(uniqueToken, process);
        return uniqueToken;
    }

    // 根据Token查询进程是否已完成
    public static boolean isProcessFinished(String token) {
        Process targetProcess = PROCESS_REGISTRY.get(token);
        if (targetProcess == null) {
            return true; // 没找到则视为已完成或无效Token
        }
        try {
            // 调用exitValue()若抛出异常，说明进程还在运行；否则已结束
            int exitCode = targetProcess.exitValue();
            // 进程结束后从容器移除，避免内存泄漏
            PROCESS_REGISTRY.remove(token);
            return true;
        } catch (IllegalThreadStateException e) {
            // 异常表明进程仍在运行
            return false;
        }
    }
}

2. 主Servlet实现 #

这个Servlet同时处理启动和查询两个动作，记得开启异步支持：

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.AsyncContext;
import java.io.IOException;

@WebServlet(urlPatterns = "/videomanager", asyncSupported = true)
public class VideoManagerServlet extends HttpServlet {

    @Override
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        String action = request.getParameter("action");
        if ("process".equals(action)) {
            // 开启异步上下文，这是不阻塞请求的核心
            AsyncContext asyncCtx = request.startAsync();
            // 设置超时时间（如30秒），防止异步线程长期占用资源
            asyncCtx.setTimeout(30000);

            // 新开线程启动.exe，避免占用请求线程
            new Thread(() -> {
                Process exeProcess = null;
                try {
                    // 替换为你的.exe实际路径和参数，比如视频处理工具
                    ProcessBuilder processBuilder = new ProcessBuilder("D:\\tools\\your-app.exe", "input.mp4", "output.mp4");
                    exeProcess = processBuilder.start();

                    // 绑定进程与Token，拿到返回给客户端的标识
                    String processToken = ProcessTracker.bindProcessToToken(exeProcess);

                    // 向客户端返回Token
                    response.setContentType("text/plain;charset=utf-8");
                    response.getWriter().write("token=" + processToken);
                } catch (IOException e) {
                    // 启动失败时返回明确错误信息
                    e.printStackTrace();
                    try {
                        response.getWriter().write("error: 启动.exe失败，请检查路径和权限");
                    } catch (IOException ex) {
                        ex.printStackTrace();
                    }
                } finally {
                    // 必须调用complete()结束异步上下文
                    asyncCtx.complete();
                    // 绝对不能调用exeProcess.waitFor()，否则会再次阻塞线程！
                }
            }).start();
        } else if ("check".equals(action)) {
            // 处理查询请求，客户端传入Token查询进程状态
            String token = request.getParameter("token");
            boolean isFinished = ProcessTracker.isProcessFinished(token);
            response.setContentType("text/plain;charset=utf-8");
            response.getWriter().write(isFinished ? "completed" : "running");
        } else {
            // 非法参数返回提示
            response.setContentType("text/plain;charset=utf-8");
            response.getWriter().write("无效的action参数，请传入process或check");
        }
    }
}

必看的注意事项 #

• 异步Servlet配置：@WebServlet里必须加asyncSupported = true，否则无法开启异步上下文，会直接报错
• 线程安全：绝对不能用普通HashMap存储进程，必须用ConcurrentHashMap，避免多用户并发请求时出现数据异常
• 资源清理：进程结束后要从容器中移除，防止内存泄漏；也可以添加定时任务，定期清理已结束的进程
• 权限问题：服务器运行Servlet的用户必须拥有该.exe的执行权限，比如Windows下给Tomcat用户加权限，Linux下给文件加chmod +x权限
• 超时设置：异步上下文的超时一定要配置，否则如果启动进程的线程出错，请求会一直挂起占用资源
• 异常处理：启动进程时的IO异常必须捕获，否则客户端会收到500错误，影响体验

测试步骤 #

1. 启动Servlet容器（如Tomcat），访问http://server:8080/videomanager?action=process，会立刻收到类似token=7a2f9d4c1e8b3650的响应
2. 访问http://server:8080/videomanager?action=check&token=7a2f9d4c1e8b3650，会返回running或completed，对应进程的实时状态

内容的提问来源于stack exchange，提问作者Xtian_DM