0

我正试图用 Tokio 弄湿我的脚。当我从 Telnet 连接发送消息时，我得到Custom { kind: InvalidData, error: FrameTooBig }. 我不明白这个问题，也不知道如何克服它。

extern crate tokio;
extern crate tokio_io;

use tokio::io;
use tokio::net::TcpListener;
use tokio::prelude::*;
use tokio_io::codec::length_delimited;

fn main() {
    let addr = "127.0.0.1:12345".parse().unwrap();
    let listener = TcpListener::bind(&addr).unwrap();

    let server = listener
        .incoming()
        .for_each(|socket| {
            let transport = length_delimited::Builder::new().new_read(socket);
            let msg_proccessing = transport
                .for_each(|msg| {
                    // Note: This part is never actually executed
                    println!("{:?}", msg);
                    Ok(())
                })
                .map_err(|e| println!("waaaaaaaaaaaaaaaaa {:?}", e));
            tokio::spawn(msg_proccessing);
            Ok(())
        })
        .map_err(|_| {});
    tokio::run(server);
}

客户端：

▶ telnet localhost 12345                                     
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
\x00\x00\x00\x0bhello world
Connection closed by foreign host.
4

1 回答 1

1

问题出在客户端，与 Telnet 的工作方式有关。使用 Telnet 发送十六进制数据并不简单，所以我尝试了这个并且效果很好：

echo '\x00\x00\x00\x0bhello world' | nc localhost 12345  #WORKS!

但是，这些都不起作用：

  1. echo '\x00\x00\x00\x0bhello world' | telnet localhost

  2. ▶ telnet localhost 12345                                     
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
\x00\x00\x00\x0bhello world
Connection closed by foreign host.

似乎该FrameTooBig错误是由于 telnet 发送的消息比服务器预期的要大。我无法使用十六进制正确编码帧，然后长度与收到的长度标头不匹配，因此出现错误。

于 2018-04-24T20:26:31.890 回答