一种企业应用实时通知提醒方法与流程

1.本发明涉及数据处理技术领域，具体地涉及一种企业应用实时通知提醒方法。


背景技术：

2.企业应用开发过程中经常需要处理一些实时性要求高的数据，比如订单、消息、任务、重要通知等场景，主要通过定时轮训的方式，每隔固定间隔时间请求信息接口，根据获取到的数据结果判定是否存在需要实时处理的数据信息，同时，对于同一个消息进行不通时间的推送，也会通过控制接口返回数据的时间来决定不同时间的提醒。
3.针对不同应用规模和复杂性的变化情况，可能存在资源耗费较大，对服务器硬件资源要求不同，另一方面，通信的长连接技术更新，应用场景逐步增加，采用统一的长连接服务中心系统，对企业级应用提供从协议、管理、逻辑处理等统一的网关入口方式，也更加迫切，现有技术难以满足企业应用的对接效率并满足不同使用场景的需求。


技术实现要素：

4.本发明的目的在于克服现有技术存在的缺点，提出设计一种企业应用实时通知提醒方法，采用tcp长连接的方式，以及分层级、分角色、分人员的复杂实时通知提醒，提高了企业应用的对接效率。
5.本发明解决其技术问题所采取的技术方案是：
6.一种企业应用实时通知提醒方法，包括以下步骤：
7.l1、建立统一的通知服务中心，主要负责通信的建立、维护和管理，同时可以实时查看到建立通信连接的用户、设备终端等信息；
8.l2、所述通知服务中心与业务端建立tcp长连接，并将返回的长连接标识符进行存储，采用分层级、分角色、分人员的复杂实时通知提醒；
9.l3、应用业务中需要进行通知时，将业务中待通知人员或设备进行分组处理，并标识清晰分组的附加信息；
10.l4、通过网关处理分组请求，以及对分组进行通知，通知过程完全由通知服务中心根据附加信息执行。
11.上述技术方案提供了统一的通知服务中心，极大的与业务分解，同时采用tcp长连接的方式，以及分层级、分角色、分人员的复杂实时通知提醒，提高了企业应用的对接效率。
12.进一步的，所述通知服务中心包括任务通知分组模块，用于提供层级、角色、人员的任务通知分组服务。
13.进一步的，所述通知服务中心包括数据分组管理模块，具备临时分组数据的管理功能，可实现分组和分组数据的清洗、缓存、清理等淘汰和数据管理功能，根据数据附加信息自我检测排查，使系统具备符合业务使用的销毁机制，达到无效资源的释放和可用资源的高效利用。
14.进一步的，所述通知服务中心包括清除销毁模块，通过提供分组的人工销毁网关
入口，为业务端提供可控的分组维护错误，提高通知服务的高效使用，在业务任务需要的时候及时创建分组，业务任务可见执行逻辑不需要分组时，及时的进行分组的淘汰销毁。
15.进一步的，所述通知服务中心包括实时修改模块，针对更加复杂多变的场景，同时提供分组的实时修改入口。
16.进一步的，分组通知任务的实现，主要通过多线程或者多协成的方式进行执行，对创建分组时的附加信息进行分析，如果存在延迟执行、重复使用限制等信息，可在执行分组通知时采用线程/协成内等待的方式，达到任务统一执行。
17.进一步的，所述网关入口提供统一的通信连接入口，用于构建每个终端、用户的长连接标识，该标识可采用通用的规则，生产唯一标识，并对标记进行缓存或其他方式存储，以上任何通知推送逻辑都是基于次标记进行层级、角色、人员等分组关系绑定。
18.进一步的，所述通知服务中心还包括负载均衡调度模块，用于调度服务请求，具体包括以下步骤：
19.获取各业务端的负载均衡器接收服务请求的服务流量；
20.根据各业务端的服务流量配置调度路线；
21.将调度路线发送至配置中心进行优化处理，根据路线调度级别以及服务请求是否超时做进一步优化，以达到负载均衡的效果。
22.进一步的，所述路线调度级别ti：
[0023][0024]
其中，n为业务端数量，li为第i种业务端的权重，mi为第i种业务端的服务流量，ti为第i种服务端的利用率；p
ij
为第i种业务端的第j条服务通知的加权系数。根据路线调度级别ti将调度路线逐级发送至配置中心进行优化处理。
[0025]
进一步的，当p
ij
t
ij
＞w时，服务请求超时，对该服务请求由配置中心进行优先处理，其中，t
ij
为第i种业务端的第j条服务通知的请求时间，w为预设值，当p
ij
t
ij
大于该预设值时判定为请求超时，需及时处理，避免由此引起异常。
[0026]
本发明的技术效果：
[0027]
与现有技术相比，本发明的一种企业应用实时通知提醒方法，通过提供统一的通知服务中心，极大的与业务分解，形成独立的通知服务管理系统，在企业应用中可对通知场景快速接入使用，企业中也可以不同的应用场景共用通知服务中心，基于通知服务中心不同分组、角色以及单人员的场景提供了多重可重复使用的基础服务能力，极大的提升企业应用的对接效率，并满足不同使用场景的需求。
附图说明
[0028]
图1为本发明企业应用实时通知提醒方法示意图。
具体实施方式
[0029]
为使本发明实施例的目的、技术方案和优点更加清楚，下面结合说明书附图，对本发明实施例中的技术方案进行清楚、完整地描述。
[0030]
实施例1：
[0031]
如图1所示，本实施例涉及的一种企业应用实时通知提醒方法，包括以下步骤：
[0032]
l1、建立统一的通知服务中心，主要负责通信的建立、维护和管理，同时可以实时查看到建立通信连接的用户、设备终端等信息；所述通知服务中心提供统一的网关入口；
[0033]
l2、所述通知服务中心与业务端建立tcp长连接，并将返回的长连接标识符进行存储，采用分层级、分角色、分人员的复杂实时通知提醒；所述业务端在需要与通知服务中心通信时，通过企业内部获取网关入口的相关文档；
[0034]
l3、应用业务中需要进行通知时，将业务中待通知人员或设备进行分组处理，并标识清晰分组的附加信息；
[0035]
l4、通过网关处理分组请求，以及对此分组进行通知，通知过程完全由通知服务中心根据附加信息执行。
[0036]
所述通知服务中心包括任务通知分组模块、数据分组管理模块、清除销毁模块、实时修改模块和负载均衡调度模块。
[0037]
所述任务通知分组模块用于提供层级、角色、人员的任务通知分组服务，也可以在提供分组服务的同时编码延迟时长、重复利用等附加信息。
[0038]
所述数据分组管理模块具备临时分组数据的管理功能，可实现分组和分组数据的清洗、缓存、清理等淘汰和数据管理功能，根据数据附加信息自我检测排查，使系统具备符合业务使用的销毁机制，达到无效资源的释放和可用资源的高效利用。
[0039]
所述清除销毁模块通过提供分组的人工销毁网关入口，为业务端提供可控的分组维护错误，提高通知服务的高效使用，在业务任务需要的时候及时创建分组，业务任务可见执行逻辑不需要分组时，及时的进行分组的淘汰销毁。
[0040]
所述实时修改模块针对更加复杂多变的场景，同时提供分组的实时修改入口，例如通知任务中对不同层级、角色的分组在执行过程中进行轻量的修改时候，考虑将已创建的分组进行调整，减少对负责分组逻辑中重复执行分组逻辑校验的过程，若在任务过程中存在大量分组数据修改，可通过销毁分组并重建的方式来实现。
[0041]
所述负载均衡调度模块用于调度服务请求，具体包括以下步骤：
[0042]
获取各业务端的负载均衡器接收服务请求的服务流量；
[0043]
根据各业务端的服务流量配置调度路线；
[0044]
将调度路线发送至配置中心进行优化处理，根据路线调度级别以及服务请求是否超时做进一步优化，以达到负载均衡的效果。
[0045]
所述路线调度级别ti：
[0046][0047]
其中，n为业务端数量，li为第i种业务端的权重，mi为第i种业务端的服务流量，ti为第i种服务端的利用率；p
ij
为第i种业务端的第j条服务通知的加权系数。根据路线调度级别ti将调度路线逐级发送至配置中心进行优化处理。当p
ij
t
ij
＞w时，服务请求超时，对该服务请求由配置中心进行优先处理，其中，t
ij
为第i种业务端的第j条服务通知的请求时间，w为预设值，当p
ij
t
ij
大于该预设值时判定为请求超时，需及时处理，避免由此引起异常。
[0048]
本发明分组通知任务的实现，主要通过多线程或者多协成的方式进行执行，对创建分组时的附加信息进行分析，如果存在延迟执行、重复使用限制等信息，可在执行分组通知时采用线程/协成内等待的方式，达到任务统一执行，但最终触达时间不同，可减少对业务逻辑中延迟定时等方法的依赖，以减少复杂性。单任务通知的实现，主要为提供单用户场景的需要，提供仅针对单个人员的直接实时通知、等待通知、等待取消通知等基础服务。
[0049]
所述网关入口提供统一的通信连接入口，用于构建每个终端、用户的长连接标识，该标识可采用通用的规则，比如唯一id+业务编号+重要角色等方式，生产唯一标识，并对标记进行缓存或其他方式存储，以上任何通知推送逻辑都是基于次标记进行层级、角色等分组关系绑定。
[0050]
本发明通过数据通信连接使用pcp长连接的方式，与需要实时消息提醒的设备终端建立长连接后，存储连接标识。同时通过建立多级分层，多层延迟的方式，对n个分组层级实现不同层级不同推送提醒时间间隔的方式，对某一次提醒通知任务采用多线程以及线程内等待的方式来实现多层级、多角色、多人员的不同实时性提醒的需求，通过上述形式可以针对企业级应用中出现的复杂多变的实时及延迟通知提醒场景进行灵活可变的定制化实现，提升企业应用中对实效性、及时性、复杂性问题的解决思路。
[0051]
上述具体实施方式仅是本发明的具体个案，本发明的专利保护范围包括但不限于上述具体实施方式，任何符合本发明权利要求书且任何所属技术领域的普通技术人员对其所做的适当变化或修饰，皆应落入本发明的专利保护范围。

