13.2.2 从故障中恢复
世界银行服务对每个用户密钥每天请求数量有限制,还限制了请求的频率,因此,如果我们一次运行大量的请求,有可能会出错。解决的方法是捕获异常,稍后重试请求。
清单 13.7 实现的循环,重复执行请求,直到成功,或者尝试 20 次为止。使用异常报告失败,使用 F# 的 try … with 结构捕捉异常。
清单 13.7 重复运行 web 请求 (F# Interactive)
> let worldBankDownload(properties) =
let url = worldBankUrl(properties)
let rec loop(attempts) = async { [1]
try
return! downloadUrl(url) [2]
with _ when attempts > 0 –> [3]
printfn "Failed, retrying (%d): %A" attempts properties
do! Async.Sleep(500.0)
return! loop(attempts - 1) } [4]
loop(20);;
val worldBankDownload : seq<string * string> -> Async<string>
> let props = ["countries"], ["region", "NA"];
val props : string list * (string * string) list
> Async.RunSynchronously(worldBankDownload(props))
Failed, retrying (20): [("countries"); ("region", "NA")]
val it : string = "<?xml version=\"1.0\" encoding=\"utf-8\" (...)"
这段代码实现了递归和异步循环函数[1],尝试运行实际的下载[2]。如果下载失败,可能会引发异常。当发生异常,且剩余的尝试次数不为零时[3],会暂停工作流一段时间,然后重试下载[3]。
创建循环,通常的函数式方法是写递归函数,把剩余尝试的次数作为参数值,每次迭代递减这个值。清单 13.7使用这种模式有点拧吧(twist)。loop 函数使用异步工作流实现[1],因此,我们将创建递归的异步工作流。递归调用在异常处理程序中[4],并且使用了 return! 基本操作,运行异步循环的下一次迭代。工作流的主体尝试下载页面,而这是在捕捉可能异常的 try … with 块中完成的。
F# 中的 try … with 块类似于 C# 中的 try … catch,但还有一些额外的功能。它能够使用模式匹配区分不同的异常,with 结构非常类似于我们熟悉的 match 表达式。在清单 13.7 中,我们简单地捕捉所有异常,但添加了when 子句[2],这样,将只捕获尝试次数少于 20 异常。值得注意的是,在异步工作流内部处理异常,与我们在正常的 F# 代码中处理异常方式是一样的。这可能要归功于另外的基本操作 TryWith 和 TryFinally,在背后(under the hood)提供了异步工作流的功能;这些基本操作告诉 F#,在异步操作期间,如何处理发生的异常。
在清单 13.7 的最后几行,可以看到如何使用函数从世界银行获取数据。注意,函数属性的参数是包含函数和另外属性的元组(太绕了)。我们没有用显式元组实现,但编译器知道 theworldBankUrl 函数需要元组值。通过把计算机从网络中断开一会儿,可以模拟连接失败,你会看到,代码能够从故障中恢复过来。现在,我们已经有了可靠的下载数据的函数,下一步就是去下载我们想要使用的全部数据。
原文地址:http://blog.csdn.net/hadstj/article/details/43796105