网站首页 > java教程 正文
后端系统大多都是微服务的架构,而且还可能同时有多种语言实现的微服务,比如 java、go、python、c++、node 等。
那么问题来了,多种语言实现的微服务之间如何通信呢?
有的同学会说 http 不就行?
但 http 是文本传输,通信效率低。更重要的是这些微服务并不会提供 http 接口,因为它们又不是直接面向客户端的。
跨语言调用服务一般会用 gRPC,它是 google 出的一种跨语言的远程方法调用的方案。
其中,RPC 是 Remote Procedure Call,远程过程调用。
比如 java 微服务有个方法 aaa,node 微服务想调用它,就可以通过 gRPC 来实现。
今天我们就来用一下 gRPC。
当然,我们不会真的创建 java 的微服务,而是会用两个 nest 的微服务之间实现 gRPC 通信。
在 java、phthon、go 等语言的微服务里,接入 gRPC 都是类似的。
我们创建个 nest 项目:
我们用 monorepo 的形式来放 client 和 server 的代码。
执行:
这样,就有了两个 nest 的 application:
改下 grpc-server 的启动端口号为 3001:
分别把两个 nest 应用跑起来:
浏览器访问下:
这就代表两个 nest 应用都跑起来了。
然后我们把 grpc-server 改造成 grpc 的微服务。
安装用到的微服务的包:
grpc 的包:
修改下 grpc-server 的 main.ts
微服务不需要暴露 http 端口,只需要提供微服务之间通信的 tcp 接口就行。
这里使用 createMicroservice 创建微服务,指定传输方式 transport 改为 GRPC,并且指定微服务监听端口为 8888。
然后在 options 指定 protoPath。
在 src 下创建这个对应的文件:
这是一种叫做 protocol buffer 的语法。
我们安装个语法高亮插件
搜索 ext:proto,也就是处理 .proto 文件的插件:
安装之后就有语法高亮了:
为什么要有一种 protocol buffer 的语法呢?
因为要跨语言通信,不同语言的语法又不一样,那怎么通信呢?
定义一种用于通信的语言,各种语言都支持这种语法的解析不就行了?
这就是为什么会有 protocol buffer。
这些语法也很容易看懂:
是使用 proto3 版本的语法。
是当前包为 book,也就是一种命名空间。
这个就是定义当前服务可以远程调用的方法。
有一个 FindBook 方法,参数是 BookById,返回值是 Book
然后下面就是参数和返回值的消息格式:
book.proto 只是定义了可用的方法和参数返回值的格式,我们还要在 controller 里实现对应的方法:
实现了 findBook 方法,并通过 @GrpcMethod 把它标识为 grpc 的远程调用的方法。
在 nest-cli.json 添加 assets 配置,让 nest 在 build 的时候把 proto 也复制到 dist 目录下:
把它跑起来:
这时 dist 下就有 grpc-server 的代码了:
然后我们在 grpc-client 里连上它:
在 AppModule 里添加连接 grpc-server 的微服务的配置:
同样,客户端也是需要 proto 文件的,不然不知道怎么解析协议数据。
把 book/book.proto 文件复制过来:
然后在 AppController 里实现调用远程方法的逻辑:
注入 BOOK_PACKAGE 的 grpc 客户端对象。
在 onModuleInit 的时候调用 getService 方法,拿到 BookService 的实例。
然后调用它的 findBook 方法。
把它跑起来:
浏览器访问下:
可以看到,远程方法调用成功了。
这就是基于 grpc 的远程方法调用,用 java、python、go、c++ 等实现的微服务也是这样来通信。
通过 protocol buffer 的语法定义通信数据的格式,比如 package、service 等。
然后 server 端实现 service 对应的方法,client 端远程调用这个 service。
比如在 java 的 srping 里,需要安装这两个依赖:
然后也是定义这样的 proto 文件:
之后定义对应的 servie:
和 node 里差不多。
这样就能跨语言调用对方的方法了。
案例代码上传了 github:
https://github.com/QuarkGluonPlasma/nestjs-course-code/tree/main/grpc-client
总结
今天我们学习了基于 gRPC 的远程方法调用。
不同语言的微服务之间可以基于 gRPC 来相互调用对方的方法。
它的实现方式是通过 protocol buffer 的语法来定义通信数据的格式,定义 package、service。
然后 server 端实现 service 对应的方法,client 端远程调用这些 service。
这样就可以实现在 java、node、go、python 等多种语言之间实现微服务的远程方法调用。
如果你写一个 Node 的 BFF 层,调用别的语言的微服务时就会用到 gRPC。
原文链接:https://juejin.cn/post/7279918033531027456
猜你喜欢
- 2024-10-16 第三方接口调用方案设计(第三方接口调用方式)
- 2024-10-16 java连接数据库的常见问题及解决办法
- 2024-10-16 Java Servlet实现Hessian接口调用
- 2024-10-16 Java调用外部程序的疑惑?(java调用外部类)
- 2024-10-16 Spring6.1新特性,四种方式调用REST接口(RestClient...)
- 2024-10-16 netty系列之:使用netty搭建websocket客户端
- 2024-10-16 Java 中的 Http 客户端 API:身份验证
- 2024-10-16 axis2客户端调用免费的webservice服务的实例
- 2024-10-16 程序员2022年你不懂RPC远程过程调用,RPC框架的话真的要被淘汰了
- 2024-10-16 K8S官方java客户端之五:proto基本操作
你 发表评论:
欢迎- 最近发表
- 标签列表
-
- java反编译工具 (77)
- java反射 (57)
- java接口 (61)
- java随机数 (63)
- java7下载 (59)
- java数据结构 (61)
- java 三目运算符 (65)
- java对象转map (63)
- Java继承 (69)
- java字符串替换 (60)
- 快速排序java (59)
- java并发编程 (58)
- java api文档 (60)
- centos安装java (57)
- java调用webservice接口 (61)
- java深拷贝 (61)
- 工厂模式java (59)
- java代理模式 (59)
- java.lang (57)
- java连接mysql数据库 (67)
- java重载 (68)
- java 循环语句 (66)
- java反序列化 (58)
- java时间函数 (60)
- java是值传递还是引用传递 (62)
本文暂时没有评论,来添加一个吧(●'◡'●)