1.一种消息事件的分发方法,其特征在于,包括:如果监测到消息发布服务发布的消息事件,获取预先存储的配置信息;其中,所述配置信息包括所述消息发布服务,以及所述消息发布服务对应的至少一个消息订阅服务;根据所述配置信息对所述消息事件进行分裂,得到所述消息事件对应的至少一个目标消息事件;将至少一个所述目标消息事件分类存储至所述消息订阅服务对应的消息队列;启动预先配置的所述消息订阅服务的协程组,通过所述协程组从所述消息队列中获取所述消息订阅服务对应的所述目标消息事件,并将所述目标消息事件推送至所述消息订阅服务;其中,所述协程组被配置为从各自的所述消息队列中获取消息事件,且,在启动所述协程组之后,所述协程组用于从所述消息队列中依次获取所述消息订阅服务对应的目标消息事件,并按照预设的推送方式对目标消息事件进行推送。

2.根据权利要求1所述的方法,其特征在于,所述方法还包括:响应针对于所述消息发布服务的增加操作,获取所述消息发布服务的身份信息,基于所述消息发布服务的身份信息设置所述消息发布服务的发布权限;响应针对于所述消息订阅服务的增加操作,获取所述消息订阅服务的身份信息,基于所述消息订阅服务的身份信息设置所述消息订阅服务订阅所述消息发布服务的订阅权限;响应所述增加操作结束,将所述消息发布服务,以及,订阅所述消息发布服务的消息订阅服务进行关联存储,并生成所述配置信息。

3.根据权利要求1所述的方法,其特征在于,所述配置信息还包括所述消息订阅服务的编码信息;根据所述配置信息对所述消息事件进行分裂,得到所述消息事件对应的至少一个目标消息事件的步骤包括:基于所述配置信息确定所述消息订阅服务的数量;将所述消息事件分裂成与所述数量匹配的目标消息事件,以及,为每个所述目标消息事件标记对应的编码信息。

4.根据权利要求3所述的方法,其特征在于,将至少一个所述目标消息事件分类存储至所述消息订阅服务对应的消息队列的步骤包括:基于所述编码信息按照预先设置的命名规范生成所述消息订阅服务的消息队列的标识,以及所述消息队列的推送路由信息;提取所述目标消息事件对应的编码信息;基于所述目标消息事件对应的编码信息和所述消息订阅服务的消息队列的标识将所述目标消息事件分类存储至所述消息订阅服务对应的消息队列。

5.根据权利要求4所述的方法,其特征在于,将所述目标消息事件推送至所述消息订阅服务的步骤包括:获取所述消息队列的推送路由信息,基于所述推送路由信息将所述目标消息事件推送至所述消息订阅服务。

6.根据权利要求4所述的方法,其特征在于,所述方法还包括:监测所述消息队列中的所述目标消息事件是否推送完成;如果是,删除所述消息队列,以及所述消息队列的标识。

7.根据权利要求6所述的方法,其特征在于,所述方法还包括:监控所述消息队列的数量、每个所述消息队列对应的推送所述目标消息事件的推送次数,根据所述消息队列的数量和所述推送次数生成所述消息队列对应的第一监控数据;以及,监控所述协程组的数量、每个所述协程组推送所述目标消息事件的推送速度,根据所述协程组的数量和所述推送速度生成所述协程组对应的第二监控数据;保存所述第一监控数据和所述第二监控数据至预设存储位置。

8.根据权利要求1所述的方法,其特征在于,将所述目标消息事件推送至所述消息订阅服务之后,所述方法还包括:监测在预设时间范围内是否接收到所述消息订阅服务对所述目标消息事件的反馈信息;如果是,确定所述目标消息事件推送成功;如果否,确定所述目标消息事件推送失败,按照预先设置的时间间隔重复推送所述目标消息事件至所述消息订阅服务,直至满足推送停止条件;其中,所述推送停止条件包括:所述重复推送的次数小于预设的次数,且,监测到所述反馈信息;所述重复推送的次数达到预设的次数,且,未监测到所述反馈信息。

