SpringBoot使用GRPC框架(服务端)

这篇具有很好参考价值的文章主要介绍了SpringBoot使用GRPC框架(服务端)。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

概述:

GRPC是什么? 首先我们知道 RPC是远程过程调用。

而GRPC是RPC的一种实现。 那么为什么要用GRPC呢?

因为它支持跨语言的开发,换句话说,大家都用过FeignRPC,尤其在spring cloud中。

然而它只支持java语言,而作为微服务,可能有很多其他的服务不是java开发的。

因此需要满足这个需求,就需要一个跨语言的RPC,所以就会考虑使用GRPC

使用流程(服务端):

流程:

先创建一个普通的Maven项目

导入依赖

 文章来源地址https://www.toymoban.com/news/detail-669795.html

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.5.6</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.leadtrans</groupId>
    <artifactId>report</artifactId>
    <version>1.6.0</version>
    <name>report</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>11</java.version>
        <spring-cloud.version>2020.0.4</spring-cloud.version>
        <!--    GRPC    -->
        <grpc-spring-boot-starter.version>2.3.2</grpc-spring-boot-starter.version>
        <os-maven-plugin.version>1.6.0</os-maven-plugin.version>
        <protobuf-maven-plugin.version>0.5.1</protobuf-maven-plugin.version>
    </properties>
    <dependencies>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.78</version>
        </dependency>

        <!--    GRPC    -->
        <dependency>
            <groupId>org.lognet</groupId>
            <artifactId>grpc-spring-boot-starter</artifactId>
            <version>${grpc-spring-boot-starter.version}</version>
        </dependency>

    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <build>
        <extensions>
            <!-- os-maven-plugin -->
            <extension>
                <groupId>kr.motd.maven</groupId>
                <artifactId>os-maven-plugin</artifactId>
                <version>${os-maven-plugin.version}</version>
            </extension>
        </extensions>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-surefire-plugin</artifactId>
                <configuration>
                    <skip>true</skip>
                </configuration>
            </plugin>
            <!-- protobuf-maven-plugin -->
            <plugin>
                <groupId>org.xolstice.maven.plugins</groupId>
                <artifactId>protobuf-maven-plugin</artifactId>
                <version>${protobuf-maven-plugin.version}</version>
                <configuration>
                    <protocArtifact>com.google.protobuf:protoc:3.5.1-1:exe:${os.detected.classifier}</protocArtifact>
                    <pluginId>grpc-java</pluginId>
                    <pluginArtifact>io.grpc:protoc-gen-grpc-java:1.11.0:exe:${os.detected.classifier}</pluginArtifact>
                    <outputDirectory>${project.build.sourceDirectory}</outputDirectory>
                    <clearOutputDirectory>false</clearOutputDirectory>
                </configuration>
                <executions>
                    <execution>
                        <goals>
                            <goal>compile</goal>
                            <goal>compile-custom</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
        </plugins>
    </build>

</project>

创建proto文件夹:

proto文件夹必须和java文件夹同级

grpc-spring-boot-starter,spring boot,java,spring,rpc

 

在文件夹下创建proto文件:

HelloWorld.protp

syntax = "proto3";

option java_multiple_files = true;
//生成grpc封装各种类的路径, 必须和SpringBoot启动类同级或更低
option java_package="com.example.test.helloworld";

//请求
message Request {
  double num1 = 1;
  double num2 = 2;
  OperateType opType = 3;
}

//操作类型
enum OperateType {
  Addition = 0;
  Division = 1;
  Multiplication = 2;
  Subtraction = 3;
}
//响应
message Response {
  double result = 1;
}

//定义服务
service Operate {
  rpc Calculate (Request) returns (Response);
}

 

按顺序执行指令

 grpc-spring-boot-starter,spring boot,java,spring,rpc

执行完之后会生成如下代码

grpc-spring-boot-starter,spring boot,java,spring,rpc 

实现接口接收请求:

grpc-spring-boot-starter,spring boot,java,spring,rpc

 代码:

package com.hsy.test.helloworld;

import io.grpc.stub.StreamObserver;
import org.lognet.springboot.grpc.GRpcService;

@GRpcService
public class OperateImpl extends OperateGrpc.OperateImplBase {
    @Override
    public void calculate(Request request,
                          StreamObserver<Response> responseObserver) {
        Response response=Response.newBuilder().setResult(2).build();
        System.out.println(response);
        responseObserver.onNext(response);
        responseObserver.onCompleted();
    }
}

 注意事项:

grpc-spring-boot-starter,spring boot,java,spring,rpc

 

proto文件解释:

grpc-spring-boot-starter,spring boot,java,spring,rpc

 grpc返回集合数据:

在  gRPC  中,可以使用消息类型(Message)来表示集合。通常使用  Protocol  Buffers  来定义  gRPC  中的消息类型。

假设定义了一个  User  消息类型:

proto文件:

syntax = "proto3";

