如何通过grpc双向流连接的客户端进行广播？
模型出错了，请稍后重试~
相关·内容
2回答
可以在gRPC上运行iOS服务器吗？
假设我们希望使用gRPC框架来定义API等等，现在我们希望在同一个进程中部署一个gRPC服务器，应用程序通过InprocessChannel进行连接。
是否有一个用于gRPC的iOS端口允许这样做？
浏览 0提问于2017-11-02得票数 3
我是grpc的第一个学者。我认为这是一个丑陋的问题。 使用grpc-go创建一个简单的聊天应用程序。想要实现的东西是这样的。 @ clientA、clientB、clientC中的每一个都连接到serverA，并且都有双向流连接。例如，您想通知clientA、B、C clientD已经接入serverA，有什么实现方式？ How to broadcast in gRPC from server to client? gRPC: How can I distinguish bi-streaming clients at server side? 我已经读过这些帖子了，但我想知道最佳实践。 例如
浏览 114提问于2019-05-18得票数 2
1回答
我想我理解gRPC中的客户机-服务器结构，但不知道如何使服务器能够在客户机上调用gRPC。我是在两边都实现了Client & Server (同时显示了服务器和存根)，然后有两个单独的通道，还是我错过了一个功能？
浏览 1提问于2021-01-04得票数 0
回答已采纳
我已经创建了一个GRPC服务器- Go中的流式rpc，客户端在Dart中。
通常，在本地运行服务器时，如果客户端在服务器仍在服务流时提前断开连接，则流rpc中的context将被取消，服务器将停止为流服务。
但是在云运行中，这是不一样的，当客户端断开连接时，服务器不会取消context。因此，除非容器达到超时限制，否则不会通知服务器从客户端关闭流。
因此，如果超时设置为1小时，那么即使客户端提前断开连接，服务器也要计费1小时。
云运行是否需要一些特殊的魔法，还是目前不支持？
目前唯一的解决办法是使用较小的超时(~1分钟)，然后在客户端创建重试逻辑。
浏览 9提问于2020-10-14得票数 2
回答已采纳
正如在中所解释的那样，默认流程是客户机连接到服务器并发送请求，服务器对这些请求有充分的响应(很好，希望如此)。
我对在新项目中使用grpc很感兴趣，但是流程必须是反向的。我要客户回答问题。但是它不可能是服务器，因为它会隐藏在防火墙后面，并且可能不会监听端口。
我需要的流程是：
服务器正像往常一样监听
客户端像往常一样连接到服务器
从那时起，服务器提出问题(发送请求)，客户端回答这些问题，而不是像往常那样反过来。
有什么方法可以用grpc来实现吗？它可以涉及服务器端的网络配置，但在客户端是不可能的。
浏览 0提问于2018-04-18得票数 0
7回答
我们希望为我们的gRPC-microservices构建一个Javascript/HTML。由于浏览器端不支持grpc，所以我们考虑使用web套接字连接到node.js服务器，后者通过gRPC调用目标服务。我们很难找到一个优雅的解决方案来做到这一点。特别是，因为我们使用gRPC流在我们的微服务之间推送事件。我们似乎需要第二个RPC系统，只需要在前端和node.js服务器之间进行通信。这似乎是必须维护的大量开销和额外代码。
有没有人有做这种事情的经验，或者知道如何解决这个问题？
浏览 11提问于2016-01-28得票数 82
回答已采纳
1回答
在用grpc编写服务时，我试图通过服务器端推送机制将http/2与websocket进行比较。
我知道对于websocket，客户端将发送一个请求，其中包含升级: WebSocket和Connection:将报头升级到服务器，并建立长期连接。连接建立后，服务器可以自由发送数据。
但是对于grpc来说，由于它是在http/2上从wiki页面路由的，它表示服务器需要预测客户端可能发送的请求，并尽早发送PUSH_PROMISE帧。
以下是我的两个问题：
这是否意味着服务器还需要从客户端接收相应的响应(请求)以响应此PUSH_PROMISE头，以决定客户端是否希望接收或拒绝特定的推送？
在Gr
浏览 10提问于2019-06-24得票数 5
回答已采纳
来自
在gRPC中，客户端应用程序可以像本地对象一样直接调用服务器应用程序上的方法，从而使您更容易创建分布式应用程序和服务。与许多RPC系统一样，gRPC基于定义服务的思想，指定可以使用其参数和返回类型远程调用的方法。在服务器端，服务器实现这个接口，并运行一个gRPC服务器来处理客户端调用。在客户端，客户端有一个存根，它提供与服务器完全相同的方法。
上面一段提到了一个客户机和一个服务器，前者是调用另一个方法的人。我想知道的是:已经在客户端注册的连接调用方法的服务器端可以吗？
浏览 2提问于2015-05-02得票数 21
回答已采纳
我有一个用C++编写的gRPC服务器，它运行在一个服务器上，比如Gabroo
Gabroo:~/grpc/examples/cpp/stream_server$ ./stream_server
DB parsed, loaded 1 features.
Server listening on 0.0.0.0:50051
客户端运行在同一台服务器上，收到消息后退出。
Gabroo:~/grpc/examples/cpp/stream_server$ ./stream_client
DB parsed, loaded 1 features.
-------------- GetFeature --
浏览 0提问于2018-04-30得票数 0
2回答
我正在学习用gRPC实现node.js的东西。我读到gRPC和微服务间的通信是很好的结合。
gRPC在微服务间通信环境中解决不了REST的问题是什么？
为什么要使用gRPC进行微业务间的通信？
浏览 6提问于2021-07-13得票数 1
我正在nodejs中实现一个grpc服务器。grpc很棒。我想知道是否可以从grpc服务器向客户端发送消息(不是请求/响应)？ 我知道我们在全双工的grpc中有双向通信。这意味着这是我们在socket.io(websocket)中拥有的类似功能。我们如何将消息推送到单个客户端？有可能追踪到grpc客户端吗？或者更好的是，得到一个心跳？
浏览 194提问于2021-01-23得票数 0
1回答
是否有任何方法使用Protobuf从服务器到客户端执行调用调用(而自定义调用则从客户机到服务器，而不是直接调用)？
例如，我的意思是用回调param描述*.proto文件中的服务方法？
我在使用gRPC库。
浏览 4提问于2016-02-26得票数 9
回答已采纳
1回答
gRPC是否支持服务器和客户端之间的以下通信方案? 1.客户端连接到服务器并调用waitMessages等方法。那么客户端只是在等待来自服务器的一些消息。2.服务器不定期向客户端发送消息。例如，客户端的某个方法被调用。3.客户端与服务器断开连接
我不喜欢通过轮询服务器来实现这个方案。我想调用一次服务器方法，然后等待消息。
浏览 0提问于2019-10-13得票数 0
我正在学习如何在python中使用grpc流在客户端和服务器之间交换消息。我找到了一个基本示例，它可以在服务器和客户端之间实现简单的消息发送。我正在尝试修改它，这样我就可以跟踪连接到grpc服务器(在服务器端)的所有客户端，并可以做两件事: 1)从服务器向所有客户端广播，2)向特定连接的客户端发送消息。
这是.proto文件
syntax = 'proto3';
service Scenario {
rpc Chat(stream DPong) returns (stream DPong) {}
}
message DPong {
string name =
浏览 10提问于2020-07-31得票数 0
下面是这个例子：
Google Cloud Run中的gRPC
我已经在CloudRun上部署了一个带有反射的gRPC服务。
使用grpcurl进行测试：
grpcurl \
-proto protos/calculator.proto \
-d '{"first_operand": 2.0, "second_operand": 3.0, "operation": "ADD"}' \
${ENDPOINT}:443 \
Calculator.Calculate
GRPC服务器反射协议
现在，我想按照这些说明使用反
浏览 13提问于2021-03-07得票数 2
回答已采纳
1回答
服务器到客户端通信gRpc
、、、、
我在试图找到解决方案时遇到了一些小麻烦，我想知道是否有人能为我指明正确的方向。
我正在实现一个系统，在这个系统中，多个客户端使用gRpc与服务器通信。服务用金写，客户用C写。
我正在努力研究如何最好地处理从服务器到客户端的通信。
到目前为止，我所考虑的方案如下：
在每个客户端 上安装服务器
考虑到可能有多个客户端从一个外部ip运行，我不确定是否有可能创建一个客户端来监听公共ip、本地ip和端口的组合？
使用
这似乎是上述错误的应用程序，您是否需要生成一个新的进程才能打开连接？
与gRpc服务 一起打开websocket
我觉得这不是
浏览 0提问于2017-10-31得票数 3
1回答
我在RPC文档中看到了以下4种类型的grpc：
- rpc SayHello(HelloRequest) returns (HelloResponse) {...}
- rpc LotsOfReplies(HelloRequest) returns (stream HelloResponse) {...}
- rpc LotsOfGreetings(stream HelloRequest) returns (HelloResponse) {...}
- rpc BidiHello(stream HelloRequest) returns (stream HelloResponse) {
浏览 0提问于2019-05-28得票数 2
我正在编写一个简单的聊天应用程序，使用在Go中实现的gRPC服务器。
当用户连接时，调用函数CreateStream。此函数将流保存在连接列表中：
type Server struct {
Connection []*Connection
}
func (s *Server) CreateStream(pconn *proto.Connect, stream proto.Broadcast_CreateStreamServer) error {
conn := &Connection{
stream: stream,
id: p
浏览 4提问于2022-11-17得票数 0
我正在研究如何升级传统的TCP协议，在这种协议中，任何一端都可以启动消息/事务，并且对gRPC作为一种选择感兴趣。
我的标准是：
支持authenticationlayer 7(针对当前implementation)supports TLS的第4层)。
据我目前所读到的，gRPC拥有所有这些。然而，我不清楚它是否具有对等能力。我感兴趣的行为是：
(supported)server客户端可以请求信息并向服务器发送命令，(supported)#1可以主动向客户端发送更新，而#2正在发生
在我看来，为第二个案例定义一个服务器流是可行的。它基本上是一个
// use case 2
rpc Subscr
浏览 3提问于2020-08-13得票数 0
回答已采纳
是否可以使用使两台远程主机之间的所有呼叫都使用在gRPC外部建立的TCP连接？我还想确定这个TCP连接是否可以为多个gRPC调用进行多路复用，这些调用可以是双向的，并且gRPC不会关闭套接字。
其目的是当gRPC的两端跨越防火墙时能够使用gRPC。防火墙只允许建立从防火墙内部发起的单个TCP连接。
对于这些需求，只有C++和Java实现可以在任何一方。
浏览 36提问于2016-09-24得票数 0
我有一个通过golang创建的api，它返回以下结果 {
id : drone4
item_parameter : {
altitude : 20,
longitude : 10.20
latitude : 24.5
} 作为json结果，但在代码中，它使用go例程调用go func()来处理来自grpc-server golang的结果。 像这样 go func() {
fmt.Print("start getPosition loop")
for {
msg, er
浏览 11提问于2019-05-13得票数 3
我正在使用Protobuf和gRPC进行实验，并正在学习Go基础教程：
从关于的文档中可以看出，并发使用相同的ClientConn似乎是安全的。但我不能任何关于一个人创造的存根/客户端。
假设我通过HTTP请求接收数据，我希望通过gRPC作为protobuf转发该数据，然后响应该HTTP。我应该在每次处理HTTP请求时创建一个客户机/存根，还是在设置HTTP服务器时创建客户机/存根，并在设置HTTP处理程序时传递客户机/存根？
例句:我想这样可以。
var opts []grpc.DialOption
conn, err := grpc.Dial("127.0.0.1:1234"
浏览 8提问于2022-07-19得票数 1
回答已采纳
4回答
我现在正在用gRPC创建一个小聊天应用程序，我遇到了这样一个问题:如果用户想要作为客户端连接到gRPC服务器，我想向所有其他连接的客户端广播该事件已经发生。
我正在考虑使用某种观察者，但我不知道服务器如何知道谁是连接的，以及我如何将事件广播到所有客户端，而不仅仅是一两个客户端。
我知道使用streams是答案的一部分，但因为每个客户端都使用服务器创建自己的流，所以我不确定它如何订阅其他服务器-客户端流。
浏览 4提问于2018-03-31得票数 7
我正在我的gRPC客户端上完成一元RPC操作。我想知道尝试用双向流RPC (或其中的一组)替换一元RPC是否有意义？基本上可以持续到应用程序的整个生命周期？我不知道双向流RPC是否用于像这样的标准1请求/1响应通信。其动机是避免创建新的TCP连接。
浏览 0提问于2020-01-11得票数 0
回答已采纳
在http2-spec中，服务器半关闭流(服务器发送http2.END_STREAM)，客户机仍然允许发送数据(因为它是半关闭的)。
考虑以下gRPC场景：
客户端打开bidi流到服务器并开始发送数据。
服务器关闭响应流并发送状态拖车(转换为发送http2.END_STREAM)
客户端继续发送数据
语义在gRPC中定义得很好吗？
可能的方式：
遵循http2-spec:允许客户机继续发送服务器处理的数据。
不遵循http2-spec:如果服务器关闭流，则客户端连接将隐式终止。
注意:我刚刚进行了测试，看起来gRPC for Java遵循了“不遵循http2
浏览 0提问于2019-04-04得票数 0
回答已采纳
1回答
java项目中有一个使用grpc的服务器端流媒体。当服务器和客户端之间的网络中断时，客户端甚至不知道这个问题，流观察者是空闲的，没有活动。我如何才能知道这种断开的情况？
浏览 0提问于2020-10-15得票数 0
1回答
GRPC重新连接并保持连接
、、、、
StreamObserver<RouteSummary> responseObserver = new StreamObserver<RouteSummary>() {
@Override
public void onNext(RouteSummary summary) {
LOGGER.info("Action.");
}
@Override
public void onError(Throwabl
浏览 76提问于2020-09-08得票数 0
我想定期更新发送给所有连接的客户端的数据，通过socket.io连接，socket.io是否有这样的功能或功能？
浏览 3提问于2016-04-17得票数 1
回答已采纳
我通过尝试使网络真正影响实时流而学到了这一点。例如，如果您的流以4096字节的速度传输到0。慢连接将缓冲区和跳过的地方，因为快速连接将缓冲到快速和严重失去同步。大喊/冰播是如何解释这一点的？
浏览 4提问于2016-04-28得票数 1
1回答
akka grpc自定义身份验证
、、、、
我正在使用akka (scala)，并正在寻找一种通过使用自定义挑战响应身份验证来对gRpc调用进行身份验证的方法。即，客户端使用某个密钥/标识调用grpc服务，服务以质询作为响应，客户端使用服务器可以验证的内容进行签名。 我一直在研究grpc拦截器，但这是个好主意吗？服务器中的拦截器是否可以与客户端通信，客户端也需要拦截器来响应质询请求。 谢谢。
浏览 19提问于2019-02-14得票数 2
1回答
有一个gRPC流服务器和客户机。客户端通过gRPC双向流拨号到服务器。服务器运行在一个昆宾女码头上。
在对kubeness服务器进行一次升级之后，当试图向流服务器发送请求时，客户端总是会收到EOF错误。我发现TCP连接是活动的。为什么？
我是否需要在grpc中调用"NewStream“API来重新创建一个新的strean？
func (cc *ClientConn) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error)
如果我在拨
浏览 2提问于2019-10-11得票数 0
1回答
我如何知道我通过gRPC流发送的消息是在另一端接收的？
在gRPC双向流中是否存在这样的构建，或者我是否只需要使用流，然后发送一个响应？
原始文件：
service SimpleService {
rpc SimpleRPC (stream SimpleData) returns (stream SimpleData) {}
}
message SimpleData {
string msg = 1;
}
Go代码：
client := pb.NewSimpleServiceClient(conn)
stream, err := client.SimpleRPC(context.Backgr
浏览 0提问于2019-05-10得票数 3
这个双向流是http2原生的吗？我查看了各种http2客户端。我找不到任何允许客户机和服务器建立单个连接并不断地从双方推送消息的例子。
(对于http2，可能在较低的级别上，客户机/服务器之间的通信只有一个tcp连接，所有请求/响应都在其中多路复用，但从应用程序级别找不到建立单个连接对象的任何示例，并且可以重用该连接对象来将消息推送给对方)。
那么grpc是如何实现“双向流RPC”的呢？特别是在本文档中，它表明服务器端可以定义双向流RPC，它允许客户端和服务器端连续推送消息，并实现类似websocket的特性。
浏览 7提问于2022-03-31得票数 0
1回答
我应该共享gRPC存根还是频道？
、、、、
用于创建通道的gRPC C++ API返回一个shared_ptr。生成的函数NewStub返回一个unique_ptr。然而，我看到尝试创建多个存根类型的实例，共享一个通道。他们的解决办法是共享存根。
从文档或API中还不清楚客户端是要创建多个存根实例，共享通道还是共享单个存根。请澄清存根、通道和独特的客户端连接之间的概念关系。
深入一点:服务器可以提供多个服务，客户机端点可以使用单个通道将相应的存根类型连接到每个服务。为此，显然不同的存根类型共享与服务器端点对话的单一通道。gRPC是否期望一个给定服务的每个通道只有一个客户端，还是在客户端点上可以有多个客户端与单个服务进行对话？如果允许，如
浏览 3提问于2017-10-30得票数 15
回答已采纳
前言：
我以前没有用过gRPC。我只是对这项技术进行了初步的观察，并试图了解我是否可以在我的项目中使用它。我使用的是NetCore2.1的C#，如果它对某些事情很重要的话。
问题：
我有一个服务器和多个客户机，我需要从服务器到客户机执行RPC请求。有gRPC的吗？如果是的话，我怎么能做到呢？
浏览 0提问于2018-11-01得票数 3
回答已采纳
1回答
我正在尝试构建一个异步gRPC C++客户端，它使用ClientAsyncReaderWriter实例向服务器发送流消息，或从服务器接收流消息。客户端和服务器在需要的时候相互发送消息。如何检查是否有来自服务器的消息？
ClientAsyncReaderWriter实例有一个绑定的完成队列。我尝试通过调用Next()和AsyncNext()函数来检查完成队列，以查看是否有任何事件表明有来自服务器的消息。但是，即使有来自服务器的消息，完成队列也没有事件。
class AsyncClient {
public:
AsyncClient(std::shared_ptr<grpc::Cha
浏览 21提问于2019-11-08得票数 1
回答已采纳
1回答
我正在尝试从Java客户端连接到grpc服务。问题是，该服务目前仅支持grpc-web over http1.1，这是因为在部署该服务的Azure App服务中支持http2的限制。来自io.grpc的grpc-java客户机库只支持http2协议上的grpc，maskes sense，不巧的是，它不适合我。
我设法使用来自apache和okhttp3的超文本传输协议客户端使用了一个服务，但这适用于一元调用，而不适用于服务器端流服务。
有没有人知道我可以使用的grpc-web java客户机库，或者使用方便的Http阅读grpc-web服务器端流服务的变通方法。
浏览 5提问于2021-07-30得票数 0
1回答
我正在使用vlcj来流式传输(RTSP)视频。问题是我在路由器后面，dd-wrt只有在有应用程序在监听的情况下才转发和打开端口。但是，我流式传输视频，我不监听正在流式传输的端口...
我怎样才能解决这个问题呢？如果我不使用路由器直接连接，一切正常。
*信息: linksys wrt54gl固件: DD-WRT v24-sp2 (10/10/09)分钟
浏览 4提问于2011-08-10得票数 1
我想在web浏览器中使用grpc双向流。我可以在浏览器中使用带有grpc的双向流吗？
rpc TypingStream (stream OutgoingTyping) returns (stream IncomingTyping);
}
浏览 6提问于2022-07-26得票数 2
回答已采纳
1回答
这些天在opentok上读了很多，只是为了一个广播功能，看到这个‘现场互动广播’有点困惑。
我的问题是，互动广播与普通视频聊天有何不同？
其实混乱的是，在简单的视频聊天中，如果一个客户端连接到一个会话并向它发布一个流，而其他客户机只是连接到一个会话，并且只订阅而不发布它们的流，难道不是与交互广播提议的工作方式相同吗？
浏览 8提问于2020-04-19得票数 0
回答已采纳
我正在使用这个的代码来创建我的GRPC异步服务器：
#include <memory>
#include <iostream>
#include <string>
#include <thread>
#include <grpcpp/grpcpp.h>
#include <grpc/support/log.h>
#ifdef BAZEL_BUILD
#include "examples/protos/helloworld.grpc.pb.h"
#else
#include "helloworld
浏览 13提问于2020-10-10得票数 1
1回答
在“google.golang.org/ grpc /code”中引入了一些错误，一些错误可以由grpc生成，有些不能生成，grpc流应该对应于http2.0中的流。然后，我想知道这是否意味着当那些grpc流抛出异常时TCP连接有错误，所以我只需要重新连接TCP连接，还是我有一些只用于重新连接流的方法(例如重新连接流，等等)。
for {
request, err3 := stream.Recv()
if err3 == io.EOF {
return nil
}
if err3 != nil {
浏览 3提问于2022-07-28得票数 0
回答已采纳
我读了gRPC ，但它没有深入到我喜欢看到的深度。有、、gRPC连接(本文中没有描述)和HTTP/2连接(本文没有描述)。
我想知道这些是如何结合在一起的。例如，当RPC抛出异常时，通道会发生什么情况？当通道关闭时，gRPC连接会发生什么情况？频道什么时候关闭？何时关闭gRPC连接？心跳？如果超过最后期限怎么办？
有人能回答这些问题吗，或者告诉我哪些资源可以解决？
浏览 4提问于2020-09-04得票数 14
回答已采纳
我在go中有一个使用gRPC的服务器，在react客户端上，我正在使用grpc web和grpcwebproxy，我一直试图将我的客户端连接到服务器上，但总是得到错误代码2，并显示消息: Response closed with headers。还有没有人遇到过这个问题？我现在使用的是grpc-web的improbable eng实现。
浏览 0提问于2019-05-29得票数 3
I0804 13:52:46.505722 0 C:\jenkins\workspace\gRPC_build_artifacts\platform\windows\workspace_csharp_ext_windows_x86\src\core\lib\surface\call.c:1802: grpc_call_start_batch(call=05BEFFD8, ops=05EFED58, nops=6, tag=05BC64E0, reserved=00000000) I0804 13:52:46.505722 0 C:\jenkins\workspace\gRPC_build_ar
浏览 1提问于2017-08-04得票数 0
回答已采纳
我在DigitalOcean中有Kubernetes集群，里面有一个带有gRPC服务器的吊舱。我的本地机器上有gGRP客户端。我的当事人写成了“去”。
目标是将gRPC客户端从我的本地机器连接到DO k8s集群中的gRPC服务器.
我阅读了这个指南：，并试图连接到这种uri：http://kubernetes_master_address/api/v1/namespaces/namespace_name/services/[https:]service_name[:port_name]/proxy类型。
下面是我的客户端代码的一部分：
conn, err := grpc.Dial(addr,
浏览 4提问于2020-07-11得票数 2
2回答
我正在尝试创建一个grpc python服务器，它可以跟踪所有连接的客户端。
我指的是雷·曾荫权做的一个演讲/演示，他保存了一个StreamObservers集合，并通过迭代将它们发送给所有客户端。下面是一个供参考的。
现在我的问题是如何在python中获得StreamObserver？在定义中，我只看到了self、request和context。
这是我的第一个python项目，所以这里可能会遗漏一些明显的东西。
这是我的原型，它基本上是样本原型
syntax = "proto3";
package hellostreamingworld;
// The greeting
浏览 0提问于2018-07-18得票数 1
2回答
我想创建一个简单的gRPC端点，用户可以上传他/她的照片。协议缓冲区声明如下：
message UploadImageRequest {
AuthToken auth = 1;
// An enum with either JPG or PNG
FileType image_format = 2;
// Image file as bytes
bytes image = 3;
}
不管gRPC文档中的警告如何，这种上传图片(和接收图片)的方法仍然可以吗？
如果不是，更好的方法(标准)是使用标准表单上传图片并存储图像文件位置吗？
浏览 1提问于2016-01-24得票数 25
回答已采纳
今天下午运行的实例很好，但是突然这个错误开始弹出。它假定调用函数并成功地写入分类账，但拒绝这样做：
Too many requests for /protos.Deliver, exceeding concurrency limit (2500)
peer0.org1.xxx.com-hold-em_1-c068ec292dc2ab380801d4f31ca83c6b86104d5adf00d7ee78b940a7a7381c02] func2 -> INFO 1402c 2020-06-16T05:43:20.627Z info [c-api:lib/handler.js]
浏览 4提问于2020-06-16得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
