c# - mongodb 4.0 在c#(驱动版本2.7+)中启动一个事务，在事务期间，整个数据库将被锁定，如何解决？

Question

(更新于2019-7-2)7天后，我终于解决了这个问题。好吧，我的代码还可以，WTF，浪费了这么多时间。问题是我的团队使用阿里云(一家中国公司，如亚马逊、Azure)，而 Mongodb 有很多版本，我们一年前创建了数据库，那个版本会在处理截断时锁定数据库。

如果你有什么问题，希望我的经验能帮到你。

---

原谅我糟糕的英语...

开发环境:mongodb4.0集群，3节点，支持事务。.net 核心 2.2(mongodb 驱动程序 2.7.2+)机器人3T(mongod工具)

MongoDB 数据库会在开始事务后 60 秒后被锁定，我想也许问题是锁级别，但我已经尝试了 readconcern 或 writeconvern 的所有枚举，没有任何帮助。

这是一张图片:现在数据库已锁定，我无法在 Robot 3T 中查询数据，我的 Web 应用程序也无法查询。

我的意思是，在commitTransaction/abortTransaction之前，数据库会被锁定。如果交易很大，在 30 秒内完成，实际上 webapp 无法读取数据响应给其他访问者。

事实上，我的 webapp 的用户总是说，为什么你的应用运行得这么慢(因为每个事务都会锁定数据库 0.xx 秒)

TransactionOptions option = new TransactionOptions(readConcern: ReadConcern.Snapshot,writeConcern: WriteConcern.W1);
ClientSessionOptions so =new ClientSessionOptions();
so.DefaultTransactionOptions = option;

var session = _dataBase.Client.StartSession();
var products = _dataBase.GetCollection<Product>("products"); 
var TV = new Product { Description = "Television", SKU = 4001, Price = 2000 };  
session.StartTransaction(option);

try
    { 
      products.InsertOne(session, TV); 
      // after the sentence , database will be locked 

// before commitTransaction, the webapp cannot response, like Robot 3T, // looks like the database is locked
session.CommitTransaction();

Answer 1

我试图用以下代码重现您正在谈论的那种锁定。但是我在本地环境中看不到任何事务锁定，它使用 v2.8.1 驱动程序和 mongodb 服务器 v4.0.6。您可以在您的环境中运行以下代码并报告输出吗？还要注意代码使用我的库 MongoDB.Entities所以请先用 nuget 安装它。

using MongoDB.Entities;
using System;
using System.Diagnostics;
using System.Linq;
using System.Threading.Tasks;

namespace StackOverflow
{
    public class Program
    {
        public class Product : Entity
        {
            public string Description { get; set; }
            public double Price { get; set; }
        }

        private static void Main(string[] args)
        {
            new DB("test-transacion-locking", "localhost", 27017);

            (new Product {
                Description = "television",
                Price = 399 }
            ).Save();

            Task.Run(() =>
            {
                using (var TN = new Transaction())
                {
                    var sw1 = new Stopwatch(); sw1.Start();

                    Console.WriteLine("transaction started...");

                    TN.Update<Product>()
                      .Match(p => p.Price == 399)
                      .Modify(p => p.Price, 499)
                      .Modify(p => p.Description, "updated television")
                      .Execute();

                    TN.Save(new Product { Description = "radio", Price = 199 }); ;

                    Task.Delay(10000).Wait(); //wait 10 seconds before commiting

                    TN.Commit();

                    Console.WriteLine($"transaction took: {sw1.Elapsed.TotalSeconds} seconds");
                }
            });

            Task.Delay(10).Wait(); //wait 10 millis to let the transaction begin first

            var sw2 = new Stopwatch(); sw2.Start();

            Console.WriteLine("tv count query started...");

            var tvCount = DB.Queryable<Product>()
                            .Where(p => p.Description.Contains("television"))
                            .Count();

            Console.WriteLine($"found {tvCount} televisions in {sw2.Elapsed.TotalSeconds} seconds");

            Console.ReadKey();
        }
    }
}

这是我的输出:

transaction started...
tv count query started...
found 1 televisions in 0.0986646 seconds
transaction took: 10.1092237 seconds