Конвейер распределенного последовательного потребления сообщений Message Pipe v1.0.6

Message Pipe — это последовательный конвейер сообщений, реализованный на основе Redis. Поскольку распределенная блокировка Redisson введена внутри, она является потокобезопасной. В многопоточных ситуациях потребление также будет выполняться в порядке, записанном в конвейере.

Канал сообщений разработан с использованием концепций клиента и сервера. Внутренне grpc-netty используется для установления длинных соединений для каналов сообщений для связи друг с другом. Сервер отвечает за распространение сообщений, и сообщения в каждом конвейере распределяются. через LoadBalance (балансировка нагрузки) для получения онлайн-информации о Клиенте и последовательной отправки сообщений Клиенту.

характеристика

Автоматическая регистрация

проверка сердцебиения

распространение сообщений

Последовательное потребление

Чтение и запись разделения

Безопасность резьбы

балансировка нагрузки

Автоматическая отбраковка