代碼github地址：https://github.com/LynHB/ProjectA/blob/master/src/main/java/study/http/HttpServerDemo.java
1. HttpServer類說明
1.1 介紹
該類實(shí)現(xiàn)了一個(gè)簡(jiǎn)單的HTTP服務(wù)器。HttpServer被綁定到一個(gè)IP地址和端口號(hào)，并偵聽這個(gè)地址上來自Client的傳入TCP連接。子類HttpsServer實(shí)現(xiàn)了一個(gè)處理HTTPS請(qǐng)求的服務(wù)器。
為了處理請(qǐng)求，一個(gè)或多個(gè)HttpHandler對(duì)象必須與服務(wù)器相關(guān)聯(lián)。每個(gè)這樣的HttpHandler都注冊(cè)了一個(gè)根URI路徑，該路徑表示應(yīng)用程序或服務(wù)在該服務(wù)器上的位置。處理程序到HttpServer的映射由HttpContext對(duì)象封裝。HttpContexts是通過調(diào)用createContext(String，HttpHandler)來創(chuàng)建的。任何找不到處理程序的請(qǐng)求都將以404響應(yīng)被拒絕。線程的管理可以通過提供Executor對(duì)象在此對(duì)象外部完成。如果沒有提供，則使用默認(rèn)提供。
1.2 常用方法
| 方法名 | 返回類型 | 方法說明 |
|---|---|---|
| bind(InetSocetAddr addr, int backlog) | void | 給未進(jìn)行IP和端口綁定的HttpServer進(jìn)行綁定，并可設(shè)置backlog |
| create() | HttpServer | 創(chuàng)建一個(gè)HttpServer實(shí)例，但是未進(jìn)行初始化和未綁定對(duì)應(yīng)本地地址和端口，需要結(jié)合bind(InetSocetAddr addr, int backlog)使用 |
| create(InetSocetAddr addr, int backlog) | HttpServer | 創(chuàng)建對(duì)應(yīng)實(shí)例，綁定IP和端口信息，并指定backlog數(shù) |
| createContext(String path,HttpHandler handle) | HttpContext | 通過URI綁定對(duì)應(yīng)的handle控制器，創(chuàng)建HTTP上下文。 |
| getAddress() | InetSocketAddress | 返回HttpServer相關(guān)綁定信息 |
| getExecutor() | Executor | 獲取線程池對(duì)象,通過setExecutor(Executor)設(shè)置，如果沒設(shè)置返回null |
| start | void | 在新的后臺(tái)線程中啟動(dòng)此服務(wù)器。 |
| stop | void | 通過關(guān)閉監(jiān)聽套接字并禁止處理任何新的exchange來停止此服務(wù)器。 |
1.3 簡(jiǎn)單的Demo
即可使用localhost:8888 進(jìn)行訪問。
/*
實(shí)現(xiàn)HttpHandle處理Http請(qǐng)求
*/
public class HttpServerDemo implements HttpHandler {
public static void main(String[] args) throws IOException {
// 綁定本地指定8888
HttpServer httpServer = HttpServer.create(new InetSocketAddress(InetAddress.getByName("0.0.0.0"),8888),0);
// 設(shè)置上下文信息
httpServer.createContext("/",new HttpServerDemo());
// 啟動(dòng)服務(wù)
httpServer.start();
}
@Override
public void handle(HttpExchange httpExchange) throws IOException {
String response = httpExchange.getRequestURI()+":test message";
httpExchange.sendResponseHeaders(200, 0);
OutputStream os = httpExchange.getResponseBody();
os.write(response.getBytes(StandardCharsets.UTF_8));
os.close();
}
}
