Grpc介绍

gRPC是一个现代的开源高性能RPC框架，可以在任何环境中运行。它可以有效地连接数据中心内和跨数据中心的服务，并提供可插拔的支持，以实现负载平衡，跟踪，健康检查和身份验证。它还适用于分布式计算的最后一英里，用于将设备，移动应用程序和浏览器连接到后端服务。

Faster-Grpc

Faster-Framework热衷于开发环境脚手架的快速集成与搭建，1.1.0版本开始Faster将grpc与SpringBoot进行了基础。并支持如下特性：

客户端通过动态代理来实现具体的请求方法，仅需要创建接口、标识注解即可使用，免除了编写实现类、maven生成父类的复杂步骤。
服务端通过反射调用被注解标识的类与方法接收请求。
使用JSON协议进行传输数据，序列化与反序列化默认使用Jackson，并提供了自定义Json序列化工具的方式。免除了编写.proto文件、参数顺序必须一致、参数数量必须一致等诸多困扰，

快速开始

希望您已经阅读过基本的grpc使用方式。如果您尚不熟悉，请移步grpc官方查看。

grpc-java

Maven配置

我们基于SpringBoot进行构建。Maven配置如下：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>faster-test-grpc</groupId>
    <artifactId>faster-test-grpc</artifactId>
    <version>1.0-SNAPSHOT</version>
    <parent>
        <artifactId>spring-boot-starter-parent</artifactId>
        <groupId>org.springframework.boot</groupId>
        <version>2.1.1.RELEASE</version>
    </parent>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>cn.org.faster</groupId>
            <artifactId>spring-boot-starter-grpc</artifactId>
            <version>1.1.1.RELEASE</version>
        </dependency>
    </dependencies>
</project>

服务端

application.yml

faster:
  grpc:
    enabled: true
    server:
      enabled: true #实际可不写，默认开启
      port: 50051 #端口，不写默认50051

编写服务类


@GRpcApi("unary")
@Slf4j
public class UnaryService {

    @GRpcMethod
    public void testInt(int data, StreamObserver<Integer> response) {
        log.info("请求数据:{}", data);
        response.onNext(1);
        response.onCompleted();
    }
}

@GRpcApi中的值为scheme，客户端的@GRpcService(scheme="")与服务端相同时，即可定位到服务端的服务。

@GRpcMethod默认获取当前方法名称，客户端同样使用此注解标识要调用的服务方法，可通过@GRpcMethod("xxx")修改名称，两者一致调用成功。

注意：对于GRpc而言，请求参数中只能出现一个业务参数实体，才可通过序列化工具进行序列化，不可出现多个业务参数。

客户端

application.yml

faster:
  grpc:
    enabled: true #实际可不写，默认开启
    client:
      enabled: true #实际可不写，默认开启
      services:
        test-unary: #与GRpcService中的value对应
          host: localhost # 远程主机地址
          port: 50051 # 远程端口号，不写默认50051
        test-server-stream: #与GRpcService中的value对应
          host: localhost #服务端host

定义接口

@GRpcService(value = "test-unary", scheme = "unary")
public interface UnaryService {
    @GRpcMethod
    int testInt(int data);
}

@GRpcService中的value对应配置文件中services下的key，以此获取远程host与端口。

@GRpcService中的scheme对应远程服务@GRpcApi("unary")中所定义的值，用于创建grpc fullMethod，两者一致，即可调用成功。

@GRpcMethod默认获取当前方法名称，远程服务端同样使用此注解标识提供服务的方法，可通过@GRpcMethod("xxx")修改名称，两者一致调用成功。

注意：对于GRpc而言，接口参数只能存在一个业务实体参数，才可通过序列化工具进行序列化，不可出现多个业务参数。

调用

@Slf4j
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = Application.class)
public class UnaryTest{
    @Autowired
    private UnaryService unaryService;

    @Test
    public void testInt() {
        int result = unaryService.testInt(1);
        log.info("返回数据:{}", result);
    }
}