如何从Akka TCP出站流获取本地IP与端口（SIP协议场景）

这个问题确实戳中了Akka Streams TCP API和Actor API的一个差异点——Actor模型里连接建立后会主动发送包含本地地址的消息，但Streams版本需要通过**物化值（Materialized Value）**来获取这些信息。下面给你几个实用的解决思路：

方案1：利用OutgoingConnection的物化值（最直接） #

Tcp.outgoingConnection返回的Flow本身带有一个物化值：Future[OutgoingConnection]，这个对象里直接包含了localAddress属性（完全等效于BSD的getsockname）。你只需要通过Akka Streams的viaMat和toMat方法保留并获取这个物化值即可：

import akka.actor.ActorSystem
import akka.stream.scaladsl.{Sink, Source, Tcp}
import akka.util.ByteString
import scala.concurrent.Future
import scala.util.{Failure, Success}

implicit val system = ActorSystem("SipTcpClient")
implicit val ec = system.dispatcher

// 1. 创建TCP连接Flow，注意它的物化值是Future[OutgoingConnection]
val connectionFlow = Tcp().outgoingConnection("www.google.com", 80)

// 2. 构造请求数据
val testRequests = List(
  "GET / HTTP/1.1",
  "Host: www.google.com",
  "\r\n"
).map(s => ByteString(s + "\r\n"))

// 3. 同时获取连接信息和响应结果
val (connectionFuture, responseFuture) = Source(testRequests)
  .viaMat(connectionFlow)(Keep.right) // 保留connectionFlow的物化值
  .toMat(Sink.fold(ByteString.empty)(_ ++ _))(Keep.both) // 同时保留两个物化值
  .run()

// 4. 处理连接信息（获取本地IP和端口）
connectionFuture.onComplete {
  case Success(conn) =>
    val localAddr = conn.localAddress
    println(s"本地连接IP: ${localAddr.getHostString}, 端口: ${localAddr.getPort}")
    println(s"远程连接地址: ${conn.remoteAddress}")
  case Failure(e) =>
    println(s"连接建立失败: ${e.getMessage}")
}

// 5. 处理响应结果
responseFuture.onComplete {
  case Success(resp) => println(resp.utf8String)
  case Failure(f) => println(f)
}

关键点：OutgoingConnection是Akka Streams专门用来封装连接元数据的对象，localAddress就是你需要的本地套接字信息，不需要额外调用底层API。

方案2：先获取本地地址再构造请求（适合SIP头部嵌入） #

如果你的业务逻辑需要在发送请求时就把本地IP和端口嵌入到SIP头部，可以先等待连接建立并拿到本地地址，再构造包含该信息的请求数据：

import akka.actor.ActorSystem
import akka.stream.scaladsl.{Sink, Source, Tcp}
import akka.util.ByteString
import scala.util.{Failure, Success}

implicit val system = ActorSystem("SipTcpClient")
implicit val ec = system.dispatcher

val tcp = Tcp(system)
val remoteHost = "www.google.com"
val remotePort = 80

// 1. 先获取连接的物化值
val connectionFuture = tcp.outgoingConnection(remoteHost, remotePort).materializedValue

connectionFuture.onComplete {
  case Success(conn) =>
    val localAddr = conn.localAddress
    println(s"已获取本地连接信息: ${localAddr.getHostString}:${localAddr.getPort}")

    // 2. 构造包含本地地址的SIP请求（这里用HTTP示例模拟）
    val sipRequests = List(
      s"SIP/2.0 INVITE sip:user@$remoteHost SIP/2.0",
      s"Via: SIP/2.0/TCP ${localAddr.getHostString}:${localAddr.getPort}", // 嵌入本地地址到头部
      s"Host: $remoteHost:$remotePort",
      "\r\n"
    ).map(s => ByteString(s + "\r\n"))

    // 3. 发送请求并处理响应
    Source(sipRequests)
      .via(tcp.outgoingConnection(remoteHost, remotePort))
      .runFold(ByteString.empty)(_ ++ _)
      .onComplete {
        case Success(resp) => println("响应结果:\n" + resp.utf8String)
        case Failure(f) => println("请求失败: " + f.getMessage)
      }
  case Failure(e) =>
    println("连接建立失败: " + e.getMessage)
}

优势：确保请求头部使用的是当前连接实际分配的本地IP和端口，避免了硬编码或预分配端口的不确定性。

方案3：自定义GraphStage（进阶场景） #

如果上述方案都无法满足你的需求（比如需要在Flow的每个处理步骤中都能访问本地地址），可以自定义一个GraphStage来封装TCP连接并暴露本地地址。不过这个方案需要深入Akka Streams的底层API，实现起来比较复杂，一般不推荐作为首选。

总结来说，方案1是最简洁高效的，直接利用Akka Streams的物化值机制就能拿到你需要的本地套接字信息；如果需要在请求中嵌入该信息，方案2会更贴合你的SIP协议需求。

内容的提问来源于stack exchange，提问作者David Weber