9.根据权利要求1~8任一项所述的方法,其特征在于,所述消息事件为所述消息发布服务基于HTTP协议发布的消息事件;将所述目标消息事件推送至所述消息订阅服务的步骤,还包括:基于所述HTTP协议将所述目标消息事件推送至所述消息订阅服务。

10.一种消息事件的分发平台,其特征在于,包括:发布模块,用于如果监测到消息发布服务发布的消息事件,获取预先存储的配置信息;其中,所述配置信息包括所述消息发布服务,以及所述消息发布服务对应的至少一个消息订阅服务;分裂模块,用于根据所述配置信息对所述消息事件进行分裂,得到所述消息事件对应的至少一个目标消息事件;存储模块,用于将至少一个所述目标消息事件分类存储至所述消息订阅服务对应的消息队列;推送模块,用于启动预先配置的所述消息订阅服务的协程组,通过所述协程组从所述消息队列中获取所述消息订阅服务对应的所述目标消息事件,并将所述目标消息事件推送至所述消息订阅服务;其中,所述协程组被配置为从各自的所述消息队列中获取消息事件,且,在启动所述协程组之后,所述协程组用于从所述消息队列中依次获取所述消息订阅服务对应的目标消息事件,并按照预设的推送方式对目标消息事件进行推送。

11.一种消息事件的分发系统,其特征在于,所述系统包括权利要求10所述的消息事件的分发平台,还包括消息发布服务和消息订阅服务;所述消息事件的分发平台用于获取所述消息发布服务发布的消息事件,并将所述消息事件推送至所述消息订阅服务。

12.一种服务器,其特征在于,所述服务器包括处理器和存储器,所述存储器存储有能够被所述处理器执行的计算机可执行指令,所述处理器执行所述计算机可执行指令以实现权利要求1至9任一项所述的消息事件的分发方法。

13.一种计算机可读存储介质,其特征在于,所述计算机可读存储介质存储有计算机可执行指令,所述计算机可执行指令在被处理器调用和执行时,计算机可执行指令促使处理器实现权利要求1至9任一项所述的消息事件的分发方法。

信息推送分发服务器系统,消息事件的分发方法、分发平台、系统及服务器专利_专利查询 - 天眼查...相关推荐

  1. 环境保护的监测系统属于计算机,环保监测数据监控系统、处理方法、计算机设备及存储介专利_专利查询 - 天眼查...

    1.一种环保监测数据监控系统,其特征在于,所述环保监测数据监控系统包括:环保监测装置.监控装置.控制装置.通信装置,及区块链网络: 所述环保监测装置,用于对目标排放物进行环保监测,采集环保监测数据: ...

  2. 如何检测服务器运行正常运行,一种检测服务器运行状态的方法、装置和系统专利_专利查询 - 天眼查...

    1. 一种检测服务器运行状态的方法,其特征在于,应用于客户端,所述客户端本地保存 有正常服务器信息表和故障服务器信息表;所述正常服务器信息表中存储有当前处于正常 状态的各服务器的标识信息,所述故障服务 ...

  3. 华三刀片服务器如何安装系统,刀片服务器及其操作系统的安装方法及系统专利_专利查询 - 天眼查...

    一种刀片服务器操作系统的安装方法,其特征在于,包括:将刀片服务器设置为预启动执行环境PXE网卡启动:重启所述刀片服务器,所述PXE网卡获取并加载PXE控制内核:所述PXE控制内核加载操作系统启动内核以 ...

  4. 游戏服务器支付系统,一种手机游戏支付服务器、支付方法及支付系统专利_专利查询 - 天眼查...

    1.一种手机游戏支付服务器,其特征在于,包括: 一存储模块:用于存储手机游戏用户在平台的唯一身份信息以及绑定的手机号码,所述唯一身份信息至少包括平台用户唯一标识和能够验证用户归属地关系的基本信息:一获 ...

  5. android 手机分区失败怎么办,一种Android系统Data分区自修复方法及系统专利_专利查询 - 天眼查...

    1.一种Android系统Data分区自修复方法,其特征在于,包括: 步骤1: Android智能终端开机进入Android系统后,判断Data分区是否损坏,对Data分 区进行挂载,然后读取Data ...

  6. 电容触摸屏测试软件,一种电容式触摸屏的测试方法、系统及电子设备专利_专利查询 - 天眼查...

    1. 一种电容式触摸屏的测试方法,其特征在于,所述方法包括以下步骤:获取电容式触摸屏上各节点电容分别对应的采样信号:将所述采样信号转换成可处理的触摸数据后,根据预存的标准值对所述触摸数据进行分析,输出 ...

  7. 车载注册蓝牙服务器,蓝牙配对码配备方法、系统、终端、服务器及车载设备专利_专利查询 - 天眼查...

    1.一种蓝牙配对码配备方法,用于第一电子设备与第二电子设备的蓝牙配对的过程 中,所述第一电子设备和所述第二电子设备均包括用于基于蓝牙协议栈进行操作的蓝牙协 议操作模块,其特征在于,包括: 获取所述第二 ...

  8. 电话卡插到终端服务器通话时长,通话中添加背景音的方法、终端及系统专利_专利查询 - 天眼查...

    1.一种通话中添加背景音的方法,其特征在于,包括以下步骤: 监听到来电或去电,以及开始通话时,向服务器发送获取用于本次通话中营造环境声音的音频数据的请求: 接收所述服务器反馈的对应于所述请求的至少一段 ...

  9. 基于android的便利店管理,基于Android系统智能POS安全系统及启动、数专利_专利查询 - 天眼查...

    1.一种基于Android系统智能POS安全系统,其特征在于:包括应用CHJ及与该应用CPU 连接的安全CPU,所述应用CPU还与通讯模块.显示屏.内存存储器连接,所述安全CPU还与触 摸屏.接触1C ...

