Skip to content

Files

Latest commit

 

History

History
 
 

springboot-rpc-grpc-sample

Folders and files

NameName
Last commit message
Last commit date

parent directory

..
 
 
 
 
 
 

RPC服务框架之gRPC

一.什么是RPC?

RPC原理简图

图片名称

二.什么是gRPC?

gRPC是一个高性能、通用的开源RPC框架,基于HTTP/2二进制协议标准而设计,基于ProtoBuf(Protocol Buffers)序列化协议开发,且支持众多开发语言。
ProtoBuf具有了优秀的系列化协议所需的众多典型特性

ProtoBuf是一个存粹的展示层协议,可以和各种传输层协议一起使用

  • 具有标准的IDL和IDL编译器;
  • 序列化数据非常简介,紧凑,与XML相比,其序列化之后的数据量约为1/3和1/10;
  • 解析速度非常快,比对应的XML快20~100倍速度

gRPC服务端创建流程

图片名称

  • gRPC服务端基于NettyServer负责监听Socket地址,基于HTTP2协议的写入;
  • gPRC服务接口并不是使用反射来实现的,而是通过Proto工具生成的代码,将服务接口注册到gRPC内部的服务上,性能较高;
  • ServerImpl负责整个gRPC服务端消息的调度和处理,会初始化:Netty线程池、gRPC的线程池、内部服务注册等;

gRPC消息接入流程

图片名称

  • gRPC消息由netty/http2协议负责接入,通过gRPC注册的Http2FrameLister将解码后的Http Header和Http Body后,发送到gRPC的NettyServerHandler,实现Netty Http/2的消息接入;

三.gRPC实战

1.编写PB文件,proto语法参考:https://developers.google.com/protocol-buffers/docs/proto
syntax = "proto3";

option java_package = "com.ipman.rpc.grpc.springboot.lib";

// The greeter service definition.
service Greeter {
    // Sends a greeting
    rpc SayHello ( HelloRequest) returns (  HelloReply) {}

}
// The request message containing the user's name.
message HelloRequest {
    string name = 1;
}
// The response message containing the greetings
message HelloReply {
    string message = 1;
}
2.编写Server端,通过@GrpcService注解注册gRPC服务
@Slf4j
@GrpcService(GreeterOuterClass.class)
public class GreeterService extends GreeterGrpc.GreeterImplBase {

    /**
     * gRPC Server started, listening on address: 0.0.0.0, port: 8800
     *
     * @param request
     * @param responseObserver
     */
    @Override
    public void sayHello(GreeterOuterClass.HelloRequest request, StreamObserver<GreeterOuterClass.HelloReply> responseObserver) {
        String message = "Hello " + request.getName();
        final GreeterOuterClass.HelloReply.Builder replyBuilder = GreeterOuterClass.HelloReply.newBuilder().setMessage(message);
        responseObserver.onNext(replyBuilder.build());
        responseObserver.onCompleted();
        log.info("Returning " + message);
    }
}
3.编写Client端,通过@GrpcClient绑定gRPC服务端地址与端口等信息
@Service
public class GrpcClientServiceImpl implements IGrpcClientService {

    @GrpcClient("local-grpc-server")
    private Channel serverChannel;

    /**
     * 通过本地存protocol buffer存根序列化后调用gRPC服务端
     *
     * @param name
     * @return
     */
    @Override
    public String sendMessage(String name) {
        GreeterGrpc.GreeterBlockingStub stub = GreeterGrpc.newBlockingStub(serverChannel);
        GreeterOuterClass.HelloReply response = stub.sayHello(GreeterOuterClass.HelloRequest.newBuilder().setName(name).build());
        return response.getMessage();
    }
}