Message Pipe canalización de consumo secuencial de mensajes distribuidos v1.0.6

Message Pipe es una canalización de mensajes secuencial implementada en base a Redis. Dado que el bloqueo distribuido de Redisson se introduce internamente, es seguro para subprocesos y el consumo también se realizará en el orden escrito en la canalización.

Message Pipe está diseñado utilizando los conceptos de Cliente y Servidor. Internamente, grpc-netty se utiliza para establecer conexiones largas para que los canales de mensajes se comuniquen entre sí. El servidor es responsable de la distribución de mensajes y los mensajes en cada canalización se distribuyen. a través de LoadBalance (equilibrio de carga) Método para obtener información del Cliente en línea y enviar mensajes al Cliente de forma secuencial.

característica

Registro automático

control de latidos del corazón

distribución de mensajes

Consumo secuencial

Separación de lectura y escritura.

Seguridad del hilo

equilibrio de carga

sacrificio automático