使用discord.py+Flask API多进程发消息时遇Channel为None错误

问题根源 #

你用multiprocessing.Process启动Flask后，主进程（运行Discord Bot）和子进程（运行Flask）拥有完全独立的内存空间：

• Flask进程导入bot.py的client时，会重新创建一个未登录、无缓存的Discord客户端实例，而非主进程中已经完成登录并加载了频道信息的那个，因此client.get_channel()必然返回None。
• 直接在Flask同步视图中新建asyncio事件循环调用Discord异步方法，本身也不符合Discord.py的运行逻辑。

可行解决方案 #

方案1：多线程共享Bot实例（推荐，实现简单） #

用线程替代进程运行Flask，确保两者共享同一内存空间，能访问已登录的Bot客户端。

修改bot.py

import discord, asyncio
from discord import app_commands
from discord.ext import commands
from discord.ui import Button, View
from threading import Thread
from rest_api import app 

TOKEN = 'xyz'

intents = discord.Intents.all()
client = discord.Client(intents=intents)
tree = app_commands.CommandTree(client)

# 存储Bot的事件循环，供Flask线程调用
bot_loop = None

async def say(message: str):
    channel = client.get_channel(1137498510397280377)
    if channel:
        # 如需消息组件，直接在这里构建View即可
        button = Button(label="测试按钮", style=discord.ButtonStyle.green)
        view = View()
        view.add_item(button)
        await channel.send(message, view=view)

def flask_runner():
    # 关闭Flask自动重载，避免重复启动线程/进程
    app.run(debug=False, use_reloader=False)

@client.event
async def on_ready():
    global bot_loop
    bot_loop = asyncio.get_running_loop()
    print(f'已登录：{client.user}')

if __name__ == "__main__":
    # 用线程启动Flask
    flask_thread = Thread(target=flask_runner)
    flask_thread.start()
    # 启动Discord Bot
    client.run(TOKEN)

修改Flask文件（建议重命名为rest_api.py避免和库名冲突）

from flask import Flask
from flask_restful import Api, Resource
import asyncio

app = Flask(__name__)
api = Api(app)

# 从Bot模块导入共享的事件循环和发送函数
from bot import bot_loop, say

class Mess(Resource):
    def get(self, message):
        # 在Bot的事件循环中调度异步发送任务
        asyncio.run_coroutine_threadsafe(say(message), bot_loop)
        return {'状态': 200, '提示': '发送任务已提交'}

api.add_resource(Mess, "/<message>")

方案2：进程间通信（适合严格隔离进程的场景） #

用multiprocessing.Queue作为进程间通信桥梁，Flask进程将消息放入队列，主进程的Bot循环读取队列并执行发送操作。

修改bot.py

import discord, asyncio
from multiprocessing import Process, Queue
from rest_api import app 

TOKEN = 'xyz'

intents = discord.Intents.all()
client = discord.Client(intents=intents)

# 进程间通信队列
message_queue = Queue()

async def process_queue():
    while True:
        # 用to_thread避免阻塞Bot事件循环
        message = await asyncio.to_thread(message_queue.get)
        channel = client.get_channel(1137498510397280377)
        if channel:
            await channel.send(message)

@client.event
async def on_ready():
    print(f'已登录：{client.user}')
    # 启动队列处理任务
    asyncio.create_task(process_queue())

def flask_runner(q):
    app.config['MESSAGE_QUEUE'] = q
    app.run(debug=False)

if __name__ == "__main__":
    proc = Process(target=flask_runner, args=(message_queue,))
    proc.start()
    client.run(TOKEN)

修改rest_api.py

from flask import Flask
from flask_restful import Api, Resource

app = Flask(__name__)
api = Api(app)

class Mess(Resource):
    def get(self, message):
        message_queue = app.config.get('MESSAGE_QUEUE')
        if message_queue:
            message_queue.put(message)
        return {'状态': 200, '提示': '消息已加入发送队列'}

api.add_resource(Mess, "/<message>")

关键注意事项 #

• Discord.py客户端不是进程安全的，绝对不能在多进程环境中共享同一个客户端实例。
• 如需使用消息组件（按钮、选择菜单等），直接在say函数中构建View并传入channel.send()即可，无需额外修改逻辑。

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