Предыстория: у меня есть микросервис, реализованный на C ++ с REST и WebSocket API и функциональностью pub / sub. Теперь мне нужно поддерживать MQTT, и все усложняется, потому что мой микросервис должен отслеживать активные подписки по соображениям масштабируемости. Например, чтобы ограничить доставку сообщений темами и подписками, у каждого клиента может быть несколько собственных тем.
Я нашел конечные точки API REST для перечисления подписок и маршрутов: https://docs.emqx.io/broker/v3/en/rest.html#subscriptions
https://docs.emqx.io/broker/v3/en/rest.html#routes
Это, вероятно, Позвольте мне начать подписку в моем собственном сервисе. Однако мне нужен эффективный способ перехвата подписок.
Есть ли способ «подписаться» на подписанные и неподписанные перехватчики событий без необходимости писать расширение в Erlang? Например, переслать эти события в MQTT topi c, на который мой микросервис мог подписаться как клиент MQTT?
Документация по перехватам Emqx: https://docs.emqx.io/enterprise/latest/en/advanced/hooks.html