文章/答案/技术大牛

发布

社区首页 >问答首页 >WebAPI HttpContent转换为类型化对象

问WebAPI HttpContent转换为类型化对象
EN

Stack Overflow用户

提问于 2018-12-24 19:04:03

回答 2查看 362关注 0票数 1

我正在做自定义过滤器，这应该是完成简单的事情。我的所有API都封装在'Response‘对象中。我想使用过滤器填写所有属性。这是我为过滤器编写的代码：

public class MeteringFilter : IActionFilter
    {
        public Task<HttpResponseMessage> ExecuteActionFilterAsync(
            HttpActionContext actionContext,
            CancellationToken cancellationToken,
            Func<Task<HttpResponseMessage>> continuation)
        {
            var attribute =
                actionContext.ActionDescriptor.GetCustomAttributes<MeterAttribute>(true).SingleOrDefault() ??
                actionContext.ActionDescriptor.ControllerDescriptor.GetCustomAttributes<MeterAttribute>(true).SingleOrDefault();

            if (attribute == null) return continuation();

            var operation = actionContext.ActionDescriptor.ActionName;
            var user = actionContext.RequestContext.Principal.Identity.Name;
            var started = DateTimeOffset.Now;
            return continuation().ContinueWith(t => 
            {
                var completed = DateTimeOffset.Now;
                var duration = completed - started;

                var c = t.Result.Content;
                // This is code which does not work but I like to have:
                // When debugger stops here I can see Content.Value and my object but I can't use this property like below
                var cv = t.Result.Content.Value as Response<object>;

                return t.Result;
            });
        }

        public bool AllowMultiple => true;
    }

我发现了类似的问题，有人建议我做var c = t.Result.Content.ReadAsAsync(typeof(Response<>));，但是我不能这样做，因为在这种情况下我不能使lambda函数async。

对于如何从HttpContent中获取类型化对象，以便在它返回给调用者之前分配属性，有什么建议吗？

这是Response<T>

public class Response<T>
    {
        public string Url { get; set; }

        public DateTime ServerTime { get; set; }

        public TimeSpan TimeTook { get; set; }

        public T Data { get; set; }

        public Error Error { get; set; }
    }

编辑

下面是代码的外观。我确实可以访问对象，但是webservice没有响应我向客户端填充的数据。在序列化/媒体格式化之后执行的代码似乎发生了。

我猜问题变成了如何在web服务返回之前添加通用的“处理程序”，但是访问调用的开始(这样我就可以测量时间，查看请求参数等等)。

return continuation().ContinueWith(t => 
            {
                var c = t.Result.Content.ReadAsAsync(typeof(Response<object>), cancellationToken);
                if (c.Result is Response<object> response)
                {
                    Debug.WriteLine("Adding times");
                    response.ServerTime = startedOn;
                    response.TimeTook = DateTime.Now - startedOn;
                }

                return t.Result;
            }, cancellationToken);

编辑2:

下面是我要截取的示例web方法：

[HttpGet]
        public Response<LookupResponseData> Carrier(int? key = null, string id = "")
        {
            return this.GetKeyIdBundleForLookup("Carriers", key, id);
        }


private Response<LookupResponseData> GetKeyIdBundleForLookup(string lookupId, int? key, string id)
        {
            if (!key.HasValue && string.IsNullOrEmpty(id))
                return new Response<LookupResponseData>
                {
                    Error = new Error { Code = ErrorCodes.InvalidQueryParameter, Message = "Either key or id must be specified" }
                };

            var r = new Response<LookupResponseData>();
            try
            {
                this.LookupService.GetKeyIdDescription(this.AccountId, lookupId, key, id, out var keyResult, out var idResult, out var description);
                if (!keyResult.HasValue)
                    return new Response<LookupResponseData>
                    {
                        Error = new Error { Code = ErrorCodes.InvalidOrMissingRecord, Message = "No record found for parameters specified" }
                    };

                r.Data = new LookupResponseData { Key = keyResult.Value, Id = idResult, Description = description };
            }
            catch (Exception ex)
            {
                this.LoggerService.Log(this.AccountId, ex);
                return new Response<LookupResponseData>
                {
                    Error = new Error { Code = ErrorCodes.Unknown, Message = "API Call failed, please contact support. Details logged." }
                };
            }

            return r;
        }

asp.net-web-api

回答 2

Stack Overflow用户

回答已采纳

发布于 2018-12-24 22:28:17

