java - 如何向 grpc 方法添加监听器?

标签 java grpc rpc grpc-java

我需要将传入的请求推送到 kafka 主题的 grpc 方法。我正在考虑为该方法添加所有事件的监听器,以便监听器将完成推送到 kafka 的工作,而我的方法可以继续其处理。

有没有办法向 grpc 方法添加监听器?

最佳答案

我假设您的监听器将是一小段代码(或函数调用),用于将事件推送到 Kafka,您可以在“一元调用”方法或流式调用方法中插入这段代码。所以我认为这与 gRPC 无关,除非我遗漏了一些东西。看看https://github.com/grpc/grpc-java/blob/master/examples下对于一元调用和流调用示例。

关于java - 如何向 grpc 方法添加监听器?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/61211084/

相关文章:

c# - C#中的gRPC客户端不适用于具有mTLS支持的Go中的gRPC服务器

angular - 具有 Angular 6 的 GRPC Web 客户端

GWT RPC 数据格式

sockets - Socket 和 RPC 有什么区别?

rpc - RPC流式传输的含义和场景?

java - 如何在 Android 中使用 RecyclerView?

java - 如何有效地 ping 并发现网络上的所有客户端?

Java Servlet SQL 表

java - Android Webview 应用程序上下文

go - 处理上下文取消错误