.NET（Xamarin-UWP）如何在Realm实例创建的同一线程访问该实例？

• 你遇到的realm accessed from incorrect thread崩溃，本质是违反了Realm的硬性线程约束：Realm实例、以及从实例查询出的所有持久化对象，会永久绑定到创建它的线程/同步上下文，不允许跨上下文访问
• 现有代码的触发逻辑：
  • SignalR的消息接收回调运行在无同步上下文的线程池环境下，每次异步await操作的续体可能被调度到不同的线程池线程，不存在统一固定的上下文供Realm绑定
  • 你每次写操作都直接调用GetInstanceAsync()获取Realm实例，当实例首次创建时绑定的线程，和后续触发写操作的线程不一致时，就会直接抛出跨线程错误——这也是为什么崩溃随机出现在第3、4条消息时，刚好是Realm内部实例缓存命中后、上下文不匹配的节点
  • 之前使用SQLite架构没有该问题，是因为SQLite的客户端实现内置了跨线程的操作封送机制，和Realm严格的线程绑定模型完全不同。

1. 为Realm建立固定的访问上下文 #

不需要手动硬套Device.BeginInvokeOnMainThread或者额外引入Nito.AsyncEx组件，只需要给Realm实例绑定一个不随异步调度变化的固定同步上下文，就可以完全满足Realm的线程要求。
改造RealmManager，内置线程安全的Realm访问封装：

public class RealmManager
{
    private readonly object _realmLock = new object();
    private Realm _cachedRealm;
    private SynchronizationContext _realmBoundContext;

    // 封装统一的Realm操作入口，所有数据库操作都通过该方法调度
    public Task<T> RunOnRealmThread<T>(Func<Realm, Task<T>> realmAction)
    {
        // 已经初始化绑定上下文时，把操作封送到绑定上下文执行
        if (_realmBoundContext != null)
        {
            var tcs = new TaskCompletionSource<T>();
            _realmBoundContext.Post(async _ =>
            {
                try
                {
                    T result;
                    lock (_realmLock)
                    {
                        // 自动重连已关闭的Realm实例
                        if (_cachedRealm == null || _cachedRealm.IsClosed)
                        {
                            _cachedRealm = Realm.GetInstance(syncConfig);
                        }
                    }
                    result = await realmAction(_cachedRealm);
                    tcs.SetResult(result);
                }
                catch (Exception ex)
                {
                    tcs.SetException(ex);
                }
            }, null);
            return tcs.Task;
        }

        // 首次调用时初始化绑定：用专门的后台线程上下文，不占用UI线程
        return Task.Run(async () =>
        {
            _realmBoundContext = SynchronizationContext.Current;
            lock (_realmLock)
            {
                _cachedRealm = Realm.GetInstance(syncConfig);
            }
            return await realmAction(_cachedRealm);
        });
    }
}

注意：不要为了省事把Realm上下文绑定到UI主线程，高频聊天消息的数据库写入会阻塞UI导致界面掉帧，绑定独立的后台同步上下文是最优方案。

2. 改造Repository层的调用逻辑 #

替换原有代码中直接跨线程获取Realm实例的逻辑，所有Realm操作统一走上面的固定上下文入口：

public async Task<IResponse> CreateAsync(MetaDataChatModel MetaDataChatModel)
{
    MetaDataChatModel.Id = Guid.NewGuid().ToString();
    MetaDataChatModel.Partition = _realmManager.projectPartition;
    var MetaDataChatDto = MetaDataChatModel.ToDto();

    // 替换原来直接调用GetInstanceAsync的逻辑
    return await _realmManager.RunOnRealmThread(async realm =>
    {
        await realm.WriteAsync(() =>
        {
            realm.Add(MetaDataChatDto, false);
        });
        return new Response(true);
    });
}

3. 不需要采用的冗余方案 #

• 不要把所有SignalR回调都包裹Device.BeginInvokeOnMainThread，该做法会把消息接收、数据库写入全量扔到UI线程，消息量上升后必然出现UI卡顿
• 不需要为了上下文切换引入Nito.AsyncEx组件，只要Realm有固定绑定的同步上下文，完全不需要额外的异步上下文组件做适配
• 不要在静态变量中缓存Realm实例后跨线程调用，这是Realm跨线程错误的最高发触发点。

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