如何循环运行Discord消息发送功能且无需反复启停客户端

你的核心问题在于每次发送消息都重新创建并启停Discord客户端，这会带来大量连接开销。正确的做法是只初始化一次客户端并保持长期连接，在客户端的异步上下文里处理消息发送循环。

下面提供两种常用的实现方式：

方式一：固定间隔循环发送消息 #

如果你的需求是每隔一段时间自动发送消息（比如定时推送），可以在客户端就绪后直接启动发送循环：

import discord
import asyncio

# 配置信息
TOKEN = '0000000000000000000000000000000000'
TARGET_CHANNEL_ID = 000000000000000

# 初始化客户端（仅执行一次）
intents = discord.Intents.default()
intents.message_content = True
client = discord.Client(intents=intents)

async def message_send_loop(target_channel):
    """循环发送消息的异步函数"""
    while True:
        # 替换为你的消息获取逻辑（比如从数据库、API拉取最新内容）
        current_message = f"当前时间戳: {asyncio.get_event_loop().time()}"
        
        await target_channel.send(current_message)
        # 间隔时间，单位秒，可根据需求调整
        await asyncio.sleep(60)

@client.event
async def on_ready():
    print(f"已成功登录，账号：{client.user}")
    # 获取目标频道
    target_channel = client.get_channel(TARGET_CHANNEL_ID)
    if not target_channel:
        print("错误：未找到指定频道，请检查频道ID是否正确")
        await client.close()
        return
    
    # 启动发送循环
    await message_send_loop(target_channel)

# 启动客户端
client.run(TOKEN)

说明 #

• 客户端仅初始化并连接一次，后续在保持连接的状态下循环发送消息，彻底避免重复连接的开销
• message_send_loop函数里的消息获取逻辑可以根据实际需求修改（比如读取文件、调用接口等）
• 客户端会自动处理网络断开重连，无需额外代码

方式二：基于消息队列的动态发送 #

如果你的需求是需要外部触发消息发送（比如接收其他系统的通知后发送），可以用异步队列解耦消息生成和发送逻辑：

import discord
import asyncio

# 配置信息
TOKEN = '0000000000000000000000000000000000'
TARGET_CHANNEL_ID = 000000000000000

# 创建消息队列，用于存储待发送的消息
message_queue = asyncio.Queue()

# 初始化客户端（仅执行一次）
intents = discord.Intents.default()
intents.message_content = True
client = discord.Client(intents=intents)

async def process_message_queue(target_channel):
    """后台处理消息队列的异步任务"""
    while True:
        # 从队列中取出待发送的消息
        message_content = await message_queue.get()
        try:
            await target_channel.send(message_content)
            print(f"消息发送成功：{message_content}")
        except Exception as e:
            print(f"消息发送失败：{str(e)}")
        finally:
            # 标记任务完成，让队列知道该消息已处理
            message_queue.task_done()

@client.event
async def on_ready():
    print(f"已成功登录，账号：{client.user}")
    target_channel = client.get_channel(TARGET_CHANNEL_ID)
    if not target_channel:
        print("错误：未找到指定频道，请检查频道ID是否正确")
        await client.close()
        return
    
    # 启动队列处理任务（后台运行）
    asyncio.create_task(process_message_queue(target_channel))
    print("消息发送队列已启动")

async def send_message_to_discord(content):
    """外部调用此函数提交待发送的消息"""
    await message_queue.put(content)

# ------------------------------
# 示例：模拟外部生成消息的逻辑
# ------------------------------
async def example_message_generator():
    """示例：每隔10秒生成一条测试消息"""
    for i in range(10):
        test_message = f"测试消息 {i+1}"
        await send_message_to_discord(test_message)
        await asyncio.sleep(10)

if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    try:
        # 启动消息生成任务
        loop.create_task(example_message_generator())
        # 启动Discord客户端
        loop.run_until_complete(client.start(TOKEN))
    except KeyboardInterrupt:
        # 捕获Ctrl+C，优雅关闭客户端
        loop.run_until_complete(client.close())
    finally:
        loop.close()

说明 #

• 客户端保持长期连接，后台通过队列处理消息发送
• 外部代码可以通过调用send_message_to_discord函数提交消息，无需关心客户端状态
• 队列会自动处理消息的顺序发送，即使短时间内提交大量消息也不会阻塞

关键注意事项 #

1. Intents权限配置：确保在Discord开发者后台启用了message_content权限，否则无法发送消息
2. 异步上下文：所有与Discord客户端交互的操作必须在异步函数中执行，不能在同步代码中直接调用
3. 异常处理：可以根据需求添加更多异常捕获逻辑，比如处理频道不存在、发送频率限制等问题

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