歡迎訪問我的GitHub

https://github.com/zq2599/blog_demos

內(nèi)容：所有原創(chuàng)文章分類匯總及配套源碼辟宗，涉及Java乙墙、Docker烫幕、Kubernetes、DevOPS等翩剪；

關(guān)于《java版gRPC實戰(zhàn)》系列

• 《java版gRPC實戰(zhàn)》是欣宸原創(chuàng)的面向java程序員的gRPC開發(fā)筆記，與讀者們一起通過實戰(zhàn)來學(xué)習(xí)掌握gRPC的各個知識點姆涩；

《java版gRPC實戰(zhàn)》全系列鏈接

1. 用proto生成代碼
2. 服務(wù)發(fā)布和調(diào)用
3. 服務(wù)端流
4. 客戶端流
5. 雙向流
6. 客戶端動態(tài)獲取服務(wù)端地址
7. 基于eureka的注冊發(fā)現(xiàn)

關(guān)于gRPC

1. gRPC 是一個高性能账忘、開源和通用的 RPC 框架，面向移動和 HTTP/2 設(shè)計佑吝。目前提供 C坐昙、Java 和 Go 語言版本，分別是：grpc, grpc-java, grpc-go. 其中 C 版本支持 C, C++, Node.js, Python, Ruby, Objective-C, PHP 和 C# 支持.
2. gRPC 基于 HTTP/2 標(biāo)準(zhǔn)設(shè)計芋忿，帶來諸如雙向流炸客、流控、頭部壓縮戈钢、單 TCP 連接上的多復(fù)用請求等特痹仙。這些特性使得其在移動設(shè)備上表現(xiàn)更好，更省電和節(jié)省空間占用殉了。
3. 各個進程之間可以通過gRPC相互調(diào)用开仰，如下圖：

在這里插入圖片描述

核心技術(shù)

• 為了用java發(fā)布gRPC服務(wù)，我使用的是開源庫<font color="blue">net.devh:grpc-server-spring-boot-starter</font>
• 在調(diào)用其他gRPC服務(wù)時用的是<font color="blue">net.devh:grpc-client-spring-boot-starter</font>
• 感謝該開源庫的作者Michael大神，您的智慧的簡化了java程序員的gRPC開發(fā)工作众弓，項目地址：https://github.com/yidongnan/grpc-spring-boot-starter

本篇概覽

作為系列文章的開篇恩溅，本篇要做的事情如下：

1. 明確依賴庫和開發(fā)環(huán)境
2. 新建父工程<font color="blue">grpc-tutorials</font>，今后《java版gRPC實戰(zhàn)》系列的所有源碼都在這個工程中
3. 實戰(zhàn)用proto文件自動生成java代碼

明確依賴庫和開發(fā)環(huán)境

整個系列文章涉及的依賴庫和開發(fā)環(huán)境的情況如下：

1. JDK：1.8.0_281
2. gradle：6.7.1
3. springboot：2.3.8.RELEASE
4. grpc：1.35.0
5. protobuf：3.14.0
6. grpc-server-spring-boot-starter：2.11.0.RELEASE
7. grpc-client-spring-boot-starter：2.11.0.RELEASE
8. 操作系統(tǒng)：win10專業(yè)版
9. IDEA：2021.1 (Ultimate Edition)

源碼下載

