File "D:\rocketmq-clients-python-5.0.6\rocketmq-clients-python-5.0.6\example\simple_consumer_example.py", line 133 global consumer_running ^^^^^^^^^^^^^^^^^^^^^^^ SyntaxError: name 'consumer_running' is used prior to global declaration

代码概述 该代码是一个使用 FastAPI 和 RocketMQ 构建的消息消费服务，用于监听 RocketMQ 消息并通过 HTTP 接口提供消息获取等功能。在运行时出现 `SyntaxError: name 'consumer_running' is used prior to global declaration` 错误，表示变量在被声明为 `global` 之前就被使用。 --- 代码解析 - **错误原因**：在函数内部访问或修改全局变量前，需要使用 `global` 声明。但在某些函数中（如 `lifespan`、`start_consumer` 等），`consumer_running` 或 `consumer_thread` 在 `global` 声明之前就已经被读取或判断，导致语法错误。 - **具体问题点**： ```python def start_consumer(): if consumer_thread and consumer_thread.is_alive(): # 先使用了 consumer_thread return global consumer_thread # 错误：global 声明应在函数顶部之后立即使用 ``` Python 规定，如果在一个函数内要使用 `global` 变量，必须在该变量首次使用之前就进行 `global` 声明。 --- 解决方案： 将涉及的函数中的 `global` 声明移到函数体最开始的位置（紧接在函数定义之后）即可修复此语法错误。 例如修正 `start_consumer()` 函数如下： ```python def start_consumer(): global consumer_thread, consumer_running # 所有 global 声明放在最前面 if consumer_thread and consumer_thread.is_alive(): return consumer_thread = threading.Thread(target=run_consumer, daemon=True) consumer_thread.start() logger.info("RocketMQ消费者线程已启动") ``` 同理，检查其他函数如 `stop_consumer()` 和 `lifespan()` 中是否也存在类似顺序错误。 --- ### 需要修改的关键函数示例 #### ✅ 修复后的 `lifespan` 函数： ```python @asynccontextmanager async def lifespan(app: FastAPI): global consumer_running, consumer_thread # 先声明再使用 logger.info("启动FastAPI服务...") consumer_running = False consumer_thread = None start_consumer() yield logger.info("关闭FastAPI服务...") stop_consumer() ``` #### ✅ 修复后的 `start_consumer` 函数： ```python def start_consumer(): global consumer_thread, consumer_running # 先声明 if consumer_thread and consumer_thread.is_alive(): return consumer_thread = threading.Thread(target=run_consumer, daemon=True) consumer_thread.start() logger.info("RocketMQ消费者线程已启动") ``` #### ✅ 修复后的 `stop_consumer` 函数： ```python def stop_consumer(): global consumer_running, consumer_thread # 先声明 logger.info("停止RocketMQ消费者...") consumer_running = False if consumer_thread and consumer_thread.is_alive(): consumer_thread.join(timeout=5) logger.info("RocketMQ消费者已停止") ``` --- 知识点 1. **Python 的 global 关键字作用域规则**：函数内部若需修改全局变量，必须用 `global` 显式声明，且应在其首次使用前声明。 2. **多线程与资源共享控制**：通过 `threading.Thread` 启动后台消费者线程，并通过 `global` 控制其状态，需注意并发访问问题。 3. **FastAPI 生命周期事件管理**：通过 `lifespan` 实现应用启动和关闭时的操作，是组织异步初始化逻辑的重要机制。