如何在 try 子句中定义的对象上调用 catch 子句中的方法？

Question

我正在 try-catch 块中创建一个 redis pubsub 客户端。在try 块中，客户端通过回调初始化以将消息转发给客户端。如果向客户端发送消息有问题，会抛出异常，此时我需要停止redis客户端。代码如下：

try {
  val redisClient = RedisPubSub(
    channels = Seq(currentUserId.toString),
    patterns = Seq(),
    onMessage = (pubSubMessage: PubSubMessage) => {
      responseObserver.onValue(pubSubMessage.data)
    }
  )
}
catch {
  case e: RuntimeException =>
    // redisClient isn't defined here...
    redisClient.unsubscribe(currentUserId.toString)
    redisClient.stop()
    messageStreamResult.complete(Try(true))
    responseObserver.onCompleted()
}

问题是 redis 客户端 val 没有在 catch 块中定义，因为可能有一个异常创建它。我也无法将 try-catch 块移动到回调中，因为无法（我可以找到）从回调中引用 redisClient 对象（this 无法解析）。

为了解决这个问题，我将redisClient 实例化为var 在try-catch 块之外。然后在try 块内，我停止客户端并将新的redisPubSub（如上创建）分配给redisClient var。这是一个丑陋的 hack，也容易出错（例如，如果创建第二个客户端确实存在 问题，catch 块将尝试调用错误对象上的方法）。

是否有更好的方法来编写此代码，以便在尝试将消息发送到 responseObserver 时引发异常时，我可以在 redisClient 上正确调用 stop()？

更新

我刚刚使用 Promise 解决了这个问题。有没有更简单的方法？

Answer 1

如果发送消息出现问题，不会调用该异常处理程序。这是针对设置客户端的问题。这个SO answer 讨论了发送消息时的处理错误。

至于引用客户端的回调，我认为您希望在创建客户端之后注册回调，而不是在创建时尝试传递回调。这里有一些 sample code from Debashish Ghosh 可以做到这一点。

大概该回调将在另一个线程中运行，因此如果它使用redisClient，则您必须小心并发性。理想情况下，回调可以通过一些参数到达客户端对象。如果没有，那么使用volatile 可能是处理这个问题的最简单方法，尽管我怀疑如果多个回调可能同时失败，你最终会遇到麻烦。或许像 Debashish 所做的那样使用演员来管理客户端连接？