jetty笔记

cyc1111

package com.bierbobo;

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.mortbay.jetty.Connector;
import org.mortbay.jetty.Handler;
import org.mortbay.jetty.HttpConnection;
import org.mortbay.jetty.Request;
import org.mortbay.jetty.Server;
import org.mortbay.jetty.handler.AbstractHandler;
import org.mortbay.jetty.handler.ContextHandler;
import org.mortbay.jetty.handler.HandlerCollection;
import org.mortbay.jetty.nio.SelectChannelConnector;
import org.mortbay.jetty.servlet.Context;
import org.mortbay.jetty.servlet.DefaultServlet;
import org.mortbay.jetty.servlet.ServletHolder;
import org.mortbay.jetty.webapp.WebAppContext;

public class JettyTest {

/*
* 1、jar配置 lib : jetty jetty-util servlet-api
* jsp-2.1: ant core jsp jsp-api
*
* 2、 Server(服务器) Connector(连接器) Handler(处理器)
*
* 3、 web配置文件发布正常的servlet addServlet可以发布内部servlet类
*/

public static void main(String[] args) throws Exception {

// 1:定义server
Server server = new Server(8020);

// 2:把连接器集合放到server里,可以在Server定义端口来代替
// addConnect(server);

// 3:并把处理器集合放到server里

// handlerCollection(server);
//
// contextHandler(server);
//
// context(server);

webAppContext(server);

// 4:启动server
server.start();
server.join();

}

/**
* 为Server设置连接器，可以通过new Server(8020)简单的设置连接器为SocketConnector连接器
* @param server
*/
private static void addConnect(Server server) {
Connector connector = new SelectChannelConnector();
connector.setPort(8020);
server.setConnectors(new Connector[] { connector });
}

/**
* 多个处理器即处理器集合：连接器的请求都会在每个处理器中处理
* @param server
*/
private static void handlerCollection(Server server) {
HandlerCollection handlers = new HandlerCollection();
Handler hello = new HelloHandler();
handlers.setHandlers(new Handler[] { hello });
server.setHandler(handlers);
}

/**
* 上下文处理器：一般处理来自web的请求。
* 如果要想处理servlet请求的话，首先要添加defaultservlet（拦截路径为全部），其次在增加自己的servlet，如下。
*
* @param server
*/
private static void contextHandler(Server server) {
ContextHandler context = new ContextHandler();
context.setContextPath("/");
Handler handler = new HelloHandler();
context.setHandler(handler);

server.setHandler(context);
}


private static void context(Server server) {

Context context = new Context(server, "/", Context.SESSIONS);

ServletHolder holder = new ServletHolder(DefaultServlet.class);
holder.setInitParameter("dirAllowed", "true");
holder.setInitParameter("welcomeServlets", "index.html");
holder.setInitParameter("resourceBase", "jetty/web");
context.addServlet(holder, "/*");

context.addServlet(new ServletHolder(new HelloServlet("li")),"/hello");
}


/**
* web请求处理器：上下文处理器的升级，专门处理web请求，不在需要增加defaultservlet。
* @param server
*/
private static void webAppContext(Server server) {

WebAppContext webapp = new WebAppContext(server, "web", "/");
webapp.addServlet(new ServletHolder(new HelloServlet("A")), "/A");
webapp.addServlet(new ServletHolder(new HelloServlet("B")), "/B");

// webapp.setContextPath("/");
// webapp.setResourceBase("jetty/web");
// server.setHandler(webapp);
}



static class HelloHandler extends AbstractHandler {

public void handle(String target, HttpServletRequest request,
HttpServletResponse response, int dispatch) throws IOException,
ServletException {

Request base_request = (request instanceof Request) ? (Request) request
: HttpConnection.getCurrentConnection().getRequest();
base_request.setHandled(true);

response.setContentType("text/html");
response.setStatus(HttpServletResponse.SC_OK);
response.getWriter().println("<h1>Hello OneHandler</h1>");
}

}

static class HelloServlet extends HttpServlet {

private static final long serialVersionUID = 1L;
private String greeting = "Hello World";

public HelloServlet() {
}

public HelloServlet(String greeting) {
this.greeting = greeting;
}

protected void doGet(HttpServletRequest request,
HttpServletResponse response) throws ServletException,
IOException {
System.out.println("收到请求");
response.setContentType("text/html");
response.setStatus(HttpServletResponse.SC_OK);
response.getWriter().println("<h1>" + greeting + "</h1>");
response.getWriter().println(
"session=" + request.getSession(true).getId());
response.getWriter().flush();
System.out.println("请求处理完成");
}

}
}