java的grpc的服务端maven依赖-CFANZ编程社区

Java gRPC服务端依赖与示例

简介

在Java开发中，gRPC是一种高性能、开源的RPC（远程过程调用）框架。它基于Google开发的Protocol Buffers（简称Protobuf）和HTTP/2协议，可以实现跨不同语言和平台的高效通信。本文将介绍如何在Java中使用gRPC服务端，并提供相关的代码示例。

Maven依赖

要使用Java的gRPC服务端，首先需要在项目的Maven配置文件中添加相应的依赖。下面是一个示例的Maven依赖配置：

<dependencies>
    <dependency>
        <groupId>io.grpc</groupId>
        <artifactId>grpc-netty-shaded</artifactId>
        <version>1.39.0</version>
    </dependency>
    <dependency>
        <groupId>io.grpc</groupId>
        <artifactId>grpc-protobuf</artifactId>
        <version>1.39.0</version>
    </dependency>
    <dependency>
        <groupId>io.grpc</groupId>
        <artifactId>grpc-stub</artifactId>
        <version>1.39.0</version>
    </dependency>
</dependencies>

上述配置中，grpc-netty-shaded是gRPC的核心库，grpc-protobuf和grpc-stub分别用于Protocol Buffers和gRPC的代码生成和使用。

完成Maven依赖的配置后，就可以开始编写gRPC服务端的代码了。

代码示例

下面是一个简单的gRPC服务端代码示例，用于实现一个简单的问候服务：

import io.grpc.Server;
import io.grpc.ServerBuilder;
import io.grpc.stub.StreamObserver;

public class GreetingServer {
    
    private int port;
    private Server server;
    
    public GreetingServer(int port) {
        this.port = port;
    }
    
    public void start() throws IOException {
        server = ServerBuilder.forPort(port)
            .addService(new GreetingServiceImpl())
            .build()
            .start();
        
        System.out.println("Server started, listening on port " + port);
        
        Runtime.getRuntime().addShutdownHook(new Thread(() -> {
            System.out.println("Shutting down server...");
            GreetingServer.this.stop();
            System.out.println("Server shut down");
        }));
    }
    
    public void stop() {
        if (server != null) {
            server.shutdown();
        }
    }
    
    private static class GreetingServiceImpl extends GreetingServiceGrpc.GreetingServiceImplBase {
        
        @Override
        public void sayHello(GreetingRequest request, StreamObserver<GreetingResponse> responseObserver) {
            String name = request.getName();
            GreetingResponse response = GreetingResponse.newBuilder()
                .setMessage("Hello, " + name)
                .build();
            responseObserver.onNext(response);
            responseObserver.onCompleted();
        }
    }
    
    public static void main(String[] args) throws IOException, InterruptedException {
        GreetingServer server = new GreetingServer(50051);
        server.start();
        server.blockUntilShutdown();
    }
}

上述代码中，首先定义了一个GreetingServer类，它负责启动和停止gRPC服务器。start()方法将配置服务器并启动监听指定端口的请求。stop()方法用于停止服务器。在main()方法中，首先创建了一个GreetingServer对象，并调用start()方法启动服务器。

接着，定义了一个GreetingServiceImpl类，它继承自GreetingServiceGrpc.GreetingServiceImplBase，这个类是根据gRPC服务定义自动生成的。在GreetingServiceImpl类中，实现了sayHello()方法，用于处理客户端请求并返回响应。

最后，在main()方法中创建了GreetingServer对象，并调用start()方法启动服务器。服务器启动后，会在控制台输出相应的信息。