如何让akka-http将GET请求转发到POST请求并更改属性？

nwwlzxa7 于 2022-11-06 发布在其他

关注(0)|答案(1)|浏览(139)

我正在使用akka-http处理get请求，我想转发到同一主机，但更改了以下参数：

将GET转换为POST
将端口从8080更改为8081
删除参数并发送一个JSON。我已经创建了要发送的JSON值。

我查阅了这个页面和这个answer。我正在使用extract(_.request) { request =>提取请求，然后使用StatusCodes.MovedPermanently创建一个redirect(。

val routes: Route = {
    get {
      (path(IntNumber) & parameterSeq) { (adId: Int, params: Seq[(String, String)]) =>
        // handling requests as: "http://localhost:8080/2?c=5&b=2", make sure to use the request between quotes
        println(s"The ad ID: $adId contains the parameters: ${params.map(paramString).mkString(", ")}")

        val bid = getBid(adId, params)
        println(s"bid request: ${bid.toJson.prettyPrint}")

        // HOW TO REDIRECT TO ANOTHER PORT, CHANGE THE METHOD FROM GET TO POST, AND SEND A JSON PAYLOAD?
        val newRequest = HttpRequest(
          HttpMethods.POST,
          uri = "/",
          entity = HttpEntity(ContentTypes.`application/json`, bid.toJson.toString)
        )

        redirect(
          newRequest
            .uri
            .withHost("localhost")
            .withPort(8082),
          StatusCodes.MovedPermanently
        )
        // complete(StatusCodes.OK)

      } ~ pathEndOrSingleSlash {
        complete(StatusCodes.BadRequest)
      } ~ {
        complete(StatusCodes.Forbidden)
      }
    }
  }

但是当我向akka-http应用程序$ http GET "localhost:8080/3?b=5&c=10&d=19&c=10"发送get时，端口8082上的服务器没有应答。

$ http GET "localhost:8080/3?b=5&c=10&d=19&c=10"
HTTP/1.1 301 Moved Permanently
Content-Length: 92
Content-Type: text/html; charset=UTF-8
Date: Fri, 19 Feb 2021 15:49:21 GMT
Location: //localhost:8082/
Server: akka-http/10.2.2

This and all future requests should be directed to <a href="//localhost:8082/">this URI</a>.

为了测试服务器是否在工作，我可以发送POST请求，然后收到应答：

$ http POST localhost:8082 < src/main/resources/bidders-request-10.json 
HTTP/1.1 200 OK
Content-Type: application/json;charset=UTF-8
Date: Fri, 19 Feb 2021 15:51:02 GMT
Server: Apache-Coyote/1.1
Transfer-Encoding: chunked

{
    "bid": 0,
    "content": "b:$price$",
    "id": "10"
}

akka

来源：https://stackoverflow.com/questions/66280111/how-to-make-akka-http-to-forward-a-get-request-to-a-post-request-and-change-attr

1条答案

按热度按时间

cvxl0en21#

因此，我通过创建一个执行Http().singleRequest(HttpRequest(uri = "https://akka.io"))的参与者来解决这个问题，就像这个例子一样。我的工作解决方案是：

import akka.actor.{Actor, ActorLogging, ActorSystem, Props}
import akka.http.scaladsl.Http
import akka.http.scaladsl.model._
import akka.util.ByteString
import spray.json._
import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport

object MyselfClient {
  def main(args: Array[String]): Unit = {
    val system = ActorSystem("AuctionClientSystem")
    val auctionClientActor = system.actorOf(Props[AuctionClientActor], "auctionClientActor")
    auctionClientActor ! BidRequest(1, Bid(2, List(("c", "5"), ("b", "2"))))
  }
}

case class BidRequest(requestId: Int, bid: Bid)

class AuctionClientActor extends Actor with ActorLogging
      with BidJsonProtocol with SprayJsonSupport {

  import akka.pattern.pipe
  import context.dispatcher

  implicit val system = context.system
  val http = Http(system)

  def receive = {
    case bidRequest@BidRequest(requestId, bid) =>
      println(s"received bid request: $bidRequest")
      val content = bidRequest.bid.toJson.toString
        .replace("[[", "{")
        .replace("]]", "}")
        .replace("\",\"", "\": \"")
        .replace("[", "")
        .replace("]", "")
      println(content)
      // create the request
      val httpRequest = HttpRequest(
        HttpMethods.POST,
        uri = Uri("http://localhost:8081"),
        entity = HttpEntity(
          ContentTypes.`application/json`,
          content
          // """{"id": 10, "attributes" : { "a": "1", "b": "0" }}""".stripMargin
        )
      )
      // send the request
      http.singleRequest(httpRequest).pipeTo(self)
    case HttpResponse(StatusCodes.OK, headers, entity, _) =>
      entity.dataBytes.runFold(ByteString(""))(_ ++ _).foreach { body =>
        println("Got response, body: " + body.utf8String)
      }
    case resp@HttpResponse(code, _, _, _) =>
      println("Request failed, response code: " + code)
      resp.discardEntityBytes()
  }
}

我只是不知道如何使Spray JSON不使用[和]。然后我用.replace("[[", "{")做了那个讨厌的对话。但是，解决方案已经工作了。Spray JSON我正在寻找一个更好的方法来转换它。我猜有另一种形式来创建case类，不使用[和]。

import spray.json._

case class Bid(id: Int, attributes: List[(String, String)])

trait BidJsonProtocol extends DefaultJsonProtocol {
  implicit val bidFormat = jsonFormat2(Bid)
}

赞(0）回复(0）举报 2022-11-06

我来回答

如何让akka-http将GET请求转发到POST请求并更改属性？

1条答案

相关问题

热门标签

最新问答