我正在使用Akka Http (v10.1.10)创建一个带有代理的客户端。每次响应不成功时,我都会得到一个错误,而不是正确的响应实体: akka.http.impl.engine.client.ProxyConnectionFailedException: The HTTP(S) proxy rejected to open a connection to hahahahahhahaahahhahaadsfsd.com:80 with status code: 503 Service Unavailable
at akka.http.impl.engine.client.Https
我编写了一个简单的参与者,它下载一个网页并将该页面的正文发送给它的发送者。我使用Akka HTTP来构建HTTP请求和处理HTTP响应。下面是我的代码:
class Downloader(uri: String) extends Actor {
import akka.pattern.pipe
import context.dispatcher
final implicit val materializer: ActorMaterializer = ActorMaterializer(ActorMaterializerSettings(context.system))
v
Akka.NET提供了一个F# API,它使得在Akka邮箱上将Akka参与者定义为F#函数变得非常简单。而且只要可以使用单个受歧视的联合来描述由参与者处理的所有消息,则参与者邮箱是强类型的。问题是,将所有消息定义放在一种类型中(受歧视的联合)通常会使这种类型变得混乱:行为者通常响应不同类别的消息,例如远程客户端发送的消息和内部通信中使用的消息。例如,参与者可以生成内部作业并得到内部组件的通知。使用不同的(内部)类型定义这些内部消息是有意义的,但是参与者的邮箱字符不能再是强类型,而参与者的函数如下所示:
let rec loop () =
actor {
我刚接触AKKA Streams。(使用Akka v2.4.4)我正在尝试创建一个Websocket,它可以将新的通知推送到订阅的客户端。我的策略是实现一个ActorPublisher,稍后我可以向其发送消息,然后将其推送到客户端。
为了开始,我复制了一个ActorPublisher的例子:
case class Tick()
class TickActor extends ActorPublisher[Int] {
import scala.concurrent.duration._
implicit val ec = context.dispatcher
val tick
针对这个错误,我搜索了其他的StackOverflow问题/答案,但是找不到解决这个问题的提示。
Akka HTTP应用程序在高工作负载下运行大约5个小时,没有问题,而且我开始获得多个:
Response entity was not subscribed after 1 second. Make sure to read the response `entity` body or call `entity.discardBytes()` on it -- in case you deal with `HttpResponse`, use the shortcut `response.disc