基于随机消息队列发送医疗消息的方法及系统

摘要

本发明公开基于随机消息队列发送医疗消息的方法，包括：接收用于向用户发送医疗消息的医疗消息发送请求；从设定的第一时间间隔范围内，随机地获取生成医疗消息发送请求队列的医疗消息队列的第一时间间隔；按接收到医疗消息发送请求的时间，从先到后顺序获取在第一时间间隔内的医疗消息发送请求；将在第一时间间隔内的医疗消息发送请求发送至医疗消息发送的任务队列中；根据预先设定的医疗消息发送策略，从任务队列中获取相应的医疗消息发送请求，并发送至医疗消息发送引擎；接收医疗消息发送请求的医疗消息状态回调通知，转发送至对应的医疗消息发送方。本发明解决了同时发送医疗消息导致消息发送失败的问题。

说明书

技术领域

本发明涉及在线医疗的技术领域，更具体地，涉及一种基于随机消息队列发送医疗消息的方法及系统。

背景技术

随着互联网技术的快速发展，现在的互联网结合移动网络技术能够实现不同区域的人们之间随时随地的互动沟通。基于互联网的在线医疗领域，用户可以通过互联网与医生在线互动进行医疗咨询，打破了传统医疗领域中必须用户与医生面对面沟通医治的方式，实现了跨地域的医疗资源共享，解除了医疗资源的地域限制，实现了医疗资源的合理分配，同时解决了现今在医院医治排号难、路途远等看病难的问题。

但是，在线医疗过程中医生与用户之间的沟通是通过互联网络实现的，而用户所使用的互联网不一定每时每刻都具有较好的信号，且用户的在线医疗客户端不一定一直处于在线登录状态，就可能会接收不到医生所发送的在线医疗信息。因此，为了保证在线医疗过程中，医生与用户之间进行良好的在线沟通，还需要通过其它沟通方式确保医疗消息能够及时送达至用户。因为每时每刻都有大量的用户和医生通过在线医疗平台进行在线医疗沟通，所以通过在线医疗平台每时每刻都需要发送大量的医疗消息，而对于消息服务商来讲，在线医疗平台同时发送大量消息就会被视为垃圾消息而不被发送，用户也就不能及时接收到医疗消息，从而耽误用户的治疗。

并且，通过消息发送平台向多个用户同时发送消息，又不存在反馈报告时，在消息发送端是无法得知用户是否收到所发送的消息的，也就不能保证医疗消息准确、及时地发送至用户，从而提高了在线医疗的沟通成本。

因此，提供一种安全、及时准确地将在线医疗的医疗消息发送至用户的方案是本领域亟待解决的问题。

发明内容

有鉴于此，本发明提供了一种基于随机消息队列发送医疗消息的方法及系统，解决了现有技术中在通过消息发送平台向不同用户同时发送消息不能准确、及时到达用户的技术问题。

为了解决上述技术问题，本发明提出一种基于随机消息队列发送医疗消息的方法，包括：

在医疗消息发送平台上，接收用于向用户发送医疗消息的医疗消息发送请求；

从设定的第一时间间隔范围内，随机地获取生成医疗消息发送请求队列的医疗消息队列的第一时间间隔；按接收到所述医疗消息发送请求的时间，从先到后顺序获取在所述第一时间间隔内的所述医疗消息发送请求；

将在所述第一时间间隔内的所述医疗消息发送请求发送至医疗消息发送的任务队列中；

根据预先设定的医疗消息发送策略，从所述任务队列中获取相应的所述医疗消息发送请求，并发送至医疗消息发送引擎；

接收所述医疗消息发送请求的医疗消息状态回调通知，并将所述医疗消息状态回调通知发送至对应的医疗消息发送方。

进一步地，其中，根据预先设定的医疗消息发送策略，从所述任务队列中获取相应的所述医疗消息发送请求发送至医疗消息发送引擎，进一步为：

根据所述任务队列中预先设定的第二时间间隔，按所述任务队列接收到所述医疗消息发送请求的时间，从先到后顺序获取所述任务队列中在所述第二时间间隔内的所述医疗消息发送请求发送至医疗消息发送引擎。

