如何像文档中提到的那样在java gRPC中交换传输？

syntax = "proto3";

message MyMessage {
  string content = 1;
}

protoc --java_out=./path/to/output/ ./path/to/your_proto.proto

public class MyService extends MyServiceGrpc.MyServiceImplBase {
  @Override
  public void myMethod(MyMessage request, StreamObserver<MyMessage> responseObserver) {
    // 实现业务逻辑
    MyMessage response = MyMessage.newBuilder().setContent("Response Content").build();
    responseObserver.onNext(response);
    responseObserver.onCompleted();
  }
}

public class Server {
  public static void main(String[] args) throws IOException, InterruptedException {
    int port = 50051;
    Server server = ServerBuilder.forPort(port)
        .addService(new MyService())
        .build()
        .start();

    System.out.println("Server started, listening on " + port);
    server.awaitTermination();
  }
}

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

    MyServiceGrpc.MyServiceBlockingStub blockingStub = MyServiceGrpc.newBlockingStub(channel);

    MyMessage request = MyMessage.newBuilder().setContent("Request Content").build();
    MyMessage response = blockingStub.myMethod(request);

    System.out.println("Response: " + response.getContent());

    channel.shutdown();
  }
}