
本文详解 flet 中多用户共享状态(如访问计数)的实时同步方案,指出单纯文件存储 + `page.update()` 的局限性,并提供基于服务端状态管理与事件驱动更新的可靠实践。
在 Flet 应用中,单个 page.update() 仅作用于当前用户的会话页面,无法主动推送变更给其他已连接的客户端。你遇到的问题——用户 A 看到“Views: 1”,用户 B 刷新后看到“Views: 2”,但用户 A 页面仍显示旧值——正是由于 Flet 的默认架构为「无状态会话隔离」:每个用户拥有独立的 Page 实例,彼此不共享 UI 状态,也不自动广播变更。
你尝试的 while True: page.update() 方案会导致主线程阻塞,使应用失去响应(UI 冻结、无法处理点击/路由等事件),这是严重反模式,必须避免。
✅ 正确解法的核心是:将共享状态提升至服务端全局层,并在状态变更时显式通知所有活跃页面更新 UI。Flet 提供了 page.pubsub(发布/订阅)机制,专为此类场景设计。
以下是推荐的生产就绪实现(已优化原始代码逻辑缺陷,如文件句柄泄漏、竞态条件):
import flet as ft
from pathlib import Path
# 全局共享状态(建议替换为 Redis 或数据库用于高并发)
VIEWS_FILE = Path("views.txt")
VIEWS_FILE.write_text("0") if not VIEWS_FILE.exists() else None
def get_views_count() -> int:
try:
return int(VIEWS_FILE.read_text().strip())
except (ValueError, FileNotFoundError):
return 0
def set_views_count(count: int):
VIEWS_FILE.write_text(str(count))
def main(page: ft.Page):
# 初始化:读取当前计数并创建 UI
count = get_views_count()
text_view = ft.Text(f"Views: {count}", size=24, weight="bold")
page.add(ft.Container(content=text_view, padding=20))
# 定义路由变更处理器(每次导航触发)
def route_change(e: ft.RouteChangeEvent):
nonlocal count
# 1. 原子化更新共享状态
count = get_views_count()
new_count = count + 1
set_views_count(new_count)
# 2. 更新本页 UI
text_view.value = f"Views: {new_count}"
page.update()
# 3. 广播变更给所有订阅者(关键!)
page.pubsub.send_all({"action": "update_views", "count": new_count})
page.on_route_change = route_change
# 订阅全局更新事件(所有页面实例均需注册)
def on_message(msg):
if msg.get("action") == "update_views":
text_view.value = f"Views: {msg['count']}"
page.update()
page.pubsub.subscribe(on_message)
# 可选:初始加载时也同步一次(确保新连接用户看到最新值)
page.pubsub.send_all({"action": "update_views", "count": get_views_count()})? 关键要点说明:
- page.pubsub 是跨会话通信基石:send_all() 向所有已连接的 Page 实例广播消息;每个页面通过 subscribe() 监听并响应。
- 避免文件操作陷阱:原始代码频繁 open/close 易引发竞态(多用户同时写入导致数据丢失)。改用原子化的 read_text()/write_text()(底层为独占写入)更安全;生产环境务必迁移到 Redis 等支持并发锁的存储。
- UI 更新必须显式调用 page.update():即使状态已变,Flet 不会自动重绘,必须在修改控件属性后手动触发。
- page.clean() 并非解决方案:原答案中的 page.clean() 仅清空当前页控件,无助于跨用户同步,且可能破坏复杂布局,此处已移除。
? 进阶建议:
- 对于高并发场景,用 redis-py 替代文件:redis.incr("views") 天然线程安全;
- 结合 ft.Timer 实现定时轮询(仅作降级方案,不推荐主逻辑);
- 使用 page.session.set() / get() 管理用户私有状态,与 pubsub 配合实现混合状态管理。
通过 pubsub 机制,你构建的是一个真正响应式的多用户应用——任何客户端的状态变更,都将毫秒级同步至所有在线用户界面,无需刷新,不阻塞主线程。









