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();
}
}

}