适用于顺序 WebClient 请求的良好异步模式

Question

我在 .NET 中编写的用于进行 REST 调用的大部分代码都是同步的。由于 Windows Phone 上的 Silverlight 仅支持异步 WebClient 和 HttpWebRequest 调用，因此我想知道对于公开进行 REST 调用的方法的类来说，好的异步模式是什么。

例如，我有一个应用程序需要执行以下操作。

1. 登录并获取令牌
2. 使用 #1 中的令牌获取专辑列表
3. 使用 #1 中的标记获取类别列表
4. ETC

我的类公开了一些方法：

1. 登录（）
2. 获取专辑()
3. 获取类别()

因为每个方法都需要使用异步调用来调用 WebClient，所以我需要做的基本上是阻止调用 Login 直到它返回，以便我可以调用 GetAlbums()。

在我的类中公开这些方法有什么好的方法可以解决这个问题？

Answer 1

这实际上取决于您想用这些信息做什么。例如，如果您尝试显示专辑/类别等列表，对此进行建模的一种方法是

1. 拥有一个或多个实现 INotifyPropertyChanged 接口的类，并用作视图的数据源（查看新 PhoneListApplication 中 Models 文件夹下的文件作为示例）
2. 启动异步操作来登录并获取令牌，让异步方法的回调为您存储令牌并调用将启动异步操作以获取专辑和类别列表的函数。
3. 获取专辑/类别列表的异步操作的回调可以更新 ObservableList（通过向其中添加项目）。我想你对专辑和类别各有一个类，每个类都有一个可观察的列表。无论如何，添加完成后，只需使用您更改的属性的名称调用 NotifyPropertyChanged，您的数据就会显示出来。

如果您想等待，直到通过网络收到返回的信息（例如，如果您想保留登录页面，直到您知道自己已成功通过身份验证），则存在一个明显的问题。在这种情况下，您只需更改异步回调中的页面即可。

显然，您还可以做一些更奇特的事情，让线程等待异步回调设置的事件。我建议不要让 UI 线程执行此操作，因为它限制了您进行超时等操作的能力，并且通常非常混乱。

Answer 2

您可以看一下响应式 (Rx) 框架扩展：

http://www.leading-edge-dev.de/?p=501

http://themechanicalbride.blogspot.com/2009/07/introducing-rx-linq-to-events.html

[编辑：哦 - 找到了一个很好的链接：]http://rxwiki.wikidot.com/101samples

它们提供了一种“排序”事件的方法，仅在满足某些条件时才起作用 - 例如，假设您有一个方法“AuthenticationResult Authenticate(string user, string pass)”

你可以这样做：

var foo = Observable.FromAsyncPattern<string, string, AuthenticationResult>
    (client.BeginAuthenticate, client.EndAuthenticate);
var bar = foo("username","password");
var result = bar.First();

有效地将异步方法转变为同步方法。您可以扩展它以包括“链接”：

var bar = foo("username", "password")
    .Then(authresult => DoSomethingWithResult(authresult));

整洁的东西。:)

Answer 3

我们使用所有异步函数签名编写了客户端服务层，如下所示：

public void MyFunction(
  ArtType arg, 
  Action<ReturnType> success, 
  Action<FailureType> failure);

服务代码对 Web 服务进行异步调用，返回时，如果调用成功，则调用成功回调；如果出现故障/异常，则调用失败回调。然后调用代码有点像这样：

MyServiceInstance.MyFunction(
  blahVar,
  returnVal => UIInvoker.Invoke(() => 
    {
      //some success code here
    }),
  fault => UIInvoker.Invoke(() => 
    {
      //some fault handling code here
    }));

（UIInvoker 只是一个从后台线程分派回 UI 的实用程序。）

Answer 4

我把一些更流畅的东西放在一起。

宁静-银光 是我创建的一个库，用于帮助使用 Silverlight 和 WP7。

我在下面添加了代码来展示如何使用该库从 Twitter 检索推文。

Restful-Silverlight 从 Twitter 检索推文的示例用法：

//silverlight 4 usage
List<string> tweets = new List<string>();
var baseUri = "http://search.twitter.com/";

//new up asyncdelegation
var restFacilitator = new RestFacilitator();
var restService = new RestService(restFacilitator, baseUri);
var asyncDelegation = new AsyncDelegation(restFacilitator, restService, baseUri);

//tell async delegation to perform an HTTP/GET against a URI and return a dynamic type
asyncDelegation.Get<dynamic>(new { url = "search.json", q = "#haiku" })
    //when the HTTP/GET is performed, execute the following lambda against the result set.
    .WhenFinished(
    result => 
    {
        textBlockTweets.Text = "";
        //the json object returned by twitter contains a enumerable collection called results
        tweets = (result.results as IEnumerable).Select(s => s.text as string).ToList();
        foreach (string tweet in tweets)
        {
             textBlockTweets.Text += 
             HttpUtility.HtmlDecode(tweet) + 
             Environment.NewLine + 
             Environment.NewLine;
        }
    });

asyncDelegation.Go();

//wp7 usage
var baseUri = "http://search.twitter.com/";
var restFacilitator = new RestFacilitator();
var restService = new RestService(restFacilitator, baseUri);
var asyncDelegation = new AsyncDelegation(restFacilitator, restService, baseUri);

asyncDelegation.Get<Dictionary<string, object>>(new { url = "search.json", q = "#haiku" })
               .WhenFinished(
               result =>
               {
                   List<string> tweets = new List();
                   textBlockTweets.Text = "";
                   foreach (var tweetObject in result["results"].ToDictionaryArray())
                   {
                       textBlockTweets.Text +=
                           HttpUtility.HtmlDecode(tweetObject["text"].ToString()) + 
                           Environment.NewLine + 
                           Environment.NewLine;
                   }
               });

asyncDelegation.Go();