2

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

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

原谅我可怜的英语...

开发环境：3nodes的mongodb4.0集群，支持事务。.net core 2.2 (mongodb driver 2.7.2+) Robot 3T(mongod tool)

MongoDB 数据库将在启动事务后 60 秒被锁定，我认为问题可能出在锁定级别，但我已经尝试了 readconcern 或 writeconvern 的所有枚举，没有任何帮助。

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

我的意思是，在 commitTransaction/abortTransaction 之前，数据库将被锁定。如果交易量很大，30s 完成，实际上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();
4

1 回答 1

0

我试图用下面的代码重现你所说的那种锁定。但我在使用 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
于 2019-06-25T02:52:06.210 回答