进一步地，其中，该方法进一步包括：

将所述医疗消息发送请求发送至医疗消息发送引擎后，在回调时间阈值内未收到所述医疗消息发送请求的医疗消息状态回调通知时，每隔第三时间间隔重发一次所述医疗消息发送请求至所述医疗消息发送引擎。

进一步地，其中，根据预先设定的医疗消息发送策略，从所述任务队列中获取相应的所述医疗消息发送请求，并发送至医疗消息发送引擎，进一步为：

通过Nginx负载策略将大于或等于2个的医疗消息发送引擎按资源程度从大到小排序，根据所述资源程度排序顺序选择一个医疗消息发送引擎作为执行医疗消息发送引擎；

根据预先设定的医疗消息发送策略，从所述任务队列中获取相应的所述医疗消息发送请求发送至所述执行医疗消息发送引擎。

进一步地，其中，该方法进一步包括：

检测到所选择的医疗消息发送引擎的网络不通或异常时，根据所述资源程度排序，顺序选取所述选择的医疗消息发送引擎后一个医疗消息发送引擎作为执行医疗消息发送引擎；

根据预先设定的医疗消息发送策略，从所述任务队列中获取相应的所述医疗消息发送请求，并发送至所述执行医疗消息发送引擎。

另一方面，本发明还提供一种基于随机消息队列发送医疗消息的系统，包括：医疗消息发送请求接收模块、医疗消息发送请求选取模块、医疗消息发送请求队列生成模块、医疗消息发送请求队列执行模块及医疗消息状态回调通知模块；其中，

所述医疗消息发送请求接收模块，用于在医疗消息发送平台上，接收用于向用户发送医疗消息的医疗消息发送请求；

所述医疗消息发送请求选取模块，用于从设定的第一时间间隔范围内，随机地获取生成医疗消息发送请求队列的医疗消息队列的第一时间间隔；按接收到所述医疗消息发送请求的时间，从先到后顺序获取在所述第一时间间隔内的所述医疗消息发送请求；

所述医疗消息发送请求队列生成模块，用于将在所述第一时间间隔内的所述医疗消息发送请求发送至医疗消息发送的任务队列中；

所述医疗消息发送请求队列执行模块，用于根据预先设定的医疗消息发送策略，从所述任务队列中获取相应的所述医疗消息发送请求，并发送至医疗消息发送引擎；

所述医疗消息状态回调通知模块，用于接收所述医疗消息发送请求的医疗消息状态回调通知，并将所述医疗消息状态回调通知发送至对应的医疗消息发送方。

进一步地，其中，所述医疗消息发送请求队列执行模块，进一步用于：

根据所述任务队列中预先设定的第二时间间隔，按所述任务队列接收到所述医疗消息发送请求的时间，从先到后顺序获取所述任务队列中在所述第二时间间隔内的所述医疗消息发送请求发送至医疗消息发送引擎。

进一步地，其中，该系统还包括：医疗消息发送请求重发模块，用于：

将所述医疗消息发送请求发送至医疗消息发送引擎后，在回调时间阈值内未收到所述医疗消息发送请求的医疗消息状态回调通知时，每隔第三时间间隔重发一次所述医疗消息发送请求至所述医疗消息发送引擎。

进一步地，其中，所述医疗消息发送请求队列执行模块，进一步用于：

通过Nginx负载策略将大于或等于2个的医疗消息发送引擎按资源程度从大到小排序，根据所述资源程度排序顺序选择一个医疗消息发送引擎作为执行医疗消息发送引擎；

根据预先设定的医疗消息发送策略，从所述任务队列中获取相应的所述医疗消息发送请求发送至所述执行医疗消息发送引擎。

进一步地，其中，所述医疗消息发送请求队列执行模块，进一步用于：

检测到所选择的医疗消息发送引擎的网络不通或异常时，根据所述资源程度排序，顺序选取所述选择的医疗消息发送引擎后一个医疗消息发送引擎作为执行医疗消息发送引擎；

根据预先设定的医疗消息发送策略，从所述任务队列中获取相应的所述医疗消息发送请求，并发送至所述执行医疗消息发送引擎。

