客户端调用RPC后SimpleXMLRPCServer.shutdown()失效问题求助

核心问题 #

你遇到的SimpleXMLRPCServer无法正常关闭的问题，主要是两个原因导致的：

1. shutdown()只是终止serve_forever()的循环，但不会关闭底层监听的Socket，线程会因为持有网络资源而无法退出；
2. 当有客户端调用过RPC接口后，服务器会阻塞在accept()调用上，仅靠shutdown()无法唤醒这个阻塞状态，线程会一直挂起。

另外你的代码里还有个明显的语法错误：write_state方法里的return state[address] = value是非法的，Python不允许在return语句里直接做赋值操作，得先修正这个。

修复后的完整代码 #

from threading import Lock, Thread
from xmlrpc.server import SimpleXMLRPCServer

lock = Lock()
state = {}  # 原代码漏了定义全局state字典，必须补上

def update_state(address, value):
    with lock:
        state[address] = value

class ExistingClass:
    def __init__(self, *args, **kwargs):
        self.server_thread = Thread(target=self.start_listener)
        # 设为守护线程：如果主线程意外退出，这个线程会自动终止（可选但推荐）
        self.server_thread.daemon = True
        self.server_thread.start()

    def start_listener(self):
        self.server = SimpleXMLRPCServer(("localhost", 8002), allow_none=True)
        self.server.register_function(update_state, "update_state")
        self.server.serve_forever()

    def read_state(self, address):
        with lock:
            return state[address]

    def write_state(self, address, value):
        with lock:
            state[address] = value
            return value  # 修正语法错误，按需返回赋值后的值

    def shutdown_server(self):
        # 第一步：终止serve_forever的循环
        self.server.shutdown()
        # 第二步：关闭底层Socket，彻底释放网络资源
        self.server.server_close()
        # 第三步：等待服务器线程完全退出
        self.server_thread.join()

# 测试示例
if __name__ == "__main__":
    ec = ExistingClass()
    # 这里可以先模拟客户端调用update_state，再执行关闭
    ec.shutdown_server()

关键修复点说明 #

• 补上state定义：原代码里没显式声明全局state字典，运行时会直接报错，必须补充；
• 修正write_state的语法错误：把return里的赋值拆分出来，先赋值再返回；
• 新增server_close()调用：这一步是关键，能彻底关闭监听Socket，避免线程因为持有资源无法退出；
• 线程join()等待：确保服务器线程在shutdown()后能完全结束，不会残留；
• 守护线程设置：作为兜底，如果主线程意外退出，服务器线程不会变成孤儿线程留在系统里。

额外排查点 #

如果按上面的方法改完还是有进程残留，可以检查：

• 是否还有其他未关闭的线程在占用资源；
• 客户端调用RPC后是否没有正常断开连接，这种情况可以手动给服务器发一个空连接，唤醒accept()的阻塞状态，让shutdown()能正常生效。

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