logo好方法网

一种基于平台级企业消息总线的消息处理方法和装置


技术摘要:
本发明实施例提供了一种基于平台级企业消息总线的消息处理方法及装置,云计算服务器接收发送端发送的消息推送请求信息,消息推送请求信息包括消息推送指令、消息推送内容和消息类别;云计算服务器调用云存储服务器中的二级日志,通过二级日志对消息推送指令进行验证;  全部
背景技术:
消息传输是人与人之间及企业信息系统之间常用的操作,企业服务总线 (EnterpriseServiceBus,ESB)是构建基于面向服务体系结构(Service  Oriented  Ambiguity,SOA)解决方案时所使用基础架构的关键部分,是由中间件技术实现并支持SOA 的一组基础架构功能。ESB支持异构环境中的服务、消息,以及基于事件的交互,并且具有适 当的服务级别和可管理性,ESB提供了连接企业内部。 现有的企业消息服务总线仅关注系统内部服务之间异构的数据交换,其信息传输 效率低,可靠性低,消息传输技术设施不能共享,企业业务应用的开发和构件成本高。
技术实现要素:
鉴于上述问题,提出了本发明实施例以便提供一种克服上述问题或者至少部分地 解决上述问题的一种基于平台级企业消息总线的消息处理方法和装置。 为了解决上述问题,本发明实施例公开了一种基于平台级企业消息总线的消息处 理方法,应用于平台级企业不同类型消息的传输,所述方法涉及云计算服务器,本地客户 端,以及云存储服务器;所述本地客户端分为个体、本地业务应用和第三方应用三种类型, 所述本地客户端分为发送端和接收端,所述云存储服务器用于存储二级日志; 所述方法包括: 所述云计算服务器接收所述发送端发送的消息推送请求信息,所述消息推送请求 信息包括消息推送指令、消息推送内容和消息类别; 所述云计算服务器调用所述云存储服务器中的所述二级日志,通过所述二级日志 对所述消息推送指令进行验证; 若所述消息推送指令验证成功,所述云计算服务器根据所述消息类别查找匹配所 述消息推送内容的目标传送策略; 所述云计算服务器根据匹配所述消息推送内容的目标传送策略将所述消息推送 内容传送至接收端。 进一步地,所述消息类别包括消息级别,所述若所述消息推送指令验证成功,根据 所述消息类别查找匹配所述消息推送内容的目标传送策略的步骤,包括: 若所述消息推送指令验证成功,根据所述消息级别查找出所述消息推送内容对应 的优先级; 根据所述优先级查找到所述消息推送内容对应的传输管道; 将所述消息推送内容结合所述传输管道生成第一传送策略。 进一步地,所述消息类别还包括消息推送方式,所述将所述消息推送内容结合所 5 CN 111611206 A 说 明 书 2/13 页 述传输管道生成第一传送策略的步骤之后,包括: 将所述消息推送方式结合所述第一传送策略生成所述目标传送策略。 进一步地,所述消息推送方式,包括:即时消息,和/或站内通知,和/或短信,和/或 邮件,和/或移动推送。 进一步地,所述云存储服务器还用于存储一级日志,所述根据匹配所述消息推送 内容的目标传送策略将所述消息推送内容传送至接收端的步骤之后,还包括: 将所述消息推送请求信息记录至所述一级日志; 和/或, 将所述通过所述二级日志对所述消息推送指令进行验证的过程记录至所述一级 日志; 和/或, 将所述根据所述消息类别查找匹配所述消息推送内容的目标传送策略的过程记 录至所述一级日志; 和/或, 将所述接收端反馈至所述云计算服务器的消息操作信息记录至所述一级日志。 进一步地,所述消息推送指令包括消息发送对象ID和消息接收对象ID; 所述消息推送内容包括: 消息ID,用于表示所述消息推送请求信息全局唯一性的标识; 消息标题,用于对所述消息推送请求信息的概述; 消息内容,用于展现所述消息推送请求信息的具体内容; 附件清单,用于提供附带的相关附加文档; 落地指向网页地址,用于指向所述消息推送请求信息的网络地址对应的落地页 面; 发送时间,用于记录所述发送端通过消息总线发送所述消息内容的时间; 接收时间,用于记录所述接收端通过消息总线接收所述消息内容的时间; 其它操作方式列表,用于记录接收端对消息的其它操作清单及对应的操作时间; 被引用消息ID,用于表示与当前消息推送请求信息关联的消息ID。 本发明实施例公开了一种基于平台级企业消息总线的消息处理方法,应用于平台 级企业不同类型消息的传输,所述方法涉及云计算服务器,本地客户端,以及云存储服务 器;所述本地客户端分为个体、本地业务应用和第三方应用三种类型,所述本地客户端分为 发送端和接收端,所述云存储服务器用于存储二级日志; 所述方法包括: 所述发送端生成消息推送请求信息,并发送至所述云计算服务器,所述消息推送 请求信息包括消息推送指令、消息推送内容和消息类别; 所述接收端接收所述云计算服务器反馈的根据匹配所述消息推送内容的目标传 送策略传送的消息推送内容;其中,所述云计算服务器调用所述云存储服务器中的所述二 级日志,通过所述二级日志对所述消息推送指令进行验证,若所述消息推送指令验证成功, 所述云计算服务器根据所述消息类别查找匹配所述消息推送内容生成所述目标传送策略。 本发明实施例公开了一种基于平台级企业消息总线的消息处理装置,应用于平台 6 CN 111611206 A 说 明 书 3/13 页 级企业不同类型消息的传输,所述装置涉及云计算服务器,本地客户端,以及云存储服务 器;所述本地客户端分为个体、本地业务应用和第三方应用三种类型,所述本地客户端分为 发送端和接收端,所述云存储服务器用于存储二级日志; 所述云计算服务器具体包括: 消息推送请求接收模块,用于接收所述发送端发送的消息推送请求信息,所述消 息推送请求信息包括消息推送指令、消息推送内容和消息类别; 请求验证模块,用于调用所述云存储服务器中的所述二级日志,通过所述二级日 志对所述消息推送指令进行验证; 传送策略匹配模块,用于若所述消息推送指令验证成功,根据所述消息类别查找 匹配所述消息推送内容的目标传送策略; 消息传送模块,用于根据匹配所述消息推送内容的目标传送策略将所述消息推送 内容传送至接收端。 本发明实施例公开了一种基于平台级企业消息总线的消息处理装置,应用于平台 级企业不同类型消息的传输,所述装置涉及云计算服务器,本地客户端,以及云存储服务 器;所述本地客户端分为个体、本地业务应用和第三方应用三种类型,所述本地客户端分为 发送端和接收端,所述云存储服务器用于存储二级日志; 所述本地客户端具体包括: 发送端,用于生成消息推送请求信息,并发送至所述云计算服务器,所述消息推送 请求信息包括消息推送指令、消息推送内容和消息类别; 接收端,用于接收所述云计算服务器反馈的根据匹配所述消息推送内容的目标传 送策略传送的消息推送内容;其中,所述云计算服务器调用所述云存储服务器中的所述二 级日志,通过所述二级日志对所述消息推送指令进行验证,若所述消息推送指令验证成功, 所述云计算服务器根据所述消息类别查找匹配所述消息推送内容生成所述目标传送策略。 本发明实施例公开了一种基于平台级企业消息总线的消息处理系统,应用于平台 级企业不同类型消息的传输,所述系统涉及云计算服务器,本地客户端,以及云存储服务 器;所述本地客户端分为个体、本地业务应用和第三方应用三种类型,所述本地客户端分为 发送端和接收端;具体包括: 所述发送端用于生成消息推送请求信息,并发送至所述云计算服务器,所述消息 推送请求信息包括消息推送指令、消息推送内容和消息类别; 所述云计算服务器用于接收所述发送端发送的消息推送请求信息; 所述云计算服务器还用于调用所述云存储服务器中的二级日志,通过所述二级日 志对所述消息推送指令进行验证; 所述云存储服务器用于存储所述二级日志; 所述云计算服务器还用于若所述消息推送指令验证成功,根据所述消息类别查找 匹配所述消息推送内容的目标传送策略; 所述接收端用于接收所述云计算服务器反馈的根据匹配所述消息推送内容的目 标传送策略传送的消息推送内容。 本发明实施例公开了一种电子设备,包括处理器、存储器及存储在所述存储器上 并能够在所述处理器上运行的计算机程序,所述计算机程序被所述处理器执行时实现如上 7 CN 111611206 A 说 明 书 4/13 页 述的基于平台级企业消息总线的消息处理方法的步骤。 本发明实施例公开了一种计算机可读存储介质,所述计算机可读存储介质上存储 计算机程序,所述计算机程序被处理器执行时实现如上述的基于平台级企业消息总线的消 息处理方法的步骤。 本发明实施例包括以下优点:通过企业消息总线构建了一条消息发送对象和消息 接收对象之间的桥梁,允许不同类型的消息通过企业消息总线实现信息的传输和交换,支 持多个对象实体之间的数据交换,通过策略制定,实现根据不同传输速率和质量要求的信 息在不同的传输管道中传输,实现不同推送和送达方式要求的信息通过不同的推送渠道去 送达。 附图说明 图1是本发明的一种基于平台级企业消息总线的消息处理方法实施例的步骤流程 图; 图2是本发明的一种基于平台级企业消息总线的消息处理方法实施例的步骤流程 图; 图3是本发明的一种基于平台级企业消息总线的消息处理装置实施例的结构框 图; 图4是本发明的一种基于平台级企业消息总线的消息处理装置实施例的结构框 图; 图5是本申请一实施例提供的一种基于平台级企业消息总线的消息处理系统的结 构框图; 图6是本发明一实施例的一种计算机设备的结构示意图; 图7是本发明一实施例的一种基于平台级企业消息总线的消息处理装置实施例的 结构示意图。
下载此资料需消耗2积分,
分享到:
收藏