使用Cosmos DB变更拉取GetChangeFeedStreamIterator时替换Newtonsoft为System.Text.Json咨询

方案建议 #

优先选择改造变更拉取代码为System.Text.Json原生实现，不建议全项目切换为Newtonsoft.Json，理由如下：

• ASP.NET Core默认集成System.Text.Json，全量切换Newtonsoft.Json需要调整全局序列化配置，容易引发内置中间件、模型绑定、第三方组件的兼容问题，改动风险高
• 两种序列化库混用是当前冲突的根源，彻底移除Newtonsoft.Json依赖可以从根源避免后续再出现命名策略、日期格式、嵌套对象序列化不一致的问题
• System.Text.Json性能优于Newtonsoft.Json，更适合Cosmos DB变更流这类高吞吐量的数据处理场景

System.Text.Json实现代码 #

以下是完全替换原有Newtonsoft.Json逻辑的实现，适配你原有的业务流程：

FeedIterator feedIterator = _entities.GetChangeFeedStreamIterator(startFrom, ChangeFeedMode.Incremental);

var result = new ChangedEntitiesResult();
// 复用项目全局的System.Text.Json配置，保证序列化规则一致
var jsonOptions = new JsonSerializerOptions(JsonSerializerDefaults.Web);

while (feedIterator.HasMoreResults)
{
    using ResponseMessage response = await feedIterator.ReadNextAsync();
    if (response.StatusCode == HttpStatusCode.NotModified)
    {
        result.ContinuationToken = response.ContinuationToken;
        break;
    }
    else
    {
        // 直接从流解析Json，无需额外的StreamReader转换，性能更高
        using JsonDocument doc = await JsonDocument.ParseAsync(response.Content);
        JsonElement root = doc.RootElement;
        if (root.TryGetProperty("Documents", out JsonElement documentsEle) && documentsEle.ValueKind == JsonValueKind.Array)
        {
            foreach (JsonElement documentEle in documentsEle.EnumerateArray())
            {
                // 读取type字段确定实体类型
                if (documentEle.TryGetProperty("type", out JsonElement typeEle) && typeEle.ValueKind == JsonValueKind.String)
                {
                    string entityType = typeEle.GetString();
                    object entity = _entityFactory.GetNewEntityDtoInstance(entityType);
                    
                    // 填充已有实体实例：.NET 7+ 可直接用内置Populate方法
                    JsonSerializer.Populate(documentEle, entity, jsonOptions);
                    
                    // 若为.NET 6及更低版本，可使用以下替代实现：
                    // entity = JsonSerializer.Deserialize(documentEle, entity.GetType(), jsonOptions);
                    
                    result.Entities.Add(entity);
                }
            }
        }
    }
}

注意事项 #

• 代码中的JsonSerializerOptions请和你ASP.NET Core项目全局配置的序列化规则保持一致，比如是否开启大小写不敏感、是否使用驼峰命名、自定义Converter配置等，避免反序列化异常
• 如果你的实体有特殊的序列化规则，直接把全局配置的JsonSerializerOptions实例传入即可，无需重复定义

全项目切换Newtonsoft.Json的适用场景 #

只有满足以下所有条件时，才建议选择全量切换方案：

• 项目中大量依赖Newtonsoft.Json的独有特性（比如动态契约解析、JToken高级操作、特殊Converter实现等），改造为System.Text.Json的工作量远大于切换成本
• 你可以接受全量切换后，需要重新调试所有涉及序列化的业务逻辑，处理可能出现的兼容问题

内容的提问来源于stack exchange，提问作者user1843640