Continuation 机制

2. Continuation 机制
               
public class ChatContinuation extends HttpServlet{
   
    public void doPost(HttpServletRequest request, HttpServletResponse response){
        postMessage(request, response);
    }
   
    private void postMessage(HttpServletRequest request, HttpServletResponse response)
    {
        HttpSession session = request.getSession(true);
        People people = (People)session.getAttribute(session.getId());
        if (!people.hasEvent())
        {
            Continuation continuation =
                ContinuationSupport.getContinuation(request, this);
            people.setContinuation(continuation);
            continuation.suspend(1000);
        }
        people.setContinuation(null);
        people.sendEvent(response);
    }
}



大家注意到，首先获取一个 Continuation 对象，然后把它挂起 1 秒钟，直到超时或者中间被 resume 函数唤醒位置，这里需要解释的是，在调用完 suspend 函数之后，这个线程就可处理其他的请求了，这也就大大提高了程序的并发性，使得长连接能够获得非常好的扩展性。

如果我们不使用 Continuation 机制，那么程序就如 清单 3 所示：


清单 3. 不使用 Continuation 机制
               
public class Chat extends HttpServlet{
    public void doPost(HttpServletRequest request, HttpServletResponse response){
        postMessage(request, response);
    }
   
    private void postMessage(HttpServletRequest request, HttpServletResponse response)
    {
        HttpSession session = request.getSession(true);

        People people = (People)session.getAttribute(session.getId());

        while (!people.hasEvent())
        {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        people.setContinuation(null);
        people.sendEvent(response);   
    }
}



大家注意到在等待事件发生的时间里，线程被挂起，直到所等待的事件发生为止，但在等待过程中，这个线程不能处理其他请求，这也就造成了在客户端非常多的情况下服务器的处理能力跟不上的情况。下面我们解释一下 Jetty 的 Continuation 的机制是如何工作的。

为了使用 Continuatins，Jetty 必须配置为使用它的 SelectChannelConnector 处理请求。这个 connector 构建在 java.nio API 之上，允许它维持每个连接开放而不用消耗一个线程。当使用 SelectChannelConnector 时，ContinuationSupport.getContinuation() 提供一个 SelectChannelConnector.RetryContinuation 实例（但是，您必须针对 Continuation 接口编程）。当在 RetryContinuation 上调用 suspend() 时，它抛出一个特殊的运行时异常 -- RetryRequest，该异常传播到 servlet 外并且回溯到 filter 链，最后被 SelectChannelConnector 捕获。但是不会发送一个异常响应给客户端，而是将请求维持在未决 Continuations 队列里，则 HTTP 连接保持开放。这样，用来服务请求的线程返回给 ThreadPool，然后又可以用来服务其他请求。暂停的请求停留在未决 Continuations 队列里直到指定的过期时间，或者在它的 Continuation 上调用 resume() 方法。当任何一个条件触发时，请求会重新提交给 servlet（通过 filter 链）。这样，整个请求被"重播"直到 RetryRequest 异常不再抛出，然后继续按正常情况执行。


--------------------------------------------------------------------------------
回页首
Jetty 的安全性

为了防止任何人都有权限去关闭一个已经开启的 Jetty 服务器， 我们可以通过在启动 Jetty 服务器的时候指定参数来进行控制，使得用户必须提供密码才能关闭 Jetty 服务器，启动 Jetty 服务器的命令如下所示：

java -DSTOP.PORT=8079 -DSTOP.KEY=mypassword -jar start.jar



这样，用户在停止 Jetty 服务器的时候，就必须提供密码“mypassword”。


--------------------------------------------------------------------------------
回页首
总结

Jetty 是一个非常方便使用的 Web 服务器，它的特点在于非常小，很容易嵌入到我们的应用程序当中，而且针对 Web 2.0 的 Ajax 技术进行了特别的优化，这也使得我们的使用 Ajax 的应用程序可以拥有更好的性能。



参考资料

学习

•developerWorks 文章“ 面向 Java 开发人员的 Ajax: 使用 Jetty 和 Direct Web Remoting 编写可扩展的 Comet 应用程序”：受异步服务器端事件驱动的 Ajax 应用程序实现较为困难，本文介绍了一种结合使用 Comet 模式和 Jetty 6 Continuations API 的解决方法。


•developerWorks 文章“ Comet：基于 HTTP 长连接的“服务器推”技术 ”：介绍、比较了常用的“服务器推”方案。


•“Comet: Low Latency Data for the Browser”：Alex Russell 是 Dojo Toolkit 的项目主管和 Dojo Foundation 的主席，他在这篇博客文章中提出了 Comet 这个术语。


•Comet wiki：提供了很多开源 Comet 框架的链接。


•Jetty：Jetty 是一种开源的基于标准的 Web 服务器，完全使用 Java 语言实现。


•“Ajax, Comet and Jetty”（Greg Wilkins，Webtide，2006 年 1 月）：Wilkins 的这份白皮书讨论了扩展 Ajax 连接的 Jetty 架构方法。


•Continuations：了解更多关于 Jetty 的 Continuations 特性的信息。


•“pushlet”：开源 comet 框架，使用了观察者模型。浏览器端提供了基于 AJAX 和 iframe 的 JavaScript 库，服务器端使用 Java Servlet。


•developerWorks Ajax 技术资源中心：能找到更多关于 Ajax 技术的文章和教程。


•developerWorks Web 开发技术专区：提供了关于 Web 开发和架构方面的大量文章。


•developerWorks Java 技术专区：提供了关于 Java 编程各个方面的数百篇文章。