java版gRPC实战之一:用proto生成代码
欢迎访问我的GitHub
这里分类和汇总了欣宸的全部原创(含配套源码):https://github.com/zq2599/blog_demos
关于《java版gRPC实战》系列
- 《java版gRPC实战》是欣宸原创的面向java程序员的gRPC开发笔记,与读者们一起通过实战来学习掌握gRPC的各个知识点;
《java版gRPC实战》全系列链接
- 用proto生成代码
- 服务发布和调用
- 服务端流
- 客户端流
- 双向流
- 客户端动态获取服务端地址
- 基于eureka的注册发现
关于gRPC
- gRPC 是一个高性能、开源和通用的 RPC 框架,面向移动和 HTTP/2 设计。目前提供 C、Java 和 Go 语言版本,分别是:grpc, grpc-java, grpc-go. 其中 C 版本支持 C, C++, Node.js, Python, Ruby, Objective-C, PHP 和 C# 支持.
- gRPC 基于 HTTP/2 标准设计,带来诸如双向流、流控、头部压缩、单 TCP 连接上的多复用请求等特。这些特性使得其在移动设备上表现更好,更省电和节省空间占用。
- 各个进程之间可以通过gRPC相互调用,如下图:
核心技术
- 为了用java发布gRPC服务,我使用的是开源库net.devh:grpc-server-spring-boot-starter
- 在调用其他gRPC服务时用的是net.devh:grpc-client-spring-boot-starter
- 感谢该开源库的作者Michael大神,您的智慧的简化了java程序员的gRPC开发工作,项目地址:https://github.com/yidongnan/grpc-spring-boot-starter
本篇概览
作为系列文章的开篇,本篇要做的事情如下:
- 明确依赖库和开发环境
- 新建父工程grpc-tutorials,今后《java版gRPC实战》系列的所有源码都在这个工程中
- 实战用proto文件自动生成java代码
明确依赖库和开发环境
整个系列文章涉及的依赖库和开发环境的情况如下:
- JDK:1.8.0_281
- gradle:6.7.1
- springboot:2.3.8.RELEASE
- grpc:1.35.0
- protobuf:3.14.0
- grpc-server-spring-boot-starter:2.11.0.RELEASE
- grpc-client-spring-boot-starter:2.11.0.RELEASE
- 操作系统:win10专业版
- IDEA:2021.1 (Ultimate Edition)
源码下载
- 本篇实战中的完整源码可在GitHub下载到,地址和链接信息如下表所示(https://github.com/zq2599/blog_demos):
名称 | 链接 | 备注 |
---|---|---|
项目主页 | https://github.com/zq2599/blog_demos | 该项目在GitHub上的主页 |
git仓库地址(https) | https://github.com/zq2599/blog_demos.git | 该项目源码的仓库地址,https协议 |
git仓库地址(ssh) | git@github.com:zq2599/blog_demos.git | 该项目源码的仓库地址,ssh协议 |
- 这个git项目中有多个文件夹,《java版gRPC实战》系列的源码在grpc-tutorials文件夹下,如下图红框所示:
创建《java版gRPC实战》系列的父工程
- 新建名为grpc-tutorials的gradle工程,前面提到的库及其版本都在此工程中处理好,build.gradle内容如下:
import java.time.OffsetDateTime
import java.time.format.DateTimeFormatterbuildscript {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/releasesgrpcVersion = '1.35.0'// protobuf版本 https://github.com/protocolbuffers/protobuf/releasesprotobufVersion = '3.14.0'// protobuf的gradle插件版本protobufGradlePluginVersion = '0.8.12'// sprignboot版本 https://github.com/spring-projects/spring-boot/releasesspringBootVersion = '2.3.8.RELEASE'// springcloud版本 https://github.com/spring-cloud/spring-cloud-release/releasesspringCloudVersion = 'Hoxton.SR9'// nacos版本 https://github.com/alibaba/spring-cloud-alibaba/releasesspringCloudAlibabaNacosVersion = '2.2.3.RELEASE'// security版本 https://github.com/spring-projects/spring-security-oauth/releasesspringSecurityOAuthVersion = '2.5.0.RELEASE'}
}plugins {id 'java'id 'java-library'id 'org.springframework.boot' version "${springBootVersion}" apply falseid '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 falseid '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 {// 构建时取得当前日期和时间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_8targetCompatibility = JavaVersion.VERSION_1_8options.encoding = 'UTF-8'}compileJava.options*.compilerArgs = ['-Xlint:all', '-Xlint:-processing']// Copy LICENSEtasks.withType(Jar) {from(project.rootDir) {include 'LICENSE'into 'META-INF'}}// 写入到MANIFEST.MF中的内容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
- 整个系列用到的父工程已经完成,接下来可以开始编码了;
实战用proto文件自动生成java代码
- gRPC服务能够用不同的语言编写,其中的关键是定义服务的proto文件可以被生成各种语言的代码,java也不例外,接下来一起体验;
- 在父工程grpc-tutorials下新建模块,名为grpc-lib,其build.gradle内容如下,可见主要是配置了protobuf插件,以及生成的java代码如何才能被IDE工具加入到source path中:
// 根据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/3633implementation '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模块的src/main/proto目录下新增名为helloworld.proto的文件,这里面定义了一个gRPC服务,里面含有一个接口,并且还有这个接口的入参和返回结果的定义:
syntax = "proto3";option java_multiple_files = true;
// 生成java代码的package
option java_package = "com.bolingcavalry.grpctutorials.lib";
option java_outer_classname = "HelloWorldProto";// gRPC服务
service Simple {// 接口定义rpc SayHello (HelloRequest) returns (HelloReply) {}
}// 入参的数据结构
message HelloRequest {string name = 1;
}// 返回结果的数据结构
message HelloReply {string message = 1;
}
- proto文件已经做好,接下来要根据这个文件来生成java代码,在grpc-tutorials目录下执行命令gradle grpc-lib:generateProto,即可根据helloworld.proto文件生成java代码,执行成功后会生出下图红框中的内容,这些就是java代码:
- 本篇只聊如何生成上述代码,至于这些代码的用途就留到下一篇再说吧,这里只简单提一下,SimpleGrpc里面有抽象类SimpleImplBase,制作gRPC服务的时候需要继承该类,另外,如果您要远程调用gRPC的sayHello接口,就会用到SimpleGrpc类中的SimpleStub类,其余的HelloReply、HelloRequest这些则是入参和返回的数据结构定义;
- 至此,java版gRPC实战的准备工作就完成了,根据proto文件生成java代码的方法也掌握了,接下来的章节咱们一起尝试服务的发布和调用;
你不孤单,欣宸原创一路相伴
- Java系列
- Spring系列
- Docker系列
- kubernetes系列
- 数据库+中间件系列
- DevOps系列
欢迎关注公众号:程序员欣宸
微信搜索「程序员欣宸」,我是欣宸,期待与您一同畅游Java世界…
java版gRPC实战之一:用proto生成代码相关推荐
- java版gRPC实战之五:双向流
欢迎访问我的GitHub 这里分类和汇总了欣宸的全部原创(含配套源码):https://github.com/zq2599/blog_demos <java版gRPC实战>全系列链接 用p ...
- java版gRPC实战之四:客户端流
欢迎访问我的GitHub 这里分类和汇总了欣宸的全部原创(含配套源码):https://github.com/zq2599/blog_demos <java版gRPC实战>全系列链接 用p ...
- java版gRPC实战之三:服务端流
欢迎访问我的GitHub 这里分类和汇总了欣宸的全部原创(含配套源码):https://github.com/zq2599/blog_demos <java版gRPC实战>全系列链接 用p ...
- java版gRPC实战之五:双向流,rabbitmq持久化原理
responseObserver.onNext(DeductReply.newBuilder() .setCode(code) .setMessage(message) .build()); } @O ...
- java与es8实战之五:SpringBoot应用中操作es8(带安全检查:https、账号密码、API Key)
欢迎访问我的GitHub 这里分类和汇总了欣宸的全部原创(含配套源码):https://github.com/zq2599/blog_demos 本篇概览 本篇是<java与es8实战>系 ...
- java版溺尸掉三叉戟吗_溺尸 - Minecraft Wiki,最详细的官方我的世界百科
溺尸 20( × 10) 2() 行为 攻击型 被动型(玩家不在水中并且是白天) 攻击力 近战: 简单:2() 普通:3( ) 困难:4( ) 使用三叉戟:9( ) [仅基岩版] 远程: 使用三叉 ...
- java版溺尸哪里有_溺尸 - Minecraft Wiki
溺尸 20( × 10) 2() 行为 攻击型 被动型(玩家不在水中并且是白天) 攻击力 近战: 简单:2() 普通:3( ) 困难:4( ) 使用三叉戟:9( ) [仅基岩版] 远程: 使用三叉 ...
- 简易贪吃蛇小游戏java版_用GUI实现java版贪吃蛇小游戏
本文实例为大家分享了java版贪吃蛇小游戏的具体代码,供大家参考,具体内容如下 项目结构 新建一个JFrame窗口,作为程序入口 public class GameStart{ public stat ...
- Java版数据结构之单向链表
Java版数据结构之单向链表 我的代码仓库:https://github.com/zhuangbinan/datastructure package club.zhuangbinan.linkedli ...
最新文章
- 设计模式----模板方法模式UML和实现代码
- 蓝桥杯java第八届第四题--魔方状态
- python可视化神器_详解Python可视化神器Yellowbrick使用
- 介绍TCP/udp比较好的博客
- stl源码剖析_STL源码剖析 阅读笔记(二)allocator
- ios请求头解决参数中文乱码_花了一天时间就解决了一个的请求头传参参数格式bug...
- 链表的基本操作 java_Java_实现单链表-基本操作
- hdu1202解题报告
- python编程软件哪个好-Python开发工具哪个好?好用的Python开发工具排行榜推荐下载...
- javascript中concat方法深入理解
- [翻译]深入解析Windows操作系统(下)之第十章 内存管理
- 数字信号处理1——离散时间系统与常见信号(matlab)
- ML之LIME:可解释性之LIME/SP-LIME的简介、原理、使用方法、经典案例之详细攻略
- Android攻城狮四大组件之Service
- 【软件工程】敏捷宣言
- 青龙面板-快手极速版(每天3块脚本)
- FreeRTOS消息队列
- 幼儿园教案我和计算机比本领,幼儿园大班教案《谁的本领大》
- 甲骨文java计算机考证
- 计算机连接投影仪后黑屏咋调试,电脑连上投影仪后黑屏了,怎么处理?