访问ServletContextListener中的会话变量

Question

我正在使用Grails实现上传功能，基本上用户可以上传文本文件，然后系统会将该文本文件的每一行保留为数据库记录。虽然上传工作正常，但较大的文件需要时间来处理，因此他们要求有一个进度条，以便用户可以确定他们的上传是否仍在处理或是否发生了实际错误。

为此，我所做的是创建两个URL：

/upload，它是接收上传文本文件的实际URL。
/upload/status?uploadToken=根据uploadToken返回某个上传的状态。

我所做的是在处理每一行之后，服务将更新会话级计数器变量：

// import ...

class UploadService {
    Map upload(CommonsMultipartFile record, GrailsParameterMap params) {
        Map response = [success: true]

        try {
            File file = new File(record.getOriginalFilename())
            FileUtils.writeByteArrayToFile(file, record.getBytes())
            HttpSession session = WebUtils.retrieveGrailsWebRequest().session
            List<String> lines = FileUtils.readLines(file, "UTF-8"), errors = []
            String uploadToken = params.uploadToken

            session.status.put(uploadToken,
                [message: "Checking content of the file of errors.",
                    size: lines.size(),
                    done: 0])

            lines.eachWithIndex { l, li ->
                // ... regex checking per line and appending any error to the errors List

                session.status.get(uploadToken).done++
            }

            if(errors.size() == 0) {
                session.status.put(uploadToken,
                    [message: "Persisting record to the database.",
                        size: lines.size(),
                        done: 0])

                lines.eachWithIndex { l, li ->
                    // ... Performs GORM manipulation here

                    session.status.get(uploadToken).done++
                }           
            }
            else {
                response.success = false
            }
        }
        catch(Exception e) {
            response.success = false
        }

        response << [errors: errors]

        return response
    }
}

然后创建一个连接到simple WebSocket implementation URL的/upload/status?uploadToken=。问题是我无法访问POGO上的会话变量。我甚至将POGO改为Grails服务，因为我认为这是问题的原因，但我仍然无法访问会话变量。

// import ...

@ServerEndpoint("/upload/status")
@WebListener
class UploadEndpointService implements ServletContextListener {    
    @OnOpen
    public void onOpen(Session userSession) { /* ... */ }

    @OnClose
    public void onClose(Session userSession, CloseReason closeReason) { /* ... */ }

    @OnError
    public void onError(Throwable t) { /* ... */ }

    @OnMessage
    public void onMessage(String token, Session userSession) {
        // Both of these cause IllegalStateException
        def session = WebUtils.retrieveGrailsWebRequest().session
        def session = RequestContextHolder.currentRequestAttributes().getSession()

        // This returns the session id but I don't know what to do with that information.
        String sessionId = userSession.getHttpSessionId() 

        // Sends the upload status through this line    
        sendMessage((session.get(token) as JSON).toString(), userSession)
    }

    private void sendMessage(String message, Session userSession = null) {
        Iterator<Session> iterator = users.iterator()
        while(iterator.hasNext()) {
            iterator.next().basicRemote.sendText(message)
        }
    }
}

相反，给我一个错误：

由IllegalStateException引起：未找到线程绑定请求：您是指在实际Web请求之外的请求属性，还是在最初接收线程之外处理请求？如果您实际在Web请求中操作并仍然收到此消息，则您的代码可能在DispatcherServlet / DispatcherPortlet之外运行：在这种情况下，请使用RequestContextListener或RequestContextFilter来公开当前请求。

我已经通过发送静态String内容验证了Web套接字正在工作。但我想要的是能够获得该计数器并将其设置为发送消息。我正在使用Grails 2.4.4和Grails Spring Websocket插件，虽然看起来很有前途，但只能从Grails 3开始使用。有没有办法实现这个目标，或者如果没有，我应该采用什么方法？