技术特征：
1.一种企业应用实时通知提醒方法，其特征在于：包括以下步骤：l1、建立统一的通知服务中心，负责通信的建立、维护和管理，同时实时查看到建立通信连接的用户、设备终端信息；l2、所述通知服务中心与业务端建立tcp长连接，并将返回的长连接标识符进行存储，采用分层级、分角色、分人员的复杂实时通知提醒；l3、应用业务中需要进行通知时，将业务中待通知人员或设备进行分组处理，并标识清晰分组的附加信息；l4、通过网关处理分组请求，以及对分组进行通知，通知过程完全由通知服务中心根据附加信息执行。2.根据权利要求1所述的企业应用实时通知提醒方法，其特征在于：所述通知服务中心包括任务通知分组模块，用于提供层级、角色、人员的任务通知分组服务。3.根据权利要求1所述的企业应用实时通知提醒方法，其特征在于：所述通知服务中心包括数据分组管理模块，具备临时分组数据的管理功能，实现分组和分组数据的清洗、缓存、清理和数据管理功能，根据数据附加信息自我检测排查，使系统具备符合业务使用的销毁机制。4.根据权利要求1所述的企业应用实时通知提醒方法，其特征在于：所述通知服务中心包括清除销毁模块，通过提供分组的人工销毁网关入口，为业务端提供可控的分组维护错误。5.根据权利要求1所述的企业应用实时通知提醒方法，其特征在于：所述通知服务中心包括实时修改模块，针对更加复杂多变的场景，同时提供分组的实时修改入口。6.根据权利要求1所述的企业应用实时通知提醒方法，其特征在于：分组通知任务的实现，通过多线程或者多协成的方式进行执行，对创建分组时的附加信息进行分析，如果存在延迟执行、重复使用限制信息，在执行分组通知时采用线程/协成内等待的方式，达到任务统一执行。7.根据权利要求1所述的企业应用实时通知提醒方法，其特征在于：所述网关入口提供统一的通信连接入口，用于构建每个终端、用户的长连接标识，该标识采用通用的规则，生产唯一标识，并对标记进行缓存或存储。8.根据权利要求1-7任一项所述的企业应用实时通知提醒方法，其特征在于：所述通知服务中心还包括负载均衡调度模块，用于调度服务请求，具体包括以下步骤：获取各业务端的负载均衡器接收服务请求的服务流量；根据各业务端的服务流量配置调度路线；将调度路线发送至配置中心进行优化处理，根据路线调度级别做进一步优化，以达到负载均衡的效果。9.根据权利要求8所述的企业应用实时通知提醒方法，其特征在于：所述路线调度级别t
i
：其中，n为业务端数量，l
i
为第i种业务端的权重，m
i
为第i种业务端的服务流量，t
i
为第i
种服务端的利用率；p
ij
为第i种业务端的第j条服务通知的加权系数，根据路线调度级别t
i
将调度路线逐级发送至配置中心进行优化处理。10.根据权利要求9所述的企业应用实时通知提醒方法，其特征在于：当p
ij
t
ij
＞w时，服务请求超时，对该服务请求由配置中心进行优先处理，其中，t
ij
为第i种业务端的第j条服务通知的请求时间。

技术总结
本发明涉及数据处理技术领域，具体地涉及一种企业应用实时通知提醒方法，包括以下步骤：建立统一的通知服务中心，主要负责通信的建立、维护和管理；所述通知服务中心与业务端建立TCP长连接，并将返回的长连接标识符进行存储，采用分层级、分角色、分人员的复杂实时通知提醒；应用业务中需要进行通知时，将业务中待通知人员或设备进行分组处理，并标识清晰分组的附加信息；通过网关处理分组请求，以及对分组进行通知。本发明通过提供统一的通知服务中心，极大的与业务分解，形成独立的通知服务管理系统，基于通知服务中心不同分组、角色以及单人员的场景提供了多重可重复使用的基础服务能力，提升了企业应用的对接效率。提升了企业应用的对接效率。提升了企业应用的对接效率。


技术研发人员：周伯虎
受保护的技术使用者：山东曹操送电子商务有限公司
技术研发日：2023.04.14
技术公布日：2023/8/9