Salah satu faedah utama asyncio ialah keupayaan untuk menggunakan strim tidak menyekat.
Asyncio menyediakan pengaturcaraan soket I/O yang tidak menyekat. Ini disediakan melalui aliran.
boleh membuka soket yang menyediakan akses kepada penulis strim dan penulis strim. Gunakan coroutine untuk menulis dan membaca data daripada strim dan jeda apabila sesuai. Setelah selesai, soket boleh ditutup.
Fungsi penstriman tak segerak adalah tahap rendah, bermakna mana-mana protokol yang diperlukan mesti dilaksanakan secara manual.
Ini mungkin termasuk protokol web biasa seperti:
HTTP atau HTTPS untuk berinteraksi dengan pelayan web
SMTP untuk berinteraksi dengan pelayan e-mel
FTP untuk berinteraksi dengan pelayan fail.
Strim ini juga boleh digunakan untuk mencipta pelayan untuk mengendalikan permintaan menggunakan protokol standard atau untuk membangunkan protokol khusus aplikasi anda sendiri.
Sekarang kita tahu apa itu strim tak segerak, mari lihat cara menggunakannya.
Anda boleh menggunakan fungsi asyncio.open_connection() untuk membuka sambungan soket klien TCP asyncio.
Ini ialah coroutine yang mesti menunggu dan kembali setelah sambungan soket dibuka.
Fungsi ini mengembalikan objek StreamReader dan StreamWriter untuk berinteraksi dengan soket.
... # open a connection reader, writer = await asyncio.open_connection(...)
Terdapat berbilang parameter yang boleh digunakan untuk mengkonfigurasi sambungan soket dalam fungsi asyncio.open_connection(). Dua parameter yang diperlukan ialah hos dan port.
hos ialah rentetan yang menentukan pelayan untuk disambungkan, seperti nama domain atau alamat IP.
port ialah nombor port soket, seperti 80 untuk pelayan HTTP, 443 untuk pelayan HTTPS, 23 untuk SMTP, dsb.
... # open a connection to an http server reader, writer = await asyncio.open_connection('www.google.com', 80)
Menyokong sambungan soket yang disulitkan melalui protokol SSL. Mungkin contoh yang paling biasa ialah HTTPS, yang menggantikan HTTP. Ini boleh dicapai dengan menetapkan parameter "ssl" kepada Benar.
... # open a connection to an https server reader, writer = await asyncio.open_connection('www.google.com', 443, ssl=True)
Anda boleh menggunakan fungsi asyncio.start_server() untuk membuka soket pelayan TCP asyncio. Ini adalah coroutine yang mesti menunggu.
Fungsi ini mengembalikan objek asyncio.Server yang mewakili pelayan yang sedang berjalan.
... # start a tcp server server = await asyncio.start_server(...)
Tiga parameter yang diperlukan ialah fungsi panggil balik, hos dan port. Apabila pelanggan menyambung ke pelayan, fungsi panggil balik dipanggil, yang merupakan fungsi tersuai bernama.
Hos ialah nama domain atau alamat IP yang akan ditentukan oleh pelanggan untuk disambungkan. Port yang digunakan oleh FTP ialah 21 dan port yang digunakan oleh HTTP ialah 80. Port ini ialah nombor port soket yang digunakan untuk menerima sambungan.
# handle connections async def handler(reader, writer): # ... ... # start a server to receive http connections server = await asyncio.start_server(handler, '127.0.0.1', 80)
Anda boleh menggunakan asyncio.StreamWriter untuk memindahkan data ke soket. Data ditulis dalam bait. Data bait boleh ditulis ke soket menggunakan kaedah write().
... # write byte data writer.write(byte_data)
Sebagai alternatif, kaedah writelines() boleh digunakan untuk menulis berbilang "baris" data bait yang disusun ke dalam senarai atau boleh diubah.
... # write lines of byte data writer.writelines(byte_lines)
Tiada cara untuk menulis blok data atau menggantung coroutine panggilan. Selepas menulis data bait, sebaiknya mengosongkan soket melalui kaedah drain(). Ini ialah coroutine yang akan menyebabkan pemanggil berhenti seketika sehingga data dipindahkan dan soket sedia.
... # write byte data writer.write(byte_data) # wait for data to be transmitted await writer.drain()
Gunakan asyncio.StreamReader untuk membaca data dalam soket. Data dibaca dalam format bait, jadi rentetan mungkin perlu dikodkan sebelum digunakan. Semua kaedah baca adalah coroutine yang mesti menunggu.
Sebarang bilangan bait boleh dibaca melalui kaedah read(), yang akan dibaca sehingga akhir fail (EOF).
... # read byte data byte_data = await reader.read()
Selain itu, bilangan bait untuk dibaca boleh ditentukan melalui parameter "n". Ini mungkin membantu jika anda mengetahui bilangan bait yang dijangkakan untuk respons seterusnya.
... # read byte data byte_data = await reader.read(n=100)
Anda boleh menggunakan kaedah readline() untuk membaca satu baris data. Ini mengembalikan bait sehingga baris baru 'n' atau EOF ditemui.
Ini berguna apabila membaca protokol standard untuk manipulasi baris teks.
... # read a line data byte_line = await reader.readline()
Selain itu, terdapat kaedah readexactly() untuk membaca bilangan bait yang tepat, jika tidak pengecualian akan dilemparkan dan kaedah readuntil() yang akan membaca bait sehingga bait dibaca Tentukan aksara.
Anda boleh menggunakan objek asyncio.StreamWriter untuk menutup soket rangkaian. Soket boleh ditutup dengan memanggil kaedah close(). Kaedah ini tidak menyekat.
... # close the socket writer.close()
Walaupun kaedah close() tidak menyekat, kita boleh menunggu sehingga soket ditutup sepenuhnya sebelum meneruskan. Ini boleh dicapai melalui kaedah wait_closed(). Ini adalah coroutine yang boleh ditunggu.
... # close the socket writer.close() # wait for the socket to close await writer.wait_closed()
Kami boleh menyemak sama ada soket telah ditutup atau sedang ditutup melalui kaedah is_closing().
rreeeeAtas ialah kandungan terperinci Cara menggunakan strim bukan penyekat tak segerak Python. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!
![[Web front-end] Permulaan pantas Node.js](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
