scala - Scala 中的数据压缩

Question

下面是我尝试实现一个提供压缩/解压缩字符串功能的类:

object GZipHelper {

  def deflate(txt: String): Try[String] = {
    try {
      val arrOutputStream = new ByteArrayOutputStream()
      val zipOutputStream = new GZIPOutputStream(arrOutputStream)
      zipOutputStream.write(txt.getBytes)
      new Success(Base64.encodeBase64String(arrOutputStream.toByteArray))
    } catch {
      case _: e => new Failure(e)
    }
  }

  def inflate(deflatedTxt: String): Try[String] = {
    try {
      val bytes = Base64.decodedBase64(deflatedTxt)
      val zipInputStream = GZIPInputStream(new ByteArrayInputStream(bytes))
      new success(IOUtils.toString(zipInputStream))
    } catch {
      case _: e => new Failure(e)
    }
  }
}

如您所见，关闭 finally 和 GZIPOutputStream 的 GZIPInputStream 块丢失了……我如何以“scala”方式实现它？我怎样才能改进代码？

Answer 1

由于您正在使用“老式” try 语句并将其显式转换为 scala.util.Try ，因此确实没有理由不在您的 finally 之后添加 try 块。

但是，在这种特定情况下，关闭没有什么意义，例如，您的 ByteArrayInputStream - 它不是真正的开放资源，不需要关闭。在这种情况下，您可以通过这种方式简化代码并使其更加惯用:

def inflate(deflatedTxt: String): Try[String] = Try {
   val bytes = Base64.decodedBase64(deflatedTxt)
   val zipInputStream = GZIPInputStream(new ByteArrayInputStream(bytes))
   IOUtils.toString(zipInputStream)
}

我个人不会声明 bytes 和 zipInputStream 因为它们只使用一次，但这是一个偏好问题。

这里的诀窍是使用 finally 块调用 scala.util.Try.apply - 我不确定如果不通过调用 map 实际上没有修改任何东西，这是否可能，这对我来说似乎有点疏忽。我期待在 andThen 中看到 eventually 或 scala.util.Try 方法，但它似乎不存在(还没有？)。