3.2 baseIOStream的相关函数以及IOStream类

1.BaseIOStream.fileno()

这个很简单，就是我们stream当前的文件描述符。

2.BaseIOStream.close_fd()

关闭这个fd。

3.BaseIOStream.write_to_fd(data)

尝试向这个fd去写data， 期间可能会出现未成功写入，因此函数的返回值是成功写入数据的大小。

4.BaseIOStream.read_from_fd(data)

有写也有读。

5.BaseIOStream.get_fd_error()

获取fd中所有error信息。

关于baseIOStream的信息差不都就这些了，在我们实际使用的过程中，我们不会去直接使用这个类的，我们基本都会去使用它的子类，IOStream。

以下通过官方文档的例子，来简单介绍一下IOStream。

  1. import tornado.ioloop
  2. import tornado.iostream
  3. import socket
  5. def send_request():
  6.     #向目标写数据
  7.     stream.write(b"GET / HTTP/1.0\r\nHost: friendfeed.com\r\n\r\n")
  8.     #读数据，执行回调on_headers
  9.     stream.read_until(b"\r\n\r\n", on_headers)
  11. def on_headers(data):
  12.     headers = {}
  13.     for line in data.split(b"\r\n"):
  14.        parts = line.split(b":")
  15.        if len(parts) == 2:
  16.            headers[parts[0].strip()] = parts[1].strip()
  17.     #读数据，最后关闭stream，ioloop
  18.     stream.read_bytes(int(headers[b"Content-Length"]), on_body)
  20. def on_body(data):
  21.     print(data)
  22.     stream.close()
  23.     tornado.ioloop.IOLoop.current().stop()
  25. if __name__ == '__main__':
  26.     #创建一个socket
  27.     s = socket.socket(socket.AF_INET, socket.SOCK_STREAM, 0)
  28.     #创建一个stream
  29.     stream = tornado.iostream.IOStream(s)
  30.     #连接目标，执行回调函数send_request
  31.     stream.connect(("friendfeed.com", 80), send_request)
  32.     开启ioloop
  33.     tornado.ioloop.IOLoop.current().start()