Scala Akka Streams示例：如何确保Paths.get返回非空Path对象

问题背景 #

学习Scala版Akka Streams快速入门时，遇到写入文件的示例代码无法编译的问题，原代码如下：

import java.nio.file.Paths

import scala.concurrent.*

import akka.*
import akka.actor.ActorSystem
import akka.stream.*
import akka.stream.scaladsl.*
import akka.util.ByteString
import java.nio.file.Paths

object StreamsQuickstart:
  def main(args: Array[String]): Unit =
    implicit val system: ActorSystem = ActorSystem("Quickstart")
    val source: Source[Int, NotUsed] = Source(1 to 100)

    // val done: Future[Done] = source.runForeach(println)

    val factorials = source.scan(BigInt(1))((acc, next) => acc * next)
    val result: Future[IOResult] =
      factorials.map(num => ByteString(s"$num\n")).runWith(FileIO.toPath(Paths.get("factorials.txt")))

编译报错核心原因：Paths.get("factorials.txt")在Scala 3中返回java.nio.file.Path | Null类型，但FileIO.toPath仅接受非空的Path对象作为参数，类型不匹配导致编译失败。

解决方案 #

以下几种方式可以安全解决空类型匹配问题：

1. 使用Option包装并处理空值 #

将Paths.get的结果包装为Option，通过getOrElse兜底处理空值场景：

val path = Option(Paths.get("factorials.txt")).getOrElse(throw new IllegalArgumentException("无效的文件路径"))
val result: Future[IOResult] =
  factorials.map(num => ByteString(s"$num\n")).runWith(FileIO.toPath(path))

若路径无效返回null，直接抛出异常终止程序，避免后续逻辑出现运行时空指针。

2. 使用Scala标准库的File工具类替代 #

Scala自带的scala.io.File可以更安全地生成Path对象，无需处理null：

import scala.io.File

val path = File("factorials.txt").toPath
val result: Future[IOResult] =
  factorials.map(num => ByteString(s"$num\n")).runWith(FileIO.toPath(path))

scala.io.File的toPath方法会直接返回非空的Path实例，从根源避免空类型问题。

3. 强制断言非空（仅限路径绝对有效场景） #

如果能100%确认目标路径不会返回null，可使用Scala 3的非空断言或强制类型转换：

// Scala 3非空断言语法
val path = Paths.get("factorials.txt").nn
// 或强制类型转换
val path = Paths.get("factorials.txt").asInstanceOf[java.nio.file.Path]
val result: Future[IOResult] =
  factorials.map(num => ByteString(s"$num\n")).runWith(FileIO.toPath(path))

注意：该方式不安全，若路径实际返回null会触发运行时空指针，仅适合测试或路径绝对可靠的场景。

4. 提前验证路径有效性 #

通过Java的Files工具类提前检查路径的可访问性，间接确保Path非空：

import java.nio.file.Files

val pathStr = "factorials.txt"
val parentPath = Paths.get(pathStr).getParent
require(parentPath != null && Files.isWritable(parentPath), "目标路径不可写入")
val path = Paths.get(pathStr)
val result: Future[IOResult] =
  factorials.map(num => ByteString(s"$num\n")).runWith(FileIO.toPath(path))

提前验证路径的可写性，既避免空值问题，也能提前拦截无效路径的运行时错误。

内容的提问来源于stack exchange，提问作者T-Braico