akka-http

    0热度

    1回答

    我是Akka/Spray和Scala的新手。我从阿卡文档看到,有的HttpRequest这是HTTP请求类和也有其根据阿卡文档 封装一个HttpRequest的上下文中,因为它流过一个 阿卡-HTTP路由结构的RequestContext。 我可以知道术语'context'在这里的含义是什么? 感谢

    0热度

    1回答

    我已经使用Akka-HTTP(https://github.com/theiterators/akka-http-microservice)和Scala编写的AWS服务器上的我的微服务部署到Docker容器中。一旦将服务部署到AWS服务器,我就面临内存泄漏问题&性能问题。 我已经注意到,当服务器获取更多的请求数量(如340mb,410mb,422mb ...)时,内存使用率增加。&取决于负载,然后

    0热度

    2回答

    我试图执行一个akka-http,它是一个scala程序。我的吻代码如下: - import akka.actor.ActorSystem import akka.http.scaladsl.Http import akka.http.scaladsl.model.{HttpRequest, HttpResponse} import akka.http.scaladsl.server.Dir

    1热度

    1回答

    我已经在Scala中定义的方法为getJobByID和getJobByName,现在我能够在GET通话过程中传递Id参数为 val route = (path("dataSource"/LongNumber) & get){ id => complete(getJobById(id).map(_.asJson)) } 现在我想一切按类似的方式按名称作业,但没有找到任何可用于获取作业

    0热度

    1回答

    我在我的应用程序如下路线: val myRoute = Route { context => val handler = Source.single(getRequest(context)) .via(flow(server, port)) .runWith(Sink.head).flatMap { r => // Add cookie t

    0热度

    1回答

    我正在使用akka与喷射json支持,我需要在接收的json中编辑值。 import akka.http.scaladsl.server.Directives import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport import spray.json._ final case class Item(name: St

    1热度

    1回答

    我对scala非常陌生,如果你能帮助我解决以下问题,我将不胜感激。 我使用akka-http发送http请求我想声明一个通用的发送请求方法,它将使用Unmarshall的http响应正文转换为泛型类型。 我应该如何施放Unmarshal回应给T? 发送请求的实现: def sendRequest[T](requestMessage :HttpRequestMessage) :Futu

    0热度

    1回答

    我正在尝试使用akka http生成PUT请求,其中的休息服务终点按照预期的方式使用curl完成,但是当通过创建Http生成时显示超时错误连接。 import akka.actor.ActorSystem import akka.http.scaladsl.Http import akka.http.scaladsl.model._ import akka.stream.ActorMater

    0热度

    1回答

    我是非常新的Akka Streaming和反应流。我有一个问题:是否有可能让一个剩余API接收一条消息,将其放在Kafka Bus上,然后Kafka流消费者将消息聚合到最大值。时间窗口并重新回到答案? 如何实现这样一个系统?或从哪里开始? 感谢

    2热度

    1回答

    如何在使用akka-http getFromFile方法时添加额外的响应标头。像这样有路线: path("image.jpg") { var f = new File("/path/to/image.jpg") getFromFile(f,ContentType(MediaTypes.`image/jpeg`)) } ~ 我要添加这个头: RawHeader