О AMQ

ArtFii-MQ, сокращённо AMQ — это легковесная и малозависимая система обмена сообщениями (MQ). Её особенности — удобство использования, высокая производительность и низкие требования к оборудованию.

1. Стремясь к компактности, мы также обеспечиваем высокую производительность: для распределения сообщений используется технология LMAX-Ringbuffer.
2. По умолчанию срок жизни опубликованных сообщений составляет один день, что позволяет избежать накопления большого количества просроченных и недействительных сообщений, как в RocketMQ.
3. После того как несколько потребителей подтвердят получение сообщения, оно автоматически удаляется (ALL-ACK), при этом можно настроить период хранения сообщений (постоянное хранение, ALL-ACK, временное хранение).
4. Все сообщения по умолчанию автоматически помечаются как «доставленные» после успешного получения.
5. Если клиент не подтверждает получение (NACK), можно установить количество повторных попыток и интервал между ними.
6. В случае сбоя отправки (отключение потребителя) можно также настроить количество повторных попыток и их интервал.
7. Особенностью является режим PING/PONG, который поддерживает функции, подобные RPC, но без недостатков, связанных с принудительным объединением RPC, и с лучшей производительностью (идеальный партнёр для микросервисов).
8. Обычный режим (издатель/подписчик) поддерживает массовые и высококонкурентные операции ввода-вывода для ведения журналов.
9. Встроенный мониторинг трафика и функции управления фоном.
10. Чёрный список автоматически отклоняет подключения.
11. Только после завершения проекта я обнаружил, что существует протокол MQTT (протокол IoT), и мой проект стал его примером.
12. При наличии нескольких клиентов в режиме PING/PONG первым получает сообщение тот, кто сделал это раньше, обеспечивая уникальность потребления.
13. Для удобства разработки интерфейсов 1:1 добавлен локальный режим разработки с эксклюзивной конфигурацией сообщений.

Руководство пользователя

Руководство пользователя AMQ

Специальное заявление:

Код Aio взят из smart-socket, спасибо брату Сандао, хотя я его изменил!

MAVEN:

<dependency>
    <groupId>com.artfii.amq</groupId>
    <artifactId>artfii-amq</artifactId>
    <version>0.0.6</version>
</dependency>

Примечание:

AMQ использует встроенную систему сохранения данных MAPDB, которая написана на Kotlin, поэтому для компиляции исходного кода с использованием IDEA требуется установить плагин Kotlin.