Здравствтвуйте, уважаемые.
В очередной раз хочу принести пользу обществу и поделиться своей сегодняшней находкой: HTTP сервер на базе пакета от нашего Солнышка com.sun.net.httpserver
Введение.
Чем может не устраивать развертка веб-контейнеров, таких как Apache Tomcat? В первую очередь, они достаточно увесистые. Они расчитаны на обширный круг задач, навязывая многие дополнительные возможности, в общем созданы для полноценных веб-приложений.
Часто у нас возникает потребность в небольших HTTP серверах. К примеру, у нас имеется система, которая поддерживает 2 типа соединений: постоянные и HTTP запросы. Постоянные соединения - самая важная часть, лишь изредка необходимо запрашивать HTTP страницы (http://vingrad.ru/blogs/COVD/2008/03/12/potok-dannyih-i-zapros-otvet-odno-ili-neskolko-soedineniy/ для размышления). Это не веб приложение, и полнофункциональный веб-сервер нам ни к чему.
И как раз HttpServer - небольшой пакет классов для поднятия простого Embedded HTTP сервера. Самое приятное, что их можно найти в SDK6. JavaDoc и краткое руководство на английском языке есть http://java.sun.com/javase/6/docs/jre/api/net/httpserver/spec/com/sun/net/httpserver/package-summary.html
Основная часть
Задача: вывести на страницу список заголовков, отправляемых браузером в кодировке UTF-8. Запрос к серверу http://localhost:8080/path/to/data.make
По традиции сразу выгружаю весь код
| Код |
package ru.vingrad.platon;
import com.sun.net.httpserver.*;
import java.net.InetSocketAddress;
import java.io.*;
import java.util.*;
import java.util.concurrent.*;
public class TestHttpServer {
private static final int THREADS_AMOUNT = 20;
private static final int MAX_THREADS_AMOUNT = 2*THREADS_AMOUNT;
private static final int QUEUE_CAPACITY = 1024;
public static void main(String[] args) throws IOException {
HttpServer server = HttpServer.create(new InetSocketAddress(8080), 0);
HttpContext c = server.createContext("/path/to/data.make", new HttpHandler() {
public void handle(HttpExchange httpExchange) throws IOException {
Writer w = new OutputStreamWriter(httpExchange.getResponseBody(), "UTF-8");
httpExchange.getResponseHeaders().put("Content-Type", Arrays.asList("text/plain; charset=UTF-8"));
httpExchange.sendResponseHeaders(200, 0);
System.out.println(httpExchange.getRequestURI().getQuery());
for (Map.Entry<String, List<String>> e : httpExchange.getRequestHeaders().entrySet()) {
w.write(e.getKey() + "\n");
for (String s : e.getValue())
w.write(" " + s + "\n");
}
w.write("Выход первой серии пятого сезона Доктор Хаус 16-го сентября");
w.close();
}
});
c.getFilters().add(new Filter() {
public void doFilter(HttpExchange httpExchange, Chain chain) throws IOException {
System.out.println("pre-filter");
chain.doFilter(httpExchange);
System.out.println("post-filter");
}
public String description() {
return "short description";
}
});
//server.setExecutor(null);
server.setExecutor(new ThreadPoolExecutor(THREADS_AMOUNT, MAX_THREADS_AMOUNT, 0, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(QUEUE_CAPACITY)));
server.start();
}
}
|
Вооружаемся секундомерами.
| Код |
HttpServer server = HttpServer.create(new InetSocketAddress(8080), 0);
|
Несложно догадаться что мы создаем HTTP сервер, который слушает порт 8080. 2-й параметр я не очень понял.
| Цитата |
backlog - the socket backlog. If this value is less than or equal to zero, then a system default value is used.
|
Такое ощущение, что это локальный адрес соединения... Хорошо, что есть возможность дать на откуп программе установку этого параметра, поставив неположительное значение.
Привязываем строки запросов с обработчиками
| Код |
HttpContext c = server.createContext("/path/to/print-headers.do", new HttpHandler() {
public void handle(HttpExchange httpExchange) throws IOException {
//...
}
});
|
1-я строка связывает путь на сервере с обработчику. Иными словами, если будет запрошен заданный путь, то будет вызван привязанный к нему обработчик запроса HttpHandler. Интерфейс HttpHandler содержит всего 1 метод для определения, handle(HttpExchange httpExchange). Займемся этим.
Класс HttpExchange содержит 6 важных методов, которые хорошо расписаны в документации:
| Цитата |
1. getRequestMethod() to determine the command
2. getRequestHeaders() to examine the request headers (if needed)
3. getRequestBody() returns a InputStream for reading the request body. After reading the request body, the stream is close.
4. getResponseHeaders() to set any response headers, except content-length
5. sendResponseHeaders(int,long) to send the response headers. Must be called before next step.
6. getResponseBody() to get a OutputStream to send the response body. When the response body has been written, the stream must be closed to terminate the exchange.
|
| Цитата |
1. getRequestMethod() для определения метода отправки
2. getRequestHeaders() получить заголовки клиента (не перевод)
3. getRequestBody() возвращает InputStream для чтения тела запроса. После чтения тела запроса, поток закрывается
4. getResponseHeaders() получить и установить любые заголовки ответа, кроме content-length
5. sendResponseHeaders(int,long) команда отправки заголовков. Должен вызываться перед следующим ходом. Первый аргумент статус страницы (200 - страница загружена, 404 - не найдена, 302 - перемещена), второй - длина тела ответа, если 0, то выставляется заголовок "Transfer-Encoding: chunked", т.е. тело неопределенной длины.
6. getResponseBody() возвращает OutputStream для отправки тела ответа. Когда тело полностью отправлено клиенту, поток должен быть закрыт(!) чтобы разорвать обмен данными.
|
| Код |
Writer w = new OutputStreamWriter(httpExchange.getResponseBody(), "UTF-8");
httpExchange.getResponseHeaders().put("Content-Type", Arrays.asList("text/plain; charset=UTF-8"));
httpExchange.sendResponseHeaders(200, 0);
System.out.println(httpExchange.getRequestURI().getQuery());
for (Map.Entry<String, List<String>> e : httpExchange.getRequestHeaders().entrySet()) {
w.write(e.getKey() + "\n");
for (String s : e.getValue())
w.write(" " + s + "\n");
}
w.write("Выход первой серии пятого сезона Доктор Хаус 16-го сентября");
w.close();
|
По порядку
1. Оборачиваем OutputStream ответа в поток с кодировкой UTF-8.
2. Пробуем поэксперементировать с заголовками ответа (тип документа и его кодировка)
3. отправляем ответы клиенту 200 (страница найдена) и неизвестную длину посылки.
4. Отдельного разговора заслуживает метод httpExchange.getRequestURI() в качестве теста, можете набрать в браузере строку типа "/path/to/data.make?arg1=12&arg2=name"
Мы видим, что несмотря на то, что строка запроса уже не совпадает с /path/to/data.make тем не менее HttpServer может отделать часть запроса от передаваемых параметров и вызвать обработчик, привязанный к пути /path/to/data.make
5-9. отправляем полученные заголовки запроса обратно, но уже в теле ответа, а не в виде заголовков
10. Проверяем работает ли установленная нами кодировка, выводя русский текст.
11. Обязательно(!) закрываем поток ответа.
Работа с фильтрами
| Код |
c.getFilters().add(new Filter() {
public void doFilter(HttpExchange httpExchange, Chain chain) throws IOException {
System.out.println("pre-filter");
chain.doFilter(httpExchange);
System.out.println("post-filter");
}
public String description() {
return "short description";
}
});
|
Схема довольно проста. HttpContext, который мы создали на прошлом шаге, может быть предварительно и после обработан фильтрами.
Фильтры вызываются в порядке добовления их в цепь фильтров, получаемую методом c.getFilters().
Filter#description() - краткое описание фильтра.
Методы обработки одновременных запросов
| Код |
//server.setExecutor(null);
server.setExecutor(new ThreadPoolExecutor(THREADS_AMOUNT, MAX_THREADS_AMOUNT, 0, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(QUEUE_CAPACITY)));
|
Закоментированная строка имеет место быть для супер простых серверов с небольшой степенью одновременных запросов. Executor по умолчанию обрабатывает по одной задаче в момент времени. Такой подход конечно же неприемлем в боевых условиях. На сколько я понял, выполняется что-то подобное.
| Код |
class SimpleExecutor implements Executor {
public void execute(Runnable command) {
command.run();
}
}
|
Второй строкой я привел боевой пример. Несколько потоков-работников будут параллельно обрабатывать запросы клиентов.
Вот жесткий тест на 1000 псевдоодновременных подключений:
| Код |
import java.io.IOException;
import java.net.*;
import java.util.*;
public class Go {
private static int id;
public static void main(String[] args) {
Thread[] t = new Thread[1000];
for (int i = 0; i < t.length; i++) {
Thread thread = t[i] = new Thread(new Runnable() {
public void run() {
int id;
synchronized(Go.class) {
id = Go.id;
Go.id++;
}
System.out.println("id = " + id);
for (int i = 0; i < 10; i++) {
try {
URLConnection conn = new URL("http://localhost:8080/path/to/data.make?id=" + id).openConnection();
for (Map.Entry<String, List<String>> e : conn.getHeaderFields().entrySet()) {
System.out.println(e.getKey());
for (String s : e.getValue())
System.out.println(" " + s);
}
((HttpURLConnection)conn).disconnect();
} catch (MalformedURLException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
});
thread.start();
}
}
}
|
Здесь могла бы быть ваша реклама
http://platon007.blogspot.com/2008/08/blog-post.html |
.