advance/concurrency-with-threads/web-server

[giscus[bot]]

advance/concurrency-with-threads/web-server

https://course.rs/advance/concurrency-with-threads/web-server.html

[SheilaLundin]

想学习下怎么能关闭TcpListener，for stream in listener.incoming 无法结束循环啊

[lonexw]

关闭不就无法接受请求了吗？为什么要关闭？

[sdttttt]

std的话，可以读可以客户端的某个数据帧，return来关闭；或者让listener跑子线程里，父线程获得某种条件return也可以。
tokio的话会灵活一些 https://tokio.rs/tokio/topics/shutdown

[Roxannej]

期待这一章呢

[xeekst]

可以先看官网的。https://kaisery.github.io/trpl-zh-cn/ch20-00-final-project-a-web-server.html

[xeekst]

https://doc.rust-lang.org/book/ch20-00-final-project-a-web-server.html

[showyou2023]

一下代码是官方的web server的代码。
我有个问题，为什么用filter 替代take_while后，代码不能正常执行？

use std::fs;
use std::io::{BufRead, BufReader, Write};
use std::net::{TcpListener, TcpStream};

fn main() {
let listner = TcpListener::bind("127.0.0.1:8080").unwrap();
println!("Waiting...");
for stream in listner.incoming() {
let stream = stream.unwrap();
println!("connection in main...");
handle_connection(stream);
}
}
//take_while
fn handle_connection(mut stream: TcpStream) {
let buf_reader = BufReader::new(&mut stream);
let http_request: Vec<_> = buf_reader
.lines()
.map(|result| result.unwrap())
.take_while(|line| !line.is_empty())
.collect();
println!("request:\r\n{:#?}",http_request);
let http_response = "HTTP/1.1 200 ok";
let contents=fs::read_to_string("index.html").unwrap();
let http_response=format!("{}\r\n\r\n{}",http_response,contents);
println!("response:\r\n{:#?}",http_response);
stream.write_all(http_response.as_bytes()).unwrap();
stream.flush().unwrap();
}

[showyou2023]

这个项目，设计修改思路在官网讲的非常清楚。
虽然挺烧脑，确实值得仔细揣摩。
反复看，反复思考，反复敲代码，直到理解下的完整代码重建。

不理解的，先照猫画虎的默背下代码，终会在某一点上突然领悟，此现象发生过很多次。