与现有技术相比，本发明的基于随机消息队列发送医疗消息的方法及系统，实现了如下的有益效果：

(1)本发明所述的基于随机消息队列发送医疗消息的方法及系统，在医疗消息发送平台上从发送消息的定时时间范围内，随机获取此次的发送消息请求的定时长度，根据获取的发送消息请求定时长度从消息发送请求集合中获取相应的医疗消息发送请求传输至任务队列中形成随机消息队列，根据随机消息队列执行医疗消息的发送，通过消息队列化发送解决了同时发送消息导致消息发送失败的问题。

(2)本发明所述的基于随机消息队列发送医疗消息的方法及系统，基于随机消息队列发送医疗消息至用户，并接收用户的反馈通知，在消息发送不成功时进行消息重发，确保医疗消息能准确、及时地发送至用户。

(3)本发明所述的基于随机消息队列发送医疗消息的方法及系统，结合多个消息发送服务器，从中选取资源最优的消息发送服务器执行医疗消息的发送，并在检测到当前消息发送服务器不可用时，切换到其它消息发送服务器，确保医疗消息能准确、及时地发送至用户，同时降低了消息重发的资源占用问题。

当然，实施本发明的任一产品必不特定需要同时达到以上所述的所有技术效果。

通过以下参照附图对本发明的示例性实施例的详细描述，本发明的其它特征及其优点将会变得清楚。

附图说明

被结合在说明书中并构成说明书的一部分的附图示出了本发明的实施例，并且连同其说明一起用于解释本发明的原理。

图1为本发明实施例1中所述基于随机消息队列发送医疗消息的方法的流程示意图；

图2为本发明实施例2中所述基于随机消息队列发送医疗消息的方法的流程示意图；

图3为本发明实施例3中所述基于随机消息队列发送医疗消息的系统的结构示意图；

图4为本发明实施例3中所述基于随机消息队列发送医疗消息的系统中信息传输的示意图。

具体实施方式

现在将参照附图来详细描述本发明的各种示例性实施例。应注意到：除非另外具体说明，否则在这些实施例中阐述的部件和步骤的相对布置、数字表达式和数值不限制本发明的范围。

以下对至少一个示例性实施例的描述实际上仅仅是说明性的，决不作为对本发明及其应用或使用的任何限制。

对于相关领域普通技术人员已知的技术、方法和设备可能不作详细讨论，但在适当情况下，所述技术、方法和设备应当被视为说明书的一部分。

在这里示出和讨论的所有例子中，任何具体值应被解释为仅仅是示例性的，而不是作为限制。因此，示例性实施例的其它例子可以具有不同的值。

应注意到：相似的标号和字母在下面的附图中表示类似项，因此，一旦某一项在一个附图中被定义，则在随后的附图中不需要对其进行进一步讨论。

实施例1

如图1所示，为本实施例中所述基于随机消息队列发送医疗消息的方法的流程示意图。本实施所述的基于随机消息队列发送医疗消息的方法通过随时、定时发送在线医疗过程中的医疗信息，解决了现有技术中不能同时向不同用户发送消息或向用户发送的消息不能准确到达的问题。本实施所述的基于随机消息队列发送医疗消息的方法包括如下步骤：

步骤101、医疗消息的发送方通过在线医疗平台向用户发送医疗消息，生成用于向用户发送医疗消息的医疗消息发送请求，并将所述医疗消息发送请求发送至所述在线医疗平台。

在所述医疗消息发送请求中包括有医疗消息内容、发送方的标识、目标用户的标识以及回调指令等信息数据。在所述医疗消息发送请求通过医疗消息发送引擎传输到所述目标用户时，基于所述回调指令及发送方的标识向所述发送方反馈医疗消息状态回调通知，由此在所述发送方就能获知所发送的医疗消息准确达到目标用户。

步骤102、所述在线医疗平台接收所述医疗消息发送请求，并记录接收所述医疗消息发送请求的时间。

每时每刻都会有大量的医疗消息请求发送到所述在线医疗平台，通过记录所述医疗消息发送请求的时间，可以合理有序地安排各个医疗消息通过医疗消息发送队列发送至各个目标用户的策略。

