基于MQTT服务器集群实现共享订阅的方法

摘要

本发明公开了一种基于MQTT服务器集群实现共享订阅的方法，包括以下步骤：设置共享订阅主题：在标准的主题定义前设置共享订阅前缀，所述共享订阅前缀包括队列共享订阅前缀和分组共享订阅前缀；搭建基于Erlang mnesia集群技术的MQTT服务器集群，该MQTT服务器集群包括基于事件驱动架构、mnesia分布式数据库、ets路由表和map分组映射的智能路由系统；基于分层架构设计对MQTT服务器集群的结构进行优化；进入共享订阅处理流程；进入消息发布流程；本发明通过共享订阅，使得同一个消息不会发送到多个订阅者，从而实现订阅端的多个节点之间的负载均衡。