Llamadas de transmisión en las bibliotecas cliente de Cloud para Java

Las llamadas de transmisión permiten patrones de interacción más complejos que las solicitudes y respuestas simples, lo que permite enviar o recibir varios mensajes a través de una sola conexión.

Las bibliotecas cliente de Cloud para Java admiten tres tipos de llamadas de transmisión:

• Transmisión desde el servidor: El servidor te envía una transmisión de respuestas.
• Transmisión del cliente: Envías una transmisión de solicitudes al servidor.
• Transmisión bidireccional: Puedes enviar un flujo de solicitudes al servidor, y el servidor puede devolverte un flujo de respuestas.

Las implementaciones de transmisión se modelan según las implementaciones de gRPC Java para la transmisión bidireccional, del cliente y del servidor.

Compatibilidad con la transmisión en todos los transportes

La transmisión es totalmente compatible cuando se usa gRPC, pero solo parcialmente compatible con HttpJson. Consulta la siguiente tabla para ver la compatibilidad con la transmisión.

Se admiten llamadas unarias (sin transmisión) para gRPC y HttpJson.

Cómo determinar el tipo de transmisión

Para determinar el tipo de transmisión de la llamada, verifica el tipo Callable que se devolvió:

• ServerStreamingCallable: Transmisión desde el servidor.
• ClientStreamingCallable: Transmisión del cliente.
• BidiStreamingCallable: Transmisión bidireccional.

Por ejemplo, para usar Java-Aiplatform y Java-Speech, haz lo siguiente:

// Server Streaming
ServerStreamingCallable<ReadTensorboardBlobDataRequest, ReadTensorboardBlobDataResponse> callable = aiplatformClient.readTensorboardBlobDataCallable();

// Bidirectional Streaming
BidiStreamingCallable<StreamingRecognizeRequest, StreamingRecognizeResponse> callable = speechClient.streamingRecognizeCallable();

Cómo realizar llamadas de transmisión

La forma de realizar una llamada de transmisión variará según si usas la transmisión del servidor o la transmisión bidireccional.

Transmisión desde el servidor

La transmisión por servidor no requiere una implementación adicional. La clase ServerStream te permite iterar el flujo de respuestas. Si usamos Java-Maps-Routing como ejemplo, a continuación, se muestra cómo llamar a la API de transmisión por servidor:

try (RoutesClient routesClient = RoutesClient.create()) {
  ServerStreamingCallable<ComputeRouteMatrixRequest, RouteMatrixElement> computeRouteMatrix =
    routesClient.computeRouteMatrixCallable();  
  ServerStream<RouteMatrixElement> stream = computeRouteMatrix.call(
    ComputeRouteMatrixRequest.newBuilder().build());
  for (RouteMatrixElement element : stream) {
    // Do something with response
  }
}

En este ejemplo, el cliente envía un solo ComputeRouteMatrixRequest y recibe un flujo de respuestas.

Transmisión bidireccional

La transmisión bidireccional requiere una implementación adicional para realizar la llamada. Si usamos Java-Speech como ejemplo, los siguientes pasos proporcionan una implementación de ejemplo para realizar una llamada de transmisión bidireccional.

Primero, implementa la interfaz ResponseObserver con el siguiente código como guía:

class BidiResponseObserver<T> implements ResponseObserver<T> {
  private final List<T> responses = new ArrayList<>();
  private final SettableApiFuture<List<T>> future = SettableApiFuture.create();

  @Override
  public void onStart(StreamController controller) {
    // no-op
  }

  @Override
  public void onResponse(T response) {
    responses.add(response);
  }

  @Override
  public void onError(Throwable t) {
    future.setException(t);
  }

  @Override
  public void onComplete() {
    future.set(responses);
  }

  public SettableApiFuture<List<T>> getFuture()