• 本篇實戰(zhàn)中的完整源碼可在GitHub下載到谓娃，地址和鏈接信息如下表所示(https://github.com/zq2599/blog_demos)：

• 這個git項目中有多個文件夾滨达，《java版gRPC實戰(zhàn)》系列的源碼在<font color="blue">grpc-tutorials</font>文件夾下奶稠，如下圖紅框所示：

在這里插入圖片描述

創(chuàng)建《java版gRPC實戰(zhàn)》系列的父工程

• 新建名為<font color="blue">grpc-tutorials</font>的gradle工程，前面提到的庫及其版本都在此工程中處理好捡遍，build.gradle內(nèi)容如下：

import java.time.OffsetDateTime
import java.time.format.DateTimeFormatter

buildscript {
    repositories {
        maven {
            url 'https://plugins.gradle.org/m2/'
        }
        // 如果有私服就在此配置窒典，如果沒有請注釋掉
        maven {
            url 'http://192.168.50.43:8081/repository/aliyun-proxy/'
        }
        // 阿里云
        maven {
            url 'http://maven.aliyun.com/nexus/content/groups/public/'
        }

        mavenCentral()
    }
    ext {
        // 項目版本
        projectVersion = '1.0-SNAPSHOT'

        // 依賴庫的版本
        grpcSpringBootStarterVersion = '2.11.0.RELEASE'

        // grpc版本 https://github.com/grpc/grpc-java/releases
        grpcVersion = '1.35.0'
        // protobuf版本 https://github.com/protocolbuffers/protobuf/releases
        protobufVersion = '3.14.0'
        // protobuf的gradle插件版本
        protobufGradlePluginVersion = '0.8.12'

        // sprignboot版本 https://github.com/spring-projects/spring-boot/releases
        springBootVersion = '2.3.8.RELEASE'
        // springcloud版本 https://github.com/spring-cloud/spring-cloud-release/releases
        springCloudVersion = 'Hoxton.SR9'
        // nacos版本 https://github.com/alibaba/spring-cloud-alibaba/releases
        springCloudAlibabaNacosVersion = '2.2.3.RELEASE'
        // security版本 https://github.com/spring-projects/spring-security-oauth/releases
        springSecurityOAuthVersion = '2.5.0.RELEASE'
    }
}

plugins {
    id 'java'
    id 'java-library'
    id 'org.springframework.boot' version "${springBootVersion}" apply false
    id 'io.spring.dependency-management' version '1.0.11.RELEASE'
    id 'net.nemerosa.versioning' version '2.14.0'
    id 'com.google.protobuf' version '0.8.14'
    id 'io.franzbecker.gradle-lombok' version '4.0.0' apply false
    id 'com.github.ben-manes.versions' version '0.36.0' // gradle dependencyUpdates
}

// If you attempt to build without the `--scan` parameter in `gradle 6.0+` it will cause a build error that it can't find
// a buildScan property to change. This avoids that problem.
if (hasProperty('buildScan')) {
    buildScan {
        termsOfServiceUrl = 'https://gradle.com/terms-of-service'
        termsOfServiceAgree = 'yes'
    }
}

wrapper {
    gradleVersion = '6.7.1'
}

def buildTimeAndDate = OffsetDateTime.now()

ext {
    // 構(gòu)建時取得當(dāng)前日期和時間
    buildDate = DateTimeFormatter.ISO_LOCAL_DATE.format(buildTimeAndDate)
    buildTime = DateTimeFormatter.ofPattern('HH:mm:ss.SSSZ').format(buildTimeAndDate)
    buildRevision = versioning.info.commit
}

allprojects {
    apply plugin: 'java'
    apply plugin: 'idea'
    apply plugin: 'eclipse'
    apply plugin: 'io.spring.dependency-management'
    apply plugin: 'io.franzbecker.gradle-lombok'

    compileJava {
        sourceCompatibility = JavaVersion.VERSION_1_8
        targetCompatibility = JavaVersion.VERSION_1_8
        options.encoding = 'UTF-8'
    }

    compileJava.options*.compilerArgs = [
            '-Xlint:all', '-Xlint:-processing'
    ]

    // Copy LICENSE
    tasks.withType(Jar) {
        from(project.rootDir) {
            include 'LICENSE'
            into 'META-INF'
        }
    }

    // 寫入到MANIFEST.MF中的內(nèi)容
    jar {
        manifest {
            attributes(
                    'Created-By': "${System.properties['java.version']} (${System.properties['java.vendor']} ${System.properties['java.vm.version']})".toString(),
                    'Built-By': 'travis',
                    'Build-Date': buildDate,
                    'Build-Time': buildTime,
                    'Built-OS': "${System.properties['os.name']}",
                    'Build-Revision': buildRevision,
                    'Specification-Title': project.name,
                    'Specification-Version': projectVersion,
                    'Specification-Vendor': 'Will Zhao',
                    'Implementation-Title': project.name,
                    'Implementation-Version': projectVersion,
                    'Implementation-Vendor': 'Will Zhao'
            )
        }
    }

    repositories {
        mavenCentral()

        // 如果有私服就在此配置，如果沒有請注釋掉
        maven {
            url 'http://192.168.50.43:8081/repository/aliyun-proxy/'
        }

        // 阿里云
        maven {
            url 'http://maven.aliyun.com/nexus/content/groups/public/'
        }

        jcenter()
    }

    buildscript {
        repositories {
            maven { url 'https://plugins.gradle.org/m2/' }
        }
    }
}

allprojects { project ->
    buildscript {
        dependencyManagement {
            imports {
                mavenBom "org.springframework.boot:spring-boot-starter-parent:${springBootVersion}"
                mavenBom "org.springframework.cloud:spring-cloud-dependencies:${springCloudVersion}"
                mavenBom "com.google.protobuf:protobuf-bom:${protobufVersion}"
                mavenBom "io.grpc:grpc-bom:${grpcVersion}"
                mavenBom "org.junit:junit-bom:5.7.0"
            }

            dependencies {
                dependency 'org.projectlombok:lombok:1.16.16'
                dependency 'org.apache.commons:commons-lang3:3.11'
                dependency 'commons-collections:commons-collections:3.2.2'
                dependency "net.devh:grpc-server-spring-boot-starter:${grpcSpringBootStarterVersion}"
                dependency "net.devh:grpc-client-spring-boot-starter:${grpcSpringBootStarterVersion}"
            }
        }

        ext {
            micrometerVersion = dependencyManagement.importedProperties['micrometer.version']
            springFrameworkVersion = dependencyManagement.importedProperties['spring-framework.version']
            springSecurityVersion = dependencyManagement.importedProperties['spring-security.version']
            springCloudCommonsVersion = dependencyManagement.importedProperties['spring-cloud-commons.version']
        }
    }
}

group = 'com.bolingcavalry'
version = projectVersion

• 整個系列用到的父工程已經(jīng)完成稽莉，接下來可以開始編碼了瀑志；

實戰(zhàn)用proto文件自動生成java代碼

• gRPC服務(wù)能夠用不同的語言編寫，其中的關(guān)鍵是定義服務(wù)的proto文件可以被生成各種語言的代碼污秆，java也不例外劈猪，接下來一起體驗；
• 在父工程<font color="blue">grpc-tutorials</font>下新建模塊良拼，名為<font color="blue">grpc-lib</font>战得，其build.gradle內(nèi)容如下，可見主要是配置了protobuf插件庸推，以及生成的java代碼如何才能被IDE工具加入到source path中：

// 根據(jù)proto生成java代碼的gradle插件
plugins {
    id 'com.google.protobuf'
}

dependencies {
    implementation 'io.grpc:grpc-netty-shaded'
    implementation 'io.grpc:grpc-protobuf'
    implementation 'io.grpc:grpc-stub'
    if (JavaVersion.current().isJava9Compatible()) {
        // Workaround for @javax.annotation.Generated
        // see: https://github.com/grpc/grpc-java/issues/3633
        implementation 'jakarta.annotation:jakarta.annotation-api'
    }
}


protobuf {
    protoc {
        artifact = "com.google.protobuf:protoc:${protobufVersion}"
    }
    // 自動生成的代碼放在這里
    generatedFilesBaseDir = "$projectDir/src/generated"
    clean {
        delete generatedFilesBaseDir
    }
    // 生成java代碼的插件
    plugins {
        grpc {
            artifact = 'io.grpc:protoc-gen-grpc-java'
        }
    }
    generateProtoTasks {
        all()*.plugins {
            grpc {}
        }
    }
}

// 對于eclipse常侦，通過以下腳本可以將生成的代碼加入source路徑中，編譯時會被用到
eclipse {
    classpath {
        file.beforeMerged { cp ->
            def generatedGrpcFolder = new org.gradle.plugins.ide.eclipse.model.SourceFolder('src/generated/main/grpc', null);
            generatedGrpcFolder.entryAttributes['ignore_optional_problems'] = 'true';
            cp.entries.add( generatedGrpcFolder );
            def generatedJavaFolder = new org.gradle.plugins.ide.eclipse.model.SourceFolder('src/generated/main/java', null);
            generatedJavaFolder.entryAttributes['ignore_optional_problems'] = 'true';
            cp.entries.add( generatedJavaFolder );
        }
    }
}

// 對于idea贬媒，通過以下腳本可以將生成的代碼加入source路徑中聋亡，編譯時會被用到
idea {
    module {
        sourceDirs += file('src/generated/main/java')
        sourceDirs += file('src/generated/main/grpc')
        generatedSourceDirs += file('src/generated/main/java')
        generatedSourceDirs += file('src/generated/main/grpc')
    }
}

• 在grpc-lib模塊的<font color="blue">src/main/proto</font>目錄下新增名為<font color="red">helloworld.proto</font>的文件，這里面定義了一個gRPC服務(wù)际乘，里面含有一個接口坡倔，并且還有這個接口的入?yún)⒑头祷亟Y(jié)果的定義：

