问题标签 [akka-grpc]

根据我得到的基本教程sbt run，在 Scala、akka-grpc 项目上运行：

alpn-boot 是否与 Java 12 不兼容？这是想表达什么？它适用于 Java 11 吗？我可以让它与 12 一起工作，让它相信它是 Java 11 吗？

[完整源代码]

我很难理解 Akka grpc 的基础知识。在 Akka 文档中，我看到了 Akka protobuf 客户端使用来自 Akka protobuf 服务器的服务的示例。

我可以使用 Akka 来使用来自非 Akka protobuf 服务的数据吗？

我在 java 中有一个示例 protobuf 项目，它将 protobuf 请求消息发送到服务器并使用 netty 通道处理程序获取响应，类似于：

因此，如果我理解正确的话，这基本上会创建一个 netty Bootstrap 并在创建通道时添加一个管道。

如何在 Akka grpc（解码器等）中设置此管道？

好的，遵循使用 Java 8 的先决条件和说明，项目创建工作。

sbt new akka/akka-grpc-quickstart-java.g8

然后继续指南

./gradlew compileJava也可以。

但随后./gradlew --info runServer因以下错误/问题而失败：

和

原帖：

我无法让 Akka-GRPC 示例运行。我尝试在此处遵循本指南，但是当我下载示例项目时，它似乎不完整。

这就是树命令输出：

项目结构中没有源文件或 gradlew oder pom.xml。

接下来，我从 GitHub克隆了该示例的存储库，并按照自述文件中的说明进行操作，主要是 command sbt new akka/akka-grpc-quickstart-java.g8。

然后我进入源文件所在的 project/sources 文件夹 ./src/main/g8/ 并尝试从那里按照指南中的说明进行操作。由于某些属性错误，这也不起作用：

在此之前，我必须在 ./gradle/wrapper/gradle-wrapper.properties 中设置另一个 gradle 版本（6.1.1，为 4.5.1）以使其与 Java 13 兼容。

试图至少暂时让它工作，我将属性硬编码到 build.gradle 文件中：

但这也只让我到目前为止：

由于字符限制，再次无法包含整个堆栈跟踪。

我错过了什么？我应该进一步采用哪种方法？

我有一个带有 Scala Play 的 HTTP 后端。工作正常。现在我想在它上面设置一个 gRPC-API（理论上应该可以）。

要设置 gRPC，我基本上遵循akka-quickstart

我可以运行sbt compile并在target/../ dic中获取我生成的 Scala 类。但是如果我尝试运行sbt run我会得到

所以我知道我使用的一些库对于 Akka 2.6.5 来说太旧了，但我不明白如何在较低的 Akka 版本上设置我的服务。

我的插件.sbt

我的 build.sbt

我尝试使用Akka-gRPC和Slick开发 gRPC 服务器。我也将机身用于 DI。

源代码在这里

问题是如果它在作为 gRPC 服务器执行时收到请求会导致失败。如果它不作为 gRPC 服务器启动，而只是从数据库中读取资源，则该过程成功。

有什么区别？

在 Follows 中，它使用 slick 从数据库中读取对象。 ...Component是机身对象。它将由主模块使用。

以下是 gRPC 服务器源代码。

以下是主要模块。

当UserResolveService和UserServiceImpl被直接调用时，从数据库中加载对象的过程就成功了。

但是，将应用程序作为 gRPC 服务器运行时，收到请求时会发生错误。

虽然我想了一天，但我无法解决……请你帮我解决。

我正在使用akka grpc（v 10.2.0），

我正在并行创建 100 个客户端（对 grpc 服务器进行压力测试）。有时，在客户端，我会看到如下错误：

但在服务器上一切都很好，没有错误。有时这个客户端（并行生成 100 个连接）只是挂起。流挂起没有错误。

如果我要重新启动客户端，一切都会开始正常工作，所以服务器没问题。不确定在哪里寻找问题？

我有一个akka-gRPC服务双向流，我正在单元测试中对其进行测试。该服务有用途akka-stream，我使用TestSink.probe来测试回复消息。我收到了来自服务的消息，但是有一个与超时相关的错误，我无法弄清楚是什么原因。这是测试：

错误是：

断言失败：在等待 OnComplete 时，在 expectMsg 期间超时（3 秒） java.lang.AssertionError：断言失败：在 akka 等待 OnComplete 时，在 expectMsg 期间超时（3 秒） .testkit.TestKitBase.expectMsg_internal(TestKit.scala:459) 在 akka.testkit.TestKitBase.expectMsg(TestKit.scala:436) 在 akka.testkit.TestKitBase.expectMsg$(TestKit.scala:436) 在 akka.testkit.TestKit .expectMsg(TestKit.scala:969) at akka.stream.testkit.TestSubscriber$ManualProbe.expectComplete(StreamTestKit.scala:479) at com.example.helloworld.GreeterServiceImplSpec.$anonfun$new$5(GreeterServiceImplSpec.scala:121)

我正在尝试使用播放框架和 grpc 设置测试项目。

我的build.sbt：

plugins.sbt：

原型：

现在根据文档：https ://developer.lightbend.com/docs/play-grpc/current/play/sumption-grpc.html这个设置也应该AkkaGrpcClientModule为我生成，但它不会发生。这是生成的工件列表：

我在设置中错过了什么吗？

我正在尝试使用 akka-grpc，但在使用它时遇到了兼容性问题。我使用 akka 库，例如 akka-actor 和 akka-persistence 等。他们都使用akkaversion 2.6.5。但是，当使用 akka-grpcaddSbtPlugin("com.lightbend.akka.grpc" % "sbt-akka-grpc" % "1.1.1")我的项目开始使用 2.6.9 版本时，我收到以下错误：

是否有与 akka 2.6.5 版兼容的 akka-grpc 版本？

编辑一些额外的信息 我有来自akka 2.6.5 版本的akka​​-grpc 依赖树的每个依赖。但是，当我在 shell 中运行时，我可以看到它们使用 2.6.9 我想这怎么会发生？