FileTransferServiceGrpc java实现demo

以下是一个简单的FileTransferServiceGrpc Java实现demo：

首先，我们需要定义一个proto文件，例如FileTransfer.proto，包含以下内容：

syntax = "proto3";

package filetransfer;

service FileTransferService {
  rpc uploadFile(FileUploadRequest) returns (FileUploadResponse) {}
  rpc downloadFile(FileDownloadRequest) returns (stream FileDownloadResponse) {}
  rpc deleteFile(FileDeleteRequest) returns (FileDeleteResponse) {}
}

message FileUploadRequest {
  string file_name = 1;
  bytes file_content = 2;
}

message FileUploadResponse {
  bool success = 1;
}

message FileDownloadRequest {
  string file_name = 1;
}

message FileDownloadResponse {
  bytes file_content = 1;
}

message FileDeleteRequest {
  string file_name = 1;
}

message FileDeleteResponse {
  bool success = 1;
}

接下来，在命令行中使用protoc编译工具生成Java代码：

$ protoc --java_out=. FileTransfer.proto

然后，我们可以在服务端代码中使用FileTransferServiceGrpc类来实现具体的文件传输服务。例如，以下是一个简单的服务端实现：

public class FileTransferServer {
  private static final int PORT = 50051;

  public static void main(String[] args) throws Exception {
    Server server = ServerBuilder.forPort(PORT).addService(new FileTransferServiceImpl()).build().start();
    System.out.println("Server started, listening on " + PORT);
    server.awaitTermination();
  }

  static class FileTransferServiceImpl extends FileTransferServiceGrpc.FileTransferServiceImplBase {
    @Override
    public void uploadFile(FileUploadRequest request, StreamObserver<FileUploadResponse> responseObserver) {
      // 处理文件上传请求
      // ...
      FileUploadResponse response = FileUploadResponse.newBuilder().setSuccess(true).build();
      responseObserver.onNext(response);
      responseObserver.onCompleted();
    }

    @Override
    public void downloadFile(FileDownloadRequest request, StreamObserver<FileDownloadResponse> responseObserver) {
      // 处理文件下载请求
      // ...
      FileDownloadResponse response = FileDownloadResponse.newBuilder().setFileContent(ByteString.copyFrom(fileContent)).build();
      responseObserver.onNext(response);
      responseObserver.onCompleted();
    }

    @Override
    public void deleteFile(FileDeleteRequest request, StreamObserver<FileDeleteResponse> responseObserver) {
      // 处理文件删除请求
      // ...
      FileDeleteResponse response = FileDeleteResponse.newBuilder().setSuccess(true).build();
      responseObserver.onNext(response);
      responseObserver.onCompleted();
    }
  }
}

在以上实现中，我们创建了一个FileTransferServer类，并在main方法中启动了一个gRPC服务。在服务端实现中，我们继承了FileTransferServiceGrpc.FileTransferServiceImplBase类，并重写了三个文件传输服务接口方法，分别处理文件上传、下载和删除请求。在每个接口方法中，我们可以根据具体需求实现具体的文件传输逻辑，并通过responseObserver向客户端返回响应结果。