借用Tokio未来,借来的价值不够长

问题描述 投票:0回答:1

我正在尝试使用Rust和tokio编写一个简单的HTTP服务器。

一切正常,直到我想发送回复。

代码如下:

use std::fs;
use std::sync::Arc;
use tokio::net::TcpListener; // 0.1.15
use tokio::prelude::*;

fn main() {
    let addr = "0.0.0.0:8080".parse().unwrap();
    let listener = TcpListener::bind(&addr).expect("unable to bind TCP listener");

    let incoming = listener.incoming();

    let server = incoming
        .map_err(|e| eprintln!("accept failed = {:?}", e))
        .for_each(|socket| {
            println!(
                "Connection established: from {:?} to {:?}",
                socket.peer_addr(),
                socket.local_addr()
            );
            let bytes = vec![0; 512];
            let processor = tokio::io::read(socket, bytes)
                .and_then(|(socket, bytes, _size)| {
                    println!("Request: {}", String::from_utf8_lossy(&bytes[..]));
                    let contents = fs::read_to_string("hello.html").unwrap();
                    let response = Arc::new(format!("HTTP/1.1 200 OK\r\n\r\n{}", contents));
                    let response = response.clone();
                    tokio::io::write_all(socket, response.as_bytes()).and_then(|_| Ok(()))
                })
                .map_err(|_| ());
            tokio::spawn(processor);
            Ok(())
        });

    tokio::run(server);
}
error[E0597]: `response` does not live long enough
  --> src/main.rs:27:50
   |
27 |                     tokio::io::write_all(socket, response.as_bytes()).and_then(|_| Ok(()))
   |                                                  ^^^^^^^^ borrowed value does not live long enough
28 |                 })
   |                 - `response` dropped here while still borrowed

我如何声明响应足够活?

rust borrow-checker rust-tokio
1个回答
1
投票

你怎么能让它发挥作用?

正如我在评论中所指出的:使用into_bytes,而不是用Arc包装并传递借来的字节数组。

Playground


@大卫:

但我不明白为什么用弧包裹没有。

Arc计算内部对象的参考:

  • 当你clone()时它会增加参考
  • Arc的所有者掉线时,它会减少参考。
  • 当引用计数减少到0时,它会从内存中删除

在你的情况下Arc的所有者,命名为responseresponse在范围内创建,并在相同范围的末尾删除。在创建时它的引用计数为1,在删除后它变为0。但是你已经在Arc中将Future的参考文献从记忆中移除之前通过了。

请注意,write_all()创建了一个FutureFuture带有你的Arc的引用,在Future执行之前将其从记忆中删除。

注意:WriteAll可以拥有借来的或移动的值,它期望一个通用参数可以转换为slice

© www.soinside.com 2019 - 2024. All rights reserved.