对消息订阅进行配置的方法和装置与流程

1.本发明涉及互联网技术领域，特别涉及对消息订阅进行配置的方法和装置。


背景技术：

2.随着互联网技术的迅速发展，软件产品及服务也经历着翻天覆地的变化，而不同软件产品之间的联系和对接也变得越来越频繁。
3.然而，对于传统的订阅功能，在和第三方系统对接时往往需要编写复杂的逻辑来对订阅内容进行过滤，对第三方系统的接口进行适配，组装请求体、获取请求体认证信息等，这一过程复杂且重复。而且在和陌生系统对接时由于需求的调整，开发人员往往需要同步修改代码，每一次修改都有可能引发未知bug，进而进一步花费大量的开发成本。因此，传统的系统对接方法开发成本较高。


技术实现要素：

4.本发明提供了对消息订阅进行配置的方法和装置，能够以较低的开发成本实现本地系统与第三方系统的对接。
5.第一方面，本发明实施例提供了对消息订阅进行配置的方法，包括：
6.对本地消息状态进行监控，确定待配置消息；其中，所述待配置消息用于推送到目标第三方系统；
7.确定所述待配置消息的订阅规则；其中，所述订阅规则包括接口信息和接收人信息；
8.从与本地系统对接的至少一个第三方系统中，确定所述目标第三方系统；
9.根据所述订阅规则，将所述待配置消息推送至所述目标第三方系统。
10.在一种可能的实现方式中，所述确定所述待配置消息的订阅规则，包括：
11.将通过识别模型插件传递的消息状态，配置为通过不同的接口进行消息推送；
12.和/或，
13.确定所述待配置消息的接收人和/或接收用户组的范围。
14.在一种可能的实现方式中，在从与本地系统对接的至少一个第三方系统中确定所述目标第三方系统之后，以及在根据所述订阅规则将所述待配置消息推送至所述目标第三方系统之前，进一步包括：
15.根据所述目标第三方系统，将所述待配置消息通过json格式进行数据配置；以及，
16.对所述待配置消息的数据发送格式进行自定义。
17.在一种可能的实现方式中，所述根据所述订阅规则将所述待配置消息推送至所述目标第三方系统，包括：
18.通过接口配置从所述目标第三方系统获取token；
19.将携带有所述token认证信息的待配置信息推送至所述目标第三方系统；其中，所述认证信息包括：请求头、请求行和请求体。
20.在一种可能的实现方式中，在根据所述订阅规则将所述待配置消息推送至所述目标第三方系统之后，进一步包括：
21.对本地系统的消息推送进行记录，得到消息推送记录；
22.从所述消息推送记录中确定出未推送成功的异常推送记录；
23.根据所述异常推送记录，对各个未推送成功的配置消息进行再次推送。
24.第二方面，本发明实施例提供了对消息订阅进行配置的装置，包括：配置消息确定模块、订阅规则确定模块、目标系统确定模块和配置消息推送模块；
25.所述配置消息确定模块，用于对本地消息状态进行监控，确定待配置消息；其中，所述待配置消息用于推送到目标第三方系统；
26.所述订阅规则确定模块，用于确定所述配置消息确定模块确定的所述待配置消息的订阅规则；其中，所述订阅规则包括接口信息和接收人信息；
27.所述目标系统确定模块，用于从与本地系统对接的至少一个第三方系统中，确定所述目标第三方系统；
28.所述配置消息推送模块，用于根据所述订阅规则确定模块确定的所述订阅规则，将所述待配置消息推送至所述目标系统确定模块确定的所述目标第三方系统。
29.在一种可能的实现方式中，所述订阅规则确定模块在确定所述待配置消息的订阅规则时，配置成执行如下操作：
30.将通过识别模型插件传递的消息状态，配置为通过不同的接口进行消息推送；
31.和/或，
32.确定所述待配置消息的接收人和/或接收用户组的范围。
33.在一种可能的实现方式中，进一步包括：数据格式配置模块，配置为在从与本地系统对接的至少一个第三方系统中确定所述目标第三方系统之后，以及在根据所述订阅规则将所述待配置消息推送至所述目标第三方系统之前，执行如下操作：
34.根据所述目标第三方系统，将所述待配置消息通过json格式进行数据配置；以及，
35.对所述待配置消息的数据发送格式进行自定义。
36.在一种可能的实现方式中，所述配置消息推送模块在根据所述订阅规则将所述待配置消息推送至所述目标第三方系统时，配置成执行如下操作：
37.通过接口配置从所述目标第三方系统获取token；
38.将携带有所述token认证信息的待配置信息推送至所述目标第三方系统；其中，所述认证信息包括：请求头、请求行和请求体。
39.在一种可能的实现方式中，进一步包括：二次推送模块，配置为在根据所述订阅规则将所述待配置消息推送至所述目标第三方系统之后，执行如下操作：
40.对本地系统的消息推送进行记录，得到消息推送记录；
41.从所述消息推送记录中确定出未推送成功的异常推送记录；
42.根据所述异常推送记录，对各个未推送成功的配置消息进行再次推送。
43.由上述技术方案可知，在对消息订阅进行配置时，可以对本地消息状态进行监控，以确定出需要推送到目标第三方系统的待配置消息，然后确定该待配置消息的订阅规则，并从与本地系统对接的至少一个第三方系统中确定出目标第三方系统，进而可以根据确定的订阅规则，将待配置消息推送到目标第三方系统。由此可见，本方案通过将待配置的消息
根据各个第三方系统所对应的订阅规则，分别推送给相应的第三方系统，从而不需要本地系统在和各个第三方系统进行对接时频繁地进行代码开发和修改，从而能够降低开发成本。
附图说明
44.为了更清楚地说明本发明实施例或现有技术中的技术方案，下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。
45.图1是本发明一个实施例提供的一种对消息订阅进行配置的方法的流程图；
46.图2是本发明一个实施例提供的一种对消息订阅进行配置的装置的示意图。
具体实施方式
47.如前所述，随着互联网技术的迅速发展，软件产品及服务也经历着翻天覆地的变化，而不同软件产品之间的联系和对接也变得越来越频繁。
48.然而，对于传统的订阅功能，在和第三方系统对接时往往需要编写复杂的逻辑来对订阅内容进行过滤，对第三方系统的接口进行适配，组装请求体、获取请求体认证信息等，这一过程复杂且重复。而且在和陌生系统对接时由于需求的调整，开发人员往往需要同步修改代码，每一次修改都有可能引发未知bug，进而进一步花费大量的开发成本。因此，传统的系统对接方法开发成本较高。
49.为了解决这些问题，通过对订阅流程的总结归纳，本方案考虑针对各个不同的第三方系统进行规则定义，按照订阅规则分别将各自需要推送的配置消息推送到相应的第三方系统，从而避免与第三方系统进行对接时的频繁代码开发和修改，进而能够降低开发成本。
50.如图1所示，本发明实施例提供了一种对消息订阅进行配置的方法，该方法可以包括如下步骤：
51.步骤101：对本地消息状态进行监控，确定待配置消息；其中，待配置消息用于推送到目标第三方系统；
52.步骤102：确定待配置消息的订阅规则；其中，订阅规则包括接口信息和接收人信息；
53.步骤103：从与本地系统对接的至少一个第三方系统中，确定目标第三方系统；
54.步骤104：根据订阅规则，将待配置消息推送至目标第三方系统。
55.本发明实施例中，在对消息订阅进行配置时，可以对本地消息状态进行监控，以确定出需要推送到目标第三方系统的待配置消息，然后确定该待配置消息的订阅规则，并从与本地系统对接的至少一个第三方系统中确定出目标第三方系统，进而可以根据确定的订阅规则，将待配置消息推送到目标第三方系统。由此可见，本方案通过将待配置的消息根据各个第三方系统所对应的订阅规则，分别推送给相应的第三方系统，从而不需要本地系统在和各个第三方系统进行对接时频繁地进行代码开发和修改，从而能够降低开发成本。
56.步骤101对本地消息状态进行监控，确定用于推送到第三方系统的待配置消息时，
首先可以考虑启用全局系统开关和配置级开关，即控制是否启用消息订阅配置。
57.在一种可能的实现方式中，步骤102在确定待配置消息的订阅规则时，可以将通过识别模型插件传递的消息状态配置为通过不同的的接口进行消息推送。也就是说，可以为待配置消息的推送配置不同的接口，比如可以针对不同的第三方系统采用不同的接口进行待配置消息的推送。
58.此外，还可以确定待配置消息的接收人和/或接收用户组的范围。也就是说，确定该待配置消息需要推送给哪些人或哪些用户组，如此对于不需要接收该待配置消息的人或用户组则不会接收到消息，实现消息的定向和有选择的推送，提升用户的使用体验。
59.在一种可能的实现方式中，在从与本地系统对接的至少一个第三方系统中确定目标第三方系统之后，以及在根据订阅规则将待配置消息推送至目标第三方系统之前，还可以通过如下方式实现对数据格式的配置：
60.根据目标第三方系统，将待配置消息通过json格式进行数据配置；以及，
61.对待配置消息的数据发送格式进行自定义。
62.本实施例中，在确定出目标第三方系统之后，还可以根据目标第三方系统，将待配置消息通过json格式进行数据配置，然后对待配置消息的数据发送格式进行自定义。如此，通过对json格式配置的编辑，可以将消息体所有字段作为内容识别字段采用正则匹配，并可以自定义内容格式，对消息体进行定制化发送，能够实现对接效率的高效和灵活易懂的配置，解决了企业系统消息对接遇到的困难。
63.在一种可能的实现方式中，步骤104在根据订阅规则，将待配置消息推送至目标第三方系统时，可以具体通过如下方式实现：
64.通过接口配置从目标第三方系统获取token；
65.将携带有token认证信息的待配置信息推送至目标第三方系统；其中，认证信息包括：请求头、请求行和请求体。
66.在本发明实施例中，还可以考虑进行系统认证，从而提升消息推送的安全性。比如，第三方系统消息对接接口时可以先进行系统认证，携带token才将消息推送到第三方系统，本方法通过接口配置先获取到token加入系统缓存，并在发送消息请求中携带，以完成系统认证。
67.在一种可能的实现方式中，在根据订阅规则将待配置消息推送至目标第三方系统之后，如果存在消息没有推送成功，还可以通过如下方式实现对配置消息的二次推送：
68.对本地系统的消息推送进行记录，得到消息推送记录；
69.从消息推送记录中确定出未推送成功的异常推送记录；
70.根据异常推送记录，对各个未推送成功的配置消息进行再次推送。
71.在本发明实施例中，如果本地系统的消息推送进行记录得到消息推送接料，并从消息推送记录中确定出未推送成功的异常推送记录，然后根据异常推送记录对各个未推送成功的配置消息进行再次推送。如此能够保证将消息推送到相应的第三方系统中，提升消息推送的可靠性。
72.此外，由于对消息推送实行的是本地触发机制，而不是服务器轮询，既解决消息由于网络原因导致消息未推送成功的问题，也能节省服务器资源，降低服务负载。
73.在一种可能的实现方式中，本发明实施例可以通过设计以下主要结构完成：
74.1、多层开关控制
75.全局系统开关和配置级开关，控制消息订阅配置是否启用。
76.2、消息动作检测
77.通过识别模型插件传递的消息状态，支持配置个订阅规则，以此实现通过不同的接口同步消息的状态
78.3、消息接收人范围限制
79.在订阅规则中可由控制消息订阅针对个人，或是其他用户组，满足企业个性化需求。
80.4、消息内容识别控制
81.通过对json格式配置的编辑，可以将消息体所有字段作为内容识别字段采用正则匹配，并可以自定义内容格式，对消息体进行定制化发送。
82.5、消息发送记录及重试
83.符合规则的消息都会创建一条发送记录，发送记录可用来做数据统计分析，由于网络异常推送失败的消息也可以使用手动重试的方式来推送。
84.比如，以结合钉钉待办任务为具体实施例时，对本发明中通过基础配置实现系统消息推送到任意三方系统可以包括：
85.现需要将本地待办消息推送到钉钉系统，并且当本地待办完成时钉钉待办需要同步删除，该业务便可使用消息订阅配置来实现。
86.1、打开系统设置中消息订阅开关
87.进入系统设置打开消息订阅开关并刷新使得配置立即生效
88.2、参考钉钉待办推送文档，配置消息订阅规则
89.通过参考钉钉待办推送首先需要获取到认证信息，在推送待办接口携带认证信息然后推送，认证信息配置需要有请求头，请求行，请求体，通过对于业务分析，在系统新增一条待办类型的消息时需要将待办推送到钉钉，所以需要选择待办类型和消息触发动作为新增，
90.还需要获取到人员在钉钉的unionid通过对系统消息体的配置通过人员拿到unionid，制定出符合钉钉规范的数据格式进行消息推送。
91.3、测试消息订阅配置是否成功
92.在系统产生一条待办类型的消息，随后查看钉钉待办任务列表，是否产生了一条同样的消息。
93.如图2所示，本发明实施例还提供了一种对消息订阅进行配置的装置，包括：配置消息确定模块201、订阅规则确定模块202、目标系统确定模块203和配置消息推送模块204；
94.配置消息确定模块201，用于对本地消息状态进行监控，确定待配置消息；其中，待配置消息用于推送到目标第三方系统；
95.订阅规则确定模块202，用于确定配置消息确定模块201确定的待配置消息的订阅规则；其中，订阅规则包括接口信息和接收人信息；
96.目标系统确定模块203，用于从与本地系统对接的至少一个第三方系统中，确定目标第三方系统；
97.配置消息推送模块204，用于根据订阅规则确定模块202确定的订阅规则，将待配
置消息推送至目标系统确定模块203确定的目标第三方系统。
98.在一种可能的实现方式中，订阅规则确定模块202在确定待配置消息的订阅规则时，配置成执行如下操作：
99.将通过识别模型插件传递的消息状态，配置为通过不同的接口进行消息推送；
100.和/或，
101.确定待配置消息的接收人和/或接收用户组的范围。
102.在一种可能的实现方式中，进一步包括：数据格式配置模块，配置为在从与本地系统对接的至少一个第三方系统中确定目标第三方系统之后，以及在根据订阅规则将待配置消息推送至目标第三方系统之前，执行如下操作：
103.根据目标第三方系统，将待配置消息通过json格式进行数据配置；以及，
104.对待配置消息的数据发送格式进行自定义。
105.在一种可能的实现方式中，配置消息推送模块204在根据订阅规则将待配置消息推送至目标第三方系统时，配置成执行如下操作：
106.通过接口配置从目标第三方系统获取token；
107.将携带有token认证信息的待配置信息推送至目标第三方系统；其中，认证信息包括：请求头、请求行和请求体。
108.在一种可能的实现方式中，进一步包括：二次推送模块，配置为在根据订阅规则将待配置消息推送至目标第三方系统之后，执行如下操作：
109.对本地系统的消息推送进行记录，得到消息推送记录；
110.从消息推送记录中确定出未推送成功的异常推送记录；
111.根据异常推送记录，对各个未推送成功的配置消息进行再次推送。
112.本发明实施例还提供了一种计算机可读存储介质，其上存储有计算机程序，当所述计算机程序在计算机中执行时，令计算机执行本方案中任一个实施例中的方法。
113.本说明书还提供了一种计算设备，包括存储器和处理器，所述存储器中存储有可执行代码，所述处理器执行所述可执行代码时，实现本方案中任一个实施例中的方法。
114.可以理解的是，本方案实施例示意的结构并不构成对对消息订阅进行配置的装置的具体限定。在说明书的另一些实施例中，对消息订阅进行配置的装置可以包括比图示更多或者更少的部件，或者组合某些部件，或者拆分某些部件，或者不同的部件布置。图示的部件可以以硬件、软件或者软件和硬件的组合来实现。
115.需要说明的是，在本文中，诸如第一和第二之类的关系术语仅仅用来将一个实体或者操作与另一个实体或操作区分开来，而不一定要求或者暗示这些实体或操作之间存在任何这种实际的关系或者顺序。而且，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、物品或者设备不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、物品或者设备所固有的要素。在没有更多限制的情况下，由语句“包括一个
······”限定的要素，并不排除在包括所述要素的过程、方法、物品或者设备中还存在另外的相同因素。
116.本领域普通技术人员可以理解：实现上述方法实施例的全部或部分步骤可以通过程序指令相关的硬件来完成，前述的程序可以存储在计算机可读取的存储介质中，该程序在执行时，执行包括上述方法实施例的步骤；而前述的存储介质包括：rom、ram、磁碟或者光
盘等各种可以存储程序代码的介质中。
117.上述装置内的各单元之间的信息交互、执行过程等内容，由于与本方案方法实施例基于同一构思，具体内容可参见本方案方法实施例中的叙述，此处不再赘述。
118.本领域技术人员应该可以意识到，在上述一个或多个示例中，本方案所描述的功能可以用硬件、软件、挂件或它们的任意组合来实现。当使用软件实现时，可以将这些功能存储在计算机可读介质中或者作为计算机可读介质上的一个或多个指令或代码进行传输。
119.以上所述的具体实施方式，对本方案描述的目的、技术方案和有益效果进行了进一步详细说明，所应理解的是，以上所述仅为本发明的具体实施方式而已，并不用于限定本发明的保护范围，凡在本发明的技术方案的基础之上，所做的任何修改、等同替换、改进等，均应包括在本发明的保护范围之内。

