discord.py机器人实现后台运行+自定义消息输入发送方案咨询

我懂你碰到的麻烦了——discord.py是基于异步IO的框架，直接用同步的while True+input会阻塞事件循环，线程里又不能直接用await，确实容易踩坑。下面给你两个可行的实现方案，既能让机器人正常运行，又能接收你的输入发送消息：

方案一：用异步任务+asyncio.to_thread（推荐） #

这个方法利用discord.py的事件循环，把同步的input操作放到单独线程里，不会阻塞机器人的核心事件处理：

import discord
from discord.ext import commands
import asyncio

# 初始化机器人，记得开启必要的intents
bot = commands.Bot(command_prefix="!", intents=discord.Intents.all())

async def custom_message_loop():
    # 等待机器人完全就绪，确保能获取到频道
    await bot.wait_until_ready()
    target_channel = bot.get_channel(你的频道ID)  # 替换成你的频道ID
    if not target_channel:
        print("错误：找不到指定的频道！")
        return
    
    print("机器人已就绪，现在可以输入消息发送到Discord（输入exit退出）：")
    while not bot.is_closed():
        # 用to_thread把同步的input包装成异步操作，避免阻塞事件循环
        user_input = await asyncio.to_thread(input, "Bot: ")
        if user_input.lower() == "exit":
            await bot.close()
            break
        # 空消息不发送
        if user_input.strip():
            await target_channel.send(user_input)

@bot.event
async def on_ready():
    print(f"成功登录为 {bot.user.name}")
    # 创建异步任务启动消息输入循环
    bot.loop.create_task(custom_message_loop())

# 替换成你的机器人令牌
bot.run("你的机器人TOKEN")

为什么这个方法可行？ #

asyncio.to_thread会把input这个同步阻塞的操作放到单独的线程执行，这样discord.py的事件循环就能继续处理其他事件（比如命令、消息监听），不会被卡死。

方案二：用线程+事件循环调度协程 #

如果你习惯用线程来处理输入，可以通过asyncio.run_coroutine_threadsafe把发送消息的协程提交给机器人的事件循环，避免线程里直接用await报错：

import discord
from discord.ext import commands
import threading
import asyncio

bot = commands.Bot(command_prefix="!", intents=discord.Intents.all())
target_channel = None

def input_handler():
    global target_channel
    print("机器人启动中，请稍候...")
    while not bot.is_closed():
        user_input = input("Bot: ")
        if user_input.lower() == "exit":
            # 线程里关闭机器人，需要把close()协程提交到事件循环
            asyncio.run_coroutine_threadsafe(bot.close(), bot.loop)
            break
        if user_input.strip() and target_channel:
            # 把发送消息的操作提交给机器人的事件循环执行
            asyncio.run_coroutine_threadsafe(target_channel.send(user_input), bot.loop)

@bot.event
async def on_ready():
    global target_channel
    print(f"已登录为 {bot.user.name}")
    target_channel = bot.get_channel(你的频道ID)
    if not target_channel:
        print("错误：找不到指定频道！")
        await bot.close()
        return
    # 启动输入线程，设置daemon=True让线程随机器人关闭而退出
    threading.Thread(target=input_handler, daemon=True).start()

bot.run("你的机器人TOKEN")

注意事项 #

• 不要直接在on_ready里写while True+input，这会完全阻塞事件循环，导致机器人无法响应任何其他操作。
• 线程里绝对不能直接调用await，必须通过asyncio.run_coroutine_threadsafe把协程交给机器人的事件循环处理。
• 记得开启正确的intents，否则机器人可能无法获取频道或处理消息。

内容的提问来源于stack exchange，提问作者user11229202