syntax = "proto3";

option java_multiple_files = true;
// 生成java代碼的package
option java_package = "com.bolingcavalry.grpctutorials.lib";
option java_outer_classname = "HelloWorldProto";

// gRPC服務(wù)
service Simple {
    // 接口定義
    rpc SayHello (HelloRequest) returns (HelloReply) {
    }
}

// 入?yún)⒌臄?shù)據(jù)結(jié)構(gòu)
message HelloRequest {
    string name = 1;
}

// 返回結(jié)果的數(shù)據(jù)結(jié)構(gòu)
message HelloReply {
    string message = 1;
}

• proto文件已經(jīng)做好，接下來要根據(jù)這個文件來生成java代碼脖含，在<font color="red">grpc-tutorials</font>目錄下執(zhí)行命令<font color="blue">gradle grpc-lib:generateProto</font>罪塔，即可根據(jù)helloworld.proto文件生成java代碼，執(zhí)行成功后會生出下圖紅框中的內(nèi)容养葵，這些就是java代碼：

在這里插入圖片描述

• 本篇只聊如何生成上述代碼征堪，至于這些代碼的用途就留到下一篇再說吧，這里只簡單提一下关拒，SimpleGrpc里面有抽象類SimpleImplBase佃蚜，制作gRPC服務(wù)的時候需要繼承該類庸娱，另外，如果您要遠程調(diào)用gRPC的sayHello接口爽锥，就會用到SimpleGrpc類中的SimpleStub類涌韩，其余的HelloReply、HelloRequest這些則是入?yún)⒑头祷氐臄?shù)據(jù)結(jié)構(gòu)定義氯夷；

• 至此臣樱，java版gRPC實戰(zhàn)的準(zhǔn)備工作就完成了，根據(jù)proto文件生成java代碼的方法也掌握了腮考，接下來的章節(jié)咱們一起嘗試服務(wù)的發(fā)布和調(diào)用雇毫；

你不孤單，欣宸原創(chuàng)一路相伴

1. Java系列
2. Spring系列
3. Docker系列
4. kubernetes系列
5. 數(shù)據(jù)庫+中間件系列
6. DevOps系列

歡迎關(guān)注公眾號：程序員欣宸

微信搜索「程序員欣宸」踩蔚，我是欣宸棚放，期待與您一同暢游Java世界...
https://github.com/zq2599/blog_demos