问题标签 [akka-http]

我正在使用 akka-http 1.0，我想使用定义为的路由

我该如何做到这一点？

尝试创建 http 客户端/流时，此代码似乎不再起作用：

该flow方法似乎不再可用。它真的被弃用了吗？以下是现在创建 Http 连接的首选方式吗？

Akka HTTP 在路由 dsl 中很好地支持提取路径查询参数（那些在 ? 之后，由 & 连接的参数），但不支持由 ; 分隔的路径参数。（如 /my/path;JSESSIONID=123）

这如何最好地完成？

让我们从一段代码开始：

编组按预期工作。有用于转换为 json 的导入隐式：

由于某种原因，解组不起作用：

RootJsonFormat[AuthenticationData]在下实施，JsonProtocolReadWrite因此它在范围内可用。

编辑 相关部分JsonProtocolReadWrite

使用akka-http，我怎样才能构造一个只监听传入数据但不写回任何东西的Flow[Message, Message, _] 传递给它？handleWebsocketMessage无论如何都可以使用接收器吗？因为 Sink 听起来像是我需要的。

我的应用程序结构看起来像

EmailService.scala

MonitorStatusService.scala

服务器.scala

我需要的？ 我想绑定多条路线，例如

但是当我这样做时，我看到错误为

我该怎么办？

我正在尝试 Akka-http，希望有人可以阐明以下问题：

1. 如何根据请求中的 accept: 标头创建不同的路由？例如，我想要一个处理“json”的代码路径和一个处理“xml”请求的代码路径（如果缺少标头，则默认为“json”）

2. 如果我不想推断 contentType，我该如何指定它？例如，在下面的代码中，我尝试通过 compactPrint() 运行 json，但这会将其更改为字符串，因此是“text/plain”。我想覆盖它并告诉客户它仍然是 json。

我的代码是这样的；

在这种情况下，响应是 text/plain，因为 compactPrint 创建了一个字符串。非常欢迎批评。;)

我正在使用 Scala、akka-http、json4s 构建一个微服务。还为我的业务 bean 类使用案例类。我的案例类有 scala 枚举（我研究了 scala 枚举并意识到了局限性，但这完全适合我当前的用例）。

在这种背景下，当我尝试创建服务时，我无法理解在哪里定义

implicit val formats = DefaultFormats + new EnumNameSerializer(_ProfessionClaType) + new EnumNameSerializer(_LinkRelType)

以下是我粗略的 scala 类结构：

我还有一个用于对服务进行单元测试的 ScalaTest 规范，并且我还被迫formats在每个测试用例中定义。不知道我这样做是否正确。因此寻求专家意见。

以下是我的测试规范：

包装在.niftyride.unit

我使用以下代码将一些数据发布到服务器

每次演员收到如下消息10 seconds时都会调用它Notifier

问题？

我看到最初（围绕5发送到服务器的请求），但后来它挂了，我没有看到任何日志记录，服务器没有收到任何数据。在客户端一段时间后，我看到以下内容

到底是怎么回事？我该如何解决这个问题？

2015 年 7 月 15 日http://akka.io/news/2015/07/15/akka-streams-1.0-released.html说 Akka Streams 和 Akka Http 已在 1.0 版发布，但我没有看到它们在Maven Central或Typesafe repo中。似乎只有“-experimental”工件。

1.0 非实验版本托管在哪里？