捆绑 API 请求

Question

我正在创建一个 REST API，并且一直在考虑允许捆绑来自客户端的请求的想法。通过捆绑，我的意思是他们可以发送一个请求，其中包含多个“真实”请求，然后将它们一起交付给客户端。通常是 javascript ajax 请求。像这样的：

POST /bundlerequest

["/person/3243", "/person/3243/friends", "/comments/3243?pagesize=10&page=1", "/products", "/product/categories" ] 

（捆绑的请求只能是GET请求，至少目前为止） 这旨在返回类似的东西

{
    "success" : ["/person/3243", "/person/3243/friends", "/comments/3243?pagesize=10&page=1", "/products", "/product/categories" ],
    "error" : [],
    "completiontime" : 94,
    other relevant metadata...
    "responses" : [
        {"key" : "/person/3243" , "data" : {"name" : "John", ...} },
        {"key" : "/person/3243/friends" , "data" : [{"name": "Peter", "commonfriends" : 5, ...}] },
        etc...
    ]
}

这种捆绑的好处是它减少了请求的数量，这在例如移动设备上尤其重要。

所以我的第一个问题是，我的方法是一个好的方法吗？有没有人做过这样的事情的经验？

AFAIK 解决此问题的常用方法是编写服务器端代码以返回组合数据，我认为这与客户端相关。 （例如，twitter 用户流就是这样做的，它结合了个人信息、最新推文、最新个人消息等。）但这使得 API 非常固执己见，当客户端需要更改时，服务器可能需要更改以适应优化。

而第二个问题是如何实现呢？

我的后端是 ASP.NET MVC 3 和 IIS 7。我是否应该在应用程序中实现它，并在内部调用请求中指定的其他操作的 bundlerequest 操作？

是否可以直接在 IIS 7 中实现？编写一个模块，透明地拦截对 /bundlerequest 的请求，然后调用所有相应的子请求，让应用程序完全不知道发生的捆绑？这也将允许我以与应用程序无关的方式实现这一点。

Answer 1

您可以使用asynchronous controller 在服务器上聚合这些请求。让我们首先定义一个将由控制器返回的视图模型：

public class BundleRequest
{
    public string[] Urls { get; set; }
}

public class BundleResponse
{
    public IList<string> Success { get; set; }
    public IList<string> Error { get; set; }
    public IList<Response> Responses { get; set; }
}

public class Response
{
    public string Key { get; set; }
    public object Data { get; set; }
}

然后是控制器：

public class BundleController : AsyncController
{
    public void IndexAsync(BundleRequest request)
    {
        AsyncManager.OutstandingOperations.Increment();
        var tasks = request.Urls.Select(url =>
        {
            var r = WebRequest.Create(url);
            return Task.Factory.FromAsync<WebResponse>(r.BeginGetResponse, r.EndGetResponse, url);
        }).ToArray();

        Task.Factory.ContinueWhenAll(tasks, completedTasks =>
        {
            var bundleResponse = new BundleResponse
            {
                Success = new List<string>(),
                Error = new List<string>(),
                Responses = new List<Response>()
            };
            foreach (var task in completedTasks)
            {
                var url = task.AsyncState as string;
                if (task.Exception == null)
                {
                    using (var response = task.Result)
                    using (var stream = response.GetResponseStream())
                    using (var reader = new StreamReader(stream))
                    {
                        bundleResponse.Success.Add(url);
                        bundleResponse.Responses.Add(new Response
                        {
                            Key = url,
                            Data = new JavaScriptSerializer().DeserializeObject(reader.ReadToEnd())
                        });
                    }
                }
                else
                {
                    bundleResponse.Error.Add(url);
                }
            }
            AsyncManager.Parameters["response"] = bundleResponse;
            AsyncManager.OutstandingOperations.Decrement();
        });
    }

    public ActionResult IndexCompleted(BundleResponse response)
    {
        return Json(response, JsonRequestBehavior.AllowGet);
    }
}

现在我们可以调用它了：

var urls = [ 
    '@Url.Action("index", "person", new { id = 3243 }, Request.Url.Scheme, Request.Url.Host)', 
    '@Url.Action("friends", "person", new { id = 3243 }, Request.Url.Scheme, Request.Url.Host)', 
    '@Url.Action("index", "comments", new { id = 3243, pagesize = 10, page = 1 }, Request.Url.Scheme, Request.Url.Host)',
    '@Url.Action("index", "products", null, Request.Url.Scheme, Request.Url.Host)', 
    '@Url.Action("categories", "product", null, Request.Url.Scheme, Request.Url.Host)' 
];
$.ajax({
    url: '@Url.Action("Index", "Bundle")',
    type: 'POST',
    contentType: 'application/json; charset=utf-8',
    data: JSON.stringify(urls),
    success: function(bundleResponse) {
        // TODO: do something with the response
    }
});

当然，为了适应您的特定需求，可能需要进行一些调整。例如，您提到发送会话过期的 AJAX 请求，这可能会重定向到登录页面，因此不会捕获错误。这确实是 ASP.NET 中的 PITA。 Phil Haack blogged 一种以 RESTful 方式规避这种不良行为的可能方法。您只需要在请求中添加自定义标头即可。

Answer 2

我建议看wcf web api