xyz.shodown.grpc.client

类 GrpcClientProxy

java.lang.Object

xyz.shodown.grpc.client.GrpcClientProxy

所有已实现的接口:

org.springframework.beans.factory.InitializingBean

public abstract class GrpcClientProxy
extends Object
implements org.springframework.beans.factory.InitializingBean

grpc客户端代理抽象类

构造器概要

构造器

构造器和说明
GrpcClientProxy()

方法概要

限定符和类型	方法和说明
void	afterPropertiesSet()
abstract <BS extends io.grpc.stub.AbstractBlockingStub> BS	getBlockingStub(io.grpc.ManagedChannel channel) 重写方法,返回生成GRPC对象中的静态方法newBlockingStub
Connection	initConnection() 初始化连接配置
<T> T	invokeServiceBlocking(@NotNull Class<T> resultClass, @NotNull String serviceMethod, com.google.protobuf.Message... messages) 阻塞执行grpc服务端提供的service方法
<R extends com.google.protobuf.Message> R	invokeServiceBlocking(@NotNull String serviceMethod, com.google.protobuf.Message... messages) 阻塞执行grpc服务端提供的service方法
<M extends com.google.protobuf.Message> com.google.protobuf.Message	requestParam(@NotNull Object param, @NotNull Class<M> protoClass) 将DTO参数转换成proto定义的参数对象
com.google.protobuf.Message	requestParam(@NotNull Object param, com.google.protobuf.Message.Builder builder) 将DTO参数对象转换成proto定义的参数对象
<T> T	responseResult(@NotNull com.google.protobuf.Message protoResultBean, @NotNull Class<T> resultClass)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

GrpcClientProxy

public GrpcClientProxy()

方法详细资料

invokeServiceBlocking

public <R extends com.google.protobuf.Message> R invokeServiceBlocking(@NotNull
                                                                       @NotNull String serviceMethod,
                                                                       com.google.protobuf.Message... messages)

阻塞执行grpc服务端提供的service方法

类型参数:

R - proto message子类

参数:

serviceMethod - grpc service方法名称

messages - proto message参数

返回:

返回proto message执行结果

invokeServiceBlocking

public <T> T invokeServiceBlocking(@NotNull
                                   @NotNull Class<T> resultClass,
                                   @NotNull
                                   @NotNull String serviceMethod,
                                   com.google.protobuf.Message... messages)

阻塞执行grpc服务端提供的service方法

参数:

resultClass - 返回结果,自定义业务实体类型

serviceMethod - grpc service方法名称

messages - proto message参数

返回:

返回结果, 自定义返回实体对象

getBlockingStub

public abstract <BS extends io.grpc.stub.AbstractBlockingStub> BS getBlockingStub(io.grpc.ManagedChannel channel)

重写方法,返回生成GRPC对象中的静态方法newBlockingStub

参数:

channel -

返回:

GRPC对象下的BlockingStub对象

initConnection

public Connection initConnection()

初始化连接配置

返回:

连接配置对象

responseResult

public <T> T responseResult(@NotNull
                            @NotNull com.google.protobuf.Message protoResultBean,
                            @NotNull
                            @NotNull Class<T> resultClass)

类型参数:

T - 实体类型

参数:

protoResultBean - proto定义的最终接口返回的message实体

resultClass - 最终返回的实体对象,包含结果码,错误消息,数据

返回:

grpc处理结果转换后的自定义返回实体

requestParam

public com.google.protobuf.Message requestParam(@NotNull
                                                @NotNull Object param,
                                                @NotNull
                                                com.google.protobuf.Message.Builder builder)

将DTO参数对象转换成proto定义的参数对象

参数:

param - DTO参数

builder - proto参数对象的内置静态Builder

返回:

可用于grpc调用的参数

requestParam

public <M extends com.google.protobuf.Message> com.google.protobuf.Message requestParam(@NotNull
                                                                                        @NotNull Object param,
                                                                                        @NotNull
                                                                                        @NotNull Class<M> protoClass)

将DTO参数转换成proto定义的参数对象

参数:

param - DTO参数

protoClass - proto参数对象类型

返回:

proto message对象

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

指定者:

afterPropertiesSet 在接口中 org.springframework.beans.factory.InitializingBean

抛出:

Exception