iso file download
(19)中华 人民共和国 国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202111663004.4 (22)申请日 2021.12.31 (71)申请人 挂号网 (杭州) 科技有限公司 地址 311200 浙江省杭州市萧 山区萧山经 济技术开发区明星路371号3幢23层 2303室 (72)发明人 孙辉  (74)专利代理 机构 北京品源专利代理有限公司 11332 代理人 高艳红 (51)Int.Cl. G06F 9/54(2006.01) G06F 9/50(2006.01) H04L 67/56(2022.01) (54)发明名称 消息处理方法、 装置、 电子设备及存 储介质 (57)摘要 本发明实施例公开了一种消息处理方法、 装 置、 电子设备及存储介质。 该方法包括: 在对单集 群双机房中的生产者所生产的消息进行处理, 则 确定单集群双机房中的生产者的所在机房, 如果 机房为第一机房, 则确定第一机房对应的消息代 理; 确定第一机房对应的消息代理中是否包含第 一消息队列, 若是, 则将生产者生产的生产消息 发送给第一消息队列; 若否, 则将生产消息发送 给第二机房对应的消息代理中包含的第二消息 队列中, 解决了现有双机房单集群部署中消息处 理方法存在消息处理性能较低以及网络带宽的 需求较大的技术问题, 实现了对 单集群双机房中 的生产者所生产的消息的合理处理, 从而达到提 升消息的处理性能, 降低了消息处理对网络带宽 的需求的效果。 权利要求书2页 说明书12页 附图3页 CN 114356603 A 2022.04.15 CN 114356603 A 1.一种消息处 理方法, 其特 征在于, 包括: 在对单集群双机房中的生产者所生产的消息进行处理, 则确定所述单集群双机房中的 生产者的所在机房, 如果所述机房为第一机房, 则确定所述第一机房对应的消息代理; 确定所述第一机房对应的消息代理中是否包含第一消息队列, 若是, 则将所述生产者 生产的生产消息发送给 所述第一消息队列; 若否, 则将所述 生产消息发送给第二机房对应的消息代理中包 含的第二消息队列中。 2.根据权利要求1所述的方法, 其特征在于, 如果第 一机房中的消息代 理中包括第 一消 息队列, 则将所述 生产者生产的生产消息发送给 所述第一消息队列, 包括: 如果第一机房中的消息代理中包括第一消息队列, 则确定第一消息队列的队列数量, 如果所述队列数量为两个或两个以上, 则基于轮询机制将所述生产者生产的生产消息发送 给第一消息队列。 3.根据权利要求1所述的方法, 其特 征在于, 所述方法还 包括: 如果所述生产消息连续预设次数发送失败, 则将所述生产消息发送给所述第 二消息队 列中。 4.根据权利要求1所述的方法, 其特 征在于, 所述方法还 包括: 确定所有消息队列的队列名称, 其中, 所述队列名称中包 含机房标识; 根据所述机房标识对所有消息队列进行分类处 理。 5.根据权利要求1所述的方法, 其特 征在于, 所述方法还 包括: 如果所述第一机房中存在第一消费者、 所述第二机房中存在第二消费者、 所述第一机 房所对应的消息代理中存在所述第一消息队列以及所述第二机房所对应的消息代理中存 在所述第二消息队列, 则将所述第一消息队列中的消费消息发送给所述第一消费者, 以及 将所述第二消息队列中的消费消息发送给 所述第二消费者。 6.根据权利要求5所述的方法, 其特征在于, 所述将所述第 一消息队列中的消费消息发 送给所述第一消费者, 包括: 基于预设的均匀负载均衡策略, 将所述第 一消息队列中的消费消息发送给所述第 一消 费者。 7.根据权利要求5所述的方法, 其特 征在于, 所述方法还 包括: 如果所述第一机房存在所述第一消费者、 所述第二机房中未存在第二消费者、 所述第 一机房所对应的消息代理中存在所述第一消息队列以及所述第二机房所对应的消息代理 中存在所述第二消息队列, 则将所述第一消息队列和所述第二消息队列中的消费消息发送 给所述第一消费者。 8.根据权利要求5所述的方法, 其特 征在于, 所述方法还 包括: 确定所述第一机房和/或所述第二机房所对应的消息代理中所存 储的消费者信息; 根据所述消费者信息, 确定所述第一机房和/或所述第二机房中是否存在消费者。 9.一种消息处 理装置, 其特 征在于, 包括: 消息代理确定模块, 用于在对单集群双机房中的生产者所生产的消息进行处理, 则确 定所述单集群双机房中的生产者的所在机房, 如果所述机房为第一机房, 则确定所述第一 机房对应的消息代理; 第一消息发送模块, 用于确定所述第一机房对应的消息代理中是否包含第一消息队权 利 要 求 书 1/2 页 2 CN 114356603 A 2列, 若是, 则将所述 生产者生产的生产消息发送给 所述第一消息队列; 第二消息发送模块, 用于若否, 则将所述生产消息发送给第二机房对应的消息代理中 包含的第二消息队列中。 10.一种计算机可读存储介质, 其上存储有计算机程序, 其特征在于, 该程序被处理器 执行时实现如权利要求1 ‑8中任一所述的消息处 理方法。权 利 要 求 书 2/2 页 3 CN 114356603 A 3

.PDF文档 专利 消息处理方法、装置、电子设备及存储介质

文档预览
中文文档 18 页 50 下载 1000 浏览 0 评论 309 收藏 3.0分
温馨提示:本文档共18页,可预览 3 页,如浏览全部内容或当前文档出现乱码,可开通会员下载原始文档
专利 消息处理方法、装置、电子设备及存储介质 第 1 页 专利 消息处理方法、装置、电子设备及存储介质 第 2 页 专利 消息处理方法、装置、电子设备及存储介质 第 3 页
下载文档到电脑,方便使用
本文档由 人生无常 于 2024-03-19 02:02:45上传分享
站内资源均来自网友分享或网络收集整理,若无意中侵犯到您的权利,敬请联系我们微信(点击查看客服),我们将及时删除相关资源。