message User {
  int32 id = 1;
  string name = 2;
  string email = 3;
}

 如果要返回一个包含多个  User  对象的集合,可以定义一个消息类型,将多个  User  对象放在一个列表中。修改  UserList.proto  文件,添加一个新的消息类型  UserList:


message UserList {
  repeated User users = 1;
}

 在上面的定义中,使用了`repeated`  字段类型,表示该字段可以包含重复的值,也就是一个集合。

 

完整proto文件:

syntax = "proto3";

option java_multiple_files = true;
//生成grpc封装各种类的路径, 必须和SpringBoot启动类同级或更低
option java_package="com.hsy.test.user";

//对象的属性
message User {
  int32 id = 1;
  string name = 2;
  string email = 3;
}

//定义集合数据
message UserList {
  repeated User users = 1;
}

//请求
message UserRequest {
  string type = 1;
}

//响应
message UserResponse {
  UserList result = 1;
}

//定义服务
service Users {
  rpc list (UserRequest) returns (UserResponse);
}

响应接口实现:

@GRpcService
public class UserOperateImpl extends UsersGrpc.UsersImplBase {

    @Override
    public void list(UserRequest request, StreamObserver<UserResponse> responseObserver) {
        //根据名称获取参数
        String type = request.getType();
        //创建一个几个准备测试数据
        ArrayList<UserAA> users = new ArrayList<>();
        users.add(new UserAA(1, "zhangs", "aaaa@163.com"));
        users.add(new UserAA(2, "lisi", "bbb@163.com"));
        users.add(new UserAA(3, "wangwu", "ccc@163.com"));
        //使用UserList的构建器创建一个新的 UserList.Builder对象
        UserList.Builder userList = UserList.newBuilder();
        //list.forEach(c ->{...}); 遍历 list 列表,对每个元素执行 lambda 表达式中的代码块。
        users.forEach(
                c -> {
                    //创建一个新的 StoreSystemBean.Builder 对象,并设置其属性值,然后将其添加到 resList 中。
                    User.Builder bean = User.newBuilder()
                            .setId(c.getId())
                            .setName(c.getName())
                            .setEmail(c.getEmail());
                    userList.addUsers(bean);
                }
        );
        //使用 StoreResponse 的构建器创建一个新的响应对象,并将其设置为包含 resList 的结果
        UserResponse response = UserResponse.newBuilder().setResult(userList).build();
        //将响应对象返回给客户端。
        responseObserver.onNext(response);
        //通知客户端,该调用已完成。
        responseObserver.onCompleted();

    }

}

实现类与proto文件的对应关系

grpc-spring-boot-starter,spring boot,java,spring,rpc

 设置grpc服务的端口号:

方式一:

在  gRPC  中,服务端和客户端通过网络进行通信,服务端必须公开端口来侦听客户端请求。在  gRPC  中为侦听客户端请求,通常可以通过以下方式来设置端口号:

1.  在  gRPC  Server  启动时,指定端口号。  在  Java  中,启动  gRPC  Server  时可以使用  ServerBuilder  组件指定端口号和其他配置。例如:

在SpringBoot启动类中的main方法中添加如下代码

Server server = ServerBuilder.forPort(8088)
                      .addService(new MyServiceImpl())
                      .build();
server.start();

方式二:

使用  gRPC  Server  上提供的绑定  API。  gRPC  Server  提供了一个绑定  API,允许您在指定的  IP  和端口绑定服务。例如:

在SpringBoot启动类中的main方法中添加如下代码

Server server = ServerBuilder.forAddress(new InetSocketAddress("localhost", 8080))
                      .addService(new MyServiceImpl())
                      .build();
server.start();

在上述示例中,通过绑定地址  'localhost'  和端口  '8080',可以将  gRPC  服务绑定到本地主机上的该端口上。

方式三:

在升级到gRPC  v1.34及之后的版本中,还可以使用使用Bootstrap和SystemProperty配置端口的方式如下:

在SpringBoot启动类中的main方法 中添加如下代码

Bootstrap b = new Bootstrap();
b.group(new NioEventLoopGroup())
 .channel(EpollSocketChannel.class)
 .handler(new ChannelInitializer<SocketChannel>() {
     @Override
     protected void initChannel(SocketChannel ch) throws Exception {
         ChannelPipeline p = ch.pipeline();
         p.addLast(new GrpcClientInitializer());
     }
 });
System.setProperty("grpc.port", "8080");
ChannelFuture f = b.connect("localhost", Integer.parseInt(System.getProperty("grpc.port")));

在这种方式中,我们将grpc.port属性设置为端口号,而后使用Bootstrap配置客户端。

无论使用哪种方式来设置端口号,都需要确保端口号未被其他应用程序占用,并且需要部署到能够访问其所在网络的位置。

测试方式:

按图走

使用的是APIPOST工具grpc-spring-boot-starter,spring boot,java,spring,rpc

grpc-spring-boot-starter,spring boot,java,spring,rpc 

grpc-spring-boot-starter,spring boot,java,spring,rpc 

grpc-spring-boot-starter,spring boot,java,spring,rpc 

 

