处理WebSocket错误

由于WebSocket是一个共享资源，错误处理与常规查询不同。在HTTP查询中，错误只有一个消费者。在WebSocket中，错误可能有多个消费者。

多个消费者的WebSocket错误

当您的网络断开或服务器关闭连接（因为它需要一个新令牌或其他原因），所有订阅都会被终止。您可以对它们逐个重试。下面的示例使用了一个非常简单的指数退避算法：

1
apolloClient.subscription(MySubscription())
2
    .toFlow()
3
    .retryWhen { e, attempt ->
4
      delay(2.0.pow(attempt.toDouble()).toLong())
5
      // retry after the delay
6
      true
7
    }
8
    .collect {
9
      println("trips booked: ${it.data?.tripsBooked}")
10
    }

这有几个缺点（不提简单的指数退避实现）

此代码必须在不同的地方实现
尝试绑定到收集器生命周期，在网络恢复正常时无法重置

可以在配置ApolloClient时在一个更中心化的位置来管理这个问题

1
val apolloClient = ApolloClient.Builder()
2
        .httpServerUrl("https://127.0.0.1:8080/graphql")
3
        .webSocketServerUrl("https://127.0.0.1:8080/subscriptions")
4
        .webSocketReopenWhen { e, attempt ->
5
          delay(2.0.pow(attempt.toDouble()).toLong())
6
          // retry after the delay
7
          true
8
        }

上面的代码将记住所有当前的订阅并自动重新订阅服务器，而无需在每个屏幕上调用 retry。

单一消费者的WebSocket错误

在某些情况下，错误可能仅针对单个消费者。这通常发生在错误消息：

1
{
2
  "id": "3f32558f-49a3-4dc2-9d1c-445adf0a66c7",
3
  "type": "error",
4
  "payload": { }
5
}

在这些情况下，流将抛出 SubscriptionOperationException 错误，您需要处理重试：

1
apolloClient.subscription(MySubscription())
2
    .toFlow()
3
    .retryWhen { e, attempt ->
4
      if (e is SubscriptionOperationException) {
5
        // handle the operation error
6
      } else {
7
        // handle global errors that were not caught by webSocketReopenWhen
8
      }
9
    }
10
    .collect {
11
      println("trips booked: ${it.data?.tripsBooked}")
12
    }