如何将数据推送到jsp而不每2秒请求一次？

Question

我想每 2 秒将数据推送到 jsp，而不需要客户端请求。
我在这里使用 Spring 和 Hibernate。
我正在显示谷歌地图标记，我想通过从数据库中获取数据每 2 秒更新一次标记位置，但是我已经完成了每 2 秒从数据库中获取数据，但我无法将该数据推送到此jsp.

   @Scheduled(fixedRate = 2000)
   public void getData(){
                    // TODO Auto-generated method stub
                    DeviceDetails deviceDetails = realTimeDataDAO.getDeviceDetails(deviceId);
                    System.out.println(deviceDetails);
                }

我必须每 2 秒显示一些数据。谁能告诉我该怎么做？

有人知道CometAjax Push 技术，在这种情况下能用吗？

Answer 1

你有很多选择。

轮询 - 如其他答案中所述，您可以简单地让客户端中的 javascript 每 2 秒不断轮询服务器。这是一种非常常见的方法，很简单，适用于大多数浏览器。虽然不像其他一些正确设置的方法那样可扩展，但它仍然应该能够轻松扩展到中等容量（可能比您拥有的用户更多！）。

长期轮询 - 也称为 Comet，这本质上是一个长期存在的请求。这将根据您的应用服务器而有所不同。有关 Tomcat，请参见此处：http://wiki.apache.org/tomcat/WhatIsComet 或 Jetty 捆绑了一些示例。

HTML 5 解决方案 虽然 Web 传统上是基于请求响应的 - 基于事件的处理是 HTML 5 规范的一部分。由于您的事件似乎只是一种方式（服务器-> 客户端），请考虑使用事件源。请参阅：http://www.html5rocks.com/en/tutorials/eventsource/basics/ 或 Jetty 示例。这里需要注意的是，只有现代浏览器和一些应用服务器支持这些方法——例如Apache 本身并不支持 websocket。

总结一下 - 我的直觉是您的需求和简单的轮询方法很好 - 最初不要太担心性能问题。

如果您想走在最前沿，学习新事物并且可以控制您的应用服务器和框架，那么我会选择 HTML 5 方法。

彗星是这两者之间的中途之家。

Answer 2

使用 Spring 的最佳选择是将预定查询的结果存储到内存中的 bean 中，然后让另一个请求范围 bean 以可 Web 访问的方法获取存储的结果，并将其作为文本（或 JSON )。或者，您可以在每次请求更新时查询数据库。

然后，您可以从您的页面发出定时异步请求（您可能希望为此使用 YUI 连接管理器），读取响应并使用 google.maps.Map 中的 panTo 方法更新您的地图位置。

如您所见，解决方案分为 Java 和 JavaScript 部分。

对于 Java 端，您必须创建一个控制器来执行对数据库的查询（或者更好的是，将该任务委托给另一层）并以 JSON 格式返回结果，您可以为此使用http://spring-json.sourceforge.net/。它在 Spring 中有点复杂，因此您可能希望创建一个返回数据的简单 servlet。

对于 Javascript 端，一旦你有一个返回 JSON 数据的工作端点，使用 YUI Connection Manager 和 google maps api：

function update(){
    var callback = {
        success: function (o) {
            var response = YAHOO.lang.JSON.parse(o.responseText);
            map.panTo({lat: response.lat, lng: response.longi}); // map is the google.maps.Map representing your map
        },
        failure: function (o) {

        }
    }
    var sUrl = '/getData.htm'; // This is the request mapping for your bean
    YAHOO.util.Connect.asyncRequest('GET', sUrl,callback);
}

function init(){
    setTimeout("update()", 2000);
}

Answer 3

最好的方法是让客户端每 2 秒发送一次 new 请求，然后显示新数据。

由于您使用 HTTP，我假设您在客户端使用 javascript，因此您的 javascript 中需要一个计时器，每 2 秒触发一次，然后让 javascript 对服务器执行 ajax 调用以获取它可以获取的数据然后显示。

Answer 4

尝试TimerTask 或ThreadExecutor（查看计划的实施）。

Answer 5

好吧，如果您想在 Web 应用程序中实现上述解决方案，我不确定，但我认为您不能这样做。 HTTP 是一种请求/响应协议，当服务器完成发送一个响应时，它不能自行发起发送新响应。简而言之：来自客户端的一个请求 - 来自服务器的一个响应。

我认为您应该使用 AJAX（异步 Javascript 请求），以便每 2 秒向服务器询问一次新数据，并在必要时更新 DOM（网站 HTML 标记结构）。

Answer 6

我对 WebSockets 有很好的经验。服务器和浏览器之间非常快速、低开销的双向协议。不确定您的后端是什么，但 Jetty 非常支持它。只需在后端有一个计时器进程，它将遍历所有活动的 WebSockets 会话并推送更新。网上有很多关于如何使用 Websockets 的例子。

注意事项：

• 并非所有浏览器都支持 WebSockets（Chrome 和 Safari 似乎是最受支持的）
• WebSockets 流量不会遍历所有代理

根据您的要求，它可能会或可能不会被接受。

有一些像 Atmosphere 这样的项目试图抽象浏览器/服务器在 websockets 支持方面的差异，并优雅地回退到 Comet。可能值得一看。

Answer 7

//Initialize this somewhere
ScheduledExecutorService exe = Executors.newScheduledThreadPool(1);

exe.scheduleWithFixedDelay(new Runnable() {

    @Override
    public void run() {
        //The executor service tries to run 2 seconds after it last finished
        //If you code takes 1 second to run this will effectively run every 3 seconds 
    }
}, 0, //this is the initial delay
2, //this is the consecutive delay
TimeUnit.SECONDS);

exe.scheduleAtFixedRate(new Runnable() {

    @Override
    public void run() {
        //The executor service tries to run this every 2 seconds
        //If you code takes 1 second to run this will still run evey 2 seconds
    }
}, 0, //this is the initial delay
2, //this is the period it tries to run in
TimeUnit.SECONDS);

Answer 8

您需要每 2 秒将数据从服务器发送到客户端。而且您已经知道如何在服务器端每 2 秒收集一次数据。

如果这就是您所需要的，“Ajax 流”将为您提供帮助。这是在客户端。从服务器端每 2 秒您需要写入数据并刷新它。

搜索这个词会给你很多例子。但请记住，所有现代浏览器都将使用一种方法，所有 IE 浏览器都将使用 IFrame 方法来实现流。

在第一种情况下，您需要发出 XHR 请求并查看响应并进行处理。

这里有几个例子：（我没有时间完整地浏览它们）

http://ajaxpatterns.org/HTTP_Streaming

http://developers.cogentrts.com:8080/DH_ajax_1.asp

Answer 9

你可以使用ajax调用。 因为您可以使用 Javascript 编写代码，每 2 秒发送一次请求，但为此，您的服务器应该对此类请求快速响应。

我想这会对你有所帮助。

Answer 10

如果您的服务器拥有超过 1000 个用户，那么您的应用程序服务器将会失败。我建议您仅使用 Jetty 服务器支持的非阻塞输入输出方法来托管为此目的发出的请求，并将您的普通 EE 服务器用于其他应用程序。