Usar grpc stream en el idioma go

Hablamos brevemente sobre cómo usar grpc. Esta vez hablaremos sobre las transmisiones en grpc. Como sugiere el nombre, es una transmisión que puede enviar datos de forma continua y es muy adecuada para la transmisión de grandes cantidades de datos. -Comunicación a término entre el servidor y el cliente Interacción de datos, por ejemplo, el cliente puede suscribirse a ciertos datos en el lado del servidor, el lado del servidor puede usar transmisiones, las transmisiones pueden usar fuentes para enviar datos continuamente y las transmisiones se pueden usar para. enviar datos al servidor. Stream, el servidor puede usar el flujo para enviar datos continuamente.

De hecho, este flujo básicamente se ha degradado a tcp y grpc, y la capa inferior está subcontratada para nosotros, por lo que es realmente muy conveniente.

Definimos los servicios que se proporcionarán en protobuf. Si desea enviar continuamente qué fuente de datos a una secuencia anterior, simplemente recuerde compilarla después de definirla.

Puntos de conocimiento:

Cuando el cliente llama a la función de transmisión, se devolverá un objeto de transmisión. Mientras continúe leyéndose y escribiendo, la parte correspondiente puede recibir la transmisión. objeto.

Las transmisiones de grpc funcionan perfectamente con el coprocesamiento de go. Con los streams podemos implementar nuestro negocio de forma más flexible. Por ejemplo, suscripción, transmisión de big data, etc.

Las transmisiones de grpc funcionan perfectamente con el coprocesador go.