refactor: use MongoDB.Bson instead of Newtonsoft.Json.Bson

Author: cnblogs-dudu

src/Enyim.Caching/Enyim.Caching.csproj

@@ -20,11 +20,11 @@
 
   <ItemGroup>
       <FrameworkReference Include="Microsoft.AspNetCore.App" />
-      <PackageReference Include="Newtonsoft.Json.Bson" Version="1.0.2" />
   </ItemGroup>
 
   <ItemGroup>
     <PackageReference Include="MessagePack" Version="2.5.140" />
+    <PackageReference Include="MongoDB.Bson" Version="2.24.0" />
   </ItemGroup>
 
   <ItemGroup>

src/Enyim.Caching/Memcached/Transcoders/DataContractTranscoder.cs

@@ -1,43 +1,10 @@
-using System;
-using System.IO;
-using System.Runtime.Serialization;
-using System.Text;
-using Newtonsoft.Json;
-using Newtonsoft.Json.Bson;
-
 namespace Enyim.Caching.Memcached
 {
     /// <summary>
     /// Default <see cref="T:Enyim.Caching.Memcached.ITranscoder"/> implementation. Primitive types are manually serialized, the rest is serialized using <see cref="T:System.Runtime.Serialization.NetDataContractSerializer"/>.
     /// </summary>
     public class DataContractTranscoder : DefaultTranscoder
-    {
-        protected override object DeserializeObject(ArraySegment<byte> value)
-        {
-            using (var ms = new MemoryStream(value.Array, value.Offset, value.Count))
-            {
-                using (var reader = new BsonDataReader(ms))
-                {
-                    JsonSerializer serializer = new JsonSerializer();
-                    return serializer.Deserialize(reader);
-                }
-            }
-        }
-
-        protected override ArraySegment<byte> SerializeObject(object value)
-        {
-            using (var ms = new MemoryStream())
-            {
-                using (var writer = new BsonDataWriter(ms))
-                {
-                    JsonSerializer serializer = new JsonSerializer();
-                    serializer.Serialize(writer, value);
-                }
-
-                return new ArraySegment<byte>(ms.ToArray(), 0, (int)ms.Length);
-            }
-        }
-    }
+    { }
 }
 
 #region [ License information          ]

src/Enyim.Caching/Memcached/Transcoders/DefaultTranscoder.cs

@@ -1,10 +1,7 @@
-using Newtonsoft.Json;
-using Newtonsoft.Json.Bson;
+using MongoDB.Bson;
+using MongoDB.Bson.Serialization;
+using MongoDB.Bson.Serialization.Serializers;
 using System;
-using System.Collections;
-using System.IO;
-using System.Linq;
-using System.Reflection;
 using System.Text;
 
 namespace Enyim.Caching.Memcached
@@ -17,6 +14,12 @@ public class DefaultTranscoder : ITranscoder
         public const uint RawDataFlag = 0xfa52;
         private static readonly ArraySegment<byte> NullArray = new([]);
 
+        static DefaultTranscoder()
+        {
+            var objectSerializer = new ObjectSerializer(ObjectSerializer.AllAllowedTypes);
+            BsonSerializer.RegisterSerializer(objectSerializer);
+        }
+
         CacheItem ITranscoder.Serialize(object value)
         {
             return Serialize(value);
@@ -49,14 +52,7 @@ public virtual T Deserialize<T>(CacheItem item)
                 }
             }
 
-            using var ms = new MemoryStream(item.Data.ToArray());
-            using var reader = new BsonDataReader(ms);
-            if (typeof(T).GetTypeInfo().ImplementedInterfaces.Contains(typeof(IEnumerable)))
-            {
-                reader.ReadRootValueAsArray = true;
-            }
-            var serializer = new JsonSerializer();
-            return serializer.Deserialize<T>(reader);
+            return BsonSerializer.Deserialize<T>(item.Data.ToArray());
         }
 
         protected virtual CacheItem Serialize(object value)
@@ -261,15 +257,8 @@ protected virtual ArraySegment<byte> SerializeSingle(Single value)
 
         protected virtual ArraySegment<byte> SerializeObject(object value)
         {
-            using (var ms = new MemoryStream())
-            {
-                using (var writer = new BsonDataWriter(ms))
-                {
-                    var serializer = new JsonSerializer();
-                    serializer.Serialize(writer, value);
-                    return new ArraySegment<byte>(ms.ToArray(), 0, (int)ms.Length);
-                }
-            }
+            var bson = value.ToBson();
+            return new ArraySegment<byte>(bson, 0, bson.Length);
         }
 
         #endregion
@@ -347,14 +336,7 @@ protected virtual sbyte DeserializeSByte(ArraySegment<byte> data)
 
         protected virtual object DeserializeObject(ArraySegment<byte> value)
         {
-            using (var ms = new MemoryStream(value.Array, value.Offset, value.Count))
-            {
-                using (var reader = new BsonDataReader(ms))
-                {
-                    JsonSerializer serializer = new JsonSerializer();
-                    return serializer.Deserialize(reader);
-                }
-            }
+            return BsonSerializer.Deserialize<object>(value.Array);
         }
 
         #endregion

src/Enyim.Caching/Memcached/Transcoders/MessagePackTranscoder.cs

@@ -1,16 +1,6 @@
 using MessagePack;
 using MessagePack.Resolvers;
-using Microsoft.Extensions.Options;
-using Newtonsoft.Json.Bson;
-using Newtonsoft.Json.Linq;
 using System;
-using System.Collections;
-using System.Collections.Generic;
-using System.Collections.Immutable;
-using System.IO;
-using System.Reflection;
-using System.Runtime.CompilerServices;
-using System.Text;
 
 namespace Enyim.Caching.Memcached.Transcoders
 {