Created
April 3, 2020 02:41
-
-
Save DeppWang/955b6fef19f540039f36e3ca91170d94 to your computer and use it in GitHub Desktop.
A sample HTTP Server in Java, Use ServerSocket implement, code from https://www.liaoxuefeng.com/wiki/1252599548343744/1304265903570978
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import java.io.BufferedReader; | |
| import java.io.BufferedWriter; | |
| import java.io.IOException; | |
| import java.io.InputStream; | |
| import java.io.InputStreamReader; | |
| import java.io.OutputStream; | |
| import java.io.OutputStreamWriter; | |
| import java.net.ServerSocket; | |
| import java.net.Socket; | |
| import java.nio.charset.StandardCharsets; | |
| public class Server { | |
| public static void main(String[] args) throws IOException { | |
| ServerSocket ss = new ServerSocket(8080); // 监听指定端口 | |
| System.out.println("server is running..."); | |
| for (; ; ) { | |
| Socket sock = ss.accept(); | |
| System.out.println("connected from " + sock.getRemoteSocketAddress()); | |
| Thread t = new Handler(sock); | |
| t.start(); | |
| } | |
| } | |
| } | |
| class Handler extends Thread { | |
| Socket sock; | |
| public Handler(Socket sock) { | |
| this.sock = sock; | |
| } | |
| public void run() { | |
| try (InputStream input = this.sock.getInputStream()) { | |
| try (OutputStream output = this.sock.getOutputStream()) { | |
| handle(input, output); | |
| } | |
| } catch (Exception e) { | |
| try { | |
| this.sock.close(); | |
| } catch (IOException ioe) { | |
| } | |
| System.out.println("client disconnected."); | |
| } | |
| } | |
| private void handle(InputStream input, OutputStream output) throws IOException { | |
| System.out.println("Process new http request..."); | |
| BufferedReader reader = new BufferedReader(new InputStreamReader(input, StandardCharsets.UTF_8)); | |
| BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(output, StandardCharsets.UTF_8)); | |
| // 读取HTTP请求: | |
| boolean requestOk = false; | |
| String first = reader.readLine(); | |
| if (first.startsWith("GET / HTTP/1.")) { | |
| requestOk = true; | |
| } | |
| for (; ; ) { | |
| String header = reader.readLine(); | |
| if (header.isEmpty()) { // 读取到空行时, HTTP Header读取完毕 | |
| break; | |
| } | |
| System.out.println(header); | |
| } | |
| System.out.println(requestOk ? "Response OK" : "Response Error"); | |
| if (!requestOk) { | |
| // 发送错误响应: | |
| writer.write("404 Not Found\r\n"); | |
| writer.write("Content-Length: 0\r\n"); | |
| writer.write("\r\n"); | |
| writer.flush(); | |
| } else { | |
| // 发送成功响应: | |
| String data = "<html><body><h1>Hello, world!</h1></body></html>"; | |
| int length = data.getBytes(StandardCharsets.UTF_8).length; | |
| writer.write("HTTP/1.0 200 OK\r\n"); | |
| writer.write("Connection: close\r\n"); | |
| writer.write("Content-Type: text/html\r\n"); | |
| writer.write("Content-Length: " + length + "\r\n"); | |
| writer.write("\r\n"); // 空行标识Header和Body的分隔 | |
| writer.write(data); | |
| writer.flush(); | |
| } | |
| } | |
| } |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment