主页 / coding / 问题 / 77706629
Accepted
Mandroid
Asked: 2023-12-23 12:20:55 +0800 CST

无法从流中读取 Redis 请求

  • 772

我有以下代码来读取网络请求：

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 请求，例如“redis-cli PING”，它无法读取并且超时。

我犯了什么错误？

rust

1 个回答

  1. Best Answer

    Redis 使用名为 RESP（REdis 序列化协议）的协议，该协议是一种二进制安全协议，旨在序列化数据结构。它不仅仅是像 HTTP 这样的纯文本，因此简单地从 TCP 流中读取行并不总是能够正确地执行 Redis 命令。

    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;
            }
        }
    }
}

    请查看： https: //redis.io/docs/reference/protocol-spec/# :~:text=RESP%20is%20essentially%20a%20serialization,an%20array%20of%20bulk %20strings。

    • 2

相关问题