一.Grpc简介
一个2016年才由google正式发布的的RPC框架，基于http2,protobuf协议
官网地址：https://www.grpc.io
二.此文背景介绍
我跟你们一样，也是一个新手，由于公司要用到此框架还有就是个人的兴趣所致，尝试在自己的垃圾华硕本上搭建整个框架，在此记录并分享给有需要朋友。
在此多说一句，rpc框架行业流行的很多，有dubbo,thrift,spring cloud等，最近微服务的概念很火，这就导致了一个（多个）应用对应更多的服务（微应用），随之而来的就是服务之间的通信问题。当然，通讯从某个角度来划分可以分为对内服务通讯和对外服务通讯。此文主要是针对内部通讯。
三.环境
a.win7华硕本
b.eclipse+maven+git
四.let's do it
1.新建一个maven工程，并创建一个proto文件
helloword.proto文件内容如下
syntax = "proto3";
option java_package = "my.test.grpc_java";
package helloworld;
service HellowordService {
rpc SayHello (HelloRequest) returns (HelloReply) {
};
}
message HelloRequest {
string name = 1;
}
message HelloReply {
string message = 1;
}
注：eclipse有protobuff的插件，自己可以安装。protobuf的语法很简单，自己可以看看官网
2.在pom.xml中添加依赖和编译插件
貌似不能加xml串，那就自己去官网上拷吧
https://github.com/grpc/grpc-java/blob/master/README.md
3.依次执行maven-clean，maven-install
执行完后会生成两个java文件
HelloWorld.java定义了你的请求参数HelloRequest，HelloReply
重要的是HellowordServiceGrpc.java
里面定义了服务器端服务接口以及客户端的stub
4.实现一个服务端服务实现类
其实这里就是响应请求的逻辑啦，简单实现如下
public class HelloWordServiceImpl extends HellowordServiceImplBase {
@Override
public void sayHello(HelloRequest request, StreamObserver responseObserver) {
String name= request.getName();
System.out.println(name);
HelloWorld.HelloReply reply = HelloWorld.HelloReply.newBuilder().setMessage(("Hello: " + request.getName())).build();
responseObserver.onNext(reply);
responseObserver.onCompleted();
}
}
5.实现一个服务启动类，它负责监听请求并把服务实现类添加到服务列表，响应具体的请求并返回结果给调用者
public class HelloWorldServer {
private int port = 9090;
private Server server;
private void start() throws IOException {
server = ServerBuilder.forPort(port).addService(new HelloWordServiceImpl()).build().start();
System.out.println("service start...");
Runtime.getRuntime().addShutdownHook(new Thread() {
@Override
public void run() {
System.err.println("*** shutting down gRPC server since JVM is shutting down");
HelloWorldServer.this.stop();
System.err.println("*** server shut down");
}
});
}
private void stop() {
if (server != null) {
server.shutdown();
}
}
// block 一直到退出程序
private void blockUntilShutdown() throws InterruptedException {
if (server != null) {
server.awaitTermination();
}
}
public static void main(String[] args) throws IOException, InterruptedException {
final HelloWorldServer server = new HelloWorldServer();
server.start();
server.blockUntilShutdown();
}
}
其中start方法是最重要的，我们看到了里面有一个addService(new HelloWordServiceImpl())操作，玄机就在这里了，现在我们就可以把这个程序跑起来了
起来后，他应该会监听9090端口的连接，下面应该起一个客户端来访问9090端口了，看看是不是我们想要的结果
6.创建客户端程序并调用相关的服务
我们想做的、能做的不外呼两件事，
a.连接到服务提供方服务器
b.调用我们想要的服务（方法）
代码如下：
public class HelloWorldClient {
private final ManagedChannel channel;
private final HellowordServiceGrpc.HellowordServiceBlockingStub blockingStub;
public HelloWorldClient(String host, int port) {
channel = ManagedChannelBuilder.forAddress(host, port).usePlaintext(true).build();
blockingStub = HellowordServiceGrpc.newBlockingStub(channel);
}
public void shutdown() throws InterruptedException {
channel.shutdown().awaitTermination(5, TimeUnit.SECONDS);
}
public void sayHello(String name) {
HelloWorld.HelloRequest request = HelloWorld.HelloRequest.newBuilder().setName(name).build();
HelloWorld.HelloReply response = blockingStub.sayHello(request);
System.out.println(response.getMessage());
}
public static void main(String[] args) throws InterruptedException {
HelloWorldClient client = new HelloWorldClient("127.0.0.1", 9090);
for (int i = 0; i < 5; i++) {
client.sayHello("world:" + i);
}
client.shutdown();
}
}
7.运行客户端程序，发起服务调用
得到运行结果如下：
Hello: world:0
Hello: world:1
Hello: world:2
Hello: world:3
Hello: world:4
如您所愿
得到了服务器端的返回消息
到这里，我们的服务提供和服务调用流程就算大功告成了
到这里，应该会有不少人有很多疑问，比如：
服务端添加服务是什么原理，服务端怎么根据客户端的请求调用正确的服务方法等等
先到这里，下面我们再继续探索
下一篇应该会说说grpc-gateway,敬请期待
网友评论