概述

saluki是以Grpc作为底层，提供一套高性能、易于使用的分布式远程服务调用(RPC)框架

功能

• 与consul配置服务组件进行集成，提供集群环境的服务发现及治理能力。
• 简化开发方式，对于Grpc原生stub方式进行封装，提供了使用interface和pojo作为服务契约的方式
• 与spring-boot进行集成，提供了autoconfig的方式
• 扩展grpc的NameResolver，提供了RoundRobin负载均衡方式

Quick Start

• 首先使用saluki提供的gradle插件根据protoc文件生成interface及pojo模型

classpath 'com.quancheng:saluki-plugin:0.0.1+'

apply plugin: 'saluki'
compileJava.dependsOn generateProtoInterface 
generateProtoInterface.dependsOn generateProtoModel

• 根据protoc文件生成的接口及pojo如下所示

//pojo
@ProtobufEntity(User.UserGetRequest.class)
public class UserGetRequest
{
  @ProtobufAttribute
  private Long id;
  //getter setter
}

@ProtobufEntity(User.UserGetResponse.class)
public class UserGetResponse
{
  @ProtobufAttribute
  private BaseResponse base;
  @ProtobufAttribute
  private Long id;
  @ProtobufAttribute
  private String name;
  @ProtobufAttribute
  private String phone;
  //getter setter
}

//interface
public abstract interface UserService
{
  public abstract UserGetResponse get(UserGetRequest paramUserGetRequest);
}

• 添加spring-boot-saluki依赖

        gradle: compile 'com.quancheng:spring-boot-starter-saluki:1.5+
        
        maven:
        <dependency>
			<groupId>com.quancheng</groupId>
			<artifactId>spring-boot-starter-saluki</artifactId>
			<version>1.5.0-SNAPSHOT</version>
		</dependency>
		
		 

• 添加Application.properties

grpc.serverPort=12201 //服务暴露的端口
grpc.consulIp=192.168.99.101 //consul注册中心Ip
grpc.consulPort=8500 //consul注册中心port

• 服务消费端

 @SalukiReference(service = "com.quancheng.boot.starter.service.UserService", group = "default", version = "1.0.0")
 private UserService userSerivce;
    

• 服务提供端

@SalukiService(service = "com.quancheng.boot.starter.service.UserService", group = "default", version = "1.0.0")
public class GreeterServiceImpl implements GreeterService {

    @Override
    public UserGetResponse get(UserGetRequest request) {
       return new UserGetResponse();
    }

}

详细demo请看工程的example

• http2.0

由于在saluki1.0.1版本开启http2.0，需要项目引入netty ssl的native包，引入如下：

buildscript {
  repositories {
    mavenCentral()
  }
  dependencies {
    classpath 'com.google.gradle:osdetector-gradle-plugin:1.4.0'
  }
}

// Use the osdetector-gradle-plugin
apply plugin: "com.google.osdetector"

def tcnative_classifier = osdetector.classifier;
// Fedora variants use a different soname for OpenSSL than other linux distributions
// (see http://netty.io/wiki/forked-tomcat-native.html).
if (osdetector.os == "linux" && osdetector.release.isLike("fedora")) {
  tcnative_classifier += "-fedora";
}

dependencies {
    compile 'io.netty:netty-tcnative-boringssl-static:1.1.33.Fork23:'+ tcnative_classifier
}

• monitor 引入monitor agent

gradle: compile 'com.quancheng:spring-boot-starter-saluki:1.5+