Maui应用EF SQLite工作单元事件未触发排查及同步方案咨询

一、事件未触发的核心排查点 #

1. 工作单元事件的定义与订阅逻辑 #

• 检查工作单元类中是否正确实现事件触发：确保SaveChanges()执行成功后（且有实际变更时）调用DataSaved?.Invoke(this, EventArgs.Empty);，示例：

  public int SaveChanges()
  {
      var changeCount = _dbContext.SaveChanges();
      if (changeCount > 0)
      {
          DataSaved?.Invoke(this, EventArgs.Empty);
      }
      return changeCount;
  }
  

• 确认Sync Agent的订阅时机：若工作单元是瞬态（Transient）注入，需在每次获取工作单元实例后立即订阅事件；若为单例（Singleton），要确保订阅操作在容器初始化时完成，避免错过事件触发。
• 排查实例生命周期不匹配：如果工作单元是Scoped/Singleton，而Sync Agent是另一种生命周期，会导致订阅的实例与实际执行CRUD的实例不一致，无法接收事件。

2. EF SaveChanges执行异常或无实际变更 #

• 在SaveChanges()前后加断点/日志，确认方法是否真的执行成功：若代码中用try/catch吞掉了异常，会导致事件触发逻辑被跳过。
• 检查EF变更跟踪：确认实体确实被标记为Added/Modified/Deleted，若没有实际变更，SaveChanges()返回0，事件自然不会触发。

3. 依赖注入配置错误 #

• 验证工作单元与Sync Agent的注入方式：比如工作单元为Scoped时，要确保Sync Agent在同一作用域内订阅事件；避免因容器配置错误，导致创建多个Sync Agent实例，订阅的实例并非实际接收事件的对象。

二、非阻塞UI的后台同步替代方案 #

1. 基础异步后台执行（轻量场景） #

利用Task.Run在后台线程执行同步逻辑，结合MainThread在同步完成后更新UI状态：

// Sync Agent中处理事件
public class SyncAgent
{
    public SyncAgent(IUnitOfWork unitOfWork)
    {
        unitOfWork.DataSaved += HandleDataSaved;
    }

    private void HandleDataSaved(object sender, EventArgs e)
    {
        // 后台执行同步，不阻塞UI
        _ = Task.Run(async () =>
        {
            try
            {
                await SyncLocalToRemote();
                // 同步完成后更新UI（如提示同步成功）
                MainThread.BeginInvokeOnMainThread(() =>
                {
                    // 更新UI逻辑
                });
            }
            catch (Exception ex)
            {
                // 异常处理与日志记录
                MainThread.BeginInvokeOnMainThread(() =>
                {
                    // 显示错误提示
                });
            }
        });
    }

    private async Task SyncLocalToRemote()
    {
        // 实现本地数据与远程API的同步逻辑
        // 例如：拉取未同步的实体、调用上传接口、标记实体为已同步
    }
}

2. 周期性后台同步（适合批量延迟同步） #

使用PeriodicTimer实现定时同步，避免每次CRUD都触发同步，减轻服务器压力：

public class BackgroundSyncService
{
    private PeriodicTimer _syncTimer;
    private readonly IUnitOfWork _unitOfWork;

    public BackgroundSyncService(IUnitOfWork unitOfWork)
    {
        _unitOfWork = unitOfWork;
    }

    public void StartPeriodicSync()
    {
        // 每5分钟执行一次同步
        _syncTimer = new PeriodicTimer(TimeSpan.FromMinutes(5));
        _ = RunSyncLoop();
    }

    private async Task RunSyncLoop()
    {
        while (await _syncTimer.WaitForNextTickAsync())
        {
            try
            {
                var pendingEntities = await _unitOfWork.GetUnsyncedEntities();
                if (pendingEntities.Any())
                {
                    await SyncEntities(pendingEntities);
                    await _unitOfWork.MarkEntitiesAsSynced(pendingEntities);
                }
            }
            catch (Exception ex)
            {
                // 异常日志记录
            }
        }
    }

    private async Task SyncEntities(IEnumerable<BaseEntity> entities)
    {
        // 批量同步逻辑实现
    }
}

注意：不同平台对后台任务有不同限制（如iOS后台运行时间管控），需根据目标平台适配权限配置。

3. 直接监听EF DbContext变更（绕过工作单元事件问题） #

若工作单元事件方案难以调试，可直接在DbContext层面监听保存完成事件：

public class AppDbContext : DbContext
{
    public event EventHandler SaveCompleted;

    public override int SaveChanges()
    {
        var result = base.SaveChanges();
        SaveCompleted?.Invoke(this, EventArgs.Empty);
        return result;
    }

    public override async Task<int> SaveChangesAsync(CancellationToken cancellationToken = default)
    {
        var result = await base.SaveChangesAsync(cancellationToken);
        SaveCompleted?.Invoke(this, EventArgs.Empty);
        return result;
    }
}

在Sync Agent中订阅SaveCompleted事件，直接触发同步逻辑，减少中间层的问题点。

内容的提问来源于stack exchange，提问作者Zoltán