写给Java程序员的GRPC入门系列（3）

点击上方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 {
    @Override
    public 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();
    }

    @Override
    public 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結合的多項目演示。