消息转发网关系统和消息转发方法.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN112152915A(43)申请公布日2020.12.29(21)申请号201910576943.1(22)申请日2019.06.28(71)申请人北京沃东天骏信息技术有限公司地址100176北京市北京经济技术开发区科创十一街18号院2号楼4层A402室(72)发明人李爽李亚周高廉墀(74)专利代理机构中原信达知识产权代理有限责任公司11219代理人李阳伊明明(51)Int.Cl.H04L12/66(2006.01)H04L12/24(2006.01)H04L29/08(2006.01)权利要求书1页说明书9页附图4页(54)发明名称消息转发网关系统和消息转发方法(57)摘要本发明公开了一种消息转发网关系统和消息转发方法，涉及计算机技术领域。该系统的一具体实施方式包括：第一网关，用于接收HTTP请求，解析所述HTTP请求，获得待发送数据；第二网关，用于根据所述待发送数据生成待发送消息，并将待发送消息发送至目标终端。该实施方式能够使用户在多种程序设计语言环境下向目标终端发送消息，突破了官方语言的限制，而且用户不需要关心版本兼容的问题；而且，第一网关和第二网关分别负责消息转发网关系统的不同部分，构成了分层架构，达到系统分层业务解耦的目的，使数据处理更加灵活，具有较强的可维护性和可扩展性，降低了维护成本。CN112152915ACN112152915A权利要求书1/1页1.一种消息转发网关系统，其特征在于，所述系统包括：第一网关，用于接收超文本传输协议HTTP请求，解析所述HTTP请求，获得待发送数据；第二网关，用于接收来自第一网关的待发送数据，根据所述待发送数据生成待发送消息，并将所述待发送消息发送至目标终端。2.根据权利要求1所述的系统，其特征在于，所述第一网关还用于：解析所述HTTP请求，确定发起所述HTTP请求的时间；根据所述发起所述HTTP请求的时间和当前时间，确定所述HTTP请求是否过期；若是，则丢弃所述HTTP请求。3.根据权利要求1所述的系统，其特征在于，所述第一网关还用于：解析所述HTTP请求，确定发起所述HTTP请求的用户的身份信息；根据所述身份信息，确定发起所述HTTP请求的用户的权限。4.根据权利要求1所述的系统，其特征在于，所述系统还包括监控模块，用于获取监控指标，并根据监控指标确定当前阶段的消息发送状态是否正常，若否，则输出报警信息。5.根据权利要求1所述的系统，其特征在于，所述第一网关包括多个第一服务器，所述多个第一服务器共享第一域名，所述多个第一服务器轮流接收所述待发送请求；所述第二网关包括多个第二服务器，所述多个第二服务器共享第二域名，所述多个第二服务器轮流接收所述待发送消息。6.一种消息转发方法，其特征在于，用于消息转发的网关包括第一网关和第二网关，该消息转发方法包括；第一网关接收超文本传输协议HTTP请求，并解析所述待发送请求，获得待发送数据；第二网关接收来自所述第一网关的待发送数据，根据所述待发送数据生成待发送消息，并将所述待发送消息发送至目标终端。7.一种消息转发方法，其特征在于，包括：接收超文本传输协议HTTP请求；解析所述HTTP请求，获得待发送数据，所述待发送数据用于发送至第二网关，以使所述第二网关根据所述待发送数据生成待发送消息，所述待发送消息用于发送至目标终端。8.一种消息转发方法，其特征在于，包括：接收来自第一网关的待发送数据，其中，所述待发送数据通过解析接收到的超文本传输协议HTTP请求获得；根据所述待发送数据生成待发送消息，并将所述待发送消息发送至目标终端。9.一种电子设备，其特征在于，包括：一个或多个处理器；存储装置，用于存储一个或多个程序，当所述一个或多个程序被所述一个或多个处理器执行，使得所述一个或多个处理器实现如权利要求6所述的方法。10.一种计算机可读介质，其上存储有计算机程序，其特征在于，所述程序被处理器执行时实现如权利要求6所述的方法。2CN112152915A说明书1/9页消息转发网关系统和消息转发方法技术领域[0001]本发明涉及计算机技术领域，尤其涉及一种消息转发网关系统和消息转发方法。背景技术[0002]目前，随着大数据技术的发展，数据量暴增场景频现，由于此类需求往往超出传统数据处理技术的能力，使得现有的技术不能很好第满足对海量、高速数据进行实时处理和分析的需求，分布式流技术应运而生，例如分布式流处理平台Kafka。该平台的目标是为处理实时数据提供一个统一、高吞吐、低延迟的平台。现有常用的消息处理模式一般是使用原生的Kafka生产者客户端将消息发送到版本兼容的Kafka服务器集群指定的Topic，每个Topic中的消息会被分为若干个Partition(分区)，以提高消息的处理效