如何发送多条 TCP 消息并在一条消息成功后继续

Question

我目前正在编写一些网络代码，我需要发送大量消息，然后等待单个响应。

鉴于我有一个函数可以返回我拥有的套接字的输入和输出通道：

let resps = List.map uris ~f:(fun uri -> 
let%lwt (ic,oc) = connect uri in
let%lwt () = Lwt_io.write_value oc msg in
Lwt_io.read_value ic
) in
Lwt.pick resps

我对此的理解是，选择应该在resps兑现承诺后取消任何正在进行的请求。问题是，如果这些连接中的任何一个失败/被拒绝，则会Unix.ECONNREFUSED引发异常。

我的问题是迫使Lwt.pick忽略异常的正确语义是什么？

到目前为止，我想到的选择是抓住 请求中的异常显式：

let resps = List.map uris ~f:(fun uri -> 
try
let%lwt (ic,oc) = connect uri in
let%lwt () = Lwt_io.write_value oc msg in
Lwt_io.read_value ic
with Unix_error (e,_,_) -> ...
) in
Lwt.pick resps

但我不确定Lwt.pick会在什么情况下看到这些承诺被拒绝？

更新：我现在正在处理可取消、无法兑现的承诺的错误：

fst @@ Lwt.task ()

这感觉很笨拙，但到目前为止似乎有效。

Answer 1

显式处理异常是正确的。当您显式拒绝 Lwt 承诺(使用Lwt.fail(或当 Lwt 捕获异常时，在应该返回承诺的回调中(例如您将传递给Lwt.bind的回调(中，Lwt 承诺将被拒绝。

但是，要处理调用 Lwt 的代码中的异常，您必须使用try%lwt而不是普通try。