【tulip】 – I/O阻塞的小例子_程序人生

【tulip】 – I/O阻塞的小例子

admin

2023-07-31 01:50:28

0次

接下来，会把Python tulip这个网络库（也就是3.4之后的asyncio）如何实现的进行一些分析。在了解了tulip的实现方式的基础之上，希望能够把流程阻塞的功能在tulip的框架之上实现，从而可以制作一个简单的类似ansible，saltstack这样的集群调度工具。
我们先来看一个最基本的网络编程的例子

import socket

listen_sock = socket.socket(family=socket.AF_INET, type=socket.SOCK_STREAM, proto=socket.IPPROTO_IP)
listen_sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
listen_sock.bind((\'0.0.0.0\', 9090))
listen_sock.listen(0)
while True:
    conn_sock, client_addr = listen_sock.accept()
    print(\'connected from %s:%s\' % client_addr)
    input = conn_sock.recv(8192)
    while \'done\' != input.strip():
        conn_sock.sendall(input)
        input = conn_sock.recv(8192)
    conn_sock.sendall(\'bye!\\n\')
    conn_sock.close()

这是一个tcp服务器。客户端连上了之后向其发送的字符会被原样返回回来（所谓echo），除非发送的是done这个字符串。收到了done之后连接断开这个客户端的连接。

$ telnet 127.0.0.1 9090
Trying 127.0.0.1...
Connected to 127.0.0.1.
Escape character is \'^]\'.
I say hello
I say hello
done
bye!

这个例子没有使用多线程，也没有使用其他任何支持并发的技术。所以一次也就只能有一个客户端连到服务器进行通信，第二个客户端连上来之后得等一个客户端退出之后才会被服务器服务。

python TCP

上一篇：【tulip】 – 多线程的版本

下一篇：【妙用协程】 – I/O阻塞和流程阻塞

【tulip】 – I/O阻塞的小例子

相关内容

热门资讯