基于消息队列的分布式事件总线处理方法、终端及介质
基本信息
申请号 | CN202011459468.9 | 申请日 | - |
公开(公告)号 | CN112527525A | 公开(公告)日 | 2021-03-19 |
申请公布号 | CN112527525A | 申请公布日 | 2021-03-19 |
分类号 | G06F9/54(2006.01)I | 分类 | 计算;推算;计数; |
发明人 | 莫伦辉;莫伦冰;钟嘉文;赖泽平 | 申请(专利权)人 | 广州伊智信息科技有限公司 |
代理机构 | - | 代理人 | - |
地址 | 511400广东省广州市番禺区东环街番禺大道北555号天安总部中心19号楼301室之一 | ||
法律状态 | - |
摘要
摘要 | 本申请涉及计算机技术领域,旨在提供基于消息队列的分布式事件总线处理方法、终端及介质,其方法包括与发布方建立连接,获取发布事件报文;对获取的事件报文进行事件数据的基本属性校验,生成唯一的事件ID;从节点池中选择可用的节点,向消息中间件推送消息;当接收到消费方的订阅事件请求消息后,解码订阅事件请求消息,校验事件数据的合法性并获取事件ID;与消息中间件建立连接,根据事件ID,向消息中间件订阅相关的消息队列,建立回调处理器;获取回调处理器的事件,以接收消息中间件的消息,将消息进行解码,转换为订阅的事件结构,以事件报文流推送给消费方。本申请具有实现客户端的轻量级操作的效果。 |
