Я ищу пример сервера TCP в Rust.
Либо "привет мир", либо эхо-сервер были бы замечательными.
Я ищу пример сервера TCP в Rust.
Либо "привет мир", либо эхо-сервер были бы замечательными.
Вот очень простой пример, используя std::net
. Он был разработан против нынешнего мастера Руста и должен работать и на 1. *.
Будьте осторожны с этим примером; он упрощен; вы можете не захотеть, чтобы он впал в панику, если ошибка связи, прослушивания или принятия вызвала ошибку.
use std::io::Write;
use std::net::TcpListener;
use std::thread;
fn main() {
let listener = TcpListener::bind("127.0.0.1:9123").unwrap();
println!("listening started, ready to accept");
for stream in listener.incoming() {
thread::spawn(|| {
let mut stream = stream.unwrap();
stream.write(b"Hello World\r\n").unwrap();
});
}
}
Обратите внимание на парадигму в отношении принятия; вы должны инициировать запрос accept()
самостоятельно (в этом примере мы используем итератор incoming()
, который просто вызывает accept()
каждый раз), и поэтому вы получаете реальный контроль над тем, какие задачи существуют.
В результате я поместил фактический код обработки потока в отдельный поток, но это не обязательно для очень коротких запросов (это просто означает, что вы не сможете обрабатывать второй запрос при обработке первого ); вы можете просто удалить thread::spawn(|| { ... })
об этих двух строках. Использование дополнительных потоков также дает определенную степень изоляции; если поток отключится, сервер в целом не умрет (помните, однако, что нехватка памяти или паника деструктора во время размотки приведет к смерти всего сервера).
Простой TCP-эхо-сервер https://gist.github.com/seriyps/fd6d29442e16c44ba400
#![feature(phase)]
#[phase(plugin, link)] extern crate log;
extern crate green;
extern crate rustuv;
use std::io;
use std::os;
use std::io::{Listener,Acceptor,TcpStream};
// This is for green threads. If removed, will spawn 1 OS thread per client.
#[start]
fn start(argc: int, argv: *const *const u8) -> int {
green::start(argc, argv, rustuv::event_loop, main)
}
fn main() {
let host = "127.0.0.1";
let port = 8080;
let sock = io::TcpListener::bind(host, port).unwrap();
let mut acceptor = sock.listen();
for stream in acceptor.incoming() {
match stream {
Err(e) => warn!("Accept err {}", e),
Ok(stream) => {
spawn(proc() {
debug!("{}", handle_client(stream));
})
}
}
}
}
fn handle_client(mut stream: io::TcpStream) -> io::IoResult<()> {
info!("New client {}", stream.peer_name());
let mut buf = [0u8, ..4096];
loop {
let got = try!(stream.read(buf));
if got == 0 {
// Is it possible? Or IoError will be raised anyway?
break
}
try!(stream.write(buf.slice(0, got)));
}
Ok(())
}