Rust 网路编程 1

Rust 网路编程 1

Start

虽然现在rust的网络部分还很初级,基本都处在unstable状态。 不过简单的试试网络编程还是没问题。

最简单标准的tcp server流程:

bind

listen

accept

这样就可以开始接受外部链接。

看看rust里面是这些步骤是该怎么做?

bind

通过TcpListener结构来进行bind和listen。

在impl TcpListener下面有

fn bind(addr: A) -> IoResult

从上面的函数的定义可以看出,bind是TcpListener的static方法,通过::调用就可以了。

为什么是static方法?没有&self参数在第一个参数位置呗,很简单。

同时上面这个接口也是个很典型的泛型接口。

参数:addr 类型 A,要求A必须要实现ToSocketAddr traits

返回值:IoResult;

rust里面的惯用法就是用这种result集合进行返回。 对于这个结果,经常的如果这个结果不需要进行错误处理,就直接把结果unwrap出来,出错就结束运行。

//为了简单起见,引入io里面的所有东西.
use std::io::*;

fn main(){
     let listener = io::TcpListener::bind("127.0.0.1:9999").unwrap();
}

这个程序是没有问题的,我们bind到一个地址,用unwrap进结果判断,如果成功,就把真正的listener绑定到左边变量。

值得注意的是bind的参数是一个字符串常量&str,文档中可以看到&str是实现了ToSocketAddr这个traits的。 开始我都觉得难以置信。

下面进行

listen

impl Listener<TcpStream, TcpAcceptor> for TcpListener
fn listen(self) -> IoResult

从上面的接口,我们可以调用TcpListener的listen成员方法来得到一个IoResult<TcpAcceptor> 从这个接口来看,这里是一个值语义的self,如果TcpListener没有实现Copy的traits,这个地方就只能是move了。 也就是说,TcpListener在调用listen的时候,会把自己“消耗”掉,下面的代码都不能再使用了。

use std::io::*;
fn main(){
    let listener = io::TcpListener::bind("127.0.0.1:9999").unwrap();
    let acceptor = listener.listen().unwrap();
}

当我们有了一个acceptor的时候,我们看看怎讲来accept一个链接?

accept

impl Acceptor for TcpAcceptor
fn accept(&mut self) -> IoResult

上面的接口可以看出,可以直接调用TcpAcceptor的成员方法accept。但是注意这里的self是一个mut的引用。 所以我们要让acceptor不光是默认的只读

use std::io::*;
fn main(){
    let listener = io::TcpListener::bind("127.0.0.1:9999").unwrap();
    let mut acceptor = listener.listen().unwrap();
    let tcpstream = acceptor.accept().unwrap();
}

有了上面的代码,我就可以accept一个链接进来了。

为了看看效果,我们看看Tcpstream的文档,打印一些链接信息出来,最简单的就是看看对端的ip,端口。

下面这个函数看起来就不错

fn peer_name(&mut self) -> IoResult

其实从Tcpstream的接口来看,很多也需要可以能需要改变Tcpstream的内部状态。因为参数都要求是&mut self

use std::io::*;

fn main(){
    let listener = io::TcpListener::bind("127.0.0.1:9999").unwrap();
    let mut acceptor = listener.listen().unwrap();
    let mut tcpstream = acceptor.accept().unwrap();
    let socketaddr = tcpstream.peer_name().unwrap();
    println!("connection from: {}", socketaddr);
}

上面的代码就是一个最基本接收一个连接的server了,然后写个client试试。 只有一行一行,当然我们只是看这个链接建立的情况,不传数据。

use std::io::*;

fn main() {
    let mut stream = TcpStream::connect("127.0.0.1:9999").unwrap();
}

最后,我没有任何关闭socket的操作是不是有问题?

发表评论

电子邮件地址不会被公开。 必填项已用*标注