欢迎来到利索能及~ 联系电话:18621327849
利索能及
我要发布
收藏
专利号: 2018102881505
申请人: 武汉斗鱼网络科技有限公司
专利类型:发明专利
专利状态:已下证
专利领域: 电通信技术
更新日期:2024-10-29
缴费截止日期: 暂无
联系人

摘要:

权利要求书:

1.一种消息中间件的消息去重的实现方法,所述方法包括:采用Redis的列表结构作为消息中间件的消息队列;

创建生产者系统和消费者系统的订阅模型;

采用Redis的集合存放已存在消息的标识,当消息中间件收到新消息时,根据消息的主题,在对应的集合中查询该消息的标识是否已存在,若存在则忽略所述消息,若不存在则将所述消息追加入所述消息队列中。

2.根据权利要求1所述的方法,其中,所述消息中间件以超文本传输协议服务为载体,消费者和生产者通过调用所述消息中间件的应用程序编程接口进行消息的发送和获取。

3.根据权利要求2所述的方法,其中,消费者通过调用所述消息中间件的应用程序编程接口来向所述消息中间件注册订阅关系。

4.根据权利要求1所述的方法,其中,所述订阅模型的属性包括:消费者的接受订阅消息地址;

消费者可接受的消息报文结构;

消费者订阅的主题;

消费失败的处理策略。

5.根据权利要求4所述的方法,还包括,所述消息中间件收到消息后,扫描Redis消息队列,根据所述订阅模型,取出消费者订阅的主题对应的消息,并根据消费者可接受的消息报文结构对发送报文进行处理。

6.根据权利要求5所述的方法,还包括,所述消息中间件对发送报文进行处理后,尝试调用消费者接受消息的应用程序编程接口,若消费成功,则将消息推送给消费者;若消费失败,则根据配置的消费失败的处理策略进行处理。

7.根据权利要求4所述的方法,所述订阅模型的属性还包括:消息是否去重推送;若设定为消息去重推送,则根据所述方法对消息进行去重处理。

8.根据权利要求1所述的方法,将消息追加入所述消息队列中时,将消息加入所述消息队列的最左端。

9.根据权利要求1所述的方法,所述消息中间件取出消息推送给消费者时,从所述消息队列的最右端弹出消息。

10.一种根据权利要求1-9中任一项所述的方法实现消息去重的消息中间件。