Grails 3应用中长耗时进程完成后向客户端反馈的方案咨询

嘿，这个场景我太熟悉了——长耗时任务的异步处理+客户端通知确实是Web开发里的经典痛点，除了你提到的WebSocket，还有几个更贴合不同场景的方案，我结合Grails 3的特性给你拆解下：

1. 轮询（Polling）：最简单的兼容方案 #

这是门槛最低的实现方式，完全不用改现有架构的核心逻辑：

• 思路：客户端定期（比如每5秒）发送HTTP请求到Grails后端，查询任务的执行状态和结果。
• Grails实现步骤：
  • 创建一个TaskStatus域类，存储任务ID、状态（pending/running/completed/failed）、执行结果、进度等信息。
  • 在启动长耗时任务时，生成唯一的taskId，初始化一条TaskStatus记录并返回给客户端。
  • 写一个控制器方法，比如getStatus(String taskId)，根据ID查询并返回任务状态。
  • 客户端用setInterval定时调用这个接口，直到拿到完成状态。
• 优缺点：
  • ✅ 实现简单，兼容性拉满（老浏览器也支持），不需要额外依赖。
  • ❌ 存在冗余请求，实时性差，适合任务耗时在几分钟内的场景。

2. Server-Sent Events（SSE）：轻量的单向推送方案 #

如果只需要服务器给客户端发通知（不需要客户端反向发消息），SSE是比WebSocket更轻量的选择，基于HTTP协议，不用额外端口：

• 思路：客户端和服务器建立一个长连接，服务器通过这个连接主动推送任务状态更新。
• Grails实现步骤：
  • 用Spring的SseEmitter来实现，在控制器里写一个接口：

    // 用ConcurrentHashMap存储任务ID和对应的Emitter，注意线程安全
    private final Map<String, SseEmitter> taskEmitters = new ConcurrentHashMap<>()
    
    def subscribeTaskStatus(String taskId) {
        SseEmitter emitter = new SseEmitter(Long.MAX_VALUE) // 设置超时时间
        taskEmitters.put(taskId, emitter)
    
        // 连接完成或超时后清理资源
        emitter.onCompletion { taskEmitters.remove(taskId) }
        emitter.onTimeout {
            emitter.completeWithError(new IOException("连接超时"))
            taskEmitters.remove(taskId)
        }
    
        return emitter
    }
    

  • 长耗时任务完成时，从taskEmitters中取出对应的发射器，发送完成事件：

    def notifyTaskCompleted(String taskId, Map result) {
        SseEmitter emitter = taskEmitters.get(taskId)
        if (emitter) {
            emitter.send(SseEmitter.event()
                    .name("taskCompleted")
                    .data(result, MediaType.APPLICATION_JSON))
            emitter.complete() // 关闭连接
        }
    }
    

• 优缺点：
  • ✅ 实现比WebSocket简单，基于HTTP，无需额外配置，实时性接近WebSocket。
  • ❌ 仅支持单向通信，IE浏览器不兼容，适合纯服务器推送的场景。

3. 异步任务+Webhook：超长时间任务的最优解 #

如果任务耗时长达几小时，且客户端是服务端（或能暴露公网可访问的回调接口），Webhook是最省心的方案：

• 思路：客户端在提交任务时，提供一个回调URL；服务器完成任务后，主动调用这个URL推送结果。
• Grails实现步骤：
  • 用Grails的异步任务机制（@Async注解或grails.async.Promises）启动长耗时任务。
  • 任务完成后，用Grails的RestBuilder或Spring的RestTemplate调用客户端提供的Webhook URL：

    @Async
    def executeLongTask(String taskId, String webhookUrl) {
        // 执行长耗时任务逻辑...
        def result = [taskId: taskId, status: "completed", data: ...]
        // 调用Webhook
        new RestBuilder().post(webhookUrl) {
            contentType MediaType.APPLICATION_JSON
            json result
        }
    }
    

• 优缺点：
  • ✅ 完全不需要客户端保持连接或轮询，适合超长时间任务，资源占用低。
  • ❌ 客户端必须提供公网可访问的回调接口，浏览器端实现起来较麻烦（需借助后端中转）。

和WebSocket的对比 #

WebSocket是双向通信的方案，实时性最好，适合需要频繁双向交互的场景（比如任务进度实时更新+客户端中途取消任务），但实现复杂度更高，需要处理连接管理、断线重连、心跳检测等问题。Grails 3可以通过Spring WebSocket或grails-spring-websocket插件来实现。

方案选择建议 #

• 快速实现、兼容老系统 → 轮询
• 纯服务器推送、中等实时性需求 → SSE
• 超长时间任务、客户端是服务端 → Webhook
• 需要双向交互、高实时性 → WebSocket

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