一.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,敬请期待