-
17 votesanswersviews
akka http：阿卡流与演员 Build 休息服务
在akka http上使用60 API创建REST Web服务时 . 如何选择是否应该选择akka流或akka演员？在他的post中，乔斯展示了两种在akka http上创建API的方法，但他没有显示何时我应该选择一个而不是另一个 . -
2 votesanswersviews
Akka http连接池
我正在尝试为我们的akka http应用程序使用客户端连接池 . 但是，一旦达到最大连接数，请求似乎就会挂起 . 我已将问题浓缩为以下内容： import java.lang.Thread.UncaughtExceptionHandler import java.net.ServerSocket import akka.actor.ActorSystem import akka.http.scal... -
0 votesanswersviews
Akka Http错误：InvalidContentLengthException
我们有一个Akka HTTP Server在AWS上提供一些scala JS内容 . 我们've noticed that after some time, the server starts throwing the error below in the logs and although, the certain URL'工作，但是在浏览器中出现 Failed to load resource... -
1 votesanswersviews
通过数据库列名访问Slick字段
我有以下内容： case class Supplier(id: Long, name: String, desc: String, sales: Int) class SuppliersTable(tag: Tag) extends Table[Supplier](tag, "SUPPLIERS") { def id: Rep[Int] = column[Int](&qu... -
14 votesanswersviews
正确使用Akka http客户端连接池
我需要使用Akka的HTTP客户端（v2.0.2）来使用REST服务 . 逻辑方法是通过主机连接池执行此操作，因为我们期望大量的同时连接 . Flow 为此消耗 (HttpRequest, T) 并返回 (Try[HttpRequest, T) . documentation表示需要一些任意类型 T 来管理对请求的潜在无序响应，但是没有指出调用者应该对返回的 T 做什么 . 我的第一次尝试... -
6 votesanswersviews
是否使用源队列实现线程安全的akka-http中的连接池？
参考以下提到的实现： http://doc.akka.io/docs/akka-http/10.0.5/scala/http/client-side/host-level.html val poolClientFlow = Http().cachedHostConnectionPool[Promise[HttpResponse]]("akka.io") val queue = ... -
1 votesanswersviews
检测到java.lang.NoSuchMethodError错误，这可能是由类路径上不兼容的Akka版本引起的 .
检测到java.lang.NoSuchMethodError错误，这可能是由类路径上不兼容的Akka版本引起的 . 请注意，给定的Akka版本必须与您使用的所有Akka模块相同，例如：如果你使用akka-actor [2.5.4（从当前类路径解析）]所有其他核心Akka模块必须是相同的版本 . Alpakka，Persistence插件或Akka HTTP等外部项目都有自己的版本号 - 请确保您... -
0 votesanswersviews
akka spray - > akka http migration
这是我的路由器在基于喷雾的服务中的片段： path(baseUrl / version / "apps" / Segment / "users" / Segment) { (app, user) => respondWithMediaType(MediaTypes.`application/json`) { ctx => create... -
0 votesanswersviews
如何使用带有akka-http和基本身份验证的swagger
我正在尝试使用swagger＆swagger-akka-http记录akka-http API . This blog post给了我一个良好的开端，但现在我陷入困境，试图记录API使用基本身份验证的事实 . 我拥有的是： @Path("/foo") @Api(value = "/foo", produces = "application/jso... -
1 votesanswersviews
连接池本质上是在cloudant数据库中完成的吗？
我正在使用akka-http和cloudant数据库创建一个应用程序 . 我已经看过文档并且有max_connections变量，但我仍然不确定连接池是否在cloudant中固有地完成 . 在文档cloudant code (Please refer to line 418)中，有一条评论说： / ** *设置要在连接池中维护的最大连接数 . * 注意：此设置仅适用于使用可选的OkHttp依赖... -
35 votesanswersviews
Akka HTTP：将来阻止阻止服务器
我正在尝试使用Akka HTTP来基本验证我的请求 . 碰巧我有一个外部资源来进行身份验证，因此我必须对此资源进行休息调用 . 这需要一些时间，并且在处理时，我的API的其余部分似乎被阻止，等待此调用 . 我用一个非常简单的例子重现了这个： // used dispatcher: implicit val system = ActorSystem() implicit val executor =... -
3 votesanswersviews
将路由从spray.io迁移到akka http
我正在努力将应用程序从Spray.io迁移到Akka-http . 该应用程序是基于微服务的，具有许多我们构建的小型库 . 以下是在一个特定的微服务中编写指令和路由的示例： val routes = (decompressRequest & compressResponseIfRequested) { metricsRoute ~ healthStatusRoute ~... -
2 votesanswersviews
如何以编程方式在Akka Http中调用Route
在Akka Http中，可以通过这种方式定义路由系统来管理REST基础架构，如下所述：https://doc.akka.io/docs/akka-http/current/routing-dsl/overview.html val route = get { pathSingleSlash { complete(HttpEntity(ContentT... -
2 votesanswersviews
Akka / scala -OversizedPayloadException如何handel呢？
我们在akka集群上有一个分布式应用程序 . 演员“A”向远程演员发送大尺寸的消息 . 我们收到以下警告： 2016-08-10 23：08：29,737 [EndpointWriter]错误 - 瞬态关联错误（关联保持活动）akka.remote.OversizedPayloadException：丢弃发送给Actor的超大有效负载[akka.tcp：//abcd@127.0.0.1：5166... -
19 votesanswersviews
Akka Http性能调整
我在Akka-http框架（版本：10.0）上执行负载测试，我正在使用wrk工具 . wrk命令： wrk -t6 -c10000 -d 60s --timeout 10s --latency http://localhost:8080/hello 首次运行没有任何阻塞调用， object WebServer { implicit val system = ActorSystem(&quo... -
1 votesanswersviews
Akka http vs Lagom
请帮助理解1）选择Akka http vs Lagom来构建微服务2）REST API和基于Akka http / Lagom的微服务之间是否有任何区别 . 谢谢 -
0 votesanswersviews
如何使用Akka Streams和Akka HTTP订阅websockets到actor的消息？
我想通过websockets向客户发送通知 . 这些通知是由actor生成的，因此我试图在服务器启动时创建一个actor的消息流，并订阅websockects与此流的连接（仅发送自订阅以来发出的那些通知） 使用Source.actorRef，我们可以创建一个actor消息源 . val ref = Source.actorRef[Weather](Int.MaxValue, fail) ... -
2 votesanswersviews
Kafka主题到websocket
我正在尝试实现一个设置，其中我有多个Web浏览器打开与我的akka-http服务器的websocket连接，以便读取发布到kafka主题的所有消息 . 所以消息流应该这样 kafka topic -> akka-http -> websocket connection 1 -> websocket connection 2 ... -
0 votesanswersviews
Lagom akka-http集成
将 Akka HTTP 服务与/进行 Lagom 集成的最简单的解决方案是什么？ 我有两个服务 - akkahttp:8000 和 lagom:9000 ，他们正在为Angular应用程序提供方法 . 为所有服务设置一个 endpoints 会很棒 - x:8888 适用于 x:8888/akkahttp 和 x:8888/lagom . -
0 votesanswersviews
Lagom微服务和Akka HTTP配置位置
我正在使用Lagom 1.4.6并获得 akka.http.scaladsl.model.EntityStreamException: HTTP chunk size exceeds the configured limit of 1048576 bytes 使用ServiceCall获取build.sbt中定义的impl . 也不 akka.http.server.parsing.max-ch... -
2 votesanswersviews
错误：找不到参数超时的隐式值：akka.util.Timeout
我有这个代码，我在Scala中提出请求： implicit val result =system.actorOf(Props(new TestActor("TestingName")),name = "Scala") val future3:Future[String]= ask(result ,Message).mapTo[String] va... -
0 votesanswersviews
将WebSocket从Play移动到Akka HTTP
我在Play应用程序中有一个WebSocket服务器，我想将它移动到akka-http服务 . 我目前正在使用 ActorFlow.actorRef ，这是Play中不存在的一部分 . 当WebSocket被接受时，我订阅了RabbitMQ队列，并将每条消息转发给WebSocket . 当我收到来自WebSocket的消息时，我会在本地处理一些消息并将其他人转发到RabbitMQ交换机 . 我如何...