欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

SpringBoot微服務(wù)中集成gRPC的實(shí)踐指南

 更新時(shí)間:2025年07月11日 09:51:50   作者:淺沫云歸  
這篇文章主要為大家詳細(xì)介紹了SpringBoot微服務(wù)中集成gRPC的相關(guān)知識(shí),文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下

一、業(yè)務(wù)場景描述

在某電商系統(tǒng)中,推薦服務(wù)、庫存服務(wù)、訂單服務(wù)等微服務(wù)需要高效、雙向流式通信,REST+HTTP已無法滿足低延遲、高并發(fā)和嚴(yán)格類型安全的需求。為此,我們選擇在Spring Boot微服務(wù)中集成gRPC,提升服務(wù)間調(diào)用性能,并充分利用protobuf帶來的強(qiáng)類型和跨語言支持。

二、技術(shù)選型過程

常見方案對比:

  • REST+JSON:簡單易用,但網(wǎng)絡(luò)開銷大、序列化性能受限;
  • WebSocket:支持雙向通信,但消息協(xié)議需自定義,開發(fā)成本高;
  • gRPC:基于HTTP/2、支持雙向流和流控,性能優(yōu)越,自動(dòng)生成服務(wù)、客戶端代碼。

最終選型:gRPC。主要理由:

  • 基于HTTP/2,多路復(fù)用和二進(jìn)制壓縮;
  • protobuf自動(dòng)生成Java代碼,強(qiáng)類型校驗(yàn);
  • 支持流式RPC,便于實(shí)時(shí)數(shù)據(jù)處理;
  • 社區(qū)成熟,Spring生態(tài)已有starter。

三、實(shí)現(xiàn)方案詳解

3.1 構(gòu)建項(xiàng)目結(jié)構(gòu)

spring-grpc-demo/
├── proto/
│   └── order.proto
├── service-provider/
│   ├── src/main/java/...
│   └── build.gradle
├── service-consumer/
│   ├── src/main/java/...
│   └── build.gradle
└── common/
    └── build.gradle

3.2 Protobuf定義(order.proto)

syntax = "proto3";
package com.example.order;

option java_multiple_files = true;
option java_package = "com.example.order.proto";
option java_outer_classname = "OrderProto";

service OrderService {
  // 下單RPC
  rpc CreateOrder (OrderRequest) returns (OrderReply);
  // 實(shí)時(shí)訂單狀態(tài)流
  rpc WatchOrderStatus (OrderRequest) returns (stream OrderStatus);
}

message OrderRequest {
  int64 userId = 1;
  repeated int64 productIds = 2;
}

message OrderReply {
  int64 orderId = 1;
  string status = 2;
}

message OrderStatus {
  int64 orderId = 1;
  string status = 2;
  int64 timestamp = 3;
}

3.3 Service-Provider配置

build.gradle

plugins {
    id 'java'
    id 'com.google.protobuf' version '0.8.18'
    id 'org.springframework.boot' version '2.7.5'
}

dependencies {
    implementation 'org.springframework.boot:spring-boot-starter'
    implementation 'net.devh:grpc-server-spring-boot-starter:2.13.1.RELEASE'
    compile project(':common')
}

protobuf {
    protoc { artifact = "com.google.protobuf:protoc:3.19.4" }
    generatedFilesBaseDir = "$projectDir/src/main/java"
} 

Spring Boot啟動(dòng)類

@SpringBootApplication
public class OrderServiceProviderApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderServiceProviderApplication.class, args);
    }
}

OrderServiceImpl

@GRpcService
public class OrderServiceImpl extends OrderServiceGrpc.OrderServiceImplBase {

    @Override
    public void createOrder(OrderRequest req, StreamObserver<OrderReply> responseObserver) {
        // 模擬下單邏輯
        long orderId = IdGenerator.nextId();
        OrderReply reply = OrderReply.newBuilder()
            .setOrderId(orderId)
            .setStatus("CREATED")
            .build();
        responseObserver.onNext(reply);
        responseObserver.onCompleted();
    }

