一、什么是gRPC
gRPC是google发起的一个*远程过程调用(rpc)*开源框架,可以在任何语言中,用任何编程语言编写。gRPC基于HTTP/2协议,使用Protocol Buffers作为序列化工具。
gRPC官网:grpc.io/
RPC
Remote Procedure Call,远程过程调用协议,一种通过网络调用远程计算机上服务,并且无需关注交互细节。可以理解为,服务A调用另一个服务B中的某段程序,底层实现对于开发者无感知,可以是基于HTTP/1.1也可以基于HTTP/2,可以序列化成json,xml,Protocol Buffers这些都不需要关心。像Dubbo就是一个RPC框架,仅关心业务编程即可。
Protocol Buffers
Protocol Buffers是一个跨语言,跨平台可扩展的数据结构序列化的一个工具语言,和JSON类似,但比JSON更小,更高效。需要通过工具编译成指定语言的代码,相当于你定义的对象需要由工具生成。
HTTP/2
HTTP协议第二个版本,兼容HTTP/1.1(目前广泛使用的仍然是HTTP/1.1),基于SPDY协议,于2015年2月17日被批准。
特性如下:
二、简单实践
文件生成
因为gRPC基于Protocol Buffers,需要通过工具来生成。
一种完全无依赖的方式是自己下载软件,如果要使用gRPC需要额外下载protoc-gen-grpc-java
proto地址:github.com/protocolbuf…
protoc-gen-grpc-java地址:repo.maven.apache.org/maven2/io/g…
配置了好久没有配置成功,然后用了其他方案,maven插件的方式
org.springframework.boot
spring-boot-maven-plugin
org.xolstice.maven.plugins
protobuf-maven-plugin
0.6.1
com.google.protobuf:protoc:3.21.5:exe:${os.detected.classifier}
grpc-java
io.grpc:protoc-gen-grpc-java:1.48.1:exe:${os.detected.classifier}
${project.basedir}/src/main/proto
${project.basedir}/src/main/java/
false
compile
compile-custom
服务端实现
生成的文件部分就不占用过多篇幅了
仓库地址:gitee.com/Nortyr/alli…
这个是服务端实现,其中doubleStream
我测试接收stream
,返回stream
,
public class ServiceImpl extends GreeterGrpc.GreeterImplBase{
//...略
@Override
public StreamObserver doubleStream(StreamObserver responseObserver) {
return new StreamObserver() {
AtomicInteger integer=new AtomicInteger();
@Override
public void onNext(Helloworld.HelloRequest helloRequest) {
System.out.println(helloRequest.getMessage());
Helloworld.HelloReply response = Helloworld.HelloReply.newBuilder()
.setMessage("瞅你咋地~~"+integer.incrementAndGet())
.build();
responseObserver.onNext(response);
}
@Override
public void onError(Throwable throwable) {
System.out.println("error: " + throwable.getMessage());
}
@Override
public void onCompleted() {
System.out.println("Server completed");
responseObserver.onCompleted();
}
};
}
}
- 服务端代码:
public class ServerDemo {
public static void main(String[] args) throws Exception {
int port = 9091;
Server server = ServerBuilder
.forPort(port)
.addService(new ServiceImpl())
.build()
.start();
System.out.println("server started, port : " + port);
server.awaitTermination();
}
}
- 客户端代码:
private static void testDoubleStream() throws InterruptedException {
String host = "127.0.0.1";
int port = 9091;
ManagedChannel channel = ManagedChannelBuilder.forAddress(host, port).usePlaintext().build();
// client接收一个对象
GreeterGrpc.GreeterStub stub = GreeterGrpc.newStub(channel);
StreamObserver doubleStream = stub.doubleStream(new StreamObserver() {
@Override
public void onNext(Helloworld.HelloReply helloReply) {
System.out.println("Received: " + helloReply.getMessage());
}
@Override
public void onError(Throwable throwable) {
System.out.println("error: " + throwable);
}
@Override
public void onCompleted() {
System.out.println("Client completed");
}
});
doubleStream.onNext(Helloworld.HelloRequest.newBuilder().setMessage("你瞅啥~~ 1").build());
doubleStream.onNext(Helloworld.HelloRequest.newBuilder().setMessage("你瞅啥~~ 2").build());
doubleStream.onNext(Helloworld.HelloRequest.newBuilder().setMessage("你瞅啥~~ 3").build());
doubleStream.onCompleted();
Thread.sleep(10000);
channel.shutdown();
}
- 启动结果如下:
抓包分析
还没见过HTTP/2报文,想看下,发现全是TCP
需要修改下,使用http2解析
如果想要看到内容需要配置下ProtoBuf文件位置
Wireshark>Perferences>Protocols>ProtoBuf
至此over~~~
结尾
- 仓库地址:gitee.com/Nortyr/alli…
- 参考资料
- grpc.io/
- protobuf.dev/
- zh.wikipedia.org/wiki/HTTP/2
- blog.csdn.net/luo15242208…