\u4f7f\u7528 tokio \u6839\u636e\u6587\u6863\u5199\u4e00\u4e2a\u6536\u53d1\u5b57\u7b26\u4e32\u5185\u5bb9\u7684tcp server.<\/p>\n
\u6587\u6863\u5730\u5740\uff1ahttps:\/\/tokio.rs\/docs\/getting-started\/simple-server\/<\/p>\n
#[macro_use]\r\nextern crate log;\r\n\r\nextern crate bytes;\r\nextern crate tokio_io;\r\nextern crate tokio_core;\r\nextern crate tokio_proto;\r\nextern crate tokio_service;\r\nextern crate byteorder;\r\nextern crate futures;\r\n\r\n\r\nuse std::io;\r\nuse std::str;\r\nuse std::io::Cursor;\r\nuse bytes::{BytesMut,BufMut};\r\nuse tokio_io::codec::*;\r\nuse byteorder::*;\r\nuse tokio_proto::TcpServer;\r\nuse tokio_proto::pipeline::ServerProto;\r\n\/\/use tokio_proto::multiplex::ServerProto;\r\n\/\/use tokio_proto::streaming::pipeline::ServerProto;\r\nuse tokio_io::*;\r\nuse tokio_io::codec::Framed;\r\nuse tokio_service::Service;\r\nuse futures::{future,Future,BoxFuture};\r\n\r\n#[test]\r\nfn hello(){\r\n info!("hello");\r\n\r\n pub struct MessageCodec;\r\n\r\n impl Decoder for MessageCodec{\r\n type Item=String;\r\n type Error=io::Error;\r\n fn decode(&mut self, buf: &mut BytesMut) -> Result<Option<Self::Item>, Self::Error>{\r\n println!("decode:{}",buf.len());\r\n if buf.len()<=4 {\r\n return Ok(None);\r\n }\r\n\r\n\r\n let len=BigEndian::read_i32(buf.split_to(4).as_ref()) as usize;\r\n\r\n let b=buf.split_to(len);\r\n let content=str::from_utf8(b.as_ref());\r\n println!("decode 2:{}",buf.len());\r\n return Ok( Some( content.unwrap().to_owned() ));\r\n }\r\n }\r\n\r\n impl Encoder for MessageCodec{\r\n type Item=String;\r\n type Error=io::Error;\r\n fn encode(&mut self, item: String, buf: &mut BytesMut)\r\n -> Result<(), Self::Error>{\r\n println!("encode:{}",item);\r\n buf.put_i32::<BigEndian>(item.len() as i32 );\r\n buf.put_slice(item.into_bytes().as_ref());\r\n return Ok(());\r\n }\r\n }\r\n\r\n pub struct MessageProto;\r\n\r\n impl<T:AsyncRead+AsyncWrite+'static> ServerProto<T> for MessageProto{\r\n type Request=String;\r\n type Response=String;\r\n type Transport=Framed<T,MessageCodec>;\r\n\r\n type BindTransport = Result<Self::Transport,io::Error>;\r\n fn bind_transport(&self, io: T) -> Self::BindTransport{\r\n Ok(io.framed(MessageCodec))\r\n }\r\n }\r\n\r\n pub struct GameServer;\r\n\r\n impl Service for GameServer{\r\n \/\/\/ Requests handled by the service.\r\n type Request=String;\r\n\r\n \/\/\/ Responses given by the service.\r\n type Response=String;\r\n\r\n \/\/\/ Errors produced by the service.\r\n type Error=io::Error;\r\n\r\n \/\/\/ The future response value.\r\n type Future=BoxFuture<Self::Response,Self::Error >;\r\n\r\n \/\/\/ Process the request and return the response asynchronously.\r\n fn call(&self, req: Self::Request) -> Self::Future{\r\n println!("receive:{}",req);\r\n\r\n return future::ok(req.chars().rev().collect()).boxed();\r\n }\r\n }\r\n\r\n let addr="0.0.0.0:9999".parse().unwrap();\r\n let server=TcpServer::new(MessageProto,addr);\r\n\r\n println!("start running");\r\n server.serve(|| Ok(GameServer));\r\n\r\n println!("hello test");\r\n}<\/pre>\n\u7b2c\u4e00\u6b21\u57fa\u7840\u4e0a\u7b97\u6b63\u89c4\u7684\u8fb9\u770b\u6587\u6863\uff0c\u8fb9\u5199\uff0c\u8fb9\u7406\u89e3\u8bed\u6cd5\uff0c\u8fb9google\u3002<\/p>\n
\u8fc7\u7a0b\u4e2d\u638c\u63e1\u4ee5\u4e0b\u77e5\u8bc6\u70b9\uff1a<\/p>\n
1\u3001\u7c7b\u578b\u8f6c\u6362\r\ni32 \u8f6c\u4e3a u32\r\na as u32\r\n2\u3001\u4ece [u8] \u4e2d\u8bfb\u53d6\u4e00\u4e2a\u57fa\u7840\u7c7b\u578b\r\nBigEndian::read_i32(buf)\r\n3\u3001byte[] \u8f6c\u4e3a\u5b57\u7b26\u4e32\r\n str::from_utf8([u8])\r\n4\u3001\u5b57\u7b26\u4e32\u8f6c\u4e3abytes\r\nstr.into_bytes()\r\n5\u3001slice\u76ee\u524dide\u65e0\u6cd5\u505a\u5230\u667a\u80fd\u8bed\u6cd5\u63d0\u793a\u3002\r\n \u9700\u8981\u81ea\u5df1\u6765\u5904\u7406\u3002\r\n6\u3001bytes\u53d6\u4e00\u4e2aslice\u518d\u8f6c\u4e3abyte[]\r\n buf[a..b].as_ref()<\/pre>\n\u4e0b\u4e00\u6b65\u5c31\u662f\u81ea\u5df1\u7528tcpstream\u53bb\u8fde\u4e0a\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
\u4f7f\u7528 tokio \u6839\u636e\u6587\u6863\u5199\u4e00\u4e2a\u6536\u53d1\u5b57\u7b26\u4e32\u5185\u5bb9\u7684tcp server. \u6587\u6863\u5730\u5740 …<\/p>\n