最新文章

  1. xa 全局锁_fescar锁设计和隔离级别的理解
  2. ML+DM顶会时间(2020)
  3. Hasor JDBC 的难关,嵌套事务处理思路
  4. Python逻辑运算符:if and
  5. libjingle源码解析(4)-【PseudoTcp】建立UDP之上的TCP(2):对交互数据流的处理
  6. php面试hr要看你的项目,昨晚hr给了我一个面试题,说过了就安排我面试
  7. java转换工具类_Java数据转换工具类
  8. 8086地址传送指令LEA
  9. 团队作业——微博网站小调查
  10. [转载]如果看了这篇文章你还不懂傅里叶变换,那就过来掐死我吧
  11. 语义分割-FCNs in the wild: Pixel-level adversarial and constraint-based adaptation 对抗方法实现不同数据集语义分割
  12. glide加载大图片白屏崩溃闪退
  13. Cross-species regulatory sequence activity prediction
  14. ROS入门-ROS的安装及编写简单的节点talker和listener
  15. 平安科技寿险金服面试
  16. Content-Disposition:attachment没有触发浏览器下载弹框
  17. Linux专家必读的几本书
  18. Camtasia studio2023录屏和后期剪辑的软件
  19. WIN10笔记本屏幕亮度无法调节,一直是最高亮度
  20. 【数据分析】洞察业务指标体系(in)

热门文章

  1. Spring-08 的整合mybatis【重要】
  2. 全球与中国斑马纸(HSC)市场现状及未来发展趋势2022-2028
  3. verilog 设计一个电子钟
  4. 服务器返回的状态码为500,当服务端返回500的时候axois如何获取状态码和响应信息...
  5. SAP ABAP基础知识自学笔记二
  6. 好好住入围阿里应用分发青藤计划,一款家居解决方案app获力挺
  7. red5+adobe flash media live(或OBS) +酷播播放器实现简单的直播及回看(三)------简单分析直播及回放系统的设计
  8. The device ‘/dev/sdd1‘ doesn‘t seem to have a valid NTFS
  9. 工行在线支付接口实战开发流程及源码
  10. GoogLeNet网络详解并使用pytorch搭建模型