Python 官方文档:入门教程 => 点击学习
一、首先声明grpc接口 这里引入的是最新的grpc-core 1.37版本, 采用的grcp-spring-boot-starter封装的版本进行实现,GitHub地址: http
这里引入的是最新的grpc-core 1.37版本, 采用的grcp-spring-boot-starter封装的版本进行实现,GitHub地址:
https://github.com/yidongnan/grpc-spring-boot-starter
要实现gRpc通讯, 先定义接口以及入参出参信息
syntax = "proto3";
option java_multiple_files = true;
option java_package = "com.grpc.spring.api.order";
option java_outer_classname = "OrderServiceProto";
// The service definition.
service OrderService {
// The service method
rpc GetOrderInfo (GetOrderRequest) returns (GetOrderReply) {
}
}
// The request message
message GetOrderRequest {
string orderNo = 1;
}
// The response message
message GetOrderReply {
string orderNo = 1;
string userName = 2;
string address = 3;
int64 price = 4;
}
定义好之后, 就需要通过protoc工具,生成对应的JAVA代码。
为便于使用, 这里封装了bat脚本,并提供了对应的protoc执行程序。
@echo off
for %%i in (proto
@GrpcService
public class GrpcOrderService extends OrderServiceGrpc.OrderServiceImplBase {
@Value("${server.port}")
private String serverPort;
@Override
public void getOrderInfo(GetOrderRequest request, StreamObserver<GetOrderReply> responseObserver) {
GetOrderReply reply =GetOrderReply.newBuilder().setOrderNo(request.getOrderNo())
.setAddress("广东省深圳市,端口号" + serverPort)
.setUserName("tester")
.setPrice(System.currentTimeMillis())
.build();
responseObserver.onNext(reply);
responseObserver.onCompleted();
}
}
要实现gRpc服务端接口, 必须做声明, 采用@GrpcService注解, 然后继承gRpc生成的接口OrderServiceGrpc,重新getOrderInfo获取订单信息接口, 实现具体的处理逻辑。
服务端的配置
application.yml
server:
port: 18082
spring:
application:
name: grpc-spring-server
grpc:
server:
port: 0
eureka:
instance:
prefer-ip-address: true
client:
reGISter-with-eureka: true
fetch-registry: false
service-url:
defaultZone: Http://${eureka.instance.hostname:eureka.kyeapi.com}:${eureka.server.port:18761}/eureka/
服务端的gRpc端口配置为0代表随机分配, gRpc服务信息会注册至eureka。
客户端的POM依赖配置
<dependencies>
<dependency>
<groupId>com.grpc.spring</groupId>
<artifactId>grpc-spring-api</artifactId>
</dependency>
<dependency>
<groupId>net.devh</groupId>
<artifactId>grpc-client-spring-boot-starter</artifactId>
<version>${gprc.spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
<version>3.0.2</version>
</dependency>
<!-- 添加 Spring Boot 依赖 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-WEB</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
<version>3.0.2</version>
<exclusions>
<exclusion>
<artifactId>servlet-api</artifactId>
<groupId>javax.servlet</groupId>
</exclusion>
</exclusions>
</dependency>
</dependencies>
加入提供的客户端依赖grpc-client-spring-boot-starter,这里注意,添加的eureka-client依赖, 要排除servlet-api, 以免启动冲突。
客户端调用实现
GrpcOrderClientService:
@Service
@Log4j2
public class GrpcOrderClientService {
@GrpcClient("grpc-server")
private OrderServiceGrpc.OrderServiceBlockingStub orderServiceBlockingStub;
public String getOrderInfo(String orderNo) {
try {
//将远程调用的Grpc服务端接口信息, 返回给客户端。
GetOrderRequest request = GetOrderRequest.newBuilder().setOrderNo(orderNo).build();
final GetOrderReply response = orderServiceBlockingStub.getOrderInfo(request);
String result = "orderNo: " + response.getOrderNo() + ", userName: " + response.getUserName() + ", address: " + response.getAddress();
return result;
}catch (Exception e) {
log.error(e.getMessage(), e);
return "error! " + e.getMessage();
}
}
}
这里通过@GrpcClient注解, 引入gRpc接口,这里的gRpc服务端名称grpc-server要与配置文件的名称保持一致。
客户端配置
application.yml
server:
port: 18080
spring:
application:
name: grpc-spring-client
grpc:
client:
grpc-server:
address: 'discovery:///grpc-spring-server'
enableKeepAlive: true
keepAliveWithoutCalls: true
neGotiationType: plaintext
eureka:
instance:
prefer-ip-address: true
status-page-url-path: /actuator/info
health-check-url-path: /actuator/health
client:
register-with-eureka: false
fetch-registry: true
service-url:
defaultZone: http://${eureka.instance.hostname:eureka.kyeapi.com}:${eureka.server.port:18761}/eureka/
这里定义了一个gRpc的连接信息grpc-server,与前面注解的名称保持一致, adress要配置gRpc服务端的名称, 不需要配置具体的IP和端口,会通过eureka来拉取服务端的具体连接信息。
启动服务
启动Eureka服务、gRpc服务端与客户端,为便于测试负载, 这里启动两个服务端实例, 端口号分别为18081与108082。
调用验证
第一调用:
第二次调用:
可以看到, 能够正常调用gRpc服务接口, 同时gRpc也是可以支持负载均衡。
最后, 需要的完整的源码, 可以从以下链接获取:
http://xiazai.jb51.net/202109/yuanma/grpcv_jb51.rar
到此这篇关于教你在Spring Boot微服务中集成gRPC通讯的方法的文章就介绍到这了,更多相关Spring Boot集成gRPC微服务内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网!
--结束END--
本文标题: 教你在Spring Boot微服务中集成gRPC通讯的方法
本文链接: https://www.lsjlt.com/news/135169.html(转载时请注明来源链接)
有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
下载Word文档到电脑,方便收藏和打印~
2024-03-01
2024-03-01
2024-03-01
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
回答
回答
回答
回答
回答
回答
回答
回答
回答
回答
0