Início / coding / Perguntas / 77706629
Accepted
Mandroid
Asked: 2023-12-23 12:20:55 +0800 CST

Não é possível ler a solicitação redis do stream

  • 772

Tenho o seguinte código para ler uma solicitação de rede:

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

Isso funciona conforme esperado para solicitação http.

Mas para uma solicitação redis, como 'redis-cli PING', ele não é capaz de ler e atinge o tempo limite.

Que erro estou cometendo?

rust

1 respostas

  1. Best Answer

    O Redis usa um protocolo chamado RESP (REdis Serialization Protocol), que é um protocolo binário seguro projetado para serializar estruturas de dados. Não é apenas texto simples como HTTP, portanto, simplesmente ler linhas de um fluxo TCP nem sempre funcionará corretamente para comandos 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;
            }
        }
    }
}

    por favor, veja: https://redis.io/docs/reference/protocol-spec/#:~:text=RESP%20is%20essentially%20a%20serialization,an%20array%20of%20bulk%20strings .

    • 2

relate perguntas