    @Override
    public void watchOrderStatus(OrderRequest req, StreamObserver<OrderStatus> responseObserver) {
        // 模擬訂單狀態(tài)推送
        long orderId = 12345L;
        for (String status : Arrays.asList("CREATED","PROCESSING","SHIPPED","DELIVERED")) {
            OrderStatus os = OrderStatus.newBuilder()
                    .setOrderId(orderId)
                    .setStatus(status)
                    .setTimestamp(System.currentTimeMillis())
                    .build();
            responseObserver.onNext(os);
            try { Thread.sleep(1000); } catch (InterruptedException ignored) {}
        }
        responseObserver.onCompleted();
    }
}

application.yml

server:
  port: 9090
grpc:
  server:
    port: 9090
    enable-tls: false

3.4 Service-Consumer配置

build.gradle

plugins {
    id 'java'
    id 'com.google.protobuf' version '0.8.18'
    id 'org.springframework.boot' version '2.7.5'
}

dependencies {
    implementation 'org.springframework.boot:spring-boot-starter'
    implementation 'net.devh:grpc-client-spring-boot-starter:2.13.1.RELEASE'
    compile project(':common')
}

protobuf {
    protoc { artifact = "com.google.protobuf:protoc:3.19.4" }
    generatedFilesBaseDir = "$projectDir/src/main/java"
}

gRPC客戶端調(diào)用示例

@Service
public class OrderClient {

    @GrpcClient("order-service")
    private OrderServiceGrpc.OrderServiceBlockingStub blockingStub;

    public void createAndWatch() {
        OrderRequest req = OrderRequest.newBuilder()
                .setUserId(1001)
                .addProductIds(2001)
                .build();
        OrderReply reply = blockingStub.createOrder(req);
        System.out.println("Order Created: " + reply.getOrderId());

        // 訂閱狀態(tài)流
        blockingStub.withDeadlineAfter(10, TimeUnit.SECONDS)
                     .watchOrderStatus(req)
                     .forEachRemaining(status -> 
                         System.out.println("Status: " + status.getStatus())
                     );
    }
}

application.yml

grpc:
  client:
    order-service:
      address: static://localhost:9090
      enable-tls: false

四、踩過的坑與解決方案

1.Protobuf版本沖突:

  • 問題:不同模塊依賴的protobuf版本不一致,生成代碼不兼容。
  • 解決:統(tǒng)一使用com.google.protobuf:protoc:3.19.4,在根build.gradle中強(qiáng)制版本管理。

2.gRPC端口沖突:

  • 問題:Spring Boot默認(rèn)端口與gRPC服務(wù)端口共用導(dǎo)致沖突。
  • 解決:在application.yml中分別配置server.portgrpc.server.port

3.Deadline超時(shí)異常:

  • 問題:默認(rèn)無超時(shí)時(shí)間,生產(chǎn)環(huán)境下客戶端無限等待。
  • 解決:使用withDeadlineAfterwithDeadline設(shè)置合理超時(shí)。

4.流式RPC卡頓:

  • 問題:無流控或心跳時(shí)長連接容易被防火墻中斷。
  • 解決:配置HTTP/2 keepAlive(grpc.server.keepAliveTime)或底層TCP心跳。

五、總結(jié)與最佳實(shí)踐

  • 充分利用protobuf定義協(xié)議,保持向前兼容性。
  • 在生產(chǎn)環(huán)境中開啟TLS加密,保障通信安全。
  • 合理設(shè)置Deadline,避免資源長時(shí)間被占用。
  • 對重要RPC接口添加鏈路追蹤(Spring Cloud Sleuth或OpenTelemetry)。
  • 根據(jù)QPS和機(jī)器性能調(diào)整gRPC線程池和流控參數(shù)。
  • 在Kubernetes環(huán)境下,可結(jié)合gRPC Load Balancer(DNS、Envoy等)實(shí)現(xiàn)灰度發(fā)布與高可用。
  • 定期分析堆棧與日志,提前發(fā)現(xiàn)長尾請求和性能瓶頸。

