GRPCを使用して、Javaマイクロサービスパフォーマンスを向上させます。 2。.protoファイルを通じて強力な契約を定義します。 3. MavenでGRPC依存関係を構(gòu)成し、コードを生成します。 4。GRPCサーバーロジックを?qū)g裝します。 5。クライアントからサービスを呼び出します。 6. TLS、エラー処理、サービスの発見、および観察可能性を生産環(huán)境で有効にする必要があります。手順に従って、効率的でタイプセーフマイクロサービスコミュニケーションシステムをすばやく構(gòu)築します。

それで、あなたはJavaマイクロサービスアーキテクチャを構(gòu)築しており、GRPCを使用したいですか？良い選択。特にパフォーマンスや契約の明確さを気にする場合は、サービスとサービス間のコミュニケーションに速く、効率的で、優(yōu)れています。圧倒されることなく始める方法は次のとおりです。

GRPCがJavaマイクロサービスにとって理にかなっている理由

セットアップに飛び込む前に、GRPCがマイクロサービス環(huán)境でうまく適合する理由を知るのに役立ちます。

• 高性能：HTTP/2およびバイナリシリアル化（プロトコルバッファー）を使用するため、HTTP/1.1よりもJSONよりも高速で軽量です。
• 強力な契約：サービスインターフェイスとメッセージ構(gòu)造は.protoファイルで定義されているため、APIは明示的で言語に依存しません。
• 組み込みコード生成：サービスを一度定義し、ツールはJava（およびその他の言語）のクライアントとサーバーコードを生成します。
• ストリーミングのサポート：GRPCは、サーバーストリーミング、クライアントストリーミング、およびバイデーイレクトストリーミングをサポートします。これは、リアルタイムまたはイベント駆動型パターンに役立ちます。

サービスがお互いに多くのことを話し（たとえば、注文サービス通話インベントリサービス）、GRPCは遅延を減らしてスループットを改善できます。

ステップ1：プロトコルバッファーでサービスを定義します

.protoファイルを書き込むことから始めます。これにより、データモデルとサービスインターフェイスが定義されます。

例： inventory.proto

 syntax = "proto3";

パッケージcom.example.inventory;

Service InventoryService {
  rpc getstock（stockrequest）returns（stockResponse）;
}

メッセージStockRequest {
  文字列derdic_id = 1;
}

MessageStockResponse {
  int32 available_count = 1;
}

これは、製品の在庫をチェックする簡単なサービスを定義します。複數(shù)のサービスに依存している場合は、 .protoファイルを共有場所またはパッケージに保管してください。

ステップ2：JavaプロジェクトでGRPCをセットアップします

MavenまたはGradleを使用してください。これが最小のMavenセットアップ（ pom.xml ）です。

 <依存関係>
  <依存関係>
    <groupId> io.grpc </groupId>
    <artifactid> grpc-netty-shaded </artifactid>
    <バージョン> 1.58.0 </version>
  </依存関係>
  <依存関係>
    <groupId> io.grpc </groupId>
    <artifactid> grpc-protobuf </artifactid>
    <バージョン> 1.58.0 </version>
  </依存関係>
  <依存関係>
    <groupId> io.grpc </groupId>
    <artifactid> grpc-stub </artifactid>
    <バージョン> 1.58.0 </version>
  </依存関係>
</依存関係>

<build>
  <extensions>
    <extension>
      <groupid> kr.motd.maven </groupid>
      <artifactid> os-maven-plugin </artifactid>
      <バージョン> 1.7.1 </version>
    </拡張子>
  </extensions>
  <プラグイン>
    <プラグイン>
      <groupId> org.xolstice.maven.plugins </groupId>
      <artifactid> protobuf-maven-plugin </artifactid>
      <バージョン> 0.6.1 </version>
      <configuration>
        <ProtoSourceroot> $ {project.basedir}/src/main/proto </protoSourceroot>
        <OutputDirectory> $ {project.build.directory}/generated-sources </outputDirectory>
        <ClearOutputDirectory> false </clearoutputdirectory>
      </configuration>
      <実行>
        <実行>
          <ゴール>
            <ゴール>コンパイル</goal>
            <goal>コンパイルカスタム</goal>
          </目標>
        </実行>
      </実行>
    </プラグイン>
  </プラグイン>
</build>

これを追加した後、実行してください：

 MVNコンパイル

プラグインは、サービスベースクラス、スタブ、メッセージタイプなど、 .protoファイルからJavaクラスを生成します。

