MongoDB 和多个 C# 客户端线程

使用 MongoDB 和多个 C# 客户端线程 进行高效数据存储和并发操作

csharp
using MongoDB.Driver;
// 创建 MongoDB 客户端
var client = new MongoClient("mongodb://localhost:27017");
// 获取数据库
var database = client.GetDatabase("mydb");
// 获取集合
var collection = database.GetCollection("mycollection");
// 创建文档
var document = new BsonDocument
{
    { "name", "John Doe" },
    { "age", 30 },
    { "email", "johndoe@example.com" }
};
// 插入文档
collection.InsertOne(document);
// 查询文档
var filter = Builders.Filter.Eq("name", "John Doe");
var result = collection.Find(filter).ToList();
// 更新文档
var update = Builders.Update.Set("age", 35);
collection.UpdateOne(filter, update);
// 删除文档
collection.DeleteOne(filter);

csharp
using MongoDB.Driver;
using System;
using System.Threading.Tasks;
class Program
{
    static async Task Main(string[] args)
    {
        var client = new MongoClient("mongodb://localhost:27017");
        var database = client.GetDatabase("mydb");
        var collection = database.GetCollection("mycollection");
        // 创建并发任务
        var tasks = new Task[10];
        for (int i = 0; i < tasks.Length; i++)
        {
            tasks[i] = Task.Run(async () =>
            {
                // 插入文档
                var document = new BsonDocument
                {
                    { "name", $"John Doe {i}" },
                    { "age", 30 + i },
                    { "email", $"johndoe{i}@example.com" }
                };
                await collection.InsertOneAsync(document);
                // 查询文档
                var filter = Builders.Filter.Eq("name", $"John Doe {i}");
                var result = await collection.Find(filter).ToListAsync();
                // 更新文档
                var update = Builders.Update.Set("age", 35 + i);
                await collection.UpdateOneAsync(filter, update);
                // 删除文档
                await collection.DeleteOneAsync(filter);
            });
        }
        // 等待所有任务完成
        await Task.WhenAll(tasks);
        Console.WriteLine("并发操作完成！");
    }
}