Python實現(xiàn)異步IO非常簡單，asyncio是Python 3.4版本引入的標準庫，直接內(nèi)置了對異步IO的支持。

asyncio的編程模型就是一個消息循環(huán)。我們從asyncio模塊中直接獲取一個EventLoop的引用，然后把需要執(zhí)行的協(xié)程扔到EventLoop中執(zhí)行，就實現(xiàn)了異步IO。

import asyncio@asyncio.coroutinedef wget(host): print(’wget %s...’ % host) connect = asyncio.open_connection(host, 80) reader, writer = yield from connect header = ’GET / HTTP/1.0rnHost: %srnrn’ % host writer.write(header.encode(’utf-8’)) yield from writer.drain() while True: line = yield from reader.readline() if line == b’rn’: break print(’%s header > %s’ % (host, line.decode(’utf-8’).rstrip())) # Ignore the body, close the socket writer.close()loop = asyncio.get_event_loop()tasks = [wget(host) for host in [’www.sina.com.cn’, ’www.sohu.com’, ’www.163.com’]]loop.run_until_complete(asyncio.wait(tasks))loop.close()

知識點擴展：

數(shù)據(jù)流（Streams）

數(shù)據(jù)流（Streams）是用于處理網(wǎng)絡(luò)連接的高階異步/等待就緒(async/await-ready)原語,可以在不使用回調(diào)和底層傳輸協(xié)議的情況下發(fā)送和接收數(shù)據(jù)。

以下是一個用asyncio實現(xiàn)的TCP回顯客戶端：

import asyncioasync def tcp_echo_client(message): reader, writer = await asyncio.open_connection( ’127.0.0.1’, 8888) print(f’Send: {message!r}’) writer.write(message.encode()) data = await reader.read(100) print(f’Received: {data.decode()!r}’) print(’Close the connection’) writer.close() await writer.wait_closed()asyncio.run(tcp_echo_client(’Hello World!’))

到此這篇關(guān)于python中使用asyncio實現(xiàn)異步IO實例分析的文章就介紹到這了,更多相關(guān)python中使用asyncio實現(xiàn)異步IO內(nèi)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！