0

我需要在服务器中保留我的请求，直到新数据到来。我使用Tomcat 6 作为我的 Web 服务器。这是我的JQuery代码，

function sendMessage() {

    var message = $("#message").val();
    $.ajax({
        type: "POST",
        cache: false,
        url: "sendMessage.html",
        data: "message=" + message,
        dataType: "html",

        success: function(response) {

        },
        error: function(e) {
            //alert('Error: ' + e);
        },
    });
}


function startLongPolling(){

    $.ajax({
        type: "POST",
        cache: false,
        url: "LongPoll.html",
        dataType: "html",
        success: function(response) {   
            if(response != null && response !="" && response !="null")
                $("#sucess").html(response);
        },
        error: function(e) {
            //alert('Error: ' + e);
        },

        complete: function(e) {
            startLongPolling();
        },
    });
}

我的Java代码将是，

@RequestMapping(value = "LongPoll.html", method=RequestMethod.POST )
public @ResponseBody String longLongPolling(HttpSession session) {

    String sessionId = session.getId().toString();
    AgentState agentState = ApplicaionManager.agentDetail.get(sessionId);
    String message = null;

    if(ApplicaionManager.agentDetail.containsKey(sessionId)){

        while(true){

            if(agentState.isStateChange() == true){
                message = agentState.getMessage();
                if(message != null)
                    agentState.setStateChange(false);
                System.out.println("Break for session "+sessionId+" due to Agent State changed");
                break;
            }

            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
    System.out.println("While exited for session"+sessionId);
    return message;
}

但是continous request sent to server每11 秒有一个。我不知道怎么可能。我已经用chrome 开发者工具检查了这个。

在此处输入图像描述

希望我们的堆栈用户能帮助我。

4

1 回答 1

2

这是正常/预期的。根据您的浏览器和（尤其是）前端服务器（Apache/NGINX）和网络服务器（Tomcat？）配置，您将拥有：

  • 第一个响应的最大等待时间（连接超时，在您的情况下可能为 10 秒）
  • 完整响应的最大等待时间

这些设置基本上可以防止服务器收到永远不会完成的请求以及线程池中的线程用完的垃圾邮件。

您可以增加这些值，但是您应该始终在考虑超时的情况下创建这样的代码。基本上你想在客户端做：

  • 开长拉
  • 等待回复
  • 如果收到，继续
  • 如果（超时）错误，请转到步骤 1

请注意，此解决方案不可扩展：通常（例如）您将有 200 个线程处理传入请求。这个想法是他们完成得很快。如果线程池耗尽，用户将不得不等待新的连接。但是使用 200 个线程，您可以为超过 2000 个用户提供服务。但如果线程由于长池而被阻塞，则不会。

如果可能，您应该真正研究一下WebSockets，它现在在新版本的 Java 中可用。

编辑正如 Konrad 在下面建议的那样，您可以使用诸如socket.io之类的东西，它会自动回退到其他机制。服务器端可用调用Atmosphere有一个基于 Java 的实现，但我还没有尝试过。

于 2013-09-10T09:49:25.043 回答