问题标签 [lagom]

我有一个 Lagom ServerServiceCall，它让我可以访问 Lagom 的 RequestHeader，其中包含有关请求的 URI（路径）和消息协议（媒体类型）的信息。

然而，我真正想要的是找到客户端请求的“主机”和协议。在标准的 Play 应用程序中，这些数据看起来在 RequestHeader 的“host”和“proto”字段中，但 RequestHeader 的 Lagom 版本不包含这些字段。我可以在 Host 和/或各种 X-Forwarded-... 标头本身的标头值中四处寻找，但也许有更好的方法？

我正在玩 Lagom 并创建了接收 Source 作为输入并返回案例类对象的服务：

服务实现是：

当我从 Play 应用程序的控制器调用此服务时：

服务端的 "runForeach" 成功打印 A、B、C 但服务本身不返回任何结果值（应为 ResultData("TestResult", 12)）导致 Play 应用程序抛出异常：

这怎么可能解决？

在 Lagom 中，聚合根 [DDD] 每个都表示为一个 PersistentEntity。一个 PersistentEntity 是否有可能解析并持有对不同 PersistentEntity 的引用？我找不到任何说明这种情况的 Lagom 示例。

在 Spring 框架中，我们可以从请求正文或 URL 查询参数中获取参数：

我们如何才能在Lagom中支持两种参数发布方式？如何在Lagom中获取请求信息（header/uri/methods/param） ？

找不到 Cassandra 联系点，原因是：访问被拒绝。您的凭据无法通过身份验证。缺少凭据。不知道如何解决这个问题。

我正在尝试运行 lagom 示例 online-auction-scala。

请帮助理解
1) 选择 Akka http 和 Lagom 来构建微服务
2) REST API 和基于 Akka http/Lagom 的微服务之间有什么区别。

谢谢

[注意] 问题是 Lagom 框架特有的！

在我当前的项目中，当上游高速并且看起来下游无法及时处理所有消息时，观察到将消息列表从 Source 剪切到 Kafka 主题发布者的问题。正如意识到的那样，切割与 PubSubRef.subscribe() 方法的行为有关https://github.com/lagom/lagom/blob/master/pubsub/javadsl/src/main/scala/com/lightbend/lagom/javadsl /pubsub/PubSubRef.scala#L85

完整的方法定义：

使用了 OverflowStrategy.dropHead。可以改成使用背压策略吗？

UPD#1： 用例非常简单，当查询请求发布到命令主题时，获取它并从数据库表中查询对象，结果列表被推送到结果 Kafka 主题中。代码片段：

如果函数生成的对象流deserializeCommandAndQueryObjects超过默认缓冲区大小 = 1000，它会开始切割元素（我们的例子是 ~ 2.5k 个对象）。

UPD#2： 对象数据的来源是：

还有一个 Kafka 订阅objectsResultTopic：

我一直想用 Scala 创建微服务。稍后我们可能还需要一些网页。

1. 什么是微服务或 REST HTTP 方面的反应式编程？
2. Play、Lagom 和 Akka 之间有什么关系（如果有的话）？它们都用于制作微服务吗？
3. Play 是反应式的吗？
4. 微服务可以提供动态网页吗？还是我需要为此单独申请？
5. 我已经用 ReactJS 做了一些工作。这适合图片中的任何地方吗？

请帮忙

我正在运行 Lagom online-auction-java 并且出现错误，当我执行 sbt clean runAll 时在下面运行

是否有可以在 build.sbt 中使用的所有 Lagom 属性的列表？

例子：