亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

java grpc怎樣進行服務調用

小樊
83
2024-11-15 23:17:20
欄目: 編程語言

在Java中使用gRPC進行服務調用,你需要遵循以下步驟:

  1. 添加gRPC依賴

在你的項目中添加gRPC的Java庫依賴。如果你使用Maven,可以在pom.xml文件中添加以下依賴:

<dependency>
  <groupId>io.grpc</groupId>
  <artifactId>grpc-netty-shaded</artifactId>
  <version>1.42.1</version>
</dependency>
<dependency>
  <groupId>io.grpc</groupId>
  <artifactId>grpc-protobuf</artifactId>
  <version>1.42.1</version>
</dependency>
<dependency>
  <groupId>io.grpc</groupId>
  <artifactId>grpc-stub</artifactId>
  <version>1.42.1</version>
</dependency>
  1. 定義服務接口

創建一個.proto文件,定義你的服務接口。例如,創建一個名為greeter.proto的文件:

syntax = "proto3";

package greeter;

service Greeter {
  rpc SayHello (HelloRequest) returns (HelloReply) {}
}

message HelloRequest {
  string name = 1;
}

message HelloReply {
  string message = 1;
}
  1. 生成Java代碼

使用protoc編譯器生成Java代碼。在命令行中運行以下命令:

protoc --java_out=./src/main/java --grpc_out=./src/main/java --plugin=protoc-gen-grpc=`which grpc_java_plugin` greeter.proto

這將在src/main/java目錄下生成Java代碼,包括服務接口、請求和響應類。

  1. 實現服務

創建一個實現上述服務接口的類。例如,創建一個名為GreeterServiceImpl.java的文件:

package greeter;

import io.grpc.stub.StreamObserver;

public class GreeterServiceImpl extends GreeterGrpc.GreeterImplBase {
  @Override
  public void sayHello(HelloRequest req, StreamObserver<HelloReply> responseObserver) {
    HelloReply reply = HelloReply.newBuilder().setMessage("Hello, " + req.getName()).build();
    responseObserver.onNext(reply);
    responseObserver.onCompleted();
  }
}
  1. 配置gRPC服務器

創建一個gRPC服務器,將服務實現綁定到服務器上。例如,創建一個名為Server.java的文件:

package greeter;

import io.grpc.Server;
import io.grpc.ServerBuilder;

public class Server {
  public static void main(String[] args) throws Exception {
    Server server = ServerBuilder.forPort(8080)
        .addService(new GreeterServiceImpl())
        .build()
        .start();
    server.awaitTermination();
  }
}
  1. 客戶端調用服務

創建一個gRPC客戶端,調用遠程服務。例如,創建一個名為Client.java的文件:

package greeter;

import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;

public class Client {
  public static void main(String[] args) {
    ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 8080)
        .usePlaintext()
        .build();

    GreeterGrpc.GreeterStub stub = GreeterGrpc.newStub(channel);
    HelloRequest request = HelloRequest.newBuilder().setName("World").build();
    stub.sayHello(request, response -> {
      System.out.println("Response: " + response.getMessage());
    });
  }
}

現在,你可以運行服務器和客戶端代碼,客戶端將調用遠程服務并打印響應消息。

0
嘉义市| 绿春县| 长阳| 平原县| 剑阁县| 大新县| 凭祥市| 新兴县| 安乡县| 集安市| 台东县| 祁门县| 盐池县| 睢宁县| 商城县| 攀枝花市| 曲靖市| 双鸭山市| 阿合奇县| 滨州市| 宽城| 长春市| 揭阳市| 广南县| 玛多县| 新乐市| 翁牛特旗| 商城县| 玉山县| 衡阳县| 武定县| 盈江县| 利川市| 龙海市| 神池县| 苍南县| 都安| 米林县| 广安市| 汉源县| 巴彦淖尔市|