一种基于接口的消息推送方法及系统

本发明涉及消息推送技术领域，尤其涉及一种基于接口的消息推送方法及系统。

本部分的陈述仅仅是提供了与本公开相关的背景技术信息，不必然构成在先技术。

随着企业的业务融合趋势，应用系统间存在大量的数据交换需求，目前通过消息推送的方式实现企业各部门之间的基础数据共享，从而让基础数据发挥更大的价值和作用，但是传统的消息推送在数据订阅发布过程中，通过数据部捕获数据变化来触发捕获变化数据，这种方式效率低，同时也消耗自身资源，且不能有效保证消息传输过程中的安全性。

本公开为了解决上述问题，提出了一种基于接口的消息推送方法及系统，在信息推送过程中，对消息生产者的身份、信息推送时间和信息参数进行验证，保证信息传输的安全性。

为实现上述目的，本公开采用如下技术方案：

第一方面，提出了一种基于接口的消息推送方法，包括：

消息生产者向消息推送系统发送要推送信息的申请信息，申请通过对外接口B进行消息推送；

消息推送系统对申请信息进行审核，审核通过后，生成身份验证信息，将身份验证信息发送给消息生产者；

消息生产者调用对外接口B推送要推送的信息时，向消息推送系统提供身份验证信息；

消息推送系统对消息生产者身份、信息推送时间和要推送的信息参数进行验证；

当消息生产者身份、信息推送时间和信息参数验证通过后，将消息生产者要推送的信息通过对外接口B推送给消费方。

第二方面，提出了一种基于接口的消息推送系统，包括：

消息推送接口模块，用于接收消息生产者要推送信息的申请信息，申请通过对外接口B进行消息推送；

申请信息审核模块，用于对申请信息进行审核，审核通过后，生成身份验证信息，将身份验证信息发送给消息生产者；

信息推送模块，用于接收消息生产者的身份验证信息和要推送的信息，对消息生产者身份、信息推送时间和要推送的信息参数进行验证，当消息生产者身份、信息推送时间和信息参数验证通过后，将消息生产者要推送的信息通过对外接口B推送给消费方。

第三方面，提出了一种电子设备，包括存储器和处理器以及存储在存储器上并在处理器上运行的计算机指令，所述计算机指令被处理器运行时，完成一种基于接口的消息推送方法所述的步骤。

第四方面，提出了一种计算机可读存储介质，用于存储计算机指令，所述计算机指令被处理器执行时，完成一种基于接口的消息推送方法所述的步骤。

与现有技术相比，本公开的有益效果为：

1、本公开在信息推送的过程中对消息生产者的身份、信息推送时间和信息参数进行验证，保证信息传输的安全性。

2、本公开通过验证信息推送时间，对信息推送的时间进行了限制，避免了大量消息在同一时间段内涌入，造成阻塞，推送时间的平均分配也避免了服务器性能的浪费，有效的利用服务器性能，错峰分流，保障消息的推送。

本发明附加方面的优点将在下面的描述中部分给出，部分将从下面的描述中变得明显，或通过本发明的实践了解到。

构成本申请的一部分的说明书附图用来提供对本申请的进一步理解，本申请的示意性实施例及其说明用于解释本申请，并不构成对本申请的不当限定。

图1为本公开实施例1公开的一种基于接口的消息推送方法流程图。

下面结合附图与实施例对本公开作进一步说明。

应该指出，以下详细说明都是例示性的，旨在对本申请提供进一步的说明。除非另有指明，本文使用的所有技术和科学术语具有与本申请所属技术领域的普通技术人员通常理解的相同含义。

需要注意的是，这里所使用的术语仅是为了描述具体实施方式，而非意图限制根据本申请的示例性实施方式。如在这里所使用的，除非上下文另外明确指出，否则单数形式也意图包括复数形式，此外，还应当理解的是，当在本说明书中使用术语“包含”和/或“包括”时，其指明存在特征、步骤、操作、器件、组件和/或它们的组合。

在本公开中，术语如“上”、“下”、“左”、“右”、“前”、“后”、“竖直”、“水平”、“侧”、“底”等指示的方位或位置关系为基于附图所示的方位或位置关系，只是为了便于叙述本公开各部件或元件结构关系而确定的关系词，并非特指本公开中任一部件或元件，不能理解为对本公开的限制。

