我目前正在做一些实验akka及其持久性堆栈,用akka-http堆栈包装。akka-http和JsonEntityStreamingSupport
注意:为了持久性,我使用非官方插件将Akka FSM保留为mongodb。
但我的问题是使用JsonEntityStreamingSupport
,recommended by akka to serve Source
as json。
在我的情况,我有这段代码
implicit val jsonEntityStreamingSupport: JsonEntityStreamingSupport = EntityStreamingSupport.json()
val readJournal = PersistenceQuery(system).readJournalFor[ScalaDslMongoReadJournal](MongoReadJournal.Identifier)
val route =
path("workflows") {
get {
complete(readJournal.currentPersistenceIds())
}
}
Http().bindAndHandle(route, "localhost", 8081)
但不幸的是,我想出了这个错误:
$ curl localhost:8081/workflows
curl: (56) Recv failure: Connection reset by peer
我没有看到任何错误或日志,这可能会导致信息关于服务器关闭连接的原因。
有没有人已经做过这种实验?
我与阿卡2.4.16和测试它阿卡-HTTP 10.0.5