我的所有API都封装在'Response‘对象中。

首先，可以通过创建隐式运算符来简化结果：

public class Response
{
    public string Url { get; set; }
    public DateTime ServerTime { get; set; }
    public TimeSpan TimeTook { get; set; }
}

public class Response<T> : Response
{
    public T Data { get; set; }
    public Error Error { get; set; }

    public static implicit operator Response<TData>(TData data)
    {
        var result = new Response<TData>
        {
          Data = data,
        };

        return result;
    }

    public static implicit operator Response<TData>(Error error)
    {
        var result = new Response<TData>
        {
          Error = error,
        };

        return result;
    }
}

现在，应该更容易忽略创建响应的重复代码：

private Response<LookupResponseData> GetKeyIdBundleForLookup(
  string lookupId, int? key, string id)
{
  if (!key.HasValue && string.IsNullOrEmpty(id))
    return new Error 
    { 
      Code = ErrorCodes.InvalidQueryParameter, 
      Message = "Either key or id must be specified" 
    };

  try
  {
    this.LookupService.GetKeyIdDescription(this.AccountId, 
      lookupId, 
      key, 
      id, 
      out var keyResult, 
      out var idResult, 
      out var description);
    if (!keyResult.HasValue)
      return new Error 
      {
        Code = ErrorCodes.InvalidOrMissingRecord, 
        Message = "No record found for parameters specified" 
      };

    return new LookupResponseData 
    { 
      Key = keyResult.Value, 
      Id = idResult, Description = description 
    };

  catch (Exception ex)
  {
    this.LoggerService.Log(this.AccountId, ex);
    return new Error 
    { 
      Code = ErrorCodes.Unknown, 
      Message = "API Call failed, please contact support. Details logged." }
    };
  }
}

然后您可以创建一个核心异步动作过滤器

public class SampleAsyncActionFilter : IAsyncActionFilter
{
  public async Task OnActionExecutionAsync(
    ActionExecutingContext context,
    ActionExecutionDelegate next)
  {
    // do something before the action executes
    var started = DateTimeOffset.Now;     

    // Action Executes
    var resultContext = await next();

    // do something after the action executes; resultContext.Result will be set
    if  (result.Context.Result is Response response)
    {
      response.ServerTime = started;
      response.TimeTook = DateTimeOffset.Now - started;
    }
  }
}

或非核心(MVC)：

public class SampleActionFilter : ActionFilterAttribute
{
  private const string TimerKey = nameof(SampleActionFilter ) + "_TimerKey";

  public override void OnActionExecuting(ActionExecutingContext context)
  {
    context.HttpContext.Items[TimerKey] = DateTimeOffset.Now;
  }

  public override void OnActionExecuted(ActionExecutedContext context)
  {
    if (context.Result is Response response)
      && context.HttpContext.Items[TimerKey] is DateTimeOffset started) 
    {
      response.ServerTime = started;
      response.TimeTook = DateTimeOffset.Now - started;
    }
  }

或非核心(WebApi)：

public class SampleActionFilter : ActionFilterAttribute
{
  private const string TimerKey = nameof(SampleActionFilter ) + "_TimerKey";

  public override void OnActionExecuting(HttpActionContext context)
  {
    context.Request.Properties[TimerKey] = DateTimeOffset.Now;
  }

  public override void OnActionExecuted(HttpActionExecutedContext context)
  {
    if (context.Result is Response response)
      && context.Request.Properties[TimerKey] is DateTimeOffset started) 
    {
      response.ServerTime = started;
      response.TimeTook = DateTimeOffset.Now - started;
    }
  }

票数 3

Stack Overflow用户

发布于 2018-12-24 19:53:31

我修改了你的密码。希望能帮上忙。不过，我无法检查语法错误

return await continuation().ContinueWith(async t => 
{ 
    var result = await t;
    var c = await result.Content.ReadAsAsync(typeof(Response<object>), cancellationToken);
    if (c is Response<object> response)
    {
        Debug.WriteLine("Adding times");
        response.ServerTime = startedOn;
        response.TimeTook = DateTime.Now - startedOn;
    }

    return result;
}, cancellationToken);

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/53916939

复制

相似问题

问WebAPI HttpContent转换为类型化对象
EN

回答 2

Stack Overflow用户

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问WebAPI HttpContent转换为类型化对象EN

回答 2

Stack Overflow用户

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问WebAPI HttpContent转换为类型化对象
EN