Java 內(nèi)置Http Server構(gòu)建web應(yīng)用案例詳解

第Java內(nèi)置HttpServer構(gòu)建web應(yīng)用案例詳解使用Java技術(shù)構(gòu)建Web應(yīng)用時(shí)，我們通常離不開tomcat和jetty之類的servlet容器，這些Web服務(wù)器功能強(qiáng)大，性能強(qiáng)勁，深受歡迎，是運(yùn)行大型Web應(yīng)用的必備神器。

雖然Java的設(shè)計(jì)初衷就是用來開發(fā)大型應(yīng)用的，然而有時(shí)候我們開發(fā)的程序只是簡(jiǎn)單的小型應(yīng)用，對(duì)于功能的需求和性能的要求并不高，可能僅僅就幾百行甚至幾十行代碼，這個(gè)時(shí)候使用tomcat之類的Web服務(wù)器去運(yùn)行就顯得有點(diǎn)大材小用了。比如說只是將數(shù)據(jù)庫中的數(shù)據(jù)讀出來轉(zhuǎn)換成JSON，以Web服務(wù)的形式吐給調(diào)用方這樣的閹割型Web應(yīng)用。如下圖所示

二、最簡(jiǎn)單的JavaHttp服務(wù)器

其實(shí)在jdk中已經(jīng)內(nèi)置了用于此類簡(jiǎn)單Web應(yīng)用構(gòu)建需求的類庫了，sun公司提供的.httpserver包就是用來幫助我們解決這類問題的

import.httpserver.HttpExchange;

import.httpserver.HttpHandler;

import.httpserver.HttpServer;

importjava.io.IOException;

importjava.io.OutputStream;

import.InetSocketAddress;

publicclassMain{

publicstaticvoidmain(String[]arg)throwsException{

HttpServerserver=HttpServer.create(newInetSocketAddress(8001),0);

server.createContext("/test",newTestHandler());

server.start();

staticclassTestHandlerimplementsHttpHandler{

@Override

publicvoidhandle(HttpExchangeexchange)throwsIOException{

Stringresponse="helloworld";

exchange.sendResponseHeaders(200,0);

OutputStreamos=exchange.getResponseBody();

os.write(response.getBytes());

os.close();

}

如上代碼清單所示，僅僅幾行代碼就可以構(gòu)建一個(gè)五臟俱全的Web應(yīng)用了。執(zhí)行代碼，在瀏覽器地址欄里代開鏈接

http://localhost:8001/test

就能運(yùn)行這個(gè)段程序，輸入的結(jié)果為helloworld

三、獲得外部數(shù)據(jù)

那在這個(gè)程序中如何獲取到外部傳遞過來的數(shù)據(jù)呢？比如說URL上的查詢字符串，POST提交的數(shù)據(jù)等，其實(shí)也很簡(jiǎn)單

import.httpserver.HttpExchange;

import.httpserver.HttpHandler;

import.httpserver.HttpServer;

importmons.io.IOUtils;

importjava.io.IOException;

importjava.io.OutputStream;

importjava.io.UnsupportedEncodingException;

import.InetSocketAddress;

import.URLDecoder;

importjava.util.Arrays;

importjava.util.HashMap;

importjava.util.Map;

publicclassMain{

publicstaticvoidmain(String[]arg)throwsException{

HttpServerserver=HttpServer.create(newInetSocketAddress(8001),0);

server.createContext("/test",newTestHandler());

server.start();

staticclassTestHandlerimplementsHttpHandler{

@Override

publicvoidhandle(HttpExchangeexchange){

Stringresponse="helloworld";

try{

//獲得查詢字符串(get)

StringqueryString=exchange.getRequestURI().getQuery();

MapString,StringqueryStringInfo=formData2Dic(queryString);

//獲得表單提交數(shù)據(jù)(post)

StringpostString=IOUtils.toString(exchange.getRequestBody());

MapString,StringpostInfo=formData2Dic(postString);

exchange.sendResponseHeaders(200,0);

OutputStreamos=exchange.getResponseBody();

os.write(response.getBytes());

os.close();

}catch(IOExceptionie){

}catch(Exceptione){

publicstaticMapString,StringformData2Dic(StringformData){

MapString,Stringresult=newHashMap();

if(formData==null||formData.trim().length()==0){

returnresult;

finalString[]items=formData.split("

Arrays.stream(items).forEach(item-{

finalString[]keyAndVal=item.split("=");

if(keyAndVal.length==2){

try{

finalStringkey=URLDecoder.decode(keyAndVal[0],"utf8");

finalStringval=URLDecoder.decode(keyAndVal[1],"utf8");

result.put(key,val);

}catch(UnsupportedEncodingExceptione){}

returnresult;

}

上面的代碼清單標(biāo)識(shí)了實(shí)現(xiàn)的方法。

注意，要保證上面代碼編譯通過，需要引入commons-io.jar，此包中提供將InputStream轉(zhuǎn)換成String的方法。

四、并發(fā)處理

.httpserver似乎默認(rèn)不支持同時(shí)處理多個(gè)請(qǐng)求，一旦有并行的請(qǐng)求涌入，需要排隊(duì)等待程序處理，導(dǎo)致Web程序響應(yīng)卡頓。自定義實(shí)現(xiàn)的方法也很簡(jiǎn)單，為每個(gè)請(qǐng)求開一個(gè)新的線程處理即可，如下代碼清單所示

import.httpserver.HttpExchange;

import.httpserver.HttpHandler;

import.httpserver.HttpServer;

importmons.io.IOUtils;

importjava.io.IOException;

importjava.io.OutputStream;

importjava.io.UnsupportedEncodingException;

import.InetSocketAddress;

import.URLDecoder;

importjava.util.Arrays;

importjava.util.HashMap;

importjava.util.Map;

publicclassMain{

publicstaticvoidmain(String[]arg)throwsException{

HttpServerserver=HttpServer.create(newInetSocketAddress(8001),0);

server.createContext("/test",newTestHandler());

server.start();

staticclassTestHandlerimplementsHttpHandler{

@Override

publicvoidhandle(HttpExchangeexchange){

newThread(newRunnable(){

@Override

publicvoidrun(){

try{

Stringresponse="helloworld";

//獲得查詢字符串(get)

StringqueryString=exchange.getRequestURI().getQuery();

MapString,StringqueryStringInfo=formData2Dic(queryString);

//獲得表單提交數(shù)據(jù)(post)

StringpostString=IOUtils.toString(exchange.getRequestBody());

MapString,StringpostInfo=formData2Dic(postString);

exchange.sendResponseHeaders(200,0);

OutputStreamos=exchange.getResponseBody();

os.write(response.getBytes());

os.close();

}catch(IOExceptionie){

ie.printStackTrace();

}catch(Exceptione){

e.printStackTrace();

}).start();

publicstaticMapString,StringformData2Dic(StringformData){

MapString,Stringresult=newHashMap();

if(formData==null||formData.trim().length()==0){

returnresult;

finalString[]items=formData.split("

Arrays.stream(items).forEach(item-{

finalString[]keyAndVal=item.split("=");

if(keyAndVal.length==2){

try{

finalStringkey=URLDecoder.decode(keyAndVal[0],"utf8");

finalStringval=URLDecoder.decode(keyAndVal[1],"utf8");

result.put(key,val);

}catch