到了这里,关于SpringBoot使用GRPC框架(服务端)的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • [golang 微服务] 4. gRPC介绍,Protobuf结合gRPC 创建微服务

    gRPC是一个 高性能 、 开源 和 通用 的 RPC 框架 , 面向移动端 和 HTTP/2 设计,目前提供 C、Java 和 Go语言版本,分别是:grpc, grpc-java, grpc-go, 其中 C 版本支持 C, C++, Node.js, Python, Ruby, Objective-C, PHP 和 C# 支持 (1).提供几乎所有主流语言的实现, 打破语言隔阂 (2). 基于 HTTP/2 标准设计

    2024年02月04日
    浏览(45)
  • GRPC的学习(高性能远程过程调用框架)

    在一次和公司的人工智能部门的对接中,涉及到了grpc接口,实现的是实时语音流转文字。把自己对grpc的理解归纳出博客,并且分享出来。我会围绕几个点进行展开,gprc和rpc的差别,以及分析下优缺点,最后通过一个实例。 技术一GRPC和RPC的区别 通信协议:RPC使用的通信协议

    2024年02月13日
    浏览(37)
  • golang 通用的 grpc http 基础开发框架

    golang 通用的 grpc http 基础开发框架 仓库地址: https://github.com/webws/go-moda 仓库一直在更新,欢迎大家吐槽和指点 transport: 集成 http(echo、gin)和 grpc。 tracing: openTelemetry 实现微务链路追踪 pprof: 分析性能 config: 通用的配置文件读取模块,支持 toml、yaml 和 json 格式。 logger: 日志系统

    2024年02月10日
    浏览(38)
  • SpringBoot集成Dubbo启用gRPC协议

    本文记录下SpringBoot集成Dubbo启用gRPC协议,以及与原生 gRPC 在代码编写过程中的区别。 下面还有投票,帮忙投个票👍 2023.6.30 补充:Dubbo 官方文档开放,为开发者使用提供友好的支持。 Dubbo 在 2.7.5 版本开始支持原生 gRPC 协议,对于计划使用 HTTP/2 通信或者期望 gRPC 协议支持服

    2023年04月12日
    浏览(45)
  • [golang 微服务] 6. GRPC微服务集群+Consul集群+grpc-consul-resolver案例演示

    上一节讲解了consul集群: [golang 微服务] 5. 微服务服务发现介绍,安装以及consul的使用,Consul集群,这样的话,当一台server挂掉之后,集群就会从另一台server中获取服务,这就保证了客户端访问consul集群的负载均衡性. 这里还有一个问题: 就是当终端的对应的 微服务挂掉 了,consul集群se

    2024年02月09日
    浏览(39)
  • 深入剖析gRPC:Google开源的高性能RPC框架

    在本篇文章中,我们将深入剖析gRPC,Google开源的高性能RPC框架。gRPC是一种基于HTTP/2的高性能、可扩展的RPC框架,它使用Protocol Buffers作为接口定义语言,可以在多种编程语言之间实现无缝通信。 gRPC的核心设计理念是:通过使用HTTP/2作为传输协议,实现高效、可扩展的RPC通信

    2024年02月19日
    浏览(50)
  • springboot+grpc+k8s+istio环境

    2023年8月17日,本人之前使用过nacos+dubbo+springboot、eureka+feign等环境。最近学习到了istio服务网格集成到k8s也可以实现分布式微服务。 Kubernetes集群 istio集成到k8s jdk17 (8也ok) gPRC服务间通信 cloud-config服务是spring-cloud-config-server配置中心,用于加载远程配置文件,该服务端口号8081

    2024年02月12日
    浏览(41)
  • Jmeter 实现 grpc服务 压测

    网上有很多安装与配置文章,在此不做赘述 插件下载地址:JMeter Plugins :: JMeter-Plugins.org  将下载文件解压后放到Jmeter安装目录下  /lib/ext  然后在终端输入 Jmeter 即可打开 Jmeter GUI界面。 1)添加线程组:右键单击测试计划 → 添加 → 线程(用户) → 线程组 2) 添加GRPC Request:

    2024年02月08日
    浏览(55)
  • 基于protobuf构建grpc服务

    protobuf是谷歌开源的一种数据格式,适合高性能,对响应速度有要求的数据传输场景。因为profobuf是二进制数据格式,需要编码和解码。数据本身不具有可读性。因此只能反序列化之后得到真正可读的数据。 优势: 序列化后体积相比Json和XML很小,适合网络传输 支持跨平台多

    2024年02月02日
    浏览(46)
  • 【微服务】03-HttpClientFactory与gRpc

    1.1 核心能力 管理内部HttpMessageHandler的生命周期,灵活应用资源问题和DNS刷新问题 支持命名化、类型化配置,集中管理配置,避免冲突 灵活的出站请求管道配置,轻松管理请求声明周期 内置管道最外层和最内层日志记录器,有Information和Trace输出 1.2 核心对象 HttpClient HttpMes

    2024年02月11日
    浏览(28)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包