到此這篇關(guān)于SpringBoot微服務(wù)中集成gRPC的實(shí)踐指南的文章就介紹到這了,更多相關(guān)SpringBoot集成gRPC內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • Java實(shí)現(xiàn)List集合轉(zhuǎn)樹形結(jié)構(gòu)的示例詳解

    Java實(shí)現(xiàn)List集合轉(zhuǎn)樹形結(jié)構(gòu)的示例詳解

    在開發(fā)中,我們通常需要將從數(shù)據(jù)庫中查詢的集合數(shù)據(jù)轉(zhuǎn)換成類似文件系統(tǒng)一樣的樹形集合。本文將利用Java語言實(shí)現(xiàn)這一功能,感興趣的可以了解一下
    2022-08-08
  • idea mybatis配置log4j打印sql語句的示例

    idea mybatis配置log4j打印sql語句的示例

    本篇文章主要介紹了idea mybatis配置log4j打印sql語句的示例,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧
    2018-01-01
  • Spring使用hutool的HttpRequest發(fā)送請求的幾種方式

    Spring使用hutool的HttpRequest發(fā)送請求的幾種方式

    Spring HttpRequest是指Spring框架中的一個(gè)對象,它代表了HTTP客戶端發(fā)送給Web服務(wù)器的一次請求,本文給大家介紹了Spring使用hutool的HttpRequest發(fā)送請求的幾種方式,并通過代碼示例講解的非常詳細(xì),需要的朋友可以參考下
    2024-11-11
  • vue 實(shí)現(xiàn)刪除對象的元素 delete

    vue 實(shí)現(xiàn)刪除對象的元素 delete

    這篇文章主要介紹了vue 實(shí)現(xiàn)刪除對象的元素delete,具有很好的參考價(jià)值,希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2022-03-03
  • java Date類詳解及使用總結(jié)

    java Date類詳解及使用總結(jié)

    這篇文章主要介紹了java Date類詳解及使用總結(jié)的相關(guān)資料,需要的朋友可以參考下
    2017-02-02
  • 攜程Apollo(阿波羅)安裝部署以及java整合實(shí)現(xiàn)

    攜程Apollo(阿波羅)安裝部署以及java整合實(shí)現(xiàn)

    這篇文章主要介紹了攜程Apollo(阿波羅)安裝部署以及java整合實(shí)現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2019-08-08
  • 一篇文章帶你了解Java方法的使用

    一篇文章帶你了解Java方法的使用

    這篇文章主要給大家介紹了關(guān)于Java中方法使用的相關(guān)資料,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2021-08-08
  • Java數(shù)據(jù)結(jié)構(gòu)之List的使用總結(jié)

    Java數(shù)據(jù)結(jié)構(gòu)之List的使用總結(jié)

    List是Java中比較常用的集合類,指一系列存儲(chǔ)數(shù)據(jù)的接口和類,可以解決復(fù)雜的數(shù)據(jù)存儲(chǔ)問題,本文就來拿實(shí)際案例總結(jié)介紹一下List的使用方法,感興趣的朋友快來看看吧
    2021-11-11
  • SpringBoot響應(yīng)出現(xiàn)中文亂碼的解決方法

    SpringBoot響應(yīng)出現(xiàn)中文亂碼的解決方法

    這篇文章主要介紹了SpringBoot響應(yīng)出現(xiàn)中文亂碼的解決方法,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作有一定的參考價(jià)值,需要的朋友們下面隨著小編來一起來學(xué)習(xí)吧
    2024-02-02
  • Mybatis中如何設(shè)置sqlSession自動(dòng)提交

    Mybatis中如何設(shè)置sqlSession自動(dòng)提交

    在MyBatis中,默認(rèn)情況下,獲取的SqlSession對象不會(huì)自動(dòng)提交事務(wù),這意味著在進(jìn)行更新、刪除或插入等操作后,需要顯式調(diào)用commit方法來提交事務(wù),但是,可以在獲取SqlSession時(shí)通過將openSession方法的參數(shù)設(shè)置為true
    2024-09-09

最新評論