- c - 在位数组中找到第一个零
- linux - Unix 显示有关匹配两种模式之一的文件的信息
- 正则表达式替换多个文件
- linux - 隐藏来自 xtrace 的命令
用于创建 channel 的 gRPC C++ API 返回一个 shared_ptr。生成的函数 NewStub 返回一个 unique_ptr。但是我见过reports of people having issues试图创建一个 stub 类型的多个实例,共享一个 channel 。他们的解决方案是共享 stub 。
从文档或 API 中不清楚客户端是要创建共享 channel 的多个 stub 实例还是共享单个 stub 。请阐明 stub 、 channel 和唯一客户端连接之间的概念关系。
再深入一点:服务器可以提供多个服务,而客户端端点可以使用单个 channel 将相应的 stub 类型连接到这些服务中的每一个。为此,很明显不同的 stub 类型共享同一个 channel 来与服务器端点对话。对于给定服务,gRPC 是否期望每个 channel 只有一个客户端,或者我可以在客户端端点上让多个客户端与单个服务通信吗?如果允许,我如何为客户端端点上的给定服务实现多个客户端?服务器如何区分这些独立的客户端?
顺便说一句,This SO post表示 Channels 和 Stubs 都是线程安全的。 (该帖子专门针对 Java,但我假设它适用于 C++)。
最佳答案
我认为首先我们需要根据 official documents 澄清 channel 和 stub 的定义:
channel :
A gRPC channel provides a connection to a gRPC server on a specified host and port...
结论:一个 channel 代表一个 TCP 连接。
stub :
On the client side, the client has a local object known as stub (for some languages, the preferred term is client) that implements the same methods as the service.
结论: stub 代表单个客户端。
通过阅读许多其他资料,我确信单个 channel (tcp 连接)可以被多路复用,现在我们有两种选择来实现它:
一个 channel <-->一个 stub
一个 stub <-->多个流
一个 channel <-->多个 stub
一个 stub <-->多个流
唯一的区别是是否在 stub 之间共享一个 channel 。我的回答是:是的,你可以,原因是:
你的 reports of people having issues示例是用 ruby 编写的,但我也可以找到 python examples站在对面。所以行为可能取决于语言实现。
同步 cpp 客户端示例使用一个 stub 对象来发出一个 rpc,并且它没有任何关联的流对象,那么实现多路复用目的的唯一方法就是共享一个 channel 对象 stub 。
结合以上两个原因,我得出结论:在 C++ 中, stub 之间共享一个 channel 是有效的。
现在,回到你的问题:
Does gRPC expect only one client per channel for a given service or can I have multiple clients on the client endpoint talking to a single service?
当然,您可以让多个客户端与一个服务通信。
If allowed, how do I achieve multiple clients for a given service on a client endpoint?
您可以只从一个 channel 或多个 channel 生成多个 stub ,考虑到连接开销,前者是更好的选择。
How does the server distinguish these as independent clients?
这是由于http2,它可以多路复用,并且有自己的规则来实现这一点,grpc需要做的就是遵循这些规则。
希望这对您有所帮助!
关于c++ - 我应该共享 gRPC stub 还是 channel ?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47022097/
我很好奇为什么以下不起作用。一般select用default:防止死锁,但在这种情况下不是: package main import "fmt" func main () { a := mak
我一生都无法弄清楚如何切换图像排序。图像以 (x,x,3) 格式读取,theano 要求它是 (3,x,x) 格式。我尝试更改顺序numpy.array([img[:,:,i] for i in ra
我正在向 libnl 发送单个 SSID 和频率进行扫描,但我得到了多个扫描结果以及我请求的 SSID 和频率,但我需要单个扫描结果(仅适用于请求的 SSID),如何实现这一点。请帮助我,我也发送了我
我是 Golang 的新手,但正在努力理解这门伟大的语言!请帮帮我.. 我有 2 个 channel 。 “进”和“出” channel in, out := make(chan Work),
例如我有这段代码: package main import ( "fmt" ) func main() { c1 := make(chan interface{}) close
我们使用以下调用来获取经过身份验证的用户的 ChannelID,它适用于大多数情况。一些 YouTube 用户将他们的 channel 连接到 Google+ 信息页,但在这种情况下,我们的一位用户无
case 'sinfo': const sinfo = new Discord.MessageEmbed() .addField('Server Name 🔎 :', message.guild.n
我需要让所有 channel 来创建一个 bunker 命令,这使得所有 channel 都是只读的。 最佳答案 他们变了Client.servers至 Client.guilds在 newer ve
为什么当第二个值通过另一个 go routine 发送并且没有收到发送的第一个值时, channel c 没有缓冲? package main import "fmt" func sum(s []in
据我所知,内置的 split 会将一个 3 channel Mat 拆分为三个 1 channel Mat。结果,这三个 Mat 只是具有一些不同强度的灰度。 我的意图是获得三个 3 channel
如何检测当前的 RAM 配置?我需要询问 Windows RAM 当前是在单 channel 、双 channel 还是四 channel 中运行。 我搜索了很多,并没有在这个网站或其他网站上找到任何
我需要拆分一个多 channel wav 文件并将每个 channel 编码为 mp3 文件。 我知道 gtresamer 的 deinterleave 插件,但我不确定如何将它用于 wav 文件以及
关闭。这个问题需要details or clarity .它目前不接受答案。 想要改进这个问题吗? 通过 editing this post 添加详细信息并澄清问题. 关闭 8 年前。 Improve
我正在尝试运行 Hyperledger Fabric 网络,它由单个订购者、单个对等节点和一个 cli 组成。为了学习启动 Hyperledger Fabric 网络的过程,从创建与加密相关的工件到将
我在 Laravel 中使用事件广播。我正在使用基于角色的通知访问权限。我有用于广播的自定义 auth guard。当用户连接到 channel 时,客户端将具有内部权限的 access_token
我正在编写一个使用 Elixir Channels 来处理实时事件的应用程序。我知道每个客户端将打开 1 个套接字,并且可以在其上多路复用多个 channel 。所以我的应用程序是一个聊天应用程序,其
我有一些 .wav 文件,我想转换它们的频率 (fs) 和 channel 数 (nchannels)。我在jupyter笔记本python3.6上使用ffmpeg。我使用了以下命令并且它有效。 cm
我有一个视频渲染器,它需要两个 H265 流(YUV420),我需要烘焙它们以使它们中的一个与另一个形成 alpha 蒙版。这一切都已解决并且效果很好,但是如果我按照此处的说明进行操作: ffmpeg
我运行此命令以便能够将 udp 直播流传输到可使用正在构建的移动应用程序播放的 http 直播流。 它只是一个只有音频流的流。 ffmpeg -i udp://@localhost:1111 -map
我在我的 discord.js 机器人中创建了 nuke 命令,它创建了具有相同名称、权限、主题等的 channel ,并删除了“原始” channel 。但是有一个问题,如何使 channel 与“
我是一名优秀的程序员,十分优秀!