Jetty内嵌Http服务器

本例只是以HttpServlet方式实现，更多的方式可以通过http://wiki.eclipse.org/Jetty/Tutorial/Embedding_Jetty查看

注意里面的HttpClient为eclipse的HttpClient，非apache的HttpClient

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.server.Server;
import org.eclipse.jetty.servlet.ServletContextHandler;
import org.eclipse.jetty.servlet.ServletHolder;
import org.eclipse.jetty.util.thread.ExecutorThreadPool;

/**
 * 本例为Jetty内嵌Http服务器
 *
 */
public class ServletContext {
	public static void main(String[] args) throws Exception {
		Server server = new Server(8080);

		// 设置为线程池,默认是阻塞队列
		server.setThreadPool(new ExecutorThreadPool(25, 50, 30000));

		ServletContextHandler context = new ServletContextHandler(ServletContextHandler.SESSIONS);
		context.setContextPath("/benx");
		server.setHandler(context);

		context.addServlet(new ServletHolder(new HelloServlet("A")), "/A");
		context.addServlet(new ServletHolder(new HelloServlet("B")), "/B");

		server.start();
		server.join();
	}
}

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("请求处理完成");
	}
}



import org.eclipse.jetty.client.ContentExchange;
import org.eclipse.jetty.client.HttpClient;
import org.eclipse.jetty.client.HttpExchange;
import org.eclipse.jetty.util.thread.QueuedThreadPool;

/**
 * 异步请求http
 * @author jin.xiong
 *
 */
public class SynchronousExchange {

	public static void main(String[] args) throws Exception {
		HttpClient client = new HttpClient();
		client.setConnectorType(HttpClient.CONNECTOR_SELECT_CHANNEL);
		client.setMaxConnectionsPerAddress(2); // 设置最大并发数
		client.setThreadPool(new QueuedThreadPool(2)); // 设置最大线程池
		client.setTimeout(30000); // 设置超时时间，超过将调用
		client.start();

		for (int i = 0; i < 1000; i++) {
			ContentExchange exchange = new ContentExchange(true);
			exchange.setURL("http://localhost:8080/benx/A");
			client.send(exchange);
			int exchangeState = exchange.waitForDone();
			if (exchangeState == HttpExchange.STATUS_COMPLETED) {
				System.out.println("请求完成");
				System.out.println(exchange.getResponseContent());
			} else if (exchangeState == HttpExchange.STATUS_EXCEPTED) {
				System.out.println("请求错误");
			} else if (exchangeState == HttpExchange.STATUS_EXPIRED) {
				System.out.println("请求超时");
			}
			System.out.println(exchangeState);
		}
		System.out.println("end");
		client.stop();
	}
}



}