Java 如何實(shí)現(xiàn)一個(gè)http服務(wù)器
在Java中可以使用HttpServer類(lèi)來(lái)實(shí)現(xiàn)Http服務(wù)器，該類(lèi)位于com.sun.net包下(rt.jar)。實(shí)現(xiàn)代碼如下：
主程序類(lèi)
package bg.httpserver;import com.sun.net.httpserver.HttpServer;import java.io.IOException;import java.net.InetSocketAddress;import java.util.concurrent.Executors;public class HttpServerStarter { public static void main(String[] args) throws IOException { //創(chuàng)建一個(gè)HttpServer實(shí)例，并綁定到指定的IP地址和端口號(hào) HttpServer httpServer = HttpServer.create(new InetSocketAddress(8080), 0); //創(chuàng)建一個(gè)HttpContext，將路徑為/myserver請(qǐng)求映射到MyHttpHandler處理器 httpServer.createContext('/myserver', new MyHttpHandler()); //設(shè)置服務(wù)器的線(xiàn)程池對(duì)象 httpServer.setExecutor(Executors.newFixedThreadPool(10)); //啟動(dòng)服務(wù)器 httpServer.start(); }}
HttpServer：HttpServer主要是通過(guò)帶參的create方法來(lái)創(chuàng)建，第一個(gè)參數(shù)InetSocketAddress表示綁定的ip地址和端口號(hào)。第二個(gè)參數(shù)為int類(lèi)型，表示允許排隊(duì)的最大TCP連接數(shù)，如果該值小于或等于零，則使用系統(tǒng)默認(rèn)值。
createContext：可以調(diào)用多次，表示將指定的url路徑綁定到指定的HttpHandler處理器對(duì)象上，服務(wù)器接收到的所有路徑請(qǐng)求都將通過(guò)調(diào)用給定的處理程序?qū)ο髞?lái)處理。
setExecutor：設(shè)置服務(wù)器的線(xiàn)程池對(duì)象，不設(shè)置或者設(shè)為null則表示使用start方法創(chuàng)建的線(xiàn)程。
HttpHandler實(shí)現(xiàn)
package bg.httpserver;import com.sun.net.httpserver.Headers;import com.sun.net.httpserver.HttpExchange;import com.sun.net.httpserver.HttpHandler;import java.io.BufferedReader;import java.io.InputStreamReader;import java.io.OutputStream;import java.util.List;import java.util.Map;import java.util.stream.Collectors;/** * 處理/myserver路徑請(qǐng)求的處理器類(lèi) */public class MyHttpHandler implements HttpHandler { @Override public void handle(HttpExchange httpExchange) { try { StringBuilder responseText = new StringBuilder(); responseText.append('請(qǐng)求方法：').append(httpExchange.getRequestMethod()).append('<br/>'); responseText.append('請(qǐng)求參數(shù)：').append(getRequestParam(httpExchange)).append('<br/>'); responseText.append('請(qǐng)求頭：<br/>').append(getRequestHeader(httpExchange)); handleResponse(httpExchange, responseText.toString()); } catch (Exception ex) { ex.printStackTrace(); } } /** * 獲取請(qǐng)求頭 * @param httpExchange * @return */ private String getRequestHeader(HttpExchange httpExchange) { Headers headers = httpExchange.getRequestHeaders(); return headers.entrySet().stream().map((Map.Entry<String, List<String>> entry) -> entry.getKey() + ':' + entry.getValue().toString()).collect(Collectors.joining('<br/>')); } /** * 獲取請(qǐng)求參數(shù) * @param httpExchange * @return * @throws Exception */ private String getRequestParam(HttpExchange httpExchange) throws Exception { String paramStr = ''; if (httpExchange.getRequestMethod().equals('GET')) { //GET請(qǐng)求讀queryString paramStr = httpExchange.getRequestURI().getQuery(); } else { //非GET請(qǐng)求讀請(qǐng)求體 BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(httpExchange.getRequestBody(), 'utf-8')); StringBuilder requestBodyContent = new StringBuilder(); String line = null; while ((line = bufferedReader.readLine()) != null) {requestBodyContent.append(line); } paramStr = requestBodyContent.toString(); } return paramStr; } /** * 處理響應(yīng) * @param httpExchange * @param responsetext * @throws Exception */ private void handleResponse(HttpExchange httpExchange, String responsetext) throws Exception { //生成html StringBuilder responseContent = new StringBuilder(); responseContent.append('<html>').append('<body>').append(responsetext).append('</body>').append('</html>'); String responseContentStr = responseContent.toString(); byte[] responseContentByte = responseContentStr.getBytes('utf-8'); //設(shè)置響應(yīng)頭，必須在sendResponseHeaders方法之前設(shè)置！ httpExchange.getResponseHeaders().add('Content-Type:', 'text/html;charset=utf-8'); //設(shè)置響應(yīng)碼和響應(yīng)體長(zhǎng)度，必須在getResponseBody方法之前調(diào)用！ httpExchange.sendResponseHeaders(200, responseContentByte.length); OutputStream out = httpExchange.getResponseBody(); out.write(responseContentByte); out.flush(); out.close(); }}
運(yùn)行HttpServerStarter，在瀏覽器中訪(fǎng)問(wèn)如下：
以上就是Java 如何實(shí)現(xiàn)一個(gè)http服務(wù)器的詳細(xì)內(nèi)容，更多關(guān)于Java 實(shí)現(xiàn)http服務(wù)器的資料請(qǐng)關(guān)注好吧啦網(wǎng)其它相關(guān)文章！
相關(guān)文章：
1. XML入門(mén)精解之結(jié)構(gòu)與語(yǔ)法2. JS中map和parseInt的用法詳解3. ASP實(shí)現(xiàn)加法驗(yàn)證碼4. CSS Hack大全-教你如何區(qū)分出IE6-IE10、FireFox、Chrome、Opera5. ASP.NET MVC使用異步Action的方法6. ASP中if語(yǔ)句、select 、while循環(huán)的使用方法7. XML入門(mén)的常見(jiàn)問(wèn)題(一)8. 匹配模式 - XSL教程 - 49. 存儲(chǔ)于xml中需要的HTML轉(zhuǎn)義代碼10. SpringMVC+Jquery實(shí)現(xiàn)Ajax功能
網(wǎng)公網(wǎng)安備