本公开中，术语如“固接”、“相连”、“连接”等应做广义理解，表示可以是固定连接，也可以是一体地连接或可拆卸连接；可以是直接相连，也可以通过中间媒介间接相连。对于本领域的相关科研或技术人员，可以根据具体情况确定上述术语在本公开中的具体含义，不能理解为对本公开的限制。

实施例1

在该实施例中，公开了一种基于接口的消息推送方法，包括：

消息推送系统接收消息生产者要推送信息的申请信息，申请通过对外接口B进行消息推送；

消息推送系统对申请信息进行审核，审核通过后，生成身份验证信息，将身份验证信息发送给消息生产者；

消息推送系统接收消息生产者的身份验证信息和要推送的信息，对消息生产者身份、信息推送时间和要推送的信息参数进行验证，当消息生产者身份、信息推送时间和信息参数验证通过后，将消息生产者要推送的信息通过对外接口B推送给消费方。

进一步的，申请信息包括消息生产者的IP地址、消息生产者推送消息的开始时间和截止时间、要推送的信息的参数信息。

进一步的，身份验证信息包括用户名和密码。

进一步的，消息推送系统通过身份验证信息对消息生产者身份、信息推送时间和信息参数进行验证的过程为；

通过用户名和密码对消息生产者的身份进行验证，验证通过后，将信息推送时间和申请信息中的消息生产者推送消息的开始时间和截止时间进行比对，如果信息推送时间位于申请信息中的消息生产者推送消息的开始时间和截止时间之间，信息推送时间验证通过，之后对要推送的信息的信息参数进行参数验证。

进一步的，当消息生产者身份、信息推送时间和信息参数均验证通过后，将要推送的信息加入消息推送系统信息队列中，当消息推送系统监听到消息队列中消息生产者要推送的信息时，查询所有订阅对外接口B的消费方，将消息生产者要推送的信息推送给所有订阅对外接口B的消费方。

进一步的，消息生产者通过消息推送接口，将要推送的信息以参数的方式传入消息推送系统中，消息推送系统设置对外接口，消费方设置消息接收接口并在消息推送系统中订阅对外接口，消费方还将消息接收接口的信息注册到消息推送系统中。

进一步的，消费方接收到消息生产者要推送的信息后，向消息推送系统通知消息消费情况，生成消息消费日志。

结合图1对一种基于接口的消息推送方法进行详细说明，具体为：

消息生产者开发消息推送接口，消息生产者通过消息推送接口将要推送的信息以参数的方式传入消息推送系统。

将消息推送接口在消息推送系统中进行注册包装，然后消息推送系统设置外开放接口。

消息的消费方开发消息接收接口，用来接收和个性化消息处理。

消费方想要接收推送的消息，需要在消息推送系统中订阅系统的对外接口，并将消息接收接口的相关信息注册到系统。

消息生产者在推送消息前，需要向消息推送系统申请推送消息，具体为；消息生产者想要通过对外接口B推送要推送的信息时，需要先向消息推送系统发送要推送的信息的申请信息，申请信息包括但不限于消息生产者的I P地址，消息生产者推送信息的时间和截止时间，要推送的信息的参数等用于验证和限制的信息。

消息推送系统对申请信息进行审核，如果申请的消息生产者推送信息的时间和截止时间不合适，则对推送时间和截止时间进行调整，当申请信息审核通过后，生成一个用户名和密码，将用户名和密码发送至消息生产者，在消息生产者推送要推送的信息时，向消息推送系统提供该用户名和密码。

消息生产者调用对外接口B推送要推送的信息时，将用户名和密码及要推送的信息输入消息推送系统中，消息推送系统通过用户名和密码对消息生产者的身份进行验证，验证通过后，将信息推送时间和申请信息中的消息生产者推送消息的开始时间和截止时间进行比对，如果信息推送时间位于申请信息中的消息生产者推送消息的开始时间和截止时间之间，信息推送时间验证通过，之后对要推送的信息的信息参数进行参数验证，参数验证内容包括要推送的信息参数的类型，参数的个数，参数的位置等。身份验证、信息推送时间验证和信息参数验证均通过后，消息推送系统将消息生产者要推送的信息加入系统的消息队列，在数据库中记录推送日志。其中信息推送时间为消息生产者调用对外接口B推送要推送的信息时，消息推送系统自动获取。

