【问题标题】:java try-with-resource not working with scalajava try-with-resource 不适用于 scala
【发布时间】:2017-02-13 10:16:48
【问题描述】:

在 Scala 应用程序中,我尝试使用 java nio try-with-resource 构造从文件中读取行。

Scala 版本 2.11.8
Java 1.8 版

try(Stream<String> stream = Files.lines(Paths.get("somefile.txt"))){
    stream.forEach(System.out::println); // will do business process here
}catch (IOException e) {
    e.printStackTrace(); // will handle failure case here
}  

但是编译器会抛出类似
的错误 ◾未找到:价值流
◾没有catch或finally的try相当于把它的身体放在一个块里;不处理任何异常。

不确定是什么问题。我是使用 Java NIO 的新手,非常感谢任何帮助。

【问题讨论】:

标签: java scala try-with-resources


【解决方案1】:

如果您使用的是 Scala 2.13,那么您应该使用 Using object:

import scala.util.Using
val a: Try[Int] = Using(new FileInputStream("/tmp/someFile")) { fileInputStream =>
  // Do what you need in fith you fileInputStream here.
}

它有两个功能。第一个是可以创建或提供可关闭资源的函数,第二个函数是将可关闭资源作为参数,并可以将其用于某事的函数。使用 will 然后简单地说为您执行以下操作:

  1. 调用第一个函数创建可关闭资源。
  2. 调用第二个函数,并将资源作为参数提供。
  3. 保持第二个函数的返回值。
  4. 对资源调用 close。
  5. 返回它从包装在 Try 中的第二个函数获得的值(或异常)。

Using 可以用于除实现 AutoCloseable 的类之外的许多其他事物,您只需提供一个隐式值,告诉 Using 如何关闭您的特定资源。

在旧版本的 scala 中,没有直接支持 java 的 try-with-resources 构造,但您可以通过应用借用模式轻松构建自己的支持。下面是一个简单但不是最优的例子,很容易理解。这个答案后面给出了更正确的解决方案:

import java.lang.AutoCloseable

def autoClose[A <: AutoCloseable,B](
        closeable: A)(fun: (A) ⇒ B): B = {
    try {
        fun(closeable)
    } finally {
        closeable.close()
    }
}

这定义了一个可重用的方法,它的工作方式非常类似于 java 中的 try-with-resource 构造。它通过两个参数工作。首先是采用 Autoclosable 实例的子类,其次是采用与参数相同的 Autoclosable 类型的函数。函数参数的返回类型,用作方法的返回类型。然后该方法在 try 中执行该函数,并在其 finally 块中关闭 autocloseble。