步骤103、从设定的第一时间间隔范围内，随机地获取生成医疗消息发送请求队列的医疗消息队列的第一时间间隔；按接收到所述医疗消息发送请求的时间，从先到后顺序获取在所述第一时间间隔内的所述医疗消息发送请求。

在线医疗的医疗消息发送平台时刻都可能收到大量的医疗消息发送请求，同时发送这么大量的消息既会引起医疗消息发送失败，还增加了医疗消息发送平台的消息发送压力。基于在线医疗的医疗消息发送平台，根据实际需要分批发送医疗消息，同时基于医疗消息发送平台的医疗消息发送的任务队列进行分批发送处理，有利于提升医疗消息发送的成功率。而基于本步骤随机选择该批次发送医疗消息发送请求的数量(基于第一时间间隔内的医疗消息发送请求数量)，且采用随机的方式从设定的第一时间间隔范围内获取每一次分批的第一时间间隔，有利于降低医疗消息请求发送的并发峰值。

优选地，所述第一时间间隔范围为0-30分钟。通过随机算法避免发送服务的并发复杂短时间过高风险。

步骤104、将在所述第一时间间隔内的所述医疗消息发送请求发送至医疗消息发送的任务队列中。

所述医疗消息发送的任务队列是医疗消息发送平台上执行医疗消息发送的重要模块，但是在有大量待执行的医疗消息发送请求需要执行或执行的医疗消息发送请求数量/频次过多都可能导致医疗消息发送异常，先将选取的待发送的医疗消息发送请求暂存在所述任务队列中，再结合任务队列中预先设定的医疗消息发送策略

步骤105、根据预先设定的医疗消息发送策略，从所述任务队列中获取相应的所述医疗消息发送请求，并发送至医疗消息发送引擎。

优选地，预先设定的所述医疗消息发送策略可以是按照任务队列中医疗消息发送请求的请求时间，也可以是按照固定的定时时间间隔，从所述任务队列中获取相应的所述医疗消息发送请求。

步骤106、所述医疗消息发送引擎接收所述医疗消息发送平台发送的医疗消息发送请求，会根据医疗消息发送请求中的目标用户标识将医疗消息发送至目标用户。

步骤107、目标用户接收到发送方发送的医疗消息时，基于回调指令及目标用户标识自动生成携带发送方标识的医疗消息状态回调通知，并反馈至所述医疗消息发送平台。

步骤108、医疗消息发送平台接收所述医疗消息发送请求的医疗消息状态回调通知，并将所述医疗消息状态回调通知发送至对应的医疗消息发送方。

通过医疗消息状态回调通知机制，使得发送方能及时获取医疗消息发送到达目标用户的信息，也就不用再进行医疗消息发送失败的处理措施了，同时保证了医疗消息发送方与目标用户之间沟通信息的同步性。

本实施例所述的基于随机消息队列发送医疗消息的方法，根据随机消息队列执行医疗消息的发送，通过消息队列化发送解决了同时发送消息导致消息发送失败的问题。

实施例2

如图2所示，为本实施例中所述基于随机消息队列发送医疗消息的方法的流程示意图。本实施例在实施例1的基础上，描述了医疗消息发送策略、重发所述医疗消息发送请求的具体内容。本实施例所述的基于随机消息队列发送医疗消息的方法包括如下步骤：

步骤201、医疗消息的发送方通过在线医疗平台向用户发送医疗消息，生成用于向用户发送医疗消息的医疗消息发送请求，并将所述医疗消息发送请求发送至所述在线医疗平台。

步骤202、所述在线医疗平台接收所述医疗消息发送请求，并记录接收所述医疗消息发送请求的时间

步骤203、从设定的第一时间间隔范围内，随机地获取生成医疗消息发送请求队列的医疗消息队列的第一时间间隔；按接收到所述医疗消息发送请求的时间，从先到后顺序获取在所述第一时间间隔内的所述医疗消息发送请求。

步骤204、将在所述第一时间间隔内的所述医疗消息发送请求发送至医疗消息发送的任务队列中。

