基于消息队列的分布式事件总线处理方法、终端及介质

基本信息

申请号 CN202011459468.9 申请日 -
公开(公告)号 CN112527525A 公开(公告)日 2021-03-19
申请公布号 CN112527525A 申请公布日 2021-03-19
分类号 G06F9/54(2006.01)I 分类 计算;推算;计数;
发明人 莫伦辉;莫伦冰;钟嘉文;赖泽平 申请(专利权)人 广州伊智信息科技有限公司
代理机构 - 代理人 -
地址 511400广东省广州市番禺区东环街番禺大道北555号天安总部中心19号楼301室之一
法律状态 -

摘要

摘要 本申请涉及计算机技术领域,旨在提供基于消息队列的分布式事件总线处理方法、终端及介质,其方法包括与发布方建立连接,获取发布事件报文;对获取的事件报文进行事件数据的基本属性校验,生成唯一的事件ID;从节点池中选择可用的节点,向消息中间件推送消息;当接收到消费方的订阅事件请求消息后,解码订阅事件请求消息,校验事件数据的合法性并获取事件ID;与消息中间件建立连接,根据事件ID,向消息中间件订阅相关的消息队列,建立回调处理器;获取回调处理器的事件,以接收消息中间件的消息,将消息进行解码,转换为订阅的事件结构,以事件报文流推送给消费方。本申请具有实现客户端的轻量级操作的效果。