我正在尝试使用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
我如何声明响应足够活?
正如我在评论中所指出的:使用into_bytes
,而不是用Arc
包装并传递借来的字节数组。
@大卫:
但我不明白为什么用弧包裹没有。
Arc
计算内部对象的参考:
clone()
时它会增加参考Arc
的所有者掉线时,它会减少参考。在你的情况下Arc
的所有者,命名为response
。 response
在范围内创建,并在相同范围的末尾删除。在创建时它的引用计数为1,在删除后它变为0。但是你已经在Arc
中将Future
的参考文献从记忆中移除之前通过了。
请注意,write_all()
创建了一个Future
,Future
带有你的Arc
的引用,在Future
执行之前将其从记忆中删除。
注意:WriteAll
可以拥有借来的或移动的值,它期望一个通用参数可以转换为slice
。