1封邮件的gRPC服务器流
gRPC是一种高性能、开源的远程过程调用（RPC）框架，它可以用于构建分布式系统。在云计算领域，gRPC被广泛应用于构建可靠、高效的服务通信。
1封邮件的gRPC服务器流是指在gRPC通信中，服务器端向客户端发送多个邮件的过程。具体来说，服务器端可以通过gRPC的服务器流模式，将多个邮件逐个发送给客户端。
优势：
- 高性能：gRPC使用基于HTTP/2的协议进行通信，可以复用TCP连接，减少网络开销，提高性能。
- 跨语言支持：gRPC支持多种编程语言，如C++, Java, Python等，使得不同语言的服务可以相互通信。
- 强大的IDL（接口定义语言）：gRPC使用Protocol Buffers作为IDL，可以定义服务接口和消息结构，提供了强类型检查和自动代码生成的功能。
- 支持多种通信模式：除了服务器流模式，gRPC还支持客户端流、双向流和简单的请求-响应模式，可以根据实际需求选择合适的通信模式。
应用场景：
- 邮件服务：可以使用gRPC的服务器流模式，将服务器端的多封邮件逐个发送给客户端，实现高效的邮件传输。
- 即时通讯：gRPC可以用于构建实时通讯系统，通过服务器流模式实现服务器端向客户端推送消息的功能。
- 数据同步：在分布式系统中，可以使用gRPC的服务器流模式将数据从服务器端同步到客户端，保持数据的一致性。
推荐的腾讯云相关产品： 腾讯云提供了一系列与gRPC相关的产品和服务，可以帮助用户快速构建和部署gRPC应用。
- 云服务器（CVM）：腾讯云提供高性能、可扩展的云服务器，可以作为gRPC服务器端的部署环境。 产品链接：https://cloud.tencent.com/product/cvm
- 云原生容器服务（TKE）：腾讯云提供基于Kubernetes的容器服务，可以方便地部署和管理gRPC应用。 产品链接：https://cloud.tencent.com/product/tke
- 云数据库MySQL版（TencentDB for MySQL）：腾讯云提供高可用、可扩展的云数据库服务，可以作为gRPC应用的后端存储。 产品链接：https://cloud.tencent.com/product/cdb_mysql
- 云函数（SCF）：腾讯云提供无服务器的函数计算服务，可以用于处理gRPC请求和逻辑。 产品链接：https://cloud.tencent.com/product/scf
请注意，以上推荐的产品仅作为参考，具体选择应根据实际需求和情况进行。
相关·内容
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
2回答
可以在gRPC上运行iOS服务器吗？
假设我们希望使用gRPC框架来定义API等等，现在我们希望在同一个进程中部署一个gRPC服务器，应用程序通过InprocessChannel进行连接。
是否有一个用于gRPC的iOS端口允许这样做？
浏览 0提问于2017-11-02得票数 3
关于zio-grpc双流关闭调用的咨询:何时关闭？我正在使用grpcurl来测试bistream，但是zio-grpc服务器端不会太快地关闭(过一段时间就会关闭)。
我正在通过Stream.ensuring观看grpc服务器端流关闭事件。详情如下：
请求流的：通过forkDomaen在光纤中使用请求流:我假设如果流关闭，grpc请求流将被关闭。
request
.mapM { reqItem =>
// do action here
UIO(println(s"test get some data from request item: ${
浏览 13提问于2022-10-17得票数 0
回答已采纳
1回答
通过Python服务器无法工作
、、、、
我已经通过gRPC开发了Python服务器，然后将它构建到容器中并部署到云中运行，
我的gRPC服务器正在与TensorFlow应用程序集成。实际上，tensorflow用于图像ML，但这是一个示例代码。
class Calculator(calculator_pb2_grpc.CalculatorServiecer):
def Calculate(self, request, context):
try:
# Processing
return #protobuf message
except
浏览 2提问于2020-08-25得票数 3
我有一个grpc客户端应用程序，它可能会经常阻塞，这会导致它在一段时间内无法调用grpc Recv函数。在这种情况下，grpc服务器上的行为是什么？grpc服务器的Send调用会阻塞吗？在客户端调用Recv之前它会阻塞吗？
浏览 0提问于2020-04-30得票数 0
Grpc.Core 2.38.0
我有一组应用程序参与使用grpc流进行进程间通信。我们不时地注意到服务器进程中的锁定和内存耗尽(由于锁)无法完成对IAsyncStreamWriter.WriteAsync(...)的调用
最近对grpc (.net)的更改已经将WriteAsync API更改为接受CancellationToken，但是在Grpc.Core包中不能使用。
浏览 8提问于2022-06-17得票数 0
1回答
请忽略这个问题。我的设置错误，导致gRPC性能不佳。
比较GRPC和项目反应堆可以吗？
我只想比较一下REST和GRPC的性能。我看不出GRPC比反应堆更快。事实上，情况更糟。
GRPC设置：
api-server --> grpc-server
这个grpc服务器对来自api-server.The api-server的每个请求使用服务器端流响应1000“”返回Flux<String>。
WebFlux安装程序：
api-server --> rest-server
此rest服务器响应1000 "Hello“，因为来自api-server.The api-
浏览 3提问于2020-06-21得票数 1
回答已采纳
我有一个gRPC服务器，其主要内容如下：
syntax = "proto3";
service MyServicer {
rpc DoSomething(stream InputBigData) returns (stream OutputBigData) {}
}
message InputBigData {
bytes data = 1;
}
message OutputBigData {
bytes data = 1;
}
我的服务器是用以下Python代码创建的：
server = grpc.server(futures.ThreadPoolExe
浏览 2提问于2020-09-24得票数 1
我有一个用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
1回答
当我查看服务器调用的grpc自动生成类和grpc中给出的示例示例时，我可以看到我们扩展了ImplBase类并覆盖了服务方法。如下所示：
static class communicationImpl extends communicationImplBase
在C++中，为了实现异步服务，我们使用AsyncService而不是服务类扩展我们的实现。但是在java生成的Grpc类中，我看不到另一个名为/以异步开头的类。我在其中看到的唯一与服务器相关的类是以ImplBase结尾的类。那么，如何设置服务器，以便在grpc中异步处理请求？
浏览 0提问于2017-03-24得票数 3
回答已采纳
1回答
在用grpc编写服务时，我试图通过服务器端推送机制将http/2与websocket进行比较。
我知道对于websocket，客户端将发送一个请求，其中包含升级: WebSocket和Connection:将报头升级到服务器，并建立长期连接。连接建立后，服务器可以自由发送数据。
但是对于grpc来说，由于它是在http/2上从wiki页面路由的，它表示服务器需要预测客户端可能发送的请求，并尽早发送PUSH_PROMISE帧。
以下是我的两个问题：
这是否意味着服务器还需要从客户端接收相应的响应(请求)以响应此PUSH_PROMISE头，以决定客户端是否希望接收或拒绝特定的推送？
在Gr
浏览 10提问于2019-06-24得票数 5
回答已采纳
我在.NET中使用GRPC创建了一个简单的容器来上传文件，容器在我的本地机器上工作得很好，并且远程地由Nginx服务器代理。在部署容器时，我可以顺利地将文件流到服务器。然而，当我等待答复时：
var response = await stream.ResponseAsync;
我得到以下例外：
异常: HTTP/2服务器重置流。HTTP/2错误代码'INTERNAL_ERROR‘(0x2)."，DebugException="System.IO.IOException:请求被中止。-> System.Net.Http.Http2StreamException: H
浏览 5提问于2021-10-16得票数 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回答
我正在尝试构建一个异步gRPC C++客户端，它使用ClientAsyncReaderWriter实例向服务器发送流消息，或从服务器接收流消息。客户端和服务器在需要的时候相互发送消息。如何检查是否有来自服务器的消息？
ClientAsyncReaderWriter实例有一个绑定的完成队列。我尝试通过调用Next()和AsyncNext()函数来检查完成队列，以查看是否有任何事件表明有来自服务器的消息。但是，即使有来自服务器的消息，完成队列也没有事件。
class AsyncClient {
public:
AsyncClient(std::shared_ptr<grpc::Cha
浏览 21提问于2019-11-08得票数 1
回答已采纳
我正在nodejs中实现一个grpc服务器。grpc很棒。我想知道是否可以从grpc服务器向客户端发送消息(不是请求/响应)？ 我知道我们在全双工的grpc中有双向通信。这意味着这是我们在socket.io(websocket)中拥有的类似功能。我们如何将消息推送到单个客户端？有可能追踪到grpc客户端吗？或者更好的是，得到一个心跳？
浏览 194提问于2021-01-23得票数 0
1回答
我正在做一个项目，在那里我想公开一个API，它将读取一个大文件，发送响应。
由于文件的大小可以很大，所以最好是以块的形式发送文件，这样就不会给系统带来太大的内存压力。
我评估了两个选项:HTTP1.1支持的块传输()和grpc支持的服务器端流。
在grpc方法中，客户端通过rpc请求，而服务器将在grpc通道上流字节，并在完成后关闭相同的字节。
我的生态系统可以同时支持两者，客户端也支持grpc。
你能不能建议哪种选择更好，这两种方法的利弊是什么？
浏览 11提问于2022-02-10得票数 1
我的项目(在golang中)有一个用例，在这个用例中，我需要打开从单个GRPC客户端到单个/多个GRPC服务器的几个流。
说我的原始文件是-
syntax = "proto3";
package helloworld;
// The greeting service definition.
service Greeter {
// Sends a greeting
rpc SayHello (stream HelloRequest) returns (stream HelloReply) {}
}
// The request message containing
浏览 1提问于2021-06-21得票数 1
1回答
我想我理解gRPC中的客户机-服务器结构，但不知道如何使服务器能够在客户机上调用gRPC。我是在两边都实现了Client & Server (同时显示了服务器和存根)，然后有两个单独的通道，还是我错过了一个功能？
浏览 1提问于2021-01-04得票数 0
回答已采纳
我是Django框架的初学者。我编写了一个由两个微服务组成的应用程序。一个作为Django Rest服务器，另一个作为Django GRPC服务器。rest请求在第一服务器中转换为GRPC请求，并发送给第二服务器用于该进程。
------>|-----------|------->|-----------|
|rest server| |grpc server|
| | | |
<------|-----------|<----
浏览 4提问于2021-07-14得票数 0
1回答
grpc低层遥测测井
、、、、
我试图在较低的级别上度量我的服务的延迟。环顾四周，我发现可以向grpc构建器添加一个addStreamTracerFactory。
我完成了这样一个简单的实现，并打印了日志：
val server = io.grpc.netty.NettyServerBuilder.forPort(ApplicationConfig.Service.bindPort).addStreamTracerFactory(ServerStreamTracerFactory)....
class Telemetry(fullMethodName: String, headers: Metadata) extends
浏览 1提问于2019-04-03得票数 0
回答已采纳
我正在使用GRPC连接到一个服务。有时调用是成功的，有时是异常的Received unexpected EOS on DATA frame from server.失败。
我找不到原因。以下是打电话的代码：
public class LmServiceClientImpl implements LmServiceClient {
LMAttributeServiceGatewayGrpc.LMAttributeServiceGatewayBlockingStub lmAttributeServiceGatewayBlockingStub;
@Autowired
@Q
浏览 5提问于2020-05-12得票数 2
1回答
我有一个一元拦截器，它包含以下代码：
func (m Middlewares) LocationInterceptor(c context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {
ctx := c.(HarmonyContext)
location, ok := req.(interface{ GetLocation() *corev1.Location })
if !ok {
panic
浏览 1提问于2020-08-17得票数 3
我使用的是“流式RPC”API，其中MyRequests和MyResponse都是流的。
service MyStreamedService {
rpc myOperation(**stream** MyRequest) returns (**stream** MyResponse)
}
下面是包装gRPC流的类的稍微简化的版本；
public class MyStreamWrapper implements StreamObserver<MyResponse> {
public MyStreamWrapper(ManagedChannel myChannel) {
浏览 2提问于2021-09-16得票数 1
回答已采纳
2回答
gRPC的Go库提供了创建您自己的自定义拦截器(即中间件函数)的接口，我正在尝试编写两个日志拦截器。第一个是Unary Server Interceptor，我可以使用传入拦截器函数的对象轻松地记录请求参数。
func loggingUnary(context context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {
start := time.Now()
resp, err := handler(context,
浏览 1提问于2018-06-26得票数 4
1回答
@Override
public void response(RequestApp request, Grpc.Stub asyncStub) {
StreamObserver<Dto> streamObserver = new StreamObserver<Dto>() {
@Override
public void onNext(Response response) {
LOGGER.info("Response is received.
浏览 82提问于2020-10-07得票数 0
1回答
我正在运行一个Php应用程序(客户端)，它通过Grpc/Protobuf与锈蚀应用程序(服务器)通信。我看到这些电话的每小时都有持续的高峰。
通常，grpc调用将在2-4毫秒左右。但每小时的峰值从30毫秒到1.5秒不等。
我想知道这个尖峰的原因是什么，以及避免这些尖峰的任何可能方法。
原版- 3.15.5
grpc版本- 1.36.0
浏览 2提问于2021-06-11得票数 0
我在go中有一个使用gRPC的服务器，在react客户端上，我正在使用grpc web和grpcwebproxy，我一直试图将我的客户端连接到服务器上，但总是得到错误代码2，并显示消息: Response closed with headers。还有没有人遇到过这个问题？我现在使用的是grpc-web的improbable eng实现。
浏览 0提问于2019-05-29得票数 3
我的grpc服务器流函数有一个有趣的错误，我正在撕裂我的头发。通过阅读grpc godoc或在线其他地方，无法找到任何可能的原因。希望更熟悉Go和grpc流的人能够为我指明正确的方向。 我的实现尝试遵循grpc.io网站上的基本服务器流示例。 存在问题的protobuf定义： service ArrayBasedCache {
...
rpc GetRecord (GetRecordRequest) returns (stream MessageResponse) {}
}
message GetRecordRequest {
string key = 1;
}
messag
浏览 158提问于2020-10-26得票数 2
回答已采纳
我正在通过gRPC cpp示例来尝试学习。在调试流示例时，我注意到服务器上对grpc_impl::ServerReaderWriter::Read的调用会一直阻塞，直到另一端写入或流结束。 我们应该如何使服务器足够健壮，使其能够处理客户端在发送初始消息后挂起或忘记关闭流？ 也许它会调用RPC并向我发送三条消息，但永远不会关闭。似乎不存在此调用的超时版本。 在这种情况下，不是所有客户端的整个通信线程都被阻塞了吗？
浏览 121提问于2020-10-21得票数 0
回答已采纳
一个简单的grpc服务器客户端，客户端发送一个int和服务器流int的返回。
客户端正在逐个读取消息，但是服务器正在为所有响应立即运行生成器函数。
服务器代码：
import test_pb2_grpc as pb_grpc
import test_pb2 as pb2
import time
import grpc
from concurrent import futures
class test_servcie(pb_grpc.TestServicer):
def Produce(self, request, context):
for i in range(r
浏览 2提问于2017-10-31得票数 3
回答已采纳
来自
在gRPC中，客户端应用程序可以像本地对象一样直接调用服务器应用程序上的方法，从而使您更容易创建分布式应用程序和服务。与许多RPC系统一样，gRPC基于定义服务的思想，指定可以使用其参数和返回类型远程调用的方法。在服务器端，服务器实现这个接口，并运行一个gRPC服务器来处理客户端调用。在客户端，客户端有一个存根，它提供与服务器完全相同的方法。
上面一段提到了一个客户机和一个服务器，前者是调用另一个方法的人。我想知道的是:已经在客户端注册的连接调用方法的服务器端可以吗？
浏览 2提问于2015-05-02得票数 21
回答已采纳
4回答
我有两个网络服务-- gRPC客户端和gRPC服务器。服务器是用.NET Core，编写的。然而，客户端是一个.NET框架4.7.2Web应用程序，托管在IIS8.5，上。
由于升级客户端需要一段时间，所以我一直在考虑是否可以在服务器端使用HTTP/1.1而不是HTTP/2，但我无法找到如何实现这一目标的任何信息。
是否可以将HTTP1.1用于用.NET核心编写的gRPC服务器？如果是的话-怎么做？
浏览 5提问于2020-01-16得票数 14
回答已采纳
我正在使用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
回答已采纳
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
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
回答已采纳
1回答
我正在尝试构建一个系统，该系统由一个主服务器和至少两个gRPC服务(使用HTTP.Sys托管)组成，这些服务既可以是到主服务器的客户端，也可以接受来自主服务器(以下称为“Worker”)的连接。系统的每一个元素都在一个本地网络中。工作人员一旦启动连接到主服务器，主服务器就应该在池中添加连接，在池中可以访问客户机工作人员进行gRPC调用。我期望它在下面工作的例子
public class MainServer : MainServer.MainServerGrpcBase
{
public List<GrpcChannel> ChannelPool { get; set; }
浏览 3提问于2020-04-23得票数 0
7回答
我们希望为我们的gRPC-microservices构建一个Javascript/HTML。由于浏览器端不支持grpc，所以我们考虑使用web套接字连接到node.js服务器，后者通过gRPC调用目标服务。我们很难找到一个优雅的解决方案来做到这一点。特别是，因为我们使用gRPC流在我们的微服务之间推送事件。我们似乎需要第二个RPC系统，只需要在前端和node.js服务器之间进行通信。这似乎是必须维护的大量开销和额外代码。
有没有人有做这种事情的经验，或者知道如何解决这个问题？
浏览 11提问于2016-01-28得票数 82
回答已采纳
我有一个用Go编写的grpc服务器，运行良好。rpc：Send (stream FromClientMessage) returns (stream FromServerMessage)
当我使用Unity3d客户端时，我可以发送一个消息：
_requestStream.WriteAsync(new FromClientMessage {});
它工作正常-服务器接收它。现在服务器发送一条消息。
为了在Unity中接收它，我使用了教程中的示例代码：
Task.Run(async() =>
{
var stream = _client.Send().ResponseStream;
浏览 7提问于2022-01-21得票数 0
在gRPC实现中，在同一进程中从具有本地连接的gRPC服务发送对象时是否序列化对象？
假设我们有一个包含A和B类的java进程，如果A类使用gRPC客户端向B类支持的gRPC服务器发送数据，那么客户机和服务器是否共享一个Java对象引用，或者数据是通过已建立的本地Netty连接序列化和发送的？
浏览 0提问于2021-06-17得票数 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
回答已采纳
前言：
我以前没有用过gRPC。我只是对这项技术进行了初步的观察，并试图了解我是否可以在我的项目中使用它。我使用的是NetCore2.1的C#，如果它对某些事情很重要的话。
问题：
我有一个服务器和多个客户机，我需要从服务器到客户机执行RPC请求。有gRPC的吗？如果是的话，我怎么能做到呢？
浏览 0提问于2018-11-01得票数 3
回答已采纳
1回答
我的messages.proto文件中有以下模式：
message Person {
string id = 1;
string first_name = 2;
string last_name = 3;
string email = 4;
string alias = 5;
}
//CREATE, DELETE, UPDATE RESPONSES AND REQUESTS Messages
message ListPersonsRequest {
ListOptions options = 1;
}
message ListPersonsResponse {
浏览 12提问于2022-11-04得票数 1
回答已采纳
1回答
我们使用流式RPC将大文件发送到GRPC服务器。如下所示：
service FileReceiver
{
rpc addData(stream DataChunk) returns (Empty)
}
在这种情况下，是否可以使用代理负载均衡器，这样负载均衡器就不会在流请求中切换服务器？随着客户数量的增加，它的规模会扩大吗？
浏览 5提问于2017-07-13得票数 2
回答已采纳
2回答
将服务重定向到双向grpc
、、、、
我目前正在开发一个grpc服务器，它将接收来自第一个服务器的流grpc调用，并将这些调用重定向到第二个服务器，并将响应从第二个服务器重定向到第一个服务器。
我有两个proto文件
第一个文件：
syntax = "proto3";
package first.proto.pack;
service FirstProtoService {
rpc StreamingCall(stream RequestToFirstServer) returns (stream ResponseForFirstServer){}
}
message RequestToFirstServ
浏览 10提问于2021-10-06得票数 2
回答已采纳
3回答
我必须向gRPC服务器发送一个消息流，但我还必须发送大量关于该流的元数据。有没有办法定义元数据消息并使其成为客户端和服务器之间接口协定的一部分？据我所知，将另一条消息封送到元数据中看起来完全超出了我的.proto文件中的接口定义。 真的，我喜欢gRPC允许流式调用有两个参数，比如： service DataServer {
rpc AddData(DataScope, stream MyData) returns (Reply) {}
} 有没有一种正确的，或者至少是一种普遍接受的方法来解决这个问题？
浏览 36提问于2020-07-08得票数 1
回答已采纳
我有python服务器，它有grpc服务和grpc网关。在python服务器端，它使用yield发送分块数据。我可以看到使用wireshark逐个发送数据。 我在UI端使用了angular框架。当请求发出时，我立即得到响应200，一段时间后，我收到了整个数据。 但是在浏览器中，一旦接收到完整的数据，我就会得到http调用的响应。即使当我尝试使用REST客户端时，响应也在一起，它不像流一样来。 看起来浏览器只有在接收到所有数据后才会进行处理。 有没有什么我遗漏的头文件导致了这个问题？ 如何解决这个问题？
浏览 20提问于2021-10-22得票数 1
1回答
如何用HTTP/2实现gRPC客户端流/双向流？
服务器流是有意义的，因为它可以利用服务器推送来向请求发送多个响应，但我不清楚它是如何通过HTTP/2进行双向消息传递的，就像在websocket上那样。
浏览 1提问于2018-11-09得票数 2
gRPC支持多种语言的rpc服务器和客户端实现。我想知道在goLang v/s Java中实现gRPC服务器和客户端是否有显著的性能差异。如果我们正在寻找高性能和可伸缩性，那么go和java哪个实现更好呢？ 谢谢Girish T S
浏览 31提问于2019-09-16得票数 0
我正在编写一个通过GRPC发送和接收消息的Spigot插件。我的问题是，在查看时间过后，服务器崩溃，因为进程无法为新线程打开更多的文件处理程序。从一些线程转储来看，GRPC似乎是在每秒产生多个线程，而不是关闭它们。im用来接收消息流的代码如下所示： public class GRPCMessageReceiver extends BukkitRunnable {
ChatSyncGrpc.ChatSyncBlockingStub chatSync;
LockedQueue lockedQueue = new LockedQueue();
Iterator<ChatMessage>
浏览 101提问于2020-10-30得票数 0
回答已采纳
1回答
当您在GRPC中对流响应执行onNext()时，它会将其排队以进行传输，这将分配给直接缓冲区内存，而不是堆，因为这样的java.lang.OutOfMemoryError: Direct buffer memory不会生成有用的堆转储。这可以通过创建
message Chunk {
bytes data = 1
}
而会导致这个触发。正确的解决方法是确保服务器不会做任何愚蠢的事情，比如发送许多小块，但这仍然可能是可能关闭服务的DoS攻击的矢量。
我的问题是在GRPC中，是否在服务器端设置了限制数量并进一步阻塞onNext，直到队列减少，并在传输时间过长时取消操作的超时？这样，它就不会关闭服
浏览 6提问于2022-02-05得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
