1.本技术涉及通信技术领域，尤其涉及一种同网络环境的业务消息消费方法及其装置。
背景技术：2.相关技术中，在同网络环境下，消息消费端可能具有多个环境，如预发环境和线上环境等，因为预发环境版本已经更新，对比线上环境，可能会出现业务不一致的问题，如果在预发环境下消费线上环境的业务消息，或线上环境下消费预发环境的业务消息，很容易导致线上订阅系统运行结果不一致，从而发生不可预知的问题。因此如何在同网络环境下实现业务消息的环境隔离，提高消费业务消息的准确性，已经成为重要的研究方向之一。
技术实现要素：3.本技术旨在至少在一定程度上解决相关技术中的技术问题之一。为此，本技术的一个目的在于提出一种同网络环境的业务消息消费方法。
4.本技术的第二个目的在于提出一种同网络环境的业务消息消费装置。
5.本技术的第三个目的在于提出一种电子设备。
6.本技术的第四个目的在于提出一种非瞬时计算机可读存储介质。
7.本技术的第五个目的在于提出一种计算机程序产品。
8.为达上述目的，本技术第一方面实施例提出了一种同网络环境的业务消息消费方法，包括：
9.在同网络环境下，根据环境配置参数为消息消费端配置多个环境；
10.在多个环境中的目标环境下接收消息主题传输的业务消息；
11.响应于业务消息为在目标环境下生成的消息，则在目标环境下对业务消息进行消费。
12.本技术实施例中，消息发送端和消息消费端之间没有直接调用的关系，仅是通过业务消息的传输，实现同网络环境下业务消息的环境隔离，使得业务消息在适应的环境下消费，从而提高了消费业务消息的准确性。本技术实施例系统侵入性不强，耦合度低，进一步提高了消息消费端的性能。
13.为达上述目的，本技术第二方面实施例提出了一种同网络环境的业务消息消费装置，包括：
14.配置模块，用于在同网络环境下，根据环境配置参数为消息消费端配置多个环境；
15.接收模块，用于在多个环境中的目标环境下接收消息主题传输的业务消息；
16.消费模块，用于响应于业务消息为在目标环境下生成的消息，则在目标环境下对业务消息进行消费。
17.为达上述目的，本技术第三方面实施例提出了一种电子设备，包括：
18.至少一个处理器；以及
19.与至少一个处理器通信连接的存储器；其中，
20.存储器存储有可被至少一个处理器执行的指令，指令被至少一个处理器执行，以使至少一个处理器能够执行本技术第一方面实施例中提供的同网络环境的业务消息消费方法。
21.为达上述目的，本技术第四方面实施例提出了一种计算机可读存储介质，其上存储有计算机指令，其中，计算机指令用于使计算机执行根据本技术第一方面实施例中提供的同网络环境的业务消息消费方法。
22.为达上述目的，本技术第五方面实施例提出了一种计算机程序产品，包括计算机程序，计算机程序在被处理器执行时实现本技术第一方面实施例中提供的同网络环境的业务消息消费方法。
附图说明
23.图1是本技术一个实施例的同网络环境的业务消息消费方法的流程图；
24.图2是本技术一个实施例的同网络环境的业务消息消费方法的流程图；
25.图3是本技术一个实施例的同网络环境的业务消息消费方法的流程图；
26.图4是本技术一个实施例的线上环境的业务消息消费方法的流程图；
27.图5是本技术一个实施例的预发环境的业务消息消费方法的流程图；
28.图6是本技术一个实施例的同网络环境的业务消息消费装置的结构框图；
29.图7是本技术一个实施例的电子设备的结构示意图。
具体实施方式
30.下面详细描述本技术的实施例，所述实施例的示例在附图中示出，其中自始至终相同或类似的标号表示相同或类似的元件或具有相同或类似功能的元件。下面通过参考附图描述的实施例是示例性的，旨在用于解释本技术，而不能理解为对本技术的限制。
31.下面结合附图来描述本技术实施例的同网络环境的业务消息消费方法及其装置。
32.图1是本技术一个实施例的同网络环境的业务消息消费方法的流程图，如图1所示，该方法包括以下步骤：
33.s101，在同网络环境下，根据环境配置参数为消息消费端配置多个环境。
34.网络环境是指在电子计算机和现代通讯技术相结合基础上构建起来的宽带、高速、综合、广域型数字式电信网络。
35.同一个网络环境下的消息消费端可能处于不同的环境。例如，消息消费端可能处于线上环境，也就是生产环境，该环境是指正是提供对外服务的，真实用户线上使用的环境。例如，消息消费端可能处于预发环境，也就是预发布环境，预发环境是测试环境到线上环境的过渡，测试环境可能会受到一些限制，例如一些流程或数据没有测到，就可以在预发环境进行验证，从而保证数据的准确性。其中，测试环境是指基于数据模拟出的接近线上环境的环境。
36.本技术实施例中，在同一网络环境下，根据环境配置参数为消息消费端配置线上环境和预发环境。可选地，环境配置参数包括消息主题(topic)、环境参数、数据组装逻辑等。
37.可选地，消息消费端可以为终端设备，例如手机、电脑等，本技术实施例对消息消费端的形态不做限制。
38.s102，在多个环境中的目标环境下接收消息主题传输的业务消息。
39.可选地，消息发送端根据存量业务生成业务消息，消息主题根据业务消息所在的topic类从多个环境中确认目标环境，并将业务消息发送给目标环境下的消息消费端。
40.本技术实施例中，存量业务是指已经上线并发布的业务，消息发送端和消息消费端都已经运行的业务。可选地，消息发送端可以是服务器，服务器作为电子设备，在网络中为其它客户机，如个人计算(personal computer，pc)机、智能手机等终端甚至是火车系统等大型设备，提供计算或者应用服务。
41.s103，响应于业务消息为在目标环境下生成的消息，则在目标环境下对业务消息进行消费。
42.在一些实现中，可以根据业务消息中携带的环境标识判断业务消息是否为在目标环境下生成的消息，响应于业务消息为在目标环境下生成的消息，消息消费端在业务消息指示的目标环境下对业务消息进行消费，也就是说，在目标环境下处理业务消息。
43.本技术实施例中，以业务消息为地区a在时间段t内停电为例进行说明，消息消费端在目标环境下对业务消息进行处理，判断消息消费端当前所在位置是否位于地点a，若当前位置位于地点a，则在时间段t内启动备用电源。
44.本技术实施例在同网络环境下，根据环境配置参数为消息消费端配置多个环境，在多个环境中的目标环境下接收消息主题传输的业务消息，在目标环境下对业务消息进行消费。本技术实施例中，消息发送端和消息消费端之间没有直接调用的关系，仅是通过业务消息的传输，实现同网络环境下业务消息的环境隔离，使得业务消息在适应的环境下消费，从而提高了消费业务消息的准确性。本技术实施例系统侵入性不强，耦合度低，进一步提高了消息消费端的性能。
45.图2是本技术一个实施例的同网络环境的业务消息消费方法的流程图，如图2所示，该方法包括以下步骤：
46.s201，在同网络环境下，根据环境配置参数为消息消费端配置多个环境。
47.s202，在多个环境中的目标环境下接收消息主题传输的业务消息。
48.关于步骤s201，步骤s202的介绍可以参见上述实施例中的相关内容，此处不再赘述。
49.s203，获取目标环境下的消息验证参数。
50.在一些实现中，为了提高业务消息的消费的准确率，可以根据目标环境下的消息验证参数进一步对业务消息进行验证。
51.可选地，消息验证参数可以包含存业务消息的内容标签。在一些实现中，存量业务较多时，可能造成消息积压，根据内容标签对业务消息进行验证可能会影响业务消息的消费的效率。因此，为了平衡消费业务消息的效率和准确率，本技术实施例中，消息验证参数可以包含待处理业务消息的预设数量阈值和业务消息的内容标签。
52.s204，基于消息验证参数判断业务消息是否满足预设条件。
53.在一些实现中，获取多个环境中的任一环境内的待处理业务消息的数量。响应于待处理业务消息的数量大于或等于消息验证参数中的预设阈值，确定业务消息满足预设条
件。
54.在一些实现中，响应于待处理业务消息的数量小于消息验证参数中的预设阈值，获取消息验证参数中的内容标签。响应于业务消息中含有内容标签，确定内容标签命中业务消息，业务消息满足预设条件。
55.可选地，内容标签可以是业务标识，也可以是数据标识，也可以是用户标识。本技术实施例中，可以对业务消息进行识别，以确认业务消息中是否含有内容标签。
56.s205，响应于业务消息满足预设条件，在目标环境下对业务消息进行消费。
57.关于在目标环境下对业务消息进行消费的介绍可以参见上述实施例中的相关内容，此处不再赘述。
58.本技术实施例中，获取目标环境下的消息验证参数，基于消息验证参数判断业务消息是否满足预设条件，响应于业务消息满足预设条件，在目标环境下对业务消息进行消费。本技术实施例中，消息发送端和消息消费端之间没有直接调用的关系，仅是通过业务消息的传输，实现同网络环境下业务消息的环境隔离，使得业务消息在适应的环境下消费，并提高了消费业务消息的效率和准确性。本技术实施例系统侵入性不强，耦合度低，进一步提高了消息消费端的性能。
59.在一些实现中，响应于业务消息中未含有内容标签，将业务消息中的第一环境标识更新为第二环境标识，生成更新业务消息，并将更新业务消息发送给第二环境标识所标识的环境。其中，第二环境标识用于指示在第二环境标识所标识的环境下消费更新业务消息。本技术实施例以目标环境为线上环境为例进行说明，若线上环境中，业务消息未命中内容标签，将业务消息中的线上环境标识更新为预发环境标识，生成更新业务消息，并将更新业务消息重发给预发环境进行消费。
60.图3是本技术一个实施例的同网络环境的业务消息消费方法的流程图，如图3所示，该方法包括以下步骤：
61.s301，在同网络环境下，根据环境配置参数为消息消费端配置多个环境。
62.s302，在多个环境中的目标环境下接收消息主题传输的业务消息。
63.关于步骤s301，步骤s302的介绍可以参见上述实施例中的相关内容，此处不再赘述。
64.s303，从业务消息中提取第一环境标识。
65.可选地，以第一环境标识为线上环境的环境标识为例进行说明，第一环境标识可以是prd。
66.可选地，以第一环境标识为预发环境的环境标识为例进行说明，第一环境标识可以是pre。
67.s304，响应于第一环境标识指示多个环境中的目标环境，则确定业务消息在目标环境下生成的消息。
68.在一些实现中，若第一环境标识为prd，当前所在的目标环境为线上环境，则确定业务消息在目标环境下生成的消息。
69.在一些实现中，若第一环境标识为pre，当前所在的目标环境为预发环境，则确定业务消息在目标环境下生成的消息。
70.s305，在目标环境下对业务消息进行消费。
71.关于步骤s305的介绍可以参见上述实施例中的相关内容，此处不再赘述。
72.本技术实施例中，从业务消息中提取第一环境标识，响应于第一环境标识指示多个环境中的目标环境，则确定业务消息在目标环境下生成的消息，在目标环境下对业务消息进行消费。本技术实施例中，消息发送端和消息消费端之间没有直接调用的关系，仅是通过业务消息的传输，实现同网络环境下业务消息的环境隔离，使得业务消息在适应的环境下消费，并提高了消费业务消息的准确性。本技术实施例系统侵入性不强，耦合度低，进一步提高了消息消费端的性能。
73.图4是本技术一个实施例的线上环境的业务消息消费方法的流程图，如图4所示，本技术实施例以线上环境为例进行说明，消息发送端根据存量业务生成业务消息，消息主题根据业务消息所在的topic类将业务消息发送给线上环境下的消息消费端，消息消费端查询动态配置的消息验证参数，获取验证开关，若验证开关打开，则判断内容标签是否命中业务消息，若内容标签命中业务消息，则在线上环境下对业务消息进行消费，若内容标签未命中业务消息，则在线上环境下对业务消息携带的环境标识更新为预发环境的标识，生成更新业务消息，并将更新业务消息发送给预发环境。另外，若线上环境中的待处理业务消息超过预设的数量阈值，表明当前线上环境出现消息积压，此时可以对验证开关进行切换，以提高消息处理效率。可选地线上环境收到其他环境的消息积压提醒时，也可以对验证开关进行切换，以提高消息处理效率。
74.图5是本技术一个实施例的预发环境的业务消息消费方法的流程图，如图5所示，本技术实施例以预发环境为例进行说明，消息发送端根据存量业务生成业务消息，消息主题根据业务消息所在的topic类将业务消息发送给预发环境下的消息消费端，消息消费端查询动态配置的验证开关，若验证开关打开，则判断内容标签是否命中业务消息，若内容标签命中业务消息，则在预发环境下对业务消息进行消费，若内容标签未命中业务消息，则对业务消息携带的环境标识进行识别，若业务消息携带预发环境的环境标识，确定业务消息为预发消息，在预发环境下对业务消息进行消费，否则对业务消息携带的环境标识更新为线上环境的环境标识，并发送给线上环境进行消费。另外，若预发环境中的待处理业务消息超过预设的数量阈值，表明当前预发环境出现消息积压，此时可以对验证开关进行切换，以提高消息处理效率。可选地预发环境收到其他环境的消息积压提醒时，也可以对验证开关进行切换，以提高消息处理效率。
75.如图6所示，基于同一申请构思，本技术实施例还提供了一种同网络环境的业务消息消费装置600，包括：
76.配置模块610，用于在同网络环境下，根据环境配置参数为消息消费端配置多个环境；
77.接收模块620，用于在多个环境中的目标环境下接收消息主题传输的业务消息；
78.消费模块630，用于响应于业务消息为在目标环境下生成的消息，则在目标环境下对业务消息进行消费。
79.在一些实现中，消费模块630，还用于：
80.获取目标环境下的消息验证参数；
81.基于消息验证参数判断业务消息是否满足预设条件；
82.响应于业务消息满足预设条件，在目标环境下对业务消息进行消费。
83.在一些实现中，消费模块630，还用于：
84.获取多个环境中的任一环境内的待处理业务消息的数量；
85.响应于待处理业务消息的数量大于或等于消息验证参数中的预设数量阈值，确定业务消息满足预设条件。
86.在一些实现中，消费模块630，还用于：
87.响应于待处理业务消息的数量小于预设数量阈值，获取消息验证参数中的内容标签；
88.响应于业务消息中含有内容标签，确定业务消息满足预设条件。
89.在一些实现中，消费模块630，还用于：
90.响应于业务消息中未含有内容标签，将业务消息中的第一环境标识更新为第二环境标识，生成更新业务消息，第二环境标识用于指示在第二环境标识所标识的环境下消费更新业务消息。
91.在一些实现中，消费模块630，还用于：
92.将更新业务消息发送给第二环境标识所标识的环境。
93.在一些实现中，消费模块630，还用于：
94.从业务消息中提取第一环境标识；
95.响应于第一环境标识指示多个环境中的目标环境，则确定业务消息在目标环境下生成的消息。
96.本技术实施例中，消息发送端和消息消费端之间没有直接调用的关系，仅是通过业务消息的传输，实现同网络环境下业务消息的环境隔离，使得业务消息在适应的环境下消费，从而提高了消费业务消息的准确性。本技术实施例系统侵入性不强，耦合度低，进一步提高了消息消费端的性能。
97.基于同一申请构思，本技术实施例还提供了一种电子设备。
98.图7为本技术实施例提供的电子设备的结构示意图。如图7所示，该电子设备700，包括存储器710、处理器720及存储在存储器710上并可在处理器720上运行的计算机程序产品，处理器执行计算机程序时，实现前述的同网络环境的业务消息消费方法。
99.本领域内的技术人员应明白，本技术的实施例可提供为方法、系统、或计算机程序产品。因此，本技术可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且，本技术可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、cd-rom、光学存储器等)上实施的计算机程序产品的形式。
100.本技术是参照根据本技术实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器，使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。
101.这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中，使得存储在该计算机可读存储器中的指令产生包括指
令装置的制造品，该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。
102.这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上，使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理，从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。
103.基于同一申请构思，本技术实施例还提供了一种计算机可读存储介质，其上存储有计算机指令，其中，该计算机指令用于使计算机执行上述实施例中的同网络环境的业务消息消费方法。
104.基于同一申请构思，本技术实施例还提供了一种计算机程序产品，包括计算机程序，该计算机程序在被处理器执行时上述实施例中的同网络环境的业务消息消费方法。
105.应当注意的是，在权利要求中，不应将位于括号之间的任何参考符号构造成对权利要求的限制。单词“包含”不排除存在未列在权利要求中的部件或步骤。位于部件之前的单词“一”或“一个”不排除存在多个这样的部件。本技术可以借助于包括有若干不同部件的硬件以及借助于适当编程的计算机来实现。在列举了若干装置的单元权利要求中，这些装置中的若干个可以是通过同一个硬件项来具体体现。单词第一、第二、以及第三等的使用不表示任何顺序。可将这些单词解释为名称。
106.此外，术语“第一”、“第二”仅用于描述目的，而不能理解为指示或暗示相对重要性或者隐含指明所指示的技术特征的数量。由此，限定有“第一”、“第二”的特征可以明示或者隐含地包括一个或者更多个该特征。在本技术的描述中，“多个”的含义是两个或两个以上，除非另有明确具体的限定。
107.尽管已描述了本技术的优选实施例，但本领域内的技术人员一旦得知了基本创造性概念，则可对这些实施例作出另外的变更和修改。所以，所附权利要求意欲解释为包括优选实施例以及落入本技术范围的所有变更和修改。
108.显然，本领域的技术人员可以对本技术进行各种改动和变型而不脱离本发明的精神和范围。这样，倘若本技术的这些修改和变型属于本技术权利要求及其等同技术的范围之内，则本技术也意图包含这些改动和变型在内。
技术特征：1.一种同网络环境的业务消息消费方法，其特征在于，包括：在同网络环境下，根据环境配置参数为消息消费端配置多个环境；在所述多个环境中的目标环境下接收消息主题传输的业务消息；响应于所述业务消息为在所述目标环境下生成的消息，则在所述目标环境下对所述业务消息进行消费。2.根据权利要求1所述的方法，其特征在于，所述在所述目标环境下对所述业务消息进行消费，还包括：获取所述目标环境下的消息验证参数；基于所述消息验证参数判断所述业务消息是否满足预设条件；响应于所述业务消息满足预设条件，在所述目标环境下对所述业务消息进行消费。3.根据权利要求2所述的方法，其特征在于，所述基于所述消息验证参数判断所述业务消息是否满足预设条件，包括：获取多个环境中的任一环境内的待处理业务消息的数量；响应于所述待处理业务消息的数量大于或等于所述消息验证参数中的预设数量阈值，确定所述业务消息满足所述预设条件。4.根据权利要求3所述的方法，其特征在于，还包括：响应于所述待处理业务消息的数量小于所述预设数量阈值，获取所述消息验证参数中的内容标签；响应于所述业务消息中含有所述内容标签，确定所述业务消息满足所述预设条件。5.根据权利要求4所述的方法，其特征在于，还包括：响应于所述业务消息中未含有所述内容标签，将所述业务消息中的第一环境标识更新为第二环境标识，生成更新业务消息，所述第二环境标识用于指示在所述第二环境标识所标识的环境下消费所述更新业务消息。6.根据权利要求5所述的方法，其特征在于，所述生成更新业务消息之后，还包括：将所述更新业务消息发送给所述第二环境标识所标识的环境。7.根据权利要求1-6中任一项所述的方法，其特征在于，确定所述业务消息为在所述目标环境下生成的消息的过程，包括：从所述业务消息中提取第一环境标识；响应于所述第一环境标识指示所述多个环境中的所述目标环境，则确定所述业务消息在所述目标环境下生成的消息。8.一种同网络环境的业务消息消费装置，其特征在于，包括：配置模块，用于在同网络环境下，根据环境配置参数为消息消费端配置多个环境；接收模块，用于在所述多个环境中的目标环境下接收消息主题传输的业务消息；消费模块，用于响应于所述业务消息为在所述目标环境下生成的消息，则在所述目标环境下对所述业务消息进行消费。9.一种电子设备，包括：至少一个处理器；以及与所述至少一个处理器通信连接的存储器；其中，所述存储器存储有可被所述至少一个处理器执行的指令，所述指令被所述至少一个处
理器执行，以使所述至少一个处理器能够执行权利要求1-7中任一项所述的方法。10.一种存储有计算机指令的非瞬时计算机可读存储介质，其中，所述计算机指令用于使所述计算机执行根据权利要求1-7中任一项所述的方法。11.一种计算机程序产品，包括计算机程序，所述计算机程序在被处理器执行时实现根据权利要求1-7中任一项所述的方法。
技术总结本申请提出了一种同网络环境的业务消息消费方法及其装置，涉及通信技术领域。该方法包括：在同网络环境下，根据环境配置参数为消息消费端配置多个环境；在多个环境中的目标环境下接收消息主题传输的业务消息；响应于业务消息为在目标环境下生成的消息，则在目标环境下对业务消息进行消费。本申请中，消息发送端和消息消费端之间没有直接调用的关系，仅是通过业务消息的传输，实现同网络环境下业务消息的环境隔离，使得业务消息在适应的环境下消费，从而提高了消费业务消息的准确性。本申请系统侵入性不强，耦合度低，进一步提高了消息消费端的性能。消费端的性能。消费端的性能。
技术研发人员：张开庆
受保护的技术使用者：京东科技信息技术有限公司
技术研发日：2022.07.19
技术公布日：2022/11/1
