当前位置:主页 > 查看内容

Golang:MQTT服务集群共享主题设计

发布时间:2021-04-23 00:00| 位朋友查看

简介:前言 本次设计的支持集群的共享订阅的思路还存在缺陷无法支持通配符订阅正在努力实现中敬请期待或者有好的点子欢迎分享哦谢谢各位。 具体实现用在了 该项目中 集群共享订阅 单机共享订阅是非常容易实现的代码改动也比较小但是我们今天的角色不是单机的共享订……

前言:

本次设计的支持集群的共享订阅的思路,还存在缺陷,无法支持通配符订阅,正在努力实现中,敬请期待,或者有好的点子,欢迎分享哦,谢谢各位。
具体实现用在了该项目中

集群共享订阅

单机共享订阅是非常容易实现的,代码改动也比较小,但是我们今天的角色不是单机的共享订阅,而是集群的

我们采用一个简单的方式来实现部分功能,使用redis的set+hash
具体结果如下图:
在这里插入图片描述

订阅主题

订阅主题时,需要一条lua脚本向redis中操作两个key,分别操作数据
set 的key中往topic key中添加该shareName
然后往hash key中添加node名称与新增数量

取消订阅

相应的减一就行

获取订阅数据

需要获取所有的有关该主题的订阅数据,首先获取该主题所有的共享组,然后拼接主题去获取所有的共享组的数据

具体实现请移步查看:代码仓库

缺陷

只能实现对应的具体主题的订阅,还未实现通配符匹配,
看下面的初步思考
在这里插入图片描述
如果是单独实现的集群通用主题服务还好,用redis去实现感觉太复杂了。之后会继续学习完善的,多考虑几种实现

;原文链接:https://blog.csdn.net/qq_41257365/article/details/115421355
本站部分内容转载于网络,版权归原作者所有,转载之目的在于传播更多优秀技术内容,如有侵权请联系QQ/微信:153890879删除,谢谢!

推荐图文


随机推荐