步骤205、通过Nginx负载策略将大于或等于2个的医疗消息发送引擎按资源程度从大到小排序，根据所述资源程度排序顺序选择一个医疗消息发送引擎作为执行医疗消息发送引擎。

通过多医疗消息发送引擎可以增加医疗消息发送过程中的容错机制，保证在一个医疗消息发送引擎异常的情况下有多个医疗消息发送选择，也就保证了医疗消息能够准确、及时地到达目标用户。

步骤206、检测到所选择的医疗消息发送引擎的网络不通或异常时，根据所述资源程度排序，顺序选取所述选择的医疗消息发送引擎后一个医疗消息发送引擎作为执行医疗消息发送引擎。

步骤207、根据所述任务队列中预先设定的第二时间间隔，按所述任务队列接收到所述医疗消息发送请求的时间，从先到后顺序获取所述任务队列中在所述第二时间间隔内的所述医疗消息发送请求发送至执行医疗消息发送引擎。

优选地，所述第二时间间隔范围可以是0-30分钟，通过第二时间间隔的设置能够保证任务队列中待发送的医疗消息请求被分批、顺畅地发送至目标用户。

步骤208、所述医疗消息发送引擎接收所述医疗消息发送平台发送的医疗消息发送请求，会根据医疗消息发送请求中的目标用户标识将医疗消息发送至目标用户。

步骤209、目标用户接收到发送方发送的医疗消息时，基于回调指令及目标用户标识自动生成携带发送方标识的医疗消息状态回调通知，并反馈至所述医疗消息发送平台。

步骤210、医疗消息发送平台接收所述医疗消息发送请求的医疗消息状态回调通知，并将所述医疗消息状态回调通知发送至对应的医疗消息发送方。

此处的医疗消息状态回调通知表示所述医疗消息成功发送目标用户，而在所述医疗消息未发送目标用户时会产生医疗消息发送失败的状态回调通知。

步骤211、将所述医疗消息发送请求发送至医疗消息发送引擎后，在回调时间阈值内未收到所述医疗消息发送请求的医疗消息状态回调通知时，每隔第三时间间隔重发一次所述医疗消息发送请求至所述医疗消息发送引擎。

优选地，所述回调时间阈值为1-5分钟。更优选地，设置所述医疗消息发送请求的重发次数为3-10次，在超过所述医疗消息发送请求的重发次数后，向所述医疗消息的发送方反馈医疗消息发送失败的状态回调通知。

本实施例所述的基于随机消息队列发送医疗消息的方法，基于随机消息队列发送医疗消息至用户，并接收用户的反馈通知，在消息发送不成功时进行消息重发，确保医疗消息能准确、及时地发送至用户。

实施例3

如图3所示，为本实施例中所述基于随机消息队列发送医疗消息的系统的结构示意图。本实施例所述的基于随机消息队列发送医疗消息的系统用于实施上述实施例中所述基于随机消息队列发送医疗消息的方法。

本实施例中所述基于随机消息队列发送医疗消息的系统包括：医疗消息发送请求接收模块301、医疗消息发送请求选取模块302、医疗消息发送请求队列生成模块303、医疗消息发送请求队列执行模块304及医疗消息状态回调通知模块305。

其中，所述医疗消息发送请求接收模块301与所述医疗消息发送请求选取模块302相藕接，用于在医疗消息发送平台上，接收用于向用户发送医疗消息的医疗消息发送请求。

所述医疗消息发送请求选取模块302与所述医疗消息发送请求接收模块301及医疗消息发送请求队列生成模块303相藕接，用于从设定的第一时间间隔范围内，随机地获取生成医疗消息发送请求队列的医疗消息队列的第一时间间隔；按接收到所述医疗消息发送请求的时间，从先到后顺序获取在所述第一时间间隔内的所述医疗消息发送请求。

所述医疗消息发送请求队列生成模块303与所述医疗消息发送请求选取模块302及医疗消息发送请求队列执行模块304相藕接，用于将在所述第一时间间隔内的所述医疗消息发送请求发送至医疗消息发送的任务队列中。

所述医疗消息发送请求队列执行模块304与所述医疗消息发送请求队列生成模块303及医疗消息状态回调通知模块305相藕接，用于根据预先设定的医疗消息发送策略，从所述任务队列中获取相应的所述医疗消息发送请求，并发送至医疗消息发送引擎。

