Merge pull request #23673 from abpframework/AbpBsonSerializer

Add AbpBsonSerializer utility class

framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/AbpBsonSerializer.cs

@@ -0,0 +1,31 @@
+using System;
+using System.Collections.Concurrent;
+
+using System.Reflection;
+using MongoDB.Bson.Serialization;
+
+namespace Volo.Abp.MongoDB;
+
+public static class AbpBsonSerializer
+{
+    private static readonly ConcurrentDictionary<Type, IBsonSerializer> Cache;
+
+    static AbpBsonSerializer()
+    {
+        var registry = BsonSerializer.SerializerRegistry;
+        var type = typeof(BsonSerializerRegistry);
+        var cacheField = type.GetField("_cache", BindingFlags.NonPublic | BindingFlags.Instance) ??
+                         throw new AbpException($"Cannot find _cache field of {type.FullName}.");
+        Cache = (ConcurrentDictionary<Type, IBsonSerializer>)cacheField.GetValue(registry)!;
+    }
+
+    public static void RemoveSerializer<T>()
+    {
+        Cache.TryRemove(typeof(T), out _);
+    }
+
+    public static ConcurrentDictionary<Type, IBsonSerializer> GetSerializerCache()
+    {
+        return Cache;
+    }
+}

framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/AbpMongoDbModule.cs

@@ -19,7 +19,8 @@ public class AbpMongoDbModule : AbpModule
 {
     static AbpMongoDbModule()
     {
-        BsonSerializer.TryRegisterSerializer(new GuidSerializer(GuidRepresentation.Standard));
+        AbpBsonSerializer.RemoveSerializer<Guid>();
+        BsonSerializer.RegisterSerializer(new GuidSerializer(GuidRepresentation.Standard));
         BsonTypeMapper.RegisterCustomTypeMapper(typeof(Guid), new AbpGuidCustomBsonTypeMapper());
     }