我有以下代码可以从网络请求中读取:
fn handle_connection(mut stream: TcpStream) {
let buf_reader = BufReader::new(&mut stream);
let req: Vec<_> = buf_reader
.lines()
.map(|result| result.unwrap())
.take_while(|line| !line.is_empty())
.collect();
println!("Request: {:#?}", req);
}
这与预期的http请求一样.
但是对于像‘redis-cli ping’这样的redis请求，它不能读取和超时.
我犯了什么错误？
Redis使用一种名为RESP(REDIS序列化协议)的协议，这是一种设计用于序列化数据 struct 的二进制安全协议.它不只是像HTTP那样的纯文本，所以对于Redis命令来说，简单地从TCP流中读取行并不总是正确的.
use std::io::{self, BufRead, BufReader};
use std::net::TcpStream;
fn handle_connection(mut stream: TcpStream) {
let mut buf_reader = BufReader::new(&mut stream);
loop {
let mut line = String::new();
match buf_reader.read_line(&mut line) {
Ok(0) => break, // End of stream
Ok(_) => {
if line.starts_with("*") {
// Handle Redis command
// You will need to implement proper RESP parsing here
println!("Redis command: {}", line.trim());
} else {
// Not a Redis command or end of command
break;
}
}
Err(e) => {
eprintln!("Failed to read from stream: {}", e);
break;
}
}
}
}