所述医疗消息状态回调通知模块305与所述医疗消息发送请求队列执行模块304相藕接，用于接收所述医疗消息发送请求的医疗消息状态回调通知，并将所述医疗消息状态回调通知发送至对应的医疗消息发送方。

所述医疗消息发送请求队列执行模块304，进一步用于：

根据所述任务队列中预先设定的第二时间间隔，按所述任务队列接收到所述医疗消息发送请求的时间，从先到后顺序获取所述任务队列中在所述第二时间间隔内的所述医疗消息发送请求发送至医疗消息发送引擎。

所述医疗消息发送请求队列执行模块304，进一步用于：

通过Nginx负载策略将大于或等于2个的医疗消息发送引擎按资源程度从大到小排序，根据所述资源程度排序顺序选择一个医疗消息发送引擎作为执行医疗消息发送引擎；

根据预先设定的医疗消息发送策略，从所述任务队列中获取相应的所述医疗消息发送请求发送至所述执行医疗消息发送引擎。

所述医疗消息发送请求队列执行模块304，还用于：

检测到所选择的医疗消息发送引擎的网络不通或异常时，根据所述资源程度排序，顺序选取所述选择的医疗消息发送引擎后一个医疗消息发送引擎作为执行医疗消息发送引擎；

根据预先设定的医疗消息发送策略，从所述任务队列中获取相应的所述医疗消息发送请求，并发送至所述执行医疗消息发送引擎。

该系统还包括：医疗消息发送请求重发模块306与所述医疗消息状态回调通知模块305相藕接，用于：

将所述医疗消息发送请求发送至医疗消息发送引擎后，在回调时间阈值内未收到所述医疗消息发送请求的医疗消息状态回调通知时，每隔第三时间间隔重发一次所述医疗消息发送请求至所述医疗消息发送引擎。

如图4所示，为本实施例中所述基于随机消息队列发送医疗消息的系统中信息传输的示意图。在图4中，医疗消息发送方401生成医疗消息发送请求并发送至医疗消息发送平台402；医疗消息发送平台402接收医疗消息发送请求按照预定策略选取医疗消息发送请求加入到医疗消息发送平台402的任务队列403中；任务队列403根据任务队列中的设定策略选取医疗消息发送请求发送至医疗消息发送引擎404；医疗消息发送引擎404将接收到的医疗消息发送请求中携带的医疗消息发送至用户405；在用户405上生成状态回调通知并反馈至医疗消息发送平台402，由医疗消息发送平台402传达至医疗消息发送方401。

通过以上各个实施例可知，本发明的基于随机消息队列发送医疗消息的方法及系统，存在的有益效果是：

(1)本发明所述的基于随机消息队列发送医疗消息的方法及系统，在医疗消息发送平台上从发送消息的定时时间范围内，随机获取此次的发送消息请求的定时长度，根据获取的发送消息请求定时长度从消息发送请求集合中获取相应的医疗消息发送请求传输至任务队列中形成随机消息队列，根据随机消息队列执行医疗消息的发送，通过消息队列化发送解决了同时发送消息导致消息发送失败的问题。

(2)本发明所述的基于随机消息队列发送医疗消息的方法及系统，基于随机消息队列发送医疗消息至用户，并接收用户的反馈通知，在消息发送不成功时进行消息重发，确保医疗消息能准确、及时地发送至用户。

(3)本发明所述的基于随机消息队列发送医疗消息的方法及系统，结合多个消息发送服务器，从中选取资源最优的消息发送服务器执行医疗消息的发送，并在检测到当前消息发送服务器不可用时，切换到其它消息发送服务器，确保医疗消息能准确、及时地发送至用户，同时降低了消息重发的资源占用问题。

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

虽然已经通过例子对本发明的一些特定实施例进行了详细说明，但是本领域的技术人员应该理解，以上例子仅是为了进行说明，而不是为了限制本发明的范围。本领域的技术人员应该理解，可在不脱离本发明的范围和精神的情况下，对以上实施例进行修改。本发明的范围由所附权利要求来限定。