使用Python实现异步文件读写功能

pip install aiofiles

import asyncio

import aiofiles

async def read_file(file_path):

    async with aiofiles.open(file_path, mode='r') as file:

        content = await file.read()

        print(f"读取文件 {file_path} 的内容: {content}")

async def write_file(file_path, content):

    async with aiofiles.open(file_path, mode='w') as file:

        await file.write(content)

        print(f"写入文件 {file_path} 的内容: {content}")

async def main():

    # 读取文件

    await read_file('example.txt')

    # 写入文件

    await write_file('example.txt', 'Hello, 猴子音悦音乐库!')

# 运行主函数

asyncio.run(main())

import asyncio

import aiohttp

import aiofiles

async def download_music(url, file_path):

    async with aiohttp.ClientSession() as session:

        async with session.get(url) as response:

            if response.status == 200:

                async with aiofiles.open(file_path, mode='wb') as file:

                    await file.write(await response.read())

                print(f"下载完成: {file_path}")

            else:

                print(f"下载失败: {url}")

async def process_music_files(music_urls):

    tasks = []

    for url in music_urls:

        file_name = url.split('/')[-1]

        task = asyncio.create_task(download_music(url, file_name))

        tasks.append(task)

    await asyncio.gather(*tasks)

async def main():

    music_urls = [

        'https://example.com/music1.mp3',

        'https://example.com/music2.mp3',

        'https://example.com/music3.mp3'

    ]

    await process_music_files(music_urls)

# 运行主函数

asyncio.run(main())