c20: single-thread web server

polyactis · polyactis · commit 7ca16a2779c4 · 2024-02-12T22:16:25.000+08:00
diff --git a/c20_web_server/404.html b/c20_web_server/404.html
@@ -0,0 +1,11 @@
+<!DOCTYPE html>
+<html lang="en"> 
+    <head>
+        <meta charset="utf-8">
+        <title>Hello!</title>
+    </head>
+    <body>
+        <h1>Oops!</h1>
+        <p>Not available.</p>
+    </body>
+    </html>
diff --git a/c20_web_server/Cargo.toml b/c20_web_server/Cargo.toml
@@ -0,0 +1,8 @@
+[package]
+name = "c20_web_server"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
diff --git a/c20_web_server/hello.html b/c20_web_server/hello.html
@@ -0,0 +1,11 @@
+<!DOCTYPE html>
+<html lang="en">
+    <head>
+        <meta charset="utf-8">
+        <title>Hello!</title> 
+    </head>
+    <body> 
+        <h1>Hello!</h1> 
+        <p>Hi from Rust</p> 
+    </body> 
+</html>
diff --git a/c20_web_server/src/main.rs b/c20_web_server/src/main.rs
@@ -0,0 +1,34 @@
+use std::{fs, io::{BufRead, BufReader, Write}, net::{TcpListener, TcpStream}};
+
+
+fn handle_connection(mut stream: TcpStream) {
+    let buf_reader = BufReader::new(&mut stream);
+    let request_line = buf_reader.lines().next().unwrap().unwrap();
+
+    // let http_request: Vec<_> = buf_reader
+    //     .lines()
+    //     .map(|result| result.unwrap())
+    //     .take_while(|line| !line.is_empty())
+    //     .collect();
+    // println!("Request: {:#?}", http_request);
+
+
+    let (status_line, filename) = if request_line == "GET / HTTP/1.1" {
+        ("HTTP/1.1 200 OK", "hello.html")
+    } else {
+        ("HTTP/1.1 404 NOT FOUND", "404.html")
+    };
+    let contents = fs::read_to_string(filename).unwrap();
+    let length = contents.len();
+    let response = format!("{status_line}\r\nContent-Length: {length}\r\n\r\n{contents}");
+
+    stream.write_all(response.as_bytes()).unwrap();
+}
+fn main() {
+    let listener = TcpListener::bind("127.0.0.1:7878").unwrap();
+    for stream in listener.incoming() {
+        let stream = stream.unwrap();
+
+        handle_connection(stream);
+    }
+}
