点击上方GRPC专栏看系列

Abstract

网上有很多GRPC的例子，但是却没有能够写给普通Java开发人员手把手入门少走弯路的教程。
本教程保证按照步骤一步步来你就可以完成GRPC从0到1的构建。
源码地址：grpc-helloworld-for-java

前置依赖

装有maven和JDK。并且保证javac命令可用。

本文

本文是系列的第3篇，将编写自定义的server/service和client调用实现。 代码在分支：step3-client-server。

初始状态

git clone https://github.com/gaoxingliang/grpc-helloworld-for-java.git
--跟着上一篇的branch接着修改
git step2-protobuffer

编写自己的Service实现（Server端）

新建包com.example.cs来放client和server的代码。 当然你也可以把step2生成的代码打包成jar上传maven方便共享。
并且新建类：MyUserServiceImpl.java,这里自定义实现UserService的逻辑，比如这里要求用户名密码相同才认证成功：

package com.example.cs;import com.example.grpc.common.vo.*;
import com.example.grpc.user.*;
import io.grpc.stub.*;public class MyUserServiceImpl extends UserGrpc.UserImplBase {@Overridepublic void login(UserOuterClass.LoginRequest request, StreamObserver<UserOuterClass.APIResponse> responseObserver) {UserOuterClass.APIResponse.Builder resp = UserOuterClass.APIResponse.newBuilder();if (request.getUsername().equals(request.getPassword())) {resp.setResponseCode(0);resp.setResponsemessage("OK");} else {resp.setResponseCode(1);resp.setResponsemessage("FAIL");}responseObserver.onNext(resp.build());responseObserver.onCompleted();}@Overridepublic void logout(Vo.Empty request, StreamObserver<UserOuterClass.APIResponse> responseObserver) {// 没实现。}
}

新建GrpcServer实现：

package com.example.cs;import io.grpc.*;public class GrpcServer {public static void main(String[] args) throws Exception{Server server = ServerBuilder.forPort(7070).addService(new MyUserServiceImpl()).build();server.start();System.out.println("server start at 7070");server.awaitTermination();}
}

并运行，输出：

server start at 7070

编写客户端

GrpcClient.java:

package com.example.cs;import com.example.grpc.user.*;
import io.grpc.*;public class GrpcClient {public static void main(String[] args) throws Exception {ManagedChannel ch = ManagedChannelBuilder.forAddress("localhost", 7070).usePlaintext().build();UserGrpc.UserBlockingStub stub = UserGrpc.newBlockingStub(ch);UserOuterClass.APIResponse resp = stub.login(UserOuterClass.LoginRequest.newBuilder().setUsername("hello").setPassword("world").build());System.out.println("Response " + resp);ch.shutdown();}
}

运行并输出：

Response responsemessage: "FAIL"
responseCode: 1

下一步

和springboot結合的多項目演示。