你可以这样使用(这里用来获取流上findAny()的结果。

val result: Optional[String] = autoClose(Files.lines(Paths.get("somefile.txt"))) { stream ⇒
    stream.findAny()
}

如果您想捕获异常,您有 2 个选择。

  1. 在 stream.findAny() 调用周围添加一个 try/catch 块。

  2. 或者在 autoClose 方法中的 try 块中添加一个 catch 块。请注意,只有在调用 autoClose 的所有地方都可以使用 catch 块中的逻辑时,才应该这样做。

请注意,正如 Vitalii Vitrenko 指出的那样,如果客户端提供的函数和 AutoCloseable 上的 close 方法都抛出异常,则此方法将从 close 方法中吞下异常。 Java 的 try-with-resources 可以处理这个问题,我们可以让 autoClose 这样做,方法是让它更复杂一点:

  def autoClose[A <: AutoCloseable,B](
      closeable: A)(fun: (A) ⇒ B): B = {

    var t: Throwable = null
    try {
      fun(closeable)
    } catch {
      case funT: Throwable ⇒
        t = funT
        throw t
    } finally {
      if (t != null) {
        try {
          closeable.close()
        } catch {
          case closeT: Throwable ⇒
            t.addSuppressed(closeT)
            throw t
        }
      } else {
        closeable.close()
      }
    }
  }

这通过存储客户端函数抛出的潜在异常,并将 close 方法的潜在异常添加到它作为被抑制的异常来工作。这与 oracle 解释 try-with-resource 实际执行的方式非常接近:http://www.oracle.com/technetwork/articles/java/trywithresources-401775.html

然而,这是 Scala,很多人会更喜欢以更实用的方式进行编程。以更实用的方式,该方法应该返回一个 Try,而不是抛出异常。这避免了引发异常的副作用,并使客户端清楚地知道响应可能是应该处理的失败(正如 Stas 的回答中所指出的)。在函数式实现中,我们还希望避免使用 var,因此天真的尝试可能是:

  // Warning this implementation is not 100% safe, see below
  def autoCloseTry[A <: AutoCloseable,B](
      closeable: A)(fun: (A) ⇒ B): Try[B] = {

    Try(fun(closeable)).transform(
      result ⇒ {
        closeable.close()
        Success(result)
      },
      funT ⇒ {
        Try(closeable.close()).transform(
          _ ⇒ Failure(funT),
          closeT ⇒ {
            funT.addSuppressed(closeT)
            Failure(funT)
          }
        )
      }
    )
  }

他们可以这样称呼:

    val myTry = autoCloseTry(closeable) { resource ⇒
      //doSomethingWithTheResource
      33
    }
    myTry match {
      case Success(result) ⇒ doSomethingWithTheResult(result)
      case Failure(t) ⇒ handleMyExceptions(t)
    }

或者你可以在 myTry 上调用 .get 让它返回结果,或者抛出异常。

然而,正如 Kolmar 在评论中指出的那样,由于 return 语句在 scala 中的工作方式,这种实现存在缺陷。考虑以下几点:

  class MyClass extends AutoCloseable {
    override def close(): Unit = println("Closing!")
  }

  def foo: Try[Int] = {
     autoCloseTry(new MyClass) { _ => return Success(0) }
  }

  println(foo)

我们希望这会打印 Closing!,但它不会。这里的问题是函数体内的显式返回语句。它使该方法跳过 autoCloseTry 方法中的逻辑,从而只返回 Success(0),而不关闭资源。

为了解决这个问题,我们可以混合使用两种解决方案,一种具有返回 Try 的功能 API,但使用基于 try/finally 块的经典实现:

    def autoCloseTry[A <: AutoCloseable,B](
        closeable: A)(fun: (A) ⇒ B): Try[B] = {

      var t: Throwable = null
      try {
        Success(fun(closeable))
      } catch {
        case funT: Throwable ⇒
          t = funT
          Failure(t)
      } finally {
        if (t != null) {
          try {
            closeable.close()
          } catch {
            case closeT: Throwable ⇒
              t.addSuppressed(closeT)
              Failure(t)
          }
        } else {
          closeable.close()
        }
      }
    }

这应该可以解决问题,并且可以像第一次尝试一样使用。然而,它表明这有点容易出错,并且错误的实现已经在这个答案中作为推荐版本已经有一段时间了。因此,除非您试图避免使用许多库,否则您应该正确考虑使用库中的此功能。我认为已经有另一个答案指向一个,但我的猜测是有多个库,它以不同的方式解决了这个问题。

【讨论】:

  • 请注意,与 Java try-with-resources 不同,此解决方案无法处理 fun(closeable)close() 都抛出异常的情况。最后一个例外只是默默地隐藏了第一个!您可能应该在另一个 try 语句中关闭资源并使用 addSuppressed(),如 this answer 中所示
  • 感谢@VitaliiVitrenko,您是正确的。我已更新答案以包含您的意见。
  • Try 的实现是错误的。 Try 只捕获 NonFatal 异常,但即使是致命和控制流异常也必须清理资源。考虑以下代码:class MyClass extends AutoCloseable { override def close() = println("Closing!") }; def foo: Try[Int] = { autoCloseTry(new MyClass) { _ =&gt; return Success(0) } }。调用foo 不会调用closeautoCloseTry,但可以使用autoClose
  • 谢谢科尔玛。我已尝试更新答案,以解决该问题。
  • @smac89 我添加了一个例子。
【解决方案2】:

或者,您可以使用 Choppy 的(免责声明:我是作者)TryClose monad 以类似于 Scala 的 Try 的可组合方式来理解。

val ds = new JdbcDataSource()
val output = for {
  conn  <- TryClose(ds.getConnection())
  ps    <- TryClose(conn.prepareStatement("select * from MyTable"))
  rs    <- TryClose.wrap(ps.executeQuery())
} yield wrap(extractResult(rs))

您将如何处理您的信息流:

val output = for {
  stream  <- TryClose(Files.lines(Paths.get("somefile.txt")))
} yield wrap(stream.findAny())

更多信息在这里: https://github.com/choppythelumberjack/tryclose

【讨论】:

    【解决方案3】:

    您已经在其中一个答案方法中提到了:

      def autoClose[A <: AutoCloseable, B](resource: A)(code: A ⇒ B): B = {
        try
          code(resource)
        finally
          resource.close()
      }
    

    但我认为下面的更优雅:

      def autoClose[A <: AutoCloseable, B](resource: A)(code: A ⇒ B): Try[B] = {
        val tryResult = Try {code(resource)}
        resource.close()
        tryResult
      }
    

    恕我直言,使用最后一个更容易处理控制流。

    【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2016-03-12
    • 1970-01-01
    • 2023-03-26
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多