草庐IT

RPC和GRPC

全部标签

go - 如何在 Go 中断言客户端的 gRPC 错误代码

给定以下gRPC服务器端代码:import("google.golang.org/grpc/codes""google.golang.org/grpc/status"....)....func(s*Router)Assign(ctxcontext.Context,req*api.Request(*api.Response,error){returnnil,status.Errorf(codes.PermissionDenied,}....断言客户端错误是code=codes.PermissionDenied的推荐技术是什么? 最佳答案

go - RPC有超时机制吗?

如果RPC没有超时机制,如果它试图调用已关闭的服务器的RPC方法,我该如何“终止”RPC调用? 最佳答案 您可以使用channels实现超时模式:import"time"c:=make(chanerror,1)gofunc(){cselect将阻塞,直到client.Call返回或timeoutNanoseconds过去。 关于go-RPC有超时机制吗?,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com

git 推送错误 : RPC failed; result=56, HTTP 代码 = 0

关闭。这个问题需要detailsorclarity.它目前不接受答案。想改进这个问题吗?通过editingthispost添加细节并澄清问题.关闭8年前。Improvethisquestion详细信息:Usernamefor'https://xiangwan.visualstudio.com':xiangwanPasswordfor'https://xiangwan@xiangwan.visualstudio.com':Countingobjects:85,done.Deltacompressionusingupto4threads.Compressingobjects:100%(58

c++ - 启动 RPC 服务器时为 "endpoint is a duplicate"

我的程序使用MicrosoftRPC进行进程间通信。为了准备接收RPC调用,程序运行以下序列:RpcServerUseProtseqEp(),然后RpcServerRegisterIf(),然后RpcServerListen()该程序以上述顺序启动其RPC服务器,工作一段时间,然后终止,稍后可能由另一个程序重新启动。每次程序运行时,RpcServerUseProtseqEp()的参数值集都是相同的。当序列在重启后第一次运行时它总是成功,但在随后的运行中RpcServerUseProtseqEp()返回RPC_S_DUPLICATE_ENDPOINT(“端点是重复的。”)目前我只是忽略这

spring - 将 Spring Boot 与 gRPC 和 Protobuf 一起使用

任何人有任何使用gRPC和SpringBoot的示例或想法吗? 最佳答案 如果它仍然对你有用,我已经创建了gRPCspring-boot-starterhere.grpc-spring-boot-starter使用@GRpcService-enabledbean自动配置和运行嵌入式gRPC服务器。最简单的例子:@GRpcService(grpcServiceOuterClass=GreeterGrpc.class)publicstaticclassGreeterServiceimplementsGreeterGrpc.Greeter

spring - 将 Spring Boot 与 gRPC 和 Protobuf 一起使用

任何人有任何使用gRPC和SpringBoot的示例或想法吗? 最佳答案 如果它仍然对你有用,我已经创建了gRPCspring-boot-starterhere.grpc-spring-boot-starter使用@GRpcService-enabledbean自动配置和运行嵌入式gRPC服务器。最简单的例子:@GRpcService(grpcServiceOuterClass=GreeterGrpc.class)publicstaticclassGreeterServiceimplementsGreeterGrpc.Greeter

java - 什么是 RPC 端口,它与连接到 Hadoop 有什么关系?

我不太擅长社交。我试图了解如何调试hadoop连接-并且该连接依赖于RPC端口。任何关于RPC端口如何影响Java程序中的文件URL的见解(不一定与hadoop相关......)在这里都会非常有帮助...... 最佳答案 RPC端口基本上是一种识别机器和该机器上的“地址”的方法,程序正在监听某些网络连接和请求。RPC是执行此操作的基础协议(protocol)。在这种情况下,更高级别的协议(protocol)是Hadoop,但它可能是其他东西-或者你自己制作的东西。 关于java-什么是R

hadoop - 错误配置 : namenode address dfs. namenode.servicerpc-address 或 dfs.namenode.rpc-address 没有配置

我正在尝试在ec2-instance上安装Hadoop-2.6.0。我下载并安装了Hadoop。我还设置了环境变量。尝试启动hdfs服务时出现以下错误。[ec2-user@ip-10-177-1-69sbin]$./start-dfs.sh配置不正确:namenode地址dfs.namenode.servicerpc-address或dfs.namenode.rpc-address没有配置。在[]上启动名称节点报错:找不到配置目录:/home/ec2-user/hadoop2.6.0/etc/hadoop报错:找不到配置目录:/home/ec2-user/hadoop2.6.0/etc

hadoop - 组织.apache.hadoop.ipc.RpcException : RPC response exceeds maximum data length

我已经在2台机器上设置了hadoop集群。一台机器同时有master和slave-1。第二台机器有slave-2。当我使用start-all.sh启动集群时,我在secondarynamenode的.out文件中遇到以下错误:java.io.IOException:Failedonlocalexception:org.apache.hadoop.ipc.RpcException:RPCresponseexceedsmaximumdatalength;HostDetails:localhostis:"ip-10-179-185-169/10.179.185.169";destinatio

hadoop - 配置不正确 : namenode address dfs. namenode.rpc-address没有配置

当我尝试启动DataNode时出现此错误。据我所知,RPC参数仅用于HA配置,我没有设置(我认为)。2014-05-1818:05:00,589INFO[main]impl.MetricsSystemImpl(MetricsSystemImpl.java:shutdown(572))-DataNodemetricssystemshutdowncomplete.2014-05-1818:05:00,589INFO[main]datanode.DataNode(DataNode.java:shutdown(1313))-Shutdowncomplete.2014-05-1818:05:00