akka-http

1热度

1回答

我想使用reactivemongo-akkastream 0.12.1从Mongodb流式传输数据，并将结果返回到其中一条路径（使用Akka-http）的CSV流中。我没有实现，这里继为例： http://doc.akka.io/docs/akka-http/10.0.0/scala/http/routing-dsl/source-streaming-support.html#simple-cs

0热度

1回答

阿卡-HTTP使用Java创建分块实体（从斯卡拉转换）

我想下面的代码从斯卡拉转换成Java： object ChunkedStaticResponse { private def createStaticSource(fileName : String) = FileIO .fromPath(Paths get fileName) .map(p => ChunkStreamPart.apply(p

0热度

2回答

Akka-http-json“不支持的内容类型，支持：application/json”

我在使用自定义JSON编组器/解组器时遇到问题。此作品不多罚款： trait EWorksJsonSupport extends SprayJsonSupport with DefaultJsonProtocol { implicit object IndividualJsonFormat extends RootJsonFormat[Individual] { def wri

1热度

1回答

Akka HTTP代码/结构模式

我刚刚开始使用Akka Http（和Scala），并想知道是否有任何定义良好的模式来构造Akka代码。特别是，我正在寻找动态组合/聚合路线的结构模式。具体而言，我正在寻找类似下面伪代码的解决方案： trait MyActor extends Actor { val myRouter: ActorRef = context.actorOf(FromConfig.props(Props[My

0热度

1回答

使用json4s处理POST请求中的JSON数据

我试图将JSON i/p映射到我的案例类CacheRequest。请求是POST。我是新来的斯卡拉和阿卡。 import org.json4s.{DefaultFormats, Formats} implicit val formats: Formats = DefaultFormats val route: Route = traceContextAwareRoute {

0热度

1回答

全球过滤器从喷雾迁移到Akka-Http 2

我有一个使用Spray Custom Directive0的路由处理器过滤器。此自定义指令的目的是构建一个请求过滤器来定时请求处理时间。里面的喷自定义指令，我可以使用RequestContext的的功能withHttpResponseMapped采取的HttpResponse =>的HttpResponse的参数，withHttpResponseMapped会返回一个新的RequestCont

0热度

1回答

使用akka-http和mongo-scala驱动程序

我想使用akka-http和新的mongo-scala-driver作为我的休息服务。此代码工作 val routes = { pathPrefix("info") { pathEndOrSingleSlash { get { val mongoClient: MongoClient = MongoClient("mongodb://localhost

0热度

1回答

scaladsl如何设置标题？

我正在尝试做一个scaladsl路线的测试。我的航线代码是： class EmployeeRoutes (implicit logger: LoggingAdapter) extends JsonSupport { val route : Route = post { path("employee"/"echo") { logger.info("Message recive

1热度

1回答

使用akka-http实现web socker服务器时，堆内存正在增长

我正在使用akka-http实现web套接字服务器。以下是请求处理程序代码吧： def decodeService: Flow[Message, Message, _] = { Flow[Message].map { case BinaryMessage.Strict(encodeMsg) => try { WebServer.getWorkerA

0热度

1回答

Akka.net演员是否适合GET和搜索操作？

我们在当前项目中使用akka.net actor模型。我用一个实体actor来处理插入，更新和删除操作。在搜索或获取的情况下演员模型不适合？如果是在UI支持它怎么可能得到的结果（天气用于向功能）这岂不是很好的做法，使用get和查询数据akka.net角色模型？