创建将所有数据发送到http端点的akka streams接收器

import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.model._
import akka.stream.ActorMaterializer
import akka.stream.scaladsl._

object HttpEndpointReceiver {
  def main(args: Array[String]): Unit = {
    implicit val system = ActorSystem("http-endpoint-receiver")
    implicit val materializer = ActorMaterializer()
    implicit val executionContext = system.dispatcher

    val data = List("data1", "data2", "data3") // 数据源，可以是从其他地方获取的数据

    val source = Source(data) // 创建数据源

    val httpSink = Sink.foreach[String] { data =>
      val request = HttpRequest(
        method = HttpMethods.POST,
        uri = "http://example.com/endpoint", // HTTP端点的URL
        entity = HttpEntity(ContentTypes.`text/plain(UTF-8)`, data) // 发送的数据
      )

      Http().singleRequest(request) // 发送HTTP请求
    }

    source.runWith(httpSink) // 将数据源连接到HTTP发送器

    // 等待数据发送完成
    Thread.sleep(5000)

    system.terminate() // 关闭ActorSystem
  }
}