一种数据分发方法、服务器及系统

暂无

一种数据分发方法、服务器及系统\n技术领域\n[0001] 本发明涉及通信领域，尤其涉及一种数据分发方法、服务器及系统。\n背景技术\n[0002] 网元设备的网管系统是对在线的大量网元设备进行监控管理的系统。目前的网管系统如图1所示，网元设备向数据处理服务器上报数据，数据处理服务器采集该数据并进行处理。然而现有技术中，数据处理服务器和网元设备的之间对应关系是固定的，一个数据处理服务器只能处理其对应的网元设备上报的数据，当该数据处理服务器的处理能力不够时，若其对应的网元设备仍上报大量数据，就会出现数据堆积无法得到及时处理的问题。\n发明内容\n[0003] 本发明实施例提供了一种数据分发方法、服务器及系统，用以解决现有技术中存在的数据堆积无法得到及时处理的问题。\n[0004] 本发明实施例提供了一种数据分发方法，包括：\n[0005] 监测各数据处理服务器的性能指标，所述性能指标表征了数据处理服务器的处理能力；\n[0006] 将网元设备上报的待处理数据分发至性能指标满足预设条件的数据处理服务器进行处理。\n[0007] 本发明实施例还提供了一种数据分发服务器，包括：\n[0008] 监测单元，用于监测各数据处理服务器的性能指标，所述性能指标表征了数据处理服务器的处理能力；\n[0009] 分发单元，用于将网元上报的待处理数据分发至性能指标满足预设条件的数据处理服务器进行处理。\n[0010] 本发明实施例还提供了一种网管系统，包括上述数据分发服务器。\n[0011] 本发明有益效果如下：\n[0012] 本发明实施例提供的方案，对各数据处理服务器的性能指标进行监测，将待处理数据分发至性能指标满足预设条件的数据处理服务器进行处理，即将待处理数据分发至处理能力较强的数据处理服务器，避免将待处理数据分发至处理能力较弱的数据处理服务器，因此能够避免出现数据堆积无法得到及时处理的问题。\n[0013] 本发明的其它特征和优点将在随后的说明书中阐述，并且，部分地从说明书中变得显而易见，或者通过实施本发明而了解。本发明的目的和其他优点可通过在所写的说明书、权利要求书、以及附图中所特别指出的结构来实现和获得。\n附图说明\n[0014] 附图用来提供对本发明的进一步理解，并且构成说明书的一部分，与本发明实施例一起用于解释本发明，并不构成对本发明的限制。在附图中：\n[0015] 图1为现有的网管系统的示意图；\n[0016] 图2为本发明实施例提供的数据分发方法的流程图；\n[0017] 图3为本发明实施例提供的数据分发方法的详细流程图；\n[0018] 图4为本发明实施例提供的数据分发服务器的示意图；\n[0019] 图5为本发明实施例提供的网管系统的示意图。\n具体实施方式\n[0020] 本发明实施例提供了一种数据分发方法、服务器及系统，以下结合说明书附图对本发明的优选实施例进行说明，应当理解，此处所描述的优选实施例仅用于说明和解释本发明，并不用于限定本发明。并且在不冲突的情况下，本发明中的实施例及实施例中的特征可以相互组合。\n[0021] 本发明实施例提供了一种数据分发方法，如图2所示，可以包括如下步骤：\n[0022] 步骤201、监测各数据处理服务器的性能指标，其中，性能指标表征了数据处理服务器的处理能力。\n[0023] 即监测各数据处理服务器的处理能力。\n[0024] 其中，上述数据处理服务器的性能指标具体可以包括数据处理服务器的CPU使用率和CPU内存占用率中的至少一个。由于CPU使用率和CPU内存占用率相结合能够更准确地表征数据处理服务器的处理能力，因此实际实施时，可以对数据处理服务器的CPU使用率和CPU内存占用率均进行监测。\n[0025] 上述CPU使用率和CPU内存占用率仅为示例，并不用于限定本发明。在本发明的其它实施例中，其它能够表征数据处理服务器的处理能力的参数也可以作为步骤201中被监测的性能指标。\n[0026] 步骤202、将网元设备上报的待处理数据分发至性能指标满足预设条件的数据处理服务器进行处理。\n[0027] 即将网元设备上报的待处理数据分发至处理能力较强的、满足需求的数据处理服务器进行处理。\n[0028] 其中预设条件可以基于实际应用场景，根据实际用户需求来进行具体设定。\n[0029] 可见，采用本发明实施例提供的数据分发方法，避免将待处理数据分发至处理能力较弱的数据处理服务器进行处理，因此能够避免数据堆积。\n[0030] 进一步的，步骤201对各数据处理服务器的性能指标进行监测具体可以有多种监测方式，本发明不做具体限定。\n[0031] 在本发明的一个具体实施例中，监测各数据处理服务器的性能指标具体可以包括：按照第一预设周期发送性能指标查询消息给各数据处理服务器；接收在线的数据处理服务器返回的性能指标响应消息。\n[0032] 该性能指标响应消息中包含了数据处理服务器被监测的性能指标的指标值，根据该性能指标响应消息，可以确定出对应数据处理服务器是否为性能指标满足预设条件的数据处理服务器。\n[0033] 显然，在该具体实施例中，通过性能指标查询消息这一种查询消息便可以确定数据处理服务器是否在线，并同时获知在线的数据处理服务器的处理能力。\n[0034] 而在本发明的另一个具体实施例中，可以单独发送查询消息确定各数据处理服务器是否在线，以及单独发送查询消息获知在线的数据处理服务器的处理能力。即监测各数据处理服务器的性能指标不但可以包括按照第一预设周期发送性能指标查询消息给各数据处理服务器，还可以包括：按照第二预设周期发送在线查询消息给各数据处理服务器；其中，第二预设周期小于第一预设周期；针对每个数据处理服务器，若在设定时间内未接收到该数据处理服务器返回的在线响应消息，确定该数据处理服务器不在线，此时，可以直接确定该数据处理服务器不为性能指标满足预设条件的数据处理服务器；若在设定时间内接收到该数据处理服务器返回的在线响应消息，确定该数据处理服务器在线，根据该数据处理服务器返回的性能指标响应消息确定该数据处理服务器是否为性能指标满足预设条件的数据处理服务器。\n[0035] 实际实施时，上述第一预设周期可以设置为分钟级，例如2分钟；上述第二预设周期可以设置为秒级，例如5秒；较佳的，上述设定时间不大于第二预设周期，例如当第二预设周期设置为5秒时，设定时间可以设置为5秒。\n[0036] 具体采用何种方式实现数据处理服务器性能指标的监测可以根据实际应用场景进行选择，以节约处理资源、保证监测效率。\n[0037] 进一步的，步骤202进行待处理数据的分发，也可以有多种分发方式，本发明不做具体限定。\n[0038] 例如，可以将待处理数据随机分发至性能指标满足预设条件的数据处理服务器进行处理。\n[0039] 又例如，可以将待处理数据分发至性能指标满足预设条件的数据处理服务器中性能指标当前最优的数据处理服务器进行处理。\n[0040] 又例如，可以建立网元设备和性能指标满足预设条件的数据处理服务器的对应关系；针对每个网元设备，根据网元设备和性能指标满足预设条件的数据处理服务器的对应关系，当确定出该网元设备对应的数据处理服务器时，则将该网元设备上报的待处理数据分发至确定出的数据处理服务器进行处理；当未确定出该网元设备对应的数据处理服务器时，则将该网元设备上报的待处理数据分发至性能指标满足预设条件的数据处理服务器中性能指标最优的数据处理服务器进行处理。\n[0041] 下面结合附图用具体实施例对上述数据分发方法进行详细描述。在下述具体实施例中，设置一个数据分发服务器来执行具体的数据分发流程。\n[0042] 在该具体实施例中，数据分发服务器监测的数据处理服务器的性能指标具体为CPU使用率和CPU内存占用率，通过监测数据处理服务器的CPU使用率和CPU内存占用率监测数据处理服务器的处理能力。\n[0043] 假设，预设条件设定为CPU使用率和CPU内存占用率同时小于50％。即在该具体实施例中，CPU使用率和CPU内存占用率同时小于50％的数据处理服务器为性能指标满足预设条件的数据处理服务器；CPU使用率和CPU内存占用率不同时小于50％的数据处理服务器为性能指标不满足预设条件的数据处理服务器。\n[0044] 具体可以建立一个可用服务器表用于存储性能指标满足预设条件的数据处理服务器的服务器标识，还可以建立一个对应关系表用于存储网元设备和满足预设条件的数据处理服务器的对应关系，即存储网元设备的设备标识和满足预设条件的数据处理服务器的服务器标识的对应关系。该网元设备和满足预设条件的数据处理服务器的对应关系可以基于数据分发记录以及对各数据处理服务器的性能指标的监测结果进行设定更新，具体的设定更新方式会在后文进行描述。\n[0045] 如图3所示，该具体实施例提供的具体的数据分发流程包括如下步骤：\n[0046] 步骤301、网元设备向数据分发服务器上报待处理数据。\n[0047] 步骤302、数据分发服务器接收网元设备上报的待处理数据，判断存储了网元设备和满足预设条件的数据处理服务器的对应关系的对应关系表中是否存在上报待处理数据的该网元设备对应的数据处理服务器。\n[0048] 当对应关系表中存在该网元设备对应的数据处理服务器时，进入步骤303；当对应关系表中不存在该网元设备对应的数据处理服务器时，进入步骤304。\n[0049] 步骤303、数据分发服务器将该网元设备上报的待处理数据分发至对应的数据处理服务器进行处理，本次数据分发流程结束。\n[0050] 步骤304、数据分发服务器从可用服务器表中确定性能指标最优的数据处理服务器。\n[0051] 在该具体实施例中，可以优先依据数据处理服务器的CPU使用率确定性能指标最优的数据处理服务器，当无法依据数据处理服务器的CPU使用率确定出性能指标最优的数据处理服务器时，再结合处理服务器的CPU内存占用率确定性能指标最优的数据处理服务器。\n[0052] 例如，假设数据处理服务器CPU使用率和CPU内存占用率同时小于50％的数据处理服务器有3个，即可用服务器表中性能指标满足预设条件的数据处理服务器有3个，若这3个数据处理服务器的CPU使用率分别为20％、30％和40％，则可以从这3个数据处理服务器中选择CPU使用率最低的即选择CPU使用率为20％的数据处理服务器作为性能指标最优的数据处理服务器。\n[0053] 若这3个数据处理服务器的CPU使用率分别为20％、20％和40％，有2个数据处理服务器的CPU使用率为20％均为最低，则无法仅依据CPU使用率选择出性能指标最优的数据处理服务器，此时，可以再结合CPU内存占用率，从这2个CPU使用率均为20％的数据处理服务器中进行进一步选择。若这2个CPU使用率均为20％的数据处理服务器的CPU内存占用率分别为30％和40％，则可以从这2个数据处理服务器中选择CPU内存占用率较低的即选择CPU内存占用率为30％的数据处理服务器作为性能指标最优的数据处理服务器。若这2个CPU使用率均为20％的数据处理服务器的CPU内存占用率也可相同，则可以从这2个数据处理服务器中进行随机选择作为性能指标最优的数据处理服务器。\n[0054] 上述性能指标最优的数据处理服务器的具体确定方式仅为一个示例，实际实施时，可根据实际情况选择其它的确定方式，例如优先依据数据处理服务器的CPU内存占用率的确定方式。\n[0055] 步骤305、数据分发服务器将该网元设备上报的待处理数据分发至确定的性能指标最优的数据处理服务器进行处理。\n[0056] 执行完步骤305后，数据分发服务器可以建立该网元设备和该确定的性能指标最优的数据处理服务器的对应关系，将该对应关系存入对应关系表中，可以缩短下一次对该网元设备上报的待处理数据的分发时间，可以提高分发效率。\n[0057] 同时，该存储了网元设备和满足预设条件的数据处理服务器的对应关系的对应关系表还应根据对各数据处理服务器的性能指标的监测结果进行更新。当确定出一个数据处理服务器由性能指标满足预设条件的数据处理服务器变为性能指标不满足预设条件的数据处理服务器时，不但需要更新可用服务器表，若对应关系表中存在该数据处理服务器对应的对应关系，还应进行删除，以保证对应关系表的数据有效性。\n[0058] 实际实施时，数据分发服务器在监测一个数据处理服务器的性能指标之前，该数据处理服务器通常需要先在数据分发服务器进行注册，即数据分发服务器监测已注册的各数据处理服务器的性能指标；数据处理服务器的注册过程具体包括：数据处理服务器向数据分发服务器发送携带IP地址的注册请求消息；数据分发服务器接收该注册请求消息，根据该注册请求消息中携带的IP地址，生成服务器标识；数据分发服务器向发送注册请求消息的数据处理服务器返回携带生成的服务器标识的注册确认消息，数据处理服务器接收该注册确认消息。\n[0059] 进一步的，上述注册请求消息中，还可以包括该数据处理服务器的性能指标的指标值，即可以根据注册请求消息确定出该新注册的数据处理服务器是否为性能指标满足预设条件的数据处理服务器，若该新注册的数据处理服务器为性能指标满足预设条件的数据处理服务器，则可以对可用服务器表进行更新，同时也可以更新对应关系表，在对应关系表中将部分网元设备对应至该新注册的数据处理服务器，分担其它数据处理服务器的数据处理任务。\n[0060] 进一步的，数据分发服务器在根据注册请求消息中携带的IP地址生成服务器标识时，具体可以采用哈希算法，生成的服务器标识即为后续可用服务器表及对应关系表中存储的服务器标识。\n[0061] 综上，采用本发明实施例提供的数据分发方法，对网元设备上报的待处理数据能够进行及时处理，不会出现数据堆积的情况，提高了对网元设备上报的待处理数据的处理效率。\n[0062] 基于同一发明构思，根据本发明上述实施例提供的数据分发方法，相应的，本发明实施例还提供了一种数据分发服务器，如图4所示，包括监测单元401和分发单元402，其中：\n[0063] 监测单元401，用于监测各数据处理服务器的性能指标，该性能指标表征了数据处理服务器的处理能力；\n[0064] 分发单元402，用于将网元设备上报的待处理数据分发至性能指标满足预设条件的数据处理服务器进行处理。\n[0065] 其中，该数据处理服务器的性能指标包括数据处理服务器的CPU使用率和CPU内存占用率中的至少一个。\n[0066] 进一步的，监测单元401，具体用于按照第一预设周期发送性能指标查询消息给各数据处理服务器；接收在线的数据处理服务器返回的性能指标响应消息。\n[0067] 较佳的，监测单元401，还用于按照第二预设周期发送在线查询消息给各数据处理服务器；该第二预设周期小于该第一预设周期；针对每个数据处理服务器，若在设定时间内未接收到该数据处理服务器返回的在线响应消息，确定该数据处理服务器不在线；若在设定时间内未接收到该数据处理服务器返回的在线响应消息，确定该数据处理服务器在线。\n[0068] 进一步的，分发单元402，具体用于针对每个网元设备，根据网元设备和性能指标满足预设条件的数据处理服务器的对应关系，当确定出该网元设备对应的数据处理服务器时，则将该网元设备上报的待处理数据分发至确定出的数据处理服务器进行处理；当未确定出该网元设备对应的数据处理服务器时，则将该网元设备上报的待处理数据分发至性能指标满足预设条件的数据处理服务器中性能指标最优的数据处理服务器进行处理。\n[0069] 进一步的，监测单元401，具体用于监测已注册的各数据处理服务器的性能指标；\n[0070] 该数据分发服务器还包括注册单元403，用于接收数据处理服务器发送的携带IP地址的注册请求消息；根据该注册请求消息中携带的IP地址，生成服务器ID；向发送注册请求消息的数据处理服务器返回携带生成的服务器ID的注册确认消息。\n[0071] 上述各单元的功能可对应于图2或3所示流程中的相应处理步骤，在此不再赘述。\n[0072] 相应的，本发明实施例还提供了一种网管系统，包括上述数据分发服务器。如图5所示，本发明实施例提供的网管系统具体包括网元设备、数据分发服务器和数据处理服务器，其中：\n[0073] 网元设备，用于上报待处理数据给数据分发服务器；\n[0074] 数据分发服务器，用于监测各数据处理服务器的性能指标，该性能指标表征了数据处理服务器的处理能力；将网元设备上报的待处理数据分发至性能指标满足预设条件的数据处理服务器进行处理；\n[0075] 数据处理服务器，用于处理数据分发服务器分发的待处理数据。\n[0076] 其中，该数据处理服务器的性能指标包括数据处理服务器的CPU使用率和CPU内存占用率中的至少一个。\n[0077] 进一步的，数据分发服务器，具体用于按照第一预设周期发送性能指标查询消息给各数据处理服务器；接收在线的数据处理服务器返回的性能指标响应消息；\n[0078] 即在线的数据处理服务器在接收到数据分发服务器发送的性能指标查询消息后，向数据分发服务器返回性能指标响应消息。\n[0079] 较佳的，数据分发服务器，还用于按照第二预设周期发送在线查询消息给各数据处理服务器；该第二预设周期小于该第一预设周期；针对每个数据处理服务器，若在设定时间内未接收到该数据处理服务器返回的在线响应消息，确定该数据处理服务器不在线；若在设定时间内接收到该数据处理服务器返回的在线响应消息，确定该数据处理服务器在线；\n[0080] 即在线的数据处理服务器在接收到数据分发服务器发送的在线查询消息后，在设定时间内向数据处理服务器返回在线响应消息。\n[0081] 进一步的，数据分发服务器，具体用于针对每个网元设备，根据网元设备和性能指标满足预设条件的数据处理服务器的对应关系，当确定出该网元设备对应的数据处理服务器时，则将该网元设备上报的待处理数据分发至确定出的数据处理服务器进行处理；当未确定出该网元设备对应的数据处理服务器时，则将该网元设备上报的待处理数据分发至性能指标满足预设条件的数据处理服务器中性能指标最优的数据处理服务器进行处理。\n[0082] 进一步的，数据分发服务器，具体用于监测已注册的各数据处理服务器的性能指标；\n[0083] 数据分发服务器还用于接收数据处理服务器发送的携带IP地址的注册请求消息；\n根据该注册请求消息中携带的IP地址，生成服务器ID；向发送注册请求消息的数据处理服务器返回携带生成的服务器ID的注册确认消息；\n[0084] 未注册的数据处理服务器向数据分发服务器发送携带IP地址的注册请求消息；并接收数据分发服务器返回的注册确认消息。\n[0085] 综上所述，采用本发明实施例提供方案，能够对网元设备上报的待处理数据进行及时处理，避免数据堆积，对处理资源进行合理利用，提高了网管系统的动态性能。\n[0086] 显然，本领域的技术人员可以对本发明进行各种改动和变型而不脱离本发明的精神和范围。这样，倘若本发明的这些修改和变型属于本发明权利要求及其等同技术的范围之内，则本发明也意图包含这些改动和变型在内。