91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

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
普兰县| 彩票| 白河县| 华容县| 巴东县| 云南省| 南溪县| 阿尔山市| 甘南县| 临夏市| 天等县| 台南县| 长宁县| 沙河市| 通山县| 桃园市| 木兰县| 鹿邑县| 宜川县| 高雄市| 泰来县| 正镶白旗| 湖口县| 宁津县| 湘潭市| 梅州市| 江永县| 长沙市| 凤台县| 万荣县| 腾冲县| 栖霞市| 长兴县| 芷江| 武威市| 和平县| 苏尼特右旗| 芒康县| 茶陵县| 英吉沙县| 武宣县|