patricksuo
commented
5 years ago CSharp Client X rust Server
5000 clients, payload 64 bytes, 2 rounds
Total Time Elapsed: 1285.9418 Milliseconds
0 error of 5000
connect p90:13.27ms p95:1,000.52ms p99:1,006.45ms p99.9:1,007.12ms
echo p90:24.47ms p95:35.437705ms p99:43.627724ms p99.9:47.5159049ms
total p90:45.52ms p95:1006.97928ms p99:1011.268413ms p99.9:1012.6754441mssupei@sandbox-dev-hk:~/workspace/rust-echo$ cat src/main.rs
extern crate tokio;
use std::net::SocketAddr;
use tokio::io::copy;
use tokio::net::TcpListener;
use tokio::prelude::*;
fn main() {
// Bind the server's socket.
let addr: SocketAddr = "127.0.0.1:12345".parse().unwrap();
let listener = TcpListener::bind(&addr).expect("unable to bind TCP listener");
// Pull out a stream of sockets for incoming connections
let server = listener
.incoming()
.map_err(|e| eprintln!("accept failed = {:?}", e))
.for_each(|sock| {
// Split up the reading and writing parts of the
// socket.
let (reader, writer) = sock.split();
// A future that echos the data and returns how
// many bytes were copied...
let bytes_copied = copy(reader, writer);
// ... after which we'll print what happened.
let handle_conn = bytes_copied
.map(|amt| println!("wrote {:?} bytes", amt))
.map_err(|err| eprintln!("IO error {:?}", err));
// Spawn the future as a concurrent task.
tokio::spawn(handle_conn)
});
// Start the Tokio runtime
tokio::run(server);
}
mgravell
sdanyliv
echo program: https://github.com/sillyousu/TryoutPipelineSockets
Linux
win:
update: cleanup percentile table a little bit.