解决异步Python机器人中同步操作的阻塞问题

import vkreal
import asyncio
import discord
from discord.ext import commands

# 初始化Discord机器人
client = commands.Bot(command_prefix='!', intents=discord.Intents.all())

@client.event
async def on_ready():
    """当Discord机器人准备就绪时触发"""
    print('The bot is connected to Discord!')

@client.event
async def on_message(message):
    """处理Discord消息，确保命令也能被处理"""
    if message.author == client.user:
        return
    await client.process_commands(message) # 确保命令被处理

@client.command(pass_context=True)
async def hi(ctx: commands.Context):
    """一个简单的Discord命令示例"""
    await ctx.send('Hi!')

# VK API的配置（请替换为你的实际信息）
# 注意：vkreal通常使用access token而不是login/password
VK_BOT_TOKEN = "YOUR_VK_BOT_TOKEN" # 替换为你的VK机器人Access Token
VK_CHAT_ID = 123456789 # 替换为你的VK聊天ID

# 初始化vkreal会话
# 注意：vkreal的会话初始化方式与vk_api不同，通常直接使用token
# longpoll需要传入一个loop参数，通常是asyncio的默认事件循环
session = vkreal.VkApi(token=VK_BOT_TOKEN)
vk = session.api_context()
longpoll = vkreal.VkLongPoll(session, loop=asyncio.get_event_loop())

async def longpoll_listener():
    """异步监听VK消息"""
    print("Starting VK longpoll listener...")
    async for event in longpoll.listen(): # 使用 async for 确保非阻塞迭代
        # 打印事件类型，用于调试
        print(f"Received VK event: {event['type']}")

        # 这里是原有的VK消息处理逻辑，需要根据vkreal的事件结构进行调整
        # vkreal的事件结构可能与vk_api有所不同，请查阅其文档
        if event['type'] == 'message_new' and event.get('from_chat') and event.get('peer_id') == VK_CHAT_ID:
            message_text = event['text']
            user_id = event['from_id']
            # attachments = event.get('attachments', []) # 获取附件，需要根据vkreal结构调整

            # 获取用户信息（异步操作）
            user_info_list = await vk.users.get(user_ids=user_id)
            if user_info_list:
                user_info = user_info_list[0]
                user_name = f"{user_info['first_name']} {user_info['last_name']}"
            else:
                user_name = "未知用户"

            # 等待Discord客户端准备就绪
            await client.wait_until_ready()
            # 获取Discord频道ID，请替换为你的Discord频道ID
            discord_channel_id = 123456789012345678 # 替换为你的Discord频道ID
            channel = client.get_channel(discord_channel_id)

            if channel:
                # 示例：转发消息到Discord
                # 这里需要根据实际需求和附件处理逻辑进行完善
                forwarded_message = f"{user_name} » {message_text}"
                # if attachments:
                #     forwarded_message += " [Attachment]"
                # if '@all' in message_text:
                #     forwarded_message += " @everyone"
                await channel.send(forwarded_message)
            else:
                print(f"Error: Discord channel {discord_channel_id} not found.")

async def main():
    """主函数，启动Discord机器人和VK监听器"""
    async with client:
        # 创建VK监听任务
        client.loop.create_task(longpoll_listener())
        # 启动Discord机器人
        await client.start('YOUR_DISCORD_BOT_TOKEN') # 替换为你的Discord机器人Token

if __name__ == '__main__':
    try:
        asyncio.run(main())
    except KeyboardInterrupt:
        print("Bot stopped by user.")
    except Exception as e:
        print(f"An error occurred: {e}")