Pipeline de mensagens distribuídas pipeline de consumo sequencial v1.0.6

Message Pipe é um pipeline de mensagens sequencial implementado com base no Redis. Como o bloqueio distribuído Redisson é introduzido internamente, ele é thread-safe. Em situações multithread, o consumo também será executado na ordem escrita no pipeline.

Message Pipe é projetado usando os conceitos de Cliente e Servidor Internamente, grpc-netty é usado para estabelecer conexões longas para canais de mensagens se comunicarem entre si. O Servidor é responsável pela distribuição de mensagens, e as mensagens em cada pipeline são distribuídas. através do LoadBalance (método de balanceamento de carga) para obter informações on-line do Cliente e enviar mensagens ao Cliente sequencialmente.

característica

Registro automático

verificação de batimentos cardíacos

distribuição de mensagens

Consumo sequencial

Separação de leitura e gravação

Segurança do fio

balanceamento de carga

Seleção automática