Akka 集群是一个分布式计算系统，可以在多个节点之间分配任务和资源。它本身不支持 socket 客户端，但是可以利用 Akka IO 组件以及 Akka 线程模型轻松构建 socket 客户端。

下面是一个简单的示例，使用 Akka IO 组件创建多个 socket 客户端：

import akka.actor.{Actor, ActorLogging, ActorRef, ActorSystem, Props}
import akka.io.{IO, Tcp}
import java.net.InetSocketAddress

object Main extends App {
  val host = "localhost"
  val port = 9000
  val numClients = 10

  val system = ActorSystem("ClientSystem")
  val listener = system.actorOf(Props(classOf[Listener], numClients), "listener")

  IO(Tcp)(system) ! Tcp.Bind(listener, new InetSocketAddress(host, port))
}

class Listener(numClients: Int) extends Actor with ActorLogging {
  implicit val system = context.system
  IO(Tcp) ! Tcp.Bind(self, new InetSocketAddress("localhost", 0))
  var clientCount = 0

  def receive: Receive = {
    case Tcp.Connected(remote, local) =>
      val handler = context.actorOf(Props(classOf[ClientHandler], remote, sender()))
      sender() ! Tcp.Register(handler)
      clientCount += 1
      if (clientCount == numClients) {
        context.stop(self)
      }
  }
}

class ClientHandler(remote: InetSocketAddress, connection: ActorRef) extends Actor with ActorLogging {
  IO(Tcp) ! Tcp.Connect(remote)
  var connectionCount = 0

  def receive: Receive = {
    case Tcp.CommandFailed(_: Tcp.Connect) =>
      log.warning(s"Connection failed to $remote")
      context stop self

    case Tcp.Connected(_, _) =>
      connectionCount += 1
      if (connectionCount == numConnections) {
        context stop self
      }

    case Tcp.Received(data) =>
      log.info(s"Received data: $data")
      // handle data

    case Tcp.PeerClosed =>
      log.info("Connection closed