使用Akka Streams的TCP库可以轻松地建立TCP连接，从TCP流中消费数据并将其发送到指定的Sinks。

该解决方法包括以下步骤：

1. 导入必要的库和模块

import akka.Done
import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl._
import akka.util.ByteString

2. 创建一个ActorSystem和Actor Materializer

implicit val system = ActorSystem("my-system")
implicit val materializer = ActorMaterializer()

3. 创建TCP连接

val connections: Source[Tcp.IncomingConnection, Future[Tcp.ServerBinding]] =
  Tcp().bind("localhost", 8080) //绑定到指定的IP地址和端口

4. 从TCP流中消费数据并将其发送到不同的Sinks

// Sink 1
val sink1: Sink[ByteString, Future[Done]] =
  Flow[ByteString].map(bs => println(s"Sink 1: $bs")).toMat(Sink.ignore)(Keep.right)

// Sink 2
val sink2: Sink[ByteString, Future[Done]] =
  Flow[ByteString].map(bs => println(s"Sink 2: $bs")).toMat(Sink.ignore)(Keep.right)

// 将TCP流连接到Sink 1
val tcpIn1: Sink[Tcp.IncomingConnection, Future[akka.Done]] =
  connections.mapAsync(1)(conn => conn.flow.toMat(sink1)(Keep.right).run())

// 将TCP流连接到Sink 2
val tcpIn2: Sink[Tcp.IncomingConnection, Future[akka.Done]] =
  connections.mapAsync(1)(conn => conn.flow.toMat(sink2)(Keep.right).run())

// 运行TCP流连接
val doneFut1 = tcpIn1.run()
val doneFut2 = tcpIn2.run()

在这个例子中，我们使用了两个不同的Sinks：Sink1和Sink2。当数据被消费时，它们将打