消息推送系统监听获取到队列中的消息生产方要推送的信息之后，会根据消息生产者要推送的信息检索数据库，查询出所有订阅对外接口B的消费方，并获取他们注册的消息消费接口，通过调用消息消费接口，将消息生产者要推送的信息发送到消费方。

消费者在接收到消息生产者要推送的消息之后，通过消息消费接口的返回值形式通知消息消费情况，消息推送系统根据消息消费情况生成消息消费日志。

当消息生产者在调用对外接口B推送消息失败时，生成失败标志码，根据失败标志码对失败原因进行判断，如果是由于消息生产者本身调用的问题，如调用的对外接口地址有误，参数个数和类型不正确，信息推送时间不在合法范围内等问题时，消息推送系统会及时报错，进行提醒，并记录失败日志。如果是由于网络原因导致的消息推送失败，消息推送系统会进行试错机制，会在3分钟之后再次进行对外接口调用，如此反复3次，确定不是网络波动的问题，记录该次推送日志，并给该日志标记，之后会在每天进行一次推送，直到推送成功，或者是人为操作，废弃该消息。消费者调用对外接口失败处理机制与消息生产者本身失败调用的处理机制相同。

当服务器由于外部原因宕机，导致重启，系统内的消息队列被清空的话，系统会自动读取消息消费日志，对未消费的消息重新进行推送消费。

本实施例公开的一种基于接口的消息推送方法有益于实现信息的安全传输，IP、用户名密码、时间、信息参数多重的验证机制保障了信息的传输安全。

本实施例有效的利用服务器性能，错峰分流，保障消息的推送。系统能够对消息推送的时间进行限制，避免了大量消息在同一时间段内涌入，造成阻塞，推送时间的平均分配也避免了服务器性能的浪费。

实施例2

在该实施例中，公开了一种基于接口的消息推送系统，包括：

消息推送接口模块，用于接收消息生产者要推送信息的申请信息，申请通过对外接口B进行消息推送；

申请信息审核模块，用于对申请信息进行审核，审核通过后，生成身份验证信息，将身份验证信息发送给消息生产者；

信息推送模块，用于接收消息生产者的身份验证信息和要推送的信息，对消息生产者身份、信息推送时间和要推送的信息参数进行验证，当消息生产者身份、信息推送时间和信息参数验证通过后，将消息生产者要推送的信息通过对外接口B推送给消费方。

实施例3

在该实施例中，公开了一种电子设备，包括存储器和处理器以及存储在存储器上并在处理器上运行的计算机指令，所述计算机指令被处理器运行时，完成实施例1公开的一种基于接口的消息推送方法所述的步骤。

实施例4

在该实施例中，公开了一种计算机可读存储介质，用于存储计算机指令，所述计算机指令被处理器执行时，完成实施例1公开的一种基于接口的消息推送方法所述的步骤。

以上仅为本申请的优选实施例而已，并不用于限制本申请，对于本领域的技术人员来说，本申请可以有各种更改和变化。凡在本申请的精神和原则之内，所作的任何修改、等同替换、改进等，均应包含在本申请的保护范围之内。

本领域内的技术人员应明白，本申请的实施例可提供为方法、系统、或计算机程序产品。因此，本申请可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且，本申请可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、CD-ROM、光学存储器等)上实施的计算机程序产品的形式。

本申请是参照根据本申请实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器，使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。

这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中，使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品，该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。

这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上，使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理，从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。

最后应当说明的是：以上实施例仅用以说明本发明的技术方案而非对其限制，尽管参照上述实施例对本发明进行了详细的说明，所属领域的普通技术人员应当理解：依然可以对本发明的具体实施方式进行修改或者等同替换，而未脱离本发明精神和范围的任何修改或者等同替换，其均应涵盖在本发明的权利要求保护范围之内。