使用tokio_io的read_exact搭配Rc<TcpStream>时为何出现Sized溢出错误？

首先，这个错误是Rust编译器在处理泛型类型推导或Trait约束时陷入了无限递归，导致栈溢出。简单来说，当编译器试图解析某个类型需要满足的一系列约束时，发现这些约束会不断嵌套展开、没有尽头，最终就会抛出这个错误。

你的案例问题分析 #

从你给出的代码片段来看，主要有两个核心问题触发了这个错误：

1. 错误的引用类型：read_exact需要的是一个实现AsyncRead的可变引用（因为AsyncRead继承自Read，而Read的read方法需要&mut self），但你用conn.borrow()得到的是不可变的&TcpStream，这本身就不符合AsyncRead的约束。
2. 递归的Future类型推导：如果你的read_one函数后续会在read_exact的回调里再次调用自己（比如实现循环读取），编译器会试图推导一个无限嵌套的Future类型（类似ReadExact<..., Then<..., ReadExact<..., Then<...>>>>），这种无限展开直接导致了编译器的栈溢出。

具体修复方案 #

1. 修正引用类型，使用线程安全的共享方式

异步代码中共享网络连接通常需要线程安全，建议把Rc<TcpStream>换成Arc<Mutex<TcpStream>>——Arc提供线程安全的共享能力，Mutex用来获取可变引用以满足AsyncRead的要求。

2. 用Trait对象打破无限类型推导

把递归的Future装箱成Box<dyn Future<...>>，这样编译器不需要推导完整的无限嵌套类型，而是通过Trait对象来抽象，避免递归溢出。

修复后的示例代码

extern crate tokio_core;
extern crate tokio_io;
extern crate futures;

use std::sync::{Arc, Mutex};
use tokio_core::net::TcpStream;
use tokio_core::reactor::Handle;
use tokio_io::io::read_exact;
use futures::{Future, IntoFuture};

fn read_one(conn: Arc<Mutex<TcpStream>>, handle: Handle) -> Box<dyn Future<Item = (), Error = ()> + 'static> {
    // 准备读取缓冲区（这里假设读1个字节，可根据需求调整）
    let mut buf = [0u8; 1];
    
    // 获取可变的TcpStream引用
    let mut stream = conn.lock().unwrap();
    
    // 调用read_exact并处理结果
    let future = read_exact(&mut *stream, buf)
        .then(move |result| {
            match result {
                Ok((_stream, _buf)) => {
                    // 添加读取后的逻辑处理
                    println!("Read one byte successfully");
                    // 递归调用read_one继续读取，注意clone Arc
                    read_one(conn.clone(), handle)
                }
                Err(e) => {
                    eprintln!("Read error occurred: {}", e);
                    // 错误处理后返回空的成功Future
                    Ok(()).into_future()
                }
            }
        });
    
    // 装箱Future，打破无限类型推导
    Box::new(future)
}

额外注意点 #

• 如果你使用的是较新版本的Tokio（比如Tokio 1.x+），API已经有很大变化，但核心的类型推导问题解决思路是一致的。
• 尽量避免在异步代码中使用Rc，因为它不是线程安全的，而Tokio的运行时默认是多线程的，Arc才是正确的选择。

内容的提问来源于stack exchange，提问作者Earth Engine