问题标签 [akka-grpc]

有没有办法拦截akka-grpc中的请求？（我需要获取身份验证信息并用它来丰富请求）。

编写一个 scala 应用程序用于与 firestore 的 RPC api 交互，并使用 scalapb proto 编译器 /akka-grpc 中间件，如何在 .proto 文件中导入 firestore RPC API 的定义？例如。如何导入文档定义？

试图直截了当地说import "google.firestore.v1beta1.Document";会出错。

我正在连接到 AKKA GRPC 流服务器以获取消息流。当客户端由于某种原因死机/崩溃时，在服务器上找不到检测方法。

是否有任何 ErrorHandler/Callback 寄存器来了解客户端崩溃？

我正在使用 akka-grpc 生成客户端绑定。它们通常具有以下形式

func[A, B](in: Source[A]) : Source[B],

即他们消费 aSource[A]并提供 a Source[B]。

现在，我想将func它们Flow[A, B]与 akka-stream 一起使用。

我的目标是akka-grpc在我的项目中使用。通过使用演练，https://developer.lightbend.com/docs/akka-grpc/current/client/walkthrough.html我尝试生成 Scala 文件。但是，每当我构建项目（by mvn clean package）时，它都会生成 Java 文件而不是 Scala 文件。有没有办法生成 Scala 文件？我已经尝试将 Java 转换为 Scala，但没有成功。这是我的原型文件（演练中的同一个）：

我已经开始使用 ProtoBuffers 使用 Akka-GRPC，在线示例非常简洁明了，但是由于 Flatbuffers 比 ProtoBuffers 更快，并且 GRPC 声明对 FlatBuffers 的开箱即用支持，我们可以在 Akka-Grpc 中使用 flatbuffers，我已经开始工作了在它上面，FlatBuffers 似乎比 ProtoBuffer 提供的工作要多得多，所以我的问题是，是否值得使用 FlatBuffers，是否可以将 FlatBuffers 与 AkkaGrpc 一起使用（因为，它的 JVM 最后仍然不确定）并且有没有孩子项目做同样的事情。

我知道我们有 Filo，但还有其他选择 https://github.com/velvia/filo

我是 Scala 的新手。使用 Akka-grpc 开发我的第一个 scala 应用程序。

我已将我的原型定义如下：

我想验证我的请求参数，因为这里只有电子邮件是强制性的，其余是可选参数。

proto2 具有必需/可选的选项。

因此，使用 proto3 来验证这些参数可能是一个很好且有效的解决方案。

是否可以考虑案例类或将参数映射到 Map()，然后使用循环进行验证？

我有两个服务：一个发送流数据，第二个使用 akka-grpc 接收它进行通信。提供源数据时，调用服务一进行处理，并通过 grpc 客户端将其发送给服务二。当同时提供多个源数据时，服务器 1 的多个实例可能同时运行。在我的应用程序的长时间运行测试中。我在服务一中看到以下错误：

我从来没有关闭演员系统，只是在完成工作后才杀死演员。我也使用proto3andhttp2来请求绑定。这是我在服务中的一段代码：

}

等待服务 2 响应后发生错误：

我无法找到错误的原因。

更新

我发现丢失了一些流，以至于服务一发送一个流无限期地等待响应，而服务二没有收到任何东西来回复服务一但仍然不知道为什么丢失了流我也更新了akka grpc插件但是没有意义：

我是 Akka 的新手，我想通过 Akka gRPC 和集群分片创建一个分布式服务，为客户端提供数据检索服务。

所以有些人RequestActor（我不确定，gRPC 可能根本没有这样的参与者）接收客户端请求，并将其转发给另一个ProcessingActorbyshardRegion以获取查询结果。

对此有两种选择：

• tell图案
  shardRegion ! Request(raw_request, localRequestActor)

• ask图案
  shardRegion ? raw_request pipeTo(localRequestActor)

我的问题是，

1. 由于所有请求都将通过shardRegionactor转发，所以如果我使用该ask模式，shardRegionactor会成为性能瓶颈吗？或者shardRegion只是创建一个内部actor来处理future-promise的东西，一旦请求被转发，shardRegion就不再涉及？

2. 我知道与;ask相比有一些性能/资源影响。tell另一方面，ask提供了超时机制，我们必须自己用tell. 由于这是一个请求-响应交互，在我的情况下哪个是更好的选择？

谢谢！

使用 Akka-gRPC 时如何发送错误。我知道responseObserver.Error何时使用本机 gRPC 接口，但在 Akka-gRPC 中找不到最佳方法。

我试过这样做，但是我不确定这是否是一个好方法，而且它并没有提供使用谷歌的好处。超前误差模型