如何在Django中实现uWSGI多Worker的单例值热重载？

这个问题在uWSGI多进程部署下太常见了——每个Worker都是独立的进程，内存完全隔离，你修改的只是当前处理请求的那个Worker里的单例实例，其他进程的实例根本感知不到变化。下面给你几个实用的解决方案：

方案1：把属性存储到共享数据源（最推荐） #

既然单例的属性需要跨进程一致，最直接的方式就是不要把属性存在进程本地内存里，而是放到所有进程都能访问的共享存储（比如你已经在用的Redis）。这样不管哪个进程修改，所有进程读取的都是同一个值。

修改你的代码示例：

import redis
from your_singleton_decorator import singleton

# 初始化Redis连接（确保所有Worker用同一个配置）
redis_client = redis.Redis(host='localhost', port=6379, db=0)

@singleton
class A:
    def __init__(self):
        # 初始化时从Redis加载值，兜底默认值设为123
        self.value = self._load_from_redis()
    
    def _load_from_redis(self):
        raw_value = redis_client.get('a_instance_value')
        return int(raw_value) if raw_value else 123
    
    def set_value(self, new_value):
        # 先把新值写入共享存储
        redis_client.set('a_instance_value', new_value)
        # 同时更新当前进程的本地属性（可选，优化读取性能）
        self.value = new_value
    
    def get_value(self):
        # 每次获取都从Redis同步最新值，保证跨进程一致
        # 若想优化性能，可以加缓存过期逻辑（比如每5秒重新读取一次）
        self.value = self._load_from_redis()
        return self.value

这个方案的优势是完全不依赖uWSGI的特定功能，天然支持水平扩展（哪怕后续加更多Worker或多台服务器，数据一致性都能保证）。

方案2：用uWSGI信号触发所有Worker更新本地单例 #

如果你不想每次读取都走Redis，想保留本地缓存来优化性能，可以用uWSGI的信号系统：当修改值时，给所有Worker发送自定义信号，触发它们主动从共享存储刷新本地单例的属性。

修改后的代码示例：

import uwsgi
import redis
from uwsgidecorators import postfork, singleton

redis_client = redis.Redis(host='localhost', port=6379, db=0)

@singleton
class A:
    def __init__(self):
        self.value = self._load_from_redis()
    
    def _load_from_redis(self):
        raw_value = redis_client.get('a_instance_value')
        return int(raw_value) if raw_value else 123
    
    def set_value(self, new_value):
        # 1. 先写入共享存储
        redis_client.set('a_instance_value', new_value)
        # 2. 更新当前进程的本地属性
        self.value = new_value
        # 3. 给所有Worker发送自定义信号（信号ID可自定义，这里用10）
        uwsgi.signal(10)
    
    def refresh_local_value(self):
        # 从Redis同步最新值到本地
        self.value = self._load_from_redis()

# 定义信号处理函数：收到信号时刷新本地单例属性
def handle_refresh_signal(signal_num):
    A().refresh_local_value()

# 用postfork装饰器，确保每个Worker启动后都注册信号监听
@postfork
def setup_signal_listener():
    uwsgi.register_signal(10, "", handle_refresh_signal)

当你调用API的set_value方法时，当前进程会先更新Redis和自己的本地值，然后给所有Worker发信号，每个Worker收到信号后都会自动刷新本地单例的属性，实现跨进程同步。

方案3：uWSGI RPC跨进程调用（不推荐，复杂度高） #

uWSGI支持RPC机制，你可以把更新单例的方法暴露为RPC函数，然后在API调用时遍历所有Worker，调用它们的RPC方法来更新本地单例。但这个方案对uWSGI配置和代码耦合度高，且Worker数量动态变化时维护成本大，示例仅供参考：

from uwsgidecorators import rpc, singleton

@singleton
class A:
    value = 123
    def set_value(self, new_value):
        self.value = new_value

# 在每个Worker里注册RPC函数
@rpc('update_a_value')
def update_a_value(new_value):
    A().set_value(new_value)

# API接口中调用所有Worker的RPC
def get(self, requests, format=None):
    new_value = 321
    # 更新当前进程的单例
    A().set_value(new_value)
    # 遍历所有Worker（假设Worker ID从1到4）
    for worker_id in range(1, 5):
        try:
            uwsgi.rpc(worker_id, 'update_a_value', new_value)
        except Exception as e:
            print(f"更新Worker {worker_id}失败: {e}")

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