Jetty使用入门

wsxxz

一、Jetty介绍和特性
　　Jetty是一个开源的Http服务器和Web容器，它是使用Java语言编写的，开发人员可以将Jetty容器实例化成一个对象，为一些独立运行的Java应用提供网络和Web连接。
易用性：

• 通过xml或api对Jetty进行配置。
  
• 默认配置可以满足大部分需求。
  
• 将Jetty嵌入到应用程序当中只需要非常少的代码。
  

　　可扩展性：

• 在大量服务请求情况下也能保持一个可以接受的状态，利用 Continuation 机制来处理大量的用户请求以及时间比较长的连接。
  
• Jetty 设计了非常良好的接口，因此在 Jetty 的某种实现无法满足用户的需要时，用户可以非常方便地对 Jetty 的某些实现进行修改，使得 Jetty 适用于特殊的应用程序的需求。
  

　　易嵌入性：

• 非常容易嵌入到应用程序当中，可以把Jetty理解为一个嵌入式Web服务器，可以从testcase控制其运行，从而使用自动化测试不依赖于外部环境。
  

　　快速高效：

• Jetty是最快的Servlet服务器之一，可以处理上千个并发连接。
  

　　Jetty下载地址：http://docs.codehaus.org/display/JETTY/Downloading+and+Installing#download
二、Jetty内嵌服务器
　　下面的例子Jetty版本是5.1.3
依赖的Jar包

•  org.mortbay.jetty-5.1.3.jar
  
•  commons-logging.jar
  
•  servlet-api-2.5.jar
  

　　
package com.xiaocaiye.jetty;
import org.mortbay.http.HttpContext;
import org.mortbay.http.HttpServer;
import org.mortbay.http.SocketListener;
import org.mortbay.http.handler.ResourceHandler;
public class JettyService {
  public static void main(String args[]){
    //1、创建HttpServer对象,接收Http请求
    HttpServer httpServer = new HttpServer();
     //2、创建一个监听器，并注册到Server中
    SocketListener listener = new SocketListener();
     listener.setPort(80);
     httpServer.addListener(listener);
     //3、创建HttpContent对象，并注册到Server中
    HttpContext httpContext =  new HttpContext();
    httpContext.setContextPath("/web");
    httpContext.setResourceBase("/home/xiaocaiye");
    httpContext.addHandler(new ResourceHandler());
    httpServer.addContext(httpContext);
    //4.启动Server
    try {
        httpServer.start();
    } catch (Exception e) {
        e.printStackTrace();
     }
  }
}
启动后，访问 http://localhost/web
　　
下面的例子Jetty版本是7
Maven依赖
<dependency>
    <groupId>org.eclipse.jetty.aggregate</groupId>
    <artifactId>jetty-all</artifactId>
   <version>8.1.8.v20121106</version>
</dependency>
<dependency>
      <groupId>org.mortbay.jetty</groupId>
      <artifactId>jsp-2.1-glassfish</artifactId>
     <version>2.1.v20100127</version>
</dependency>

启动内嵌Jetty服务
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.webapp.WebAppContext;
/**
* 启动Jetty服务
*/
public class JettyEmbedServer {
private final static int PROT = 8080;
private final static String webapp ="D:/workspace/test-jetty/src/main/webapp";
private Server server;
  private void init(){     
      server = new Server(PROT);      
      WebAppContext context = new WebAppContext(); 
      context.setDescriptor(webapp + "/WEB-INF/web.xml"); 
      context.setResourceBase(webapp); 
      context.setContextPath("/"); 
      context.setClassLoader(Thread.currentThread().getContextClassLoader());      
      server.setHandler(context);     
       try {
        server.start(); 
       server.join();
        } catch (InterruptedException e) {
        e.printStackTrace();
       } catch (Exception e) {
         e.printStackTrace();
      }
  }

   public void close() throws Exception {
      server.stop();
       server.destroy();
   }
    public static void main(String[] args) {
        JettyEmbedServer jettyEmbedServer = new JettyEmbedServer();
         jettyEmbedServer.init();
    }
}
三、部署应用程序
　　将开发好的应用程序打成 WAR 包放到 Jetty 的 Webapps 目录下面。然后用如下的命令来启动 Jetty 服务器:
Java –jar start.jar
为了防止任何人都能去关闭Jetty服务器，可以在启动时设置关闭密码 ：
java -DSTOP.PORT=8079 -DSTOP.KEY=mypassword -jar start.jar
四、Jetty 的 Continuation 机制
　　
Ajax是Web2.0一个重要的组成部分，用什么机制来保证服务器一旦有了响应客户端马上能知道？一种是轮询，浏览器每隔几秒钟请求服务器获取变化，这会造成大量传输的浪费;另一种是长连接Comet，服务器与浏览器维持长时间的连接。
Jetty 利用 Java 语言的非堵塞 I/O 技术来处理并发的大量连接。 Jetty 有一个处理长连接的机制,一个被称为
Continuations的特性。利用 Continuation 机制，Jetty 可以使得一个线程能够用来同时处理多个从客户端
　　发送过来的异步请求.
Jetty Continuations实际是一种异步Http技术，他能让Http连接挂起直到超时或者异步事件发生，Http连接可以恢复。
package com.xiaocaiye.jetty;

import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.eclipse.jetty.continuation.Continuation;
import org.eclipse.jetty.continuation.ContinuationSupport;

public class ChatContinuation extends HttpServlet {
  private MyAsyncHandler myAsyncHandler;
  protected void doPost(HttpServletRequest req, HttpServletResponse resp)
                                          throws ServletException, IOException {
       Object results = req.getAttribute("results");//异步方式得到results
       if (results == null){//异步处理尚未返回结果
        final Continuation continuation = ContinuationSupport.getContinuation(req);
        if (continuation.isExpired()){//判断是否超时
            sendMyTimeoutResponse(resp);
            return;
        }
       //挂起Http连接
       continuation.suspend();
       myAsyncHandler.register(new MyHandler(){
             //异步事件
          public void onMyEvent(Object result){
          continuation.setAttribute("results", result);
          continuation.resume();
        }
        });
        return;
      }
   //连接恢复后返回结果
   sendMyResultResponse(resp,results);
  }
    private interface MyAsyncHandler { 
        public void register(MyHandler myHandler); 
    }   
    private interface MyHandler { 
        public void onMyEvent(Object result); 
    }
private void sendMyResultResponse(HttpServletResponse resp, Object results) throws IOException {
    resp.getWriter().write("results:" + results); 
    resp.getWriter().flush(); 
}
private void sendMyTimeoutResponse(HttpServletResponse resp) throws IOException {
   resp.getWriter().write("timeout");
}
}
　　资料来源于IBM中国(http://www.ibm.com/developerworks/cn/web/wa-lo-jetty/)
                 百度百科(http://baike.baidu.com/view/1425008.htm)