javascript - 捆绑 API 请求

Question

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

POST /bundlerequest

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

(绑定(bind)的请求只能是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...
    ]
}

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

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

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

第二个问题是如何实现这个？

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

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

Answer 1

你可以使用 asynchronous controller在服务器上聚合这些请求。让我们首先定义一个将由 Controller 返回的 View 模型:

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; }
}

然后是 Controller :

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
    }
});

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