[系统运维]python中单线程异步非阻塞

1. socket操作中产生阻塞的地方有：连接的时候，就是执行connect函数的时候，还有就是接受数据的时候产生阻塞，就是执行recv函数等待服务端返回数据的时候

2. 非阻塞就是不等待的意思，执行setblocking(False)，以上的阻塞就不再等待，但是需要我们抛出一个BlockingIOError异常

3. 异步就是执行操作完成之后自动执行回调函数，这个回调函数就会自动完成某些我们需要处理的操作，比如我们在向某个网站发送请求之后，请求完成之后，会自动执行回调函数

4. 与异步非阻塞相对应的就是同步阻塞，阻塞就是等待，同步就是按照某种顺序逐步执行

5. 代码：

import socket
import select

class Req(object):
    def __init__(self,data,func):
        self.sock = data
        self.func = func
    def fileno(self):
        return self.sock.fileno()

class Nb(object):
    def __init__(self):
        self.conn_list = []
        self.socket_list = []

    def add(self,url,func):
        client = socket.socket()
        client.setblocking(False)
        try:
            client.connect((url,80))
        except BlockingIOError:
            pass
        self.conn_list.append(Req(client,func))
        self.socket_list.append(Req(client,func))
    def run(self):
        while True:
            rlist,wlist,elist = select.select(self.socket_list,self.conn_list,[],0.05)
            for sk in wlist:
                sk.sock.sendall(b"GET /s?wd=hello HTTP/1.0\r\nhost:www.baidu.com\r\n\r\n")
                self.conn_list.remove(sk)
            for sk in rlist:
                data_list = []
                while True:
                    try:
                        data = sk.sock.recv(8096)
                        data_list.append(data)
                        if not data:
                            break
                    except BlockingIOError:
                        break
                ret = b''.join(data_list)
                print(ret.decode("utf-8"))
                sk.sock.close()
                self.socket_list.remove(sk)
            if not self.socket_list:
                break

def baidu_request(body):
    print("百度返回的结果:",body)
def sogou_request(body):
    print("搜狗返回的结果:",body)


t1 = Nb()
t1.add("www.baidu.com",baidu_request)
t1.add("www.sogou.com",sogou_request)
t1.run()