一种基于微服务架构的消息发布方法及系统.pdf

(19)国家知识产权局(12)发明专利申请(10)申请公布号CN115022318A(43)申请公布日2022.09.06(21)申请号202210598672.1(22)申请日2022.05.30(71)申请人在线途游（北京）科技有限公司地址100012北京市朝阳区红军营南路36号暖山生活B座申请人北京云游互动网络科技有限公司(72)发明人张哲铭韩腾辉乐坚强刘洋其他发明人请求不公开姓名(51)Int.Cl.H04L67/10(2022.01)H04L67/02(2022.01)H04L67/141(2022.01)H04L67/63(2022.01)权利要求书2页说明书6页附图1页(54)发明名称一种基于微服务架构的消息发布方法及系统(57)摘要本申请提供一种基于微服务架构的消息发布方法及系统，该方法包括设置分布式消息中心，并在Zookeeper消息服务中设置消息节点，将对消息节点有订阅需求的消息中心在Zookeeper消息服务中进行监听注册；微服务将产生的消息数据发送给消息中心，消息中心根据消息数据的类型进行相应的处理；当消息中心监听到消息节点上的预设事件时，从该消息节点获取消息数据，进而将获取的消息数据发送到与消息中心建立了连接的客户端。通过本申请实施例的方法，不仅将微服务的业务逻辑与消息处理进行了解耦，使用消息中心实现了消息的多种送达方式。相比现有技术中使用总线或消息队列，降低了开发难度，提高了项目的开发效率。CN115022318ACN115022318A权利要求书1/2页1.一种基于微服务架构的消息发布方法，其特征在于，包括：设置包括了多个节点的分布式消息中心；设置Zookeeper消息服务，并在所述Zookeeper消息服务中设置消息节点；将对所述消息节点有订阅需求的消息中心在Zookeeper消息服务中进行监听注册；微服务接收任务请求，根据所述任务请求产生消息数据，将所述消息数据发送给第一消息中心；所述第一消息中心将消息数据发布到所述消息节点；当其他消息中心监听到所述消息节点的预设事件时，从该消息节点获取消息数据，进而将获取的消息数据发送到与消息中心建立了连接的客户端。2.根据权利要求1所述的方法，其中，所述消息中心既是也是消息的发布者，又是消息的订阅者。3.根据权利要求1所述的方法，其中，将对所述消息节点有订阅需求的消息中心在Zookeeper消息服务中进行监听注册包括：在对所述消息节点有订阅需求的消息中心中创建监听器，将所述监听器在Zookeeper消息服务的监听器列表中进行注册；所述监听器对所述消息节点的预设路径进行监听。4.根据权利要求1所述的方法，其中，消息中心将所述消息数据发布到所述消息节点包括：根据消息数据的内容更新消息节点预设路径下的数据。5.根据权利要求1所述的方法，其中，当其他消息中心监听到所述消息节点的预设事件时，从该消息节点获取消息数据包括：当消息中心监听到所述消息节点下预设路径的数据变化事件时，接收Zookeeper消息服务发送的消息数据。6.根据权利要求5所述的方法，其中，消息节点下预设路径的数据变化事件包括但不限于：所述预设路径下的数据发生变更或所述预设路径下的子节点数据发生变更。7.根据权利要求1所述的方法，其中，所述将获取的消息数据发送到与所述消息中心建立了连接的客户端包括：消息数据基于websocket协议发送；若客户端成功对接收的消息进行接收确认，完成消息触达；若消息未触达，在客户端登录时统一重复发送消息数据。8.一种基于微服务架构的消息发布系统，其特征在于，包括：部署在Zookeeper消息服务中的消息节点；微服务单元，用于接收客户端的任务请求执行业务逻辑，并生成消息数据；分布式消息中心，用于接收微服务单元生成的消息数据，并发送给所述消息节点；所述分布式消息中心还包括监听器，用于对所述消息中心订阅的消息节点进行监听；当所述监听器监听到所述消息节点的预设事件时，从所述消息节点获取消息数据后发送到与所述消息中心建立了连接的客户端；所述Zookeeper消息服务还包括监听注册单元，用于对所述监听器进行注册。2CN115022318A权利要求书2/2页9.一种计算设备，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机指令，其特征在于，所述处理器执行所述指令时实现权利要求1‑7任意一项所述方法的步骤。10.一种计算机可读存储介质，其存储有计算机指令，其特征在于，该指令被处理器执行时实现权利要求1‑7任意一项所述方法的步骤。3CN115022318A说明书1/6页一种基于微服务架构的消息发布方法及系统技术领域[0001]本申请涉及计算机技术领域，特别涉及一种基于微服务架构的消息发布方法及系统、计算设备和计算机可读存储介质。背景技术[0002]微服务是一种软件架构风格，它是