ステップ3：サーバーを?qū)g裝します

生成されたInventoryServiceGrpc.InventoryServiceImplBaseを拡張するクラスを作成します。

 io.grpc.serverをインポートします。
io.grpc.serverbuilderをインポートします。
java.io.ioexceptionをインポートします。

Public Class InventoryServer {

  プライベートサーバーサーバー。

  public void start（）throws ioexception {
    server = serverbuilder.forport（8080）
        .addservice（new InventoryServiceImpl（））
        。建てる（）
        。始める（）;

    System.out.println（ "サーバーがポート8080で開始された"）;

    runtime.getRuntime（）。addshutdownhook（new Stread（（） - > {
      system.out.println（ "GRPCサーバーのシャットダウン"）;
      inventoryserver.this.stop（）;
    }））;

    blockuntilshutdown（）;
  }

  private void blockuntilshutdown（）throws arturnedexception {
    if（server！= null）{
      server.awaittermination（）;
    }
  }

  private void stop（）{
    if（server！= null）{
      server.shutdown（）;
    }
  }

  public static void main（string [] args）throws ioexception、arternedexception {
    new InventoryServer（）。start（）;
  }

  static class inventoryserviceimplはinventoryservicegrpc.inventoryserviceimplbaseを拡張します{
    @オーバーライド
    public void getstock（stockrequest request、strameobserver <StockResponse> ResponseObserver）{
      //ロジックをシミュレートします
      int stock = "p123" .equals（request.getProductid（））？ 42：0;

      stockResponse応答= stockResponse.newBuilder（）
          .setavailablecount（stock）
          。建てる（）;

      ResponseObserver.onnext（response）;
      ResponseObServer.OnCompleted（）;
    }
  }
}

それだけです - あなたは動作するGRPCサーバーを持っています。

ステップ4：別のマイクロサービス（クライアント）からサービスを呼び出す

次に、呼び出しサービス（たとえば、注文サービス）で、GRPCクライアントを作成します。

 Public Class InventoryClient {

  プライベート最終inventoryServiceGrpc.inventoryServiceBlockingStubブロッキングスタブ。

  public InventoryClient（String Host、int port）{
    ManagedChannel Channel = ManageedChannelBuilder.ForAddress（ホスト、ポート）
        .useplaintext（）// TLSなしで生産で使用しないでください
        。建てる（）;

    blockingStub = inventoryServiceGrpc.NewBlockingStub（Channel）;
  }

  public int getstock（String ProductID）{
    stockRequest request = stockRequest.NewBuilder（）。setProductid（ProductID）.build（）;
    stockResponse応答= blockingStub.getStock（リクエスト）;
    RESPORDS.GETAVAILABLECOUNT（）;
  }
}

次のように使用してください：

 InventoryClient Client = new InventoryClient（ "localhost"、8080）;
int stock = client.getStock（ "p123"）;
System.out.println（ "stock：" stock）;

実際の使用のためのヒント

• 生産でTLSを使用します。サービス間の暗號化を常に有効にします。 GRPCは、箱から出してSSL/TLSをサポートしています。
• GRPCステータスコードを使用したエラーを処理します。クリーンエラーの伝播にStatusとStatusException使用します。
• サービスディスカバリーと統(tǒng)合：GRPCをConsul、Eureka、Kubernetes DNSなどのツールとペアにします。
• 観察可能性を追加：ロギング、メトリック（マイクロメーターなど）、および分散トレース（例：Opentelemetry）にインターセプターを使用します。
• 緊密な結(jié)合を避けてください： .protoファイルが契約を定義している場合でも、それらを慎重にバージョンし、頻繁に変更を避けます。

まとめ

Java MicroservicesセットアップのGRPCにより、速度、安全性、クリーンなインターフェイスが得られます。小さいことを開始：1つのサービスを定義し、実行して、別のサービスから呼び出します。快適になったら、ストリーミング、認証、監(jiān)視を追加してください。

常に正しい選択ではありません（たとえば、ブラウザのクライアントが必要な場合）が、バックエンド通信通信の場合、打ち負かすのは難しいです。

基本的に、 .protoを定義し、コードを生成し、サーバーを?qū)g裝し、クライアントからの呼び出しを行うと、ローリングしています。

以上がJavaマイクロサービスアーキテクチャのGRPCを開始しますの詳細內(nèi)容です。詳細については、PHP 中國語 Web サイトの他の関連記事を參照してください。