技术特征：
1.对消息订阅进行配置的方法，其特征在于，包括：对本地消息状态进行监控，确定待配置消息；其中，所述待配置消息用于推送到目标第三方系统；确定所述待配置消息的订阅规则；其中，所述订阅规则包括接口信息和接收人信息；从与本地系统对接的至少一个第三方系统中，确定所述目标第三方系统；根据所述订阅规则，将所述待配置消息推送至所述目标第三方系统。2.根据权利要求1所述的方法，其特征在于，所述确定所述待配置消息的订阅规则，包括：将通过识别模型插件传递的消息状态，配置为通过不同的接口进行消息推送；和/或，确定所述待配置消息的接收人和/或接收用户组的范围。3.根据权利要求1所述的方法，其特征在于，在从与本地系统对接的至少一个第三方系统中确定所述目标第三方系统之后，以及在根据所述订阅规则将所述待配置消息推送至所述目标第三方系统之前，进一步包括：根据所述目标第三方系统，将所述待配置消息通过json格式进行数据配置；以及，对所述待配置消息的数据发送格式进行自定义。4.根据权利要求1所述的方法，其特征在于，所述根据所述订阅规则将所述待配置消息推送至所述目标第三方系统，包括：通过接口配置从所述目标第三方系统获取token；将携带有所述token认证信息的待配置信息推送至所述目标第三方系统；其中，所述认证信息包括：请求头、请求行和请求体。5.根据权利要求1至4中任一所述的方法，其特征在于，在根据所述订阅规则将所述待配置消息推送至所述目标第三方系统之后，进一步包括：对本地系统的消息推送进行记录，得到消息推送记录；从所述消息推送记录中确定出未推送成功的异常推送记录；根据所述异常推送记录，对各个未推送成功的配置消息进行再次推送。6.对消息订阅进行配置的装置，其特征在于，包括：配置消息确定模块、订阅规则确定模块、目标系统确定模块和配置消息推送模块；所述配置消息确定模块，用于对本地消息状态进行监控，确定待配置消息；其中，所述待配置消息用于推送到目标第三方系统；所述订阅规则确定模块，用于确定所述配置消息确定模块确定的所述待配置消息的订阅规则；其中，所述订阅规则包括接口信息和接收人信息；所述目标系统确定模块，用于从与本地系统对接的至少一个第三方系统中，确定所述目标第三方系统；所述配置消息推送模块，用于根据所述订阅规则确定模块确定的所述订阅规则，将所述待配置消息推送至所述目标系统确定模块确定的所述目标第三方系统。7.根据权利要求6所述的装置，其特征在于，所述订阅规则确定模块在确定所述待配置消息的订阅规则时，配置成执行如下操作：将通过识别模型插件传递的消息状态，配置为通过不同的接口进行消息推送；
和/或，确定所述待配置消息的接收人和/或接收用户组的范围。8.根据权利要求6所述的装置，其特征在于，进一步包括：数据格式配置模块，配置为在从与本地系统对接的至少一个第三方系统中确定所述目标第三方系统之后，以及在根据所述订阅规则将所述待配置消息推送至所述目标第三方系统之前，执行如下操作：根据所述目标第三方系统，将所述待配置消息通过json格式进行数据配置；以及，对所述待配置消息的数据发送格式进行自定义。9.根据权利要求6所述的装置，其特征在于，所述配置消息推送模块在根据所述订阅规则将所述待配置消息推送至所述目标第三方系统时，配置成执行如下操作：通过接口配置从所述目标第三方系统获取token；将携带有所述token认证信息的待配置信息推送至所述目标第三方系统；其中，所述认证信息包括：请求头、请求行和请求体。10.根据权利要求6至9中任一所述的装置，其特征在于，进一步包括：二次推送模块，配置为在根据所述订阅规则将所述待配置消息推送至所述目标第三方系统之后，执行如下操作：对本地系统的消息推送进行记录，得到消息推送记录；从所述消息推送记录中确定出未推送成功的异常推送记录；根据所述异常推送记录，对各个未推送成功的配置消息进行再次推送。

技术总结
本发明提供了对消息订阅进行配置的方法和装置，该方法包括：对本地消息状态进行监控，确定待配置消息；其中，待配置消息用于推送到目标第三方系统；确定待配置消息的订阅规则；其中，订阅规则包括接口信息和接收人信息；从与本地系统对接的至少一个第三方系统中，确定目标第三方系统；根据订阅规则，将待配置消息推送至目标第三方系统。本方案能够以较低的开发成本实现本地系统与第三方系统的对接。发成本实现本地系统与第三方系统的对接。发成本实现本地系统与第三方系统的对接。


技术研发人员：刘铭哲
受保护的技术使用者：山东浪潮通软信息科技有限公司
技术研发日：2022.02.21
技术公布日：2022/5/25