[go: up one dir, main page]

CN113961367A - Method and equipment for realizing remote data acquisition - Google Patents

Method and equipment for realizing remote data acquisition Download PDF

Info

Publication number
CN113961367A
CN113961367A CN202111148641.8A CN202111148641A CN113961367A CN 113961367 A CN113961367 A CN 113961367A CN 202111148641 A CN202111148641 A CN 202111148641A CN 113961367 A CN113961367 A CN 113961367A
Authority
CN
China
Prior art keywords
port
board
entry
data
subscription
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Granted
Application number
CN202111148641.8A
Other languages
Chinese (zh)
Other versions
CN113961367B (en
Inventor
何刚
陈勇
齐达
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
New H3C Security Technologies Co Ltd
Original Assignee
New H3C Security Technologies Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by New H3C Security Technologies Co Ltd filed Critical New H3C Security Technologies Co Ltd
Priority to CN202111148641.8A priority Critical patent/CN113961367B/en
Publication of CN113961367A publication Critical patent/CN113961367A/en
Application granted granted Critical
Publication of CN113961367B publication Critical patent/CN113961367B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Images

Classifications

    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00Arrangements for program control, e.g. control units
    • G06F9/06Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/46Multiprogramming arrangements
    • G06F9/54Interprogram communication
    • G06F9/547Remote procedure calls [RPC]; Web services
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00Arrangements for program control, e.g. control units
    • G06F9/06Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/46Multiprogramming arrangements
    • G06F9/54Interprogram communication
    • G06F9/546Message passing systems or structures, e.g. queues
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F2209/00Indexing scheme relating to G06F9/00
    • G06F2209/54Indexing scheme relating to G06F9/54
    • G06F2209/544Remote
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F2209/00Indexing scheme relating to G06F9/00
    • G06F2209/54Indexing scheme relating to G06F9/54
    • G06F2209/548Queue

Landscapes

  • Engineering & Computer Science (AREA)
  • Software Systems (AREA)
  • Theoretical Computer Science (AREA)
  • Physics & Mathematics (AREA)
  • General Engineering & Computer Science (AREA)
  • General Physics & Mathematics (AREA)
  • Data Exchanges In Wide-Area Networks (AREA)

Abstract

The application provides a method and equipment for realizing remote data acquisition. The service applying the method calls a data acquisition function corresponding to a home board subscription table entry to acquire data to be written in by executing a remote procedure call task when a home board data acquisition cycle is reached; when the data acquisition function acquires data, writing the data acquired by the data acquisition function into a local board subscription table item and setting a written identifier; when the remote acquisition cycle is reached, a data reporting function corresponding to the local board subscription table entry is called to verify that the local board subscription table entry is written, the local board identification, the written data recorded by each table entry of the local board subscription table entry and the indication index of the written data recorded by each table entry are packaged in a remote process call protocol message, and the remote process call protocol message is sent to the acquisition device.

Description

Method and equipment for realizing remote data acquisition
Technical Field
The present application relates to communications technologies, and in particular, to a method and an apparatus for implementing remote data acquisition.
Background
Telemetering is a remote data acquisition technology for monitoring the performance and faults of equipment, and rich monitoring data can be obtained in time by adopting a push mode, so that the network fault can be quickly positioned, and the problem of network operation and maintenance is solved. Depending on different data reporting modes, there are various ways to implement telemetrology. By adopting a Remote Procedure Call (RPC) Telemetry technology, the device can automatically read statistical information and push the statistical information to the collector through an RPC protocol, so that a real-time and efficient data collection function is realized.
In the frame type communication equipment, the main control board informs each service board of data acquisition, acquires the acquired data from each service board when a sampling period arrives, and sends the collected data to the acquisition unit through an RPC protocol message after the data is collected. For example, when packet loss data and overrun data of the frame device need to be collected, the main control board notifies each service board to start RPC collection, each service board traverses each service port of the board, calls a data statistics interface function to obtain the packet loss number and overrun times of each port and each queue of the board, sends the obtained packet loss number and overrun times of each port and each queue of the board to other service boards through an Inter-Process Communication (IPC), each service board performs superposition calculation on all single-board data and sends the superposed data to the main control board, and the main control board sends the superposed data to the collector through an RPC protocol message. The method has the disadvantages that the larger the number of the service boards in the frame type equipment is, the larger the IPC forming pressure in the frame type equipment is, the time consumption of superposition calculation is long, and the real situation cannot be reflected in real time due to the fact that the real-time updating efficiency of important information such as lost packets and overrun is not timely. The packet loss and the overrun data obtained by the user from the collector after superposition calculation cannot be distinguished from the packet loss and the overrun data of each service board, and the packet loss and the overrun data cannot be counted and analyzed based on the customer requirements. The data acquisition time of the existing centralized RPC statistics of the frame-type communication equipment is long, the collector cannot distinguish the acquired data, and the statistical calculation cannot be flexibly carried out according to the requirements.
Disclosure of Invention
The application aims to provide a method and equipment for realizing remote data acquisition, wherein a service board directly pushes acquired data to an acquisition device, and the real-time performance of data acquisition is improved.
In order to achieve the above object, the present application provides a method for implementing remote data acquisition, including: establishing a remote process call task for a service board of the frame type communication equipment; when the data acquisition period of the local board is reached, the remote process call task calls a data acquisition function corresponding to a local board subscription table entry to acquire data to be written; when the remote process call task acquires data from the data acquisition function, writing the data acquired by the data acquisition function into the local board subscription table item and setting a written identifier; when the remote process call task arrives at a remote acquisition cycle, calling a data reporting function corresponding to the local board subscription table entry, verifying that the local board subscription table entry is written in by the data reporting function based on the writing identification of the local board subscription table entry, encapsulating the local board identification, the written data recorded by each table entry of the local board subscription table entry and the indication index of the written data recorded by each table entry in a remote process call protocol message by the data reporting function, and sending the remote process call protocol message to the collector.
In order to achieve the above object, the present application further provides a device for implementing remote data acquisition, where the device is applied as a service board of a frame-type communication device, and the service board includes a plurality of ports, a switching unit, a processor, and a memory; the bottom layer driving data acquisition module of the exchange unit is used for executing the following operations; newly building a remote process call task; when the data acquisition period of the local board is reached, the remote process call task calls a data acquisition function corresponding to a local board subscription table entry to acquire data to be written; when the data acquisition function acquires data, the remote procedure call task writes the data acquired by the data acquisition function into the local board subscription table item and sets a written identifier; when the remote process call task arrives at a remote acquisition cycle, calling a data reporting function corresponding to the local board subscription table entry, verifying that the local board subscription table entry is written in by the data reporting function based on the writing identification of the local board subscription table entry, encapsulating the local board identification, the written data recorded by each table entry of the local board subscription table entry and the indication index of the written data recorded by each table entry in a remote process call protocol message by the data reporting function, and sending the remote process call protocol message to the collector.
The method and the device have the advantages that the service board directly pushes the collected data to the collector, the real-time performance of data collection is improved, distributed collection is achieved in frame type communication equipment merchants, and collection time is shortened. And a plurality of groups of data can be uploaded at one time through the remote procedure call protocol message, and a user can more freely process the acquired data according to the service board identification and the indication index of the remote procedure call protocol message, thereby improving the processing flexibility of the user on the acquired data of the frame type communication equipment.
Drawings
FIG. 1 is a flow chart of an embodiment of a method for remotely acquiring data provided herein;
fig. 2 is a flowchart of an embodiment of a service board acquiring port packet loss data according to the present application;
fig. 3 is a schematic diagram of an embodiment of an apparatus for implementing remote data acquisition according to the present application.
Detailed Description
A detailed description will be given of a number of examples shown in a number of figures. In the following detailed description, numerous specific details are set forth in order to provide a thorough understanding of the present application. Well-known methods, procedures, components and circuits have not been described in detail so as not to obscure the examples.
The term "including" as that term is used is meant to include, but is not limited to; the term "comprising" means including but not limited to; the terms "above," "within," and "below" include the instant numbers; the terms "greater than" and "less than" mean that the number is not included. The term "based on" means based on at least a portion thereof.
Fig. 1 is an embodiment of a method for implementing remote data acquisition, where the embodiment is applied to a service board of a frame-type communication device, and the embodiment includes the following steps:
step 101, a remote process calling task of a new service board is established;
102, when a remote process call task arrives at a data acquisition cycle of a local board, calling a data acquisition function corresponding to a local board subscription table entry to acquire data to be written;
103, when the data acquisition function acquires data, the remote process call task writes the data acquired by the data acquisition function into a local board subscription table item and sets a written identifier;
step 104, when the remote process calling task arrives at the remote acquisition period, calling a data reporting function corresponding to the local board subscription table entry;
step 105, the remote process calls a task data call reporting function to verify that the local board subscription table item is written based on the writing identification of the local board subscription table item;
step 106, a remote procedure call task data call data reporting function packages the board identification, written data recorded by each item of the board subscription item and an indication index of the written data recorded by each item into a remote procedure call protocol message;
step 107, sending the remote procedure call protocol message to the collector.
The method and the device have the advantages that the service board directly pushes the collected data to the collector, the real-time performance of data collection is improved, distributed collection is achieved in frame type communication equipment merchants, and collection time is shortened. And a plurality of groups of data can be uploaded at one time through the remote procedure call protocol message, and a user can identify the acquired data according to the service board identification and the indication index of the remote procedure call protocol message, so that the acquired data can be processed more freely, and the processing flexibility of the user on the acquired data of the frame type communication equipment is improved.
In the embodiment of fig. 1, the remote procedure call task of the service board may call the device state information (e.g., CPU and memory states) of the service board; calling physical port state information (such as optical module state and port bandwidth utilization); port packet/queue statistical data (e.g., interface packet loss and packet error statistics, queue packet loss statistics, queue buffer resource occupation status); and exchanging the table entry/resource data (such as the use condition of forwarding table entry resources, ACL flow table resources and virtual interface resources) of the chip. The method comprises the steps that a business board configures a collector, configures a collection period and configures subscription table items, a bottom layer driving data acquisition module of the business board calls corresponding data collection parameters by executing a remote process calling task to write data into corresponding subscription table items, and then sends the written subscription table items to the collector through a remote process calling protocol message when the collection period is up.
The collected data are independently sent to the collector by each service board of the frame-type equipment through a distributed data sending mechanism, the data are sent to the collector in a centralized mode without IPC communication in the frame-type communication equipment, the CPU burden of each service board is reduced, the data collection efficiency is improved, a client can perform data statistics on a certain service board or a plurality of service boards or the whole frame according to the collected data sent by each service board independently, and the statistical mode is more flexible.
Fig. 2 is a flowchart of an embodiment of a service board acquiring port packet loss data according to the present application;
step 201, traversing each service module of the board;
the service board receives a remote acquisition cycle configured by the main control board, an indication index, an operation action for adding a subscription table item, a configured port packet loss number subscription table item, a port overrun subscription table item, a port queue packet loss number subscription table item and a port queue overrun subscription table item, and triggers a remote process calling process.
And the bottom layer driving data acquisition module of the service board starts a remote procedure call task, a timer is set according to a remote acquisition period, when the timer arrives, the remote procedure call task of the service board calls a data reporting function of the written subscription table item, sends a remote procedure call protocol message to the acquisition device, and pushes acquired data to the acquisition device.
Therefore, before the timer arrives, the data to be collected needs to be written into the four subscription entries. Therefore, the board data acquisition period is a time interval different from the remote acquisition period, and the remote procedure call task starts to traverse each service Module (MOD) of the board when the board data acquisition period arrives.
Step 202, traversing each port of the board;
and the remote procedure call task traverses the physical port on each switching chip on the board.
Step 203, acquiring a virtual output queue identifier corresponding to the service module identifier and the port identifier;
in the frame communication device, an identifier MOD ID of each service module and an identifier Port ID of one physical Port on the service board correspond to one VOQ (Virtual Output Queue) index. By traversing each service module and each physical Port, the VOQ index on the service board can be obtained according to the identifier MOD ID and the physical Port ID of the service module obtained by the traversal.
Step 204, polling whether a plurality of queues corresponding to the virtual output queue identification have packet loss numbers and overrun numbers; if not, go to step 205; if yes, go to step 206;
and polling the virtual queues pointed by the VOQ indexes to acquire whether each virtual queue has a packet loss number or an overrun number (the number of times of exceeding the bandwidth of the virtual queue) or not.
Step 205, not setting the subscription table entry;
and when the virtual queues pointed by the VOQ indexes polled by the remote process call task do not have the packet loss number or the overrun number, the data which need to be written into the four subscription table entries is not needed, and the four subscription table entries are not set.
In the application, when the data to be collected is not written in each subscription table entry, the initial value of the writing state of each subscription table entry is kept, so that the remote process call task can confirm whether the data to be collected is written in the subscription table entries or not by checking whether the writing state of each subscription table entry is set or not.
If the remote procedure call task determines that any subscription table entry is not written in through verification, the data uploading parameter of the subscription table entry does not need to be called, empty acquisition data are prevented from being sent to the acquisition device, and the bandwidth occupied by useless remote procedure call protocol messages and the processing resources occupied by the acquisition device are avoided.
Step 206, writing the data into the corresponding subscription table entry;
when one or more of the virtual queues pointed by the remote procedure call task polling VOQ index has a packet loss number or an overrun number, writing the port identification, the queue identification and the packet loss number into a port queue packet loss number subscription table item and setting; and writing the port identification, the queue identification and the overrun number into the port queue overrun subscription table entry and setting.
And counting packet loss numbers of a plurality of virtual queues based on VOQ index pointing by the remote procedure call task, calculating packet loss numbers of ports of the board corresponding to the VOQ index, writing the port identification and the packet loss numbers into port packet loss number subscription table entries and setting.
And counting packet loss numbers of a plurality of virtual queues based on VOQ index pointing by the remote procedure call task, calculating the packet loss number of a local board port corresponding to the VOQ index, writing the port identification and the overrun number into the port overrun subscription table entry and setting.
Based on the embodiment shown in fig. 2, the remote procedure call task completes writing the collected data into the port packet loss number subscription table, the port over-limit subscription table, the port queue packet loss number subscription table, and the port queue over-limit subscription table.
When the timer of the remote acquisition cycle is reached, the remote procedure call task checks that the port packet loss number subscription table entry is set, a data reporting function corresponding to the port packet loss number subscription table entry is called, and the local board identifier of the service board, the port identifier and the packet loss number recorded by each table entry of the port packet loss number subscription table entry and the indication index thereof are encapsulated in the remote procedure call protocol message. For example, the three entries of the port packet loss number subscription entry respectively record the packet loss numbers of the three ports, and encapsulate the local board identifier of the service board, the port identifier and the packet loss number recorded in the entry 1 and the indication index 1, the port identifier and the packet loss number recorded in the entry 2 and the indication index 2, and the port identifier and the packet loss number recorded in the entry 3 and the indication index 3 in the remote procedure call protocol packet. Therefore, the method can support the one-time uploading of multiple groups of data, and a user can select the packet loss number of the port needing to be counted according to the counting requirement, so that the subsequent data counting is more flexible.
And the remote procedure call task checks that the port over-limit subscription table entry is set, and a data reporting function of the port over-limit subscription table entry is called to encapsulate the service board identifier, the port identifier and the over-limit number recorded by each table entry of the port over-limit subscription table entry and an indication index thereof in the remote procedure call protocol message. For example, 2 entries of the port over-limit subscription entry record the over-limit number of 2 ports, respectively, and encapsulate the local board identifier of the service board, the port identifier and the over-limit number recorded in the entry 1 and the indication index 1, and the port identifier and the over-limit number recorded in the entry 2 and the indication index 2 in the remote procedure call protocol packet.
And the remote procedure call task check queue packet loss number subscription table entry is set, and a data reporting function corresponding to the queue packet loss number subscription table entry is called to package the service board identifier, the port identifier recorded by each table entry, the queue identifier, the packet loss number and the indication index thereof in a remote procedure call protocol message. For example, 2 entries of the port over-limit subscription entry record the packet loss numbers of the virtual queues queue1 and queue8 of the port1, respectively, and encapsulate the local board identifier of the service board, the port1 identifier recorded in the entry 1, the virtual queue identifier queue1, and the packet loss number indication index 1, and the port1 identifier, the virtual queue identifier queue8, and the packet loss number indication index 2 recorded in the entry 2 into the remote procedure call protocol packet.
And the remote procedure call task checks that the queue over-limit subscription table entry is set, calls a data reporting function corresponding to the queue over-limit subscription table entry, and encapsulates the service board identifier, the port identifier recorded by each table entry, the queue identifier, the over-limit number and an indication index thereof in the remote procedure call protocol message. For example, 2 entries of the port over-limit subscription entry record the over-limit numbers of the virtual queues queue1 and queue8 of the port1, respectively, and encapsulate the service board identifier, the port1 identifier, the virtual queue identifier queue1 and the packet loss number indication index 1 recorded in the entry 1, and the port1 identifier, the virtual queue identifier queue8 and the packet loss number indication index 2 recorded in the entry 2 into the remote procedure call protocol packet.
According to the method, the collected data are uploaded to the collector in a service board distributed reporting mode, and each service board is independently processed, so that the cpu occupancy rate of the upper process of the main control board is not influenced; the performance bottleneck is reduced, a user can flexibly select a statistical object and a statistical direction from the collected data reported by each service board, and the flexibility of data statistics is improved for the user.
Fig. 3 is a schematic diagram of an embodiment of the present remote data acquisition apparatus provided in the present application. The 30 device is applied as a service board of a frame-type communication device, and the service board comprises a plurality of ports, a switching unit, a processor and a memory; the bottom layer driving data acquisition module which can be used as a switching unit of the switching chip is used for executing the following operations;
newly building a remote process call task; when the data acquisition period of the local board is reached, the remote process call task calls a data acquisition function corresponding to a local board subscription table entry to acquire data to be written; when the data acquisition function acquires data, the remote procedure call task writes the data acquired by the data acquisition function into the local board subscription table item and sets a written identifier; when the remote process call task arrives at a remote acquisition cycle, calling a data reporting function corresponding to the local board subscription table entry, verifying that the local board subscription table entry is written in by the data reporting function based on the writing identification of the local board subscription table entry, encapsulating the local board identification, the written data recorded by each table entry of the local board subscription table entry and the indication index of the written data recorded by each table entry in a remote process call protocol message by the data reporting function, and sending the remote process call protocol message to the acquirer based on the network address of the acquirer.
The remote process call task executed by the bottom layer driving data acquisition module does not modify the unwritten identification of the subscription table entry of the local board when the data acquisition function does not acquire data; when a remote process calling task executed by the bottom layer driving data acquisition module arrives at a remote acquisition cycle, calling a data reporting function corresponding to the local board subscription table entry, and verifying that the local board subscription table entry is not written in by the data reporting function based on the unwritten identification of the local board subscription table entry, and waiting for the next remote acquisition cycle.
The processor executes the processor-executable instructions in the memory for performing the following operations; receiving a remote acquisition cycle configured by a master control board; receiving an indication index configured by a master control board; receiving an operation action of adding a subscription table item configured by a main control board; receiving a home board subscription table item configured by a main control board; and synchronizing a remote acquisition cycle of a newly-built remote process call task, an indication index, operation actions for adding a subscription table entry and a local board subscription table entry to the bottom layer driving data.
The subscription list item of the board is a port packet loss number subscription list item, a port over-limit subscription list item, a port queue packet loss number subscription list item and a port queue over-limit subscription list item.
The port packet loss number subscription table entry, the port over-limit subscription table entry, the port queue packet loss number subscription table entry and the port queue over-limit subscription table entry correspond to packet loss data acquisition parameters; the remote procedure call task calls a packet loss data acquisition parameter to acquire data to be written includes executing the following operations: traversing each local board service module and each local board port; identifying a virtual output queue index based on the identification of each local board service module and the ID of each local board port; polling whether a plurality of queues pointed by each identified virtual output queue index have lost packet numbers and overrun numbers; if yes, counting packet loss numbers and overrun numbers of the ports of the board corresponding to each identified virtual output queue index based on the packet loss numbers and the overrun numbers of the queues pointed by each identified virtual output queue index; writing the port identification and the packet loss number of the port of the local board corresponding to each identified virtual output queue index into a port packet loss number subscription table entry; writing the port identification and the overrun number of the port of the local board corresponding to each identified virtual output queue index into a port overrun subscription table entry; writing the port identification, the queue identification and the packet loss number of the identified multiple queues pointed by each virtual output queue index into a packet loss number subscription table entry of the port queue; and writing the port identification, the queue identification and the overrun number of the plurality of queues pointed by each identified virtual output queue index into the port queue overrun subscription table entry.
A remote procedure call task calls a data reporting function corresponding to a port packet loss number subscription table entry, and encapsulates the local board identifier of the service board, the port identifier and the packet loss number recorded in each table entry of the port packet loss number subscription table entry and an indication index thereof in a remote procedure call protocol message; a remote procedure call task calls a data reporting function corresponding to a port over-limit subscription table entry, and encapsulates the local board identifier of the service board, the port identifier and the over-limit number recorded by each table entry of the port over-limit subscription table entry and an indication index thereof in a remote procedure call protocol message; a remote procedure call task calls a data reporting function corresponding to a queue packet loss number subscription table entry, and encapsulates a local board identifier of a service board, a port identifier recorded by each table entry of a port packet loss number subscription table entry, a queue identifier, a packet loss number and an indication index thereof in a remote procedure call protocol message; and the remote procedure call task calls a data reporting function corresponding to the queue overrun subscription table entry, and encapsulates the local board identifier of the service board, the port identifier recorded by each table entry of the port overrun subscription table entry, the queue identifier, the overrun number and an indication index thereof in a remote procedure call protocol message.
The above description is only exemplary of the present application and should not be taken as limiting the present application, as any modification, equivalent replacement, or improvement made within the spirit and principle of the present application should be included in the scope of protection of the present application.

Claims (12)

1.一种实现远程数据采集的方法,其特征在于,所述方法包括:1. a method for realizing remote data collection, is characterized in that, described method comprises: 为框式通信设备的业务板新建远程过程调用任务;Create a new remote procedure call task for the service board of the frame communication device; 所述远程过程调用任务在本板数据获取周期到达时,调用所述本板订阅表项对应的数据获取函数获取需写入的数据;When the data acquisition cycle of the local board arrives, the remote procedure call task calls the data acquisition function corresponding to the subscription entry of the local board to acquire the data to be written; 所述远程过程调用任务在所述数据获取函数获取到数据时,将所述数据获取函数获取到的数据写入所述本板订阅表项并设置已写入标识;When the data acquisition function acquires the data, the remote procedure call task writes the data acquired by the data acquisition function into the local board subscription entry and sets the written flag; 所述远程过程调用任务在远程采集周期到达时,调用所述本板订阅表项对应的数据上报函数且所述数据上报函数基于所述本板订阅表项的写入标识校验所述本板订阅表项已被写入,所述数据上报函数将本板标识、所述本板订阅表项的每条表项记录的已写入数据及每条表项记录的已写入数据的指示索引封装在远程过程调用协议报文,发送所述远程过程调用协议报文到采集器。When the remote procedure call task arrives in the remote collection period, the data reporting function corresponding to the subscription entry of the local board is called, and the data reporting function verifies the board based on the write identifier of the subscription entry of the local board. The subscription entry has been written, and the data reporting function indexes the board identifier, the written data recorded in each entry of the board subscription entry, and the indication index of the written data recorded in each entry. The remote procedure call protocol message is encapsulated in the remote procedure call protocol message, and the remote procedure call protocol message is sent to the collector. 2.根据权利要求1所述的方法,其特征在于,所述方法还包括:2. The method according to claim 1, wherein the method further comprises: 所述远程过程调用任务在所述数据获取函数未获取到数据时,不修改所述本板订阅表项的未写入标识;The remote procedure call task does not modify the unwritten flag of the subscription entry of the local board when the data acquisition function does not acquire data; 所述远程过程调用任务在远程采集周期到达时,调用所述本板订阅表项对应的数据上报函数且所述数据上报函数基于所述本板订阅表项的未写入标识校验所述本板订阅表项未被写入,则等待下一次远程采集周期。When the remote procedure call task arrives in the remote collection period, the data reporting function corresponding to the subscription entry of the local board is called, and the data reporting function verifies the local board based on the unwritten identifier of the subscription entry of the local board. If the board subscription entry has not been written, wait for the next remote collection cycle. 3.根据权利要求2所述的方法,其特征在于,为业务板新建远程过程调用任务包括;3. The method according to claim 2, wherein creating a new remote procedure call task for the service board comprises; 接收由主控板配置的所述的远程采集周期;receiving the remote collection cycle configured by the main control board; 接收由所述主控板配置的所述指示索引;receiving the indication index configured by the main control board; 接收由所述主控板配置的增加订阅表项的操作动作;receiving an operation action of adding a subscription entry configured by the main control board; 接收由所述主控板配置的所述本板订阅表项。Receive the local board subscription entry configured by the main control board. 4.根据权利要求3所述的方法,其特征在于,所述本板订阅表项是端口丢包数订阅表项,端口超限订阅表项,端口队列丢包数订阅表项,端口队列超限订阅表项。4. The method according to claim 3, wherein the sub-board subscription entry is a port packet loss subscription entry, a port overrun subscription entry, a port queue packet loss subscription entry, and a port queue overrun subscription entry. Limited subscription entries. 5.根据权利要求4所述的方法,其特征在于,所述端口丢包数订阅表项、端口超限订阅表项、所述端口队列丢包数订阅表项以及端口队列超限订阅表项对应于丢包数据获取参数;5. The method according to claim 4, wherein the port packet loss number subscription entry, the port overrun subscription entry, the port queue packet loss number subscription entry and the port queue overrun subscription entry Corresponding to the parameters of packet loss data acquisition; 所述远程过程调用任务调用所述丢包数据获取参数获取需写入的数据包括:The remote procedure call task invoking the packet loss data acquisition parameter to acquire the data to be written includes: 遍历每个本板业务模块和每个本板端口;Traverse each local board service module and each local board port; 基于每个本板业务模块的标识和每个本板端口的ID识别一个虚拟输出队列索引;Identify a virtual output queue index based on the ID of each local board service module and the ID of each local board port; 轮询识别的每个虚拟输出队列索引指向的多个队列是否有丢包数和超限数;Polling whether the multiple queues pointed to by each virtual output queue index identified have the number of dropped packets and the number of overruns; 若是,基于识别的每个虚拟输出队列索引指向的多个队列的丢包数和超限数,统计识别的每个虚拟输出队列索引对应的本板端口的丢包数和超限数;If so, based on the identified packet loss and overrun counts of multiple queues pointed to by each virtual output queue index, count the packet loss and overrun count of the port on the board corresponding to each identified virtual output queue index; 将识别的每个虚拟输出队列索引对应的本板端口的端口标识及丢包数写入所述端口丢包数订阅表项;Write the port identifier and packet loss number of the port on the board corresponding to each identified virtual output queue index into the port packet loss number subscription table entry; 将识别的每个虚拟输出队列索引对应的本板端口的端口标识及超限数写入所述端口超限订阅表项;Write the port identifier and the over-limit number of the port on the board corresponding to each identified virtual output queue index into the port over-limit subscription entry; 将识别的每个虚拟输出队列索引指向的多个队列的端口标识、队列标识及丢包数写入所述端口队列丢包数订阅表项;Write the port identifiers, queue identifiers and packet loss counts of the multiple queues pointed to by each virtual output queue index identified into the port queue packet loss count subscription table entry; 将识别的每个虚拟输出队列索引指向的多个队列的端口标识、队列标识及超限数写入所述端口队列超限订阅表项。Write the port identifiers, queue identifiers, and overrun numbers of the multiple queues identified by each virtual output queue index to the port queue overrun subscription entry. 6.根据权利要求5所述的方法,其特征在于,所述数据上报函数将本板标识、所述本板订阅表项的每条表项记录的已写入数据及每条表项记录的已写入数据的指示索引封装在远程过程调用协议报文包括:6. The method according to claim 5, wherein the data reporting function reports the written data of each entry record of the board identification, the board subscription entry and the recorded data of each entry. The indication index of the written data is encapsulated in the remote procedure call protocol message including: 所述端口丢包数订阅表项对应的数据上报函数将所述业务板的本板标识、所述端口丢包数订阅表项的每条表项记录的端口标识和丢包数及其指示索引封装在所述远程过程调用协议报文;The data reporting function corresponding to the port packet loss number subscription entry sends the local board identifier of the service board, the port identifier and the packet loss number recorded in each entry of the port packet loss number subscription entry, and their indication index. encapsulated in the remote procedure call protocol message; 所述端口超限订阅表项对应的数据上报函数将所述业务板的本板标识、所述端口超限订阅表项的每条表项记录的端口标识和超限数及其指示索引封装在所述远程过程调用协议报文;The data reporting function corresponding to the port over-limit subscription entry encapsulates the local board identification of the service board, the port identification and over-limit number recorded in each entry of the port over-limit subscription entry, and its indication index in the the remote procedure call protocol message; 所述队列丢包数订阅表项对应的数据上报函数将所述业务板的本板标识、所述端口丢包数订阅表项的每条表项记录的端口标识、队列标识和丢包数及其指示索引封装在所述远程过程调用协议报文;The data reporting function corresponding to the queue packet loss number subscription entry sends the local board identifier of the service board, the port identifier, queue identifier and packet loss number recorded in each entry of the port packet loss number subscription entry, and the number of packets lost. It indicates that the index is encapsulated in the remote procedure call protocol message; 所述队列超限订阅表项对应的数据上报函数将所述业务板的本板标识、所述端口超限订阅表项的每条表项记录的端口标识、队列标识和超限数及其指示索引封装在所述远程过程调用协议报文。The data reporting function corresponding to the queue over-limit subscription entry reports the local board ID of the service board, the port ID, queue ID, and over-limit number and their indications recorded in each entry of the port over-limit subscription entry. The index is encapsulated in the remote procedure call protocol message. 7.一种实现远程数据采集的设备,其特征在于,所述设备应用为框式通信设备的业务板,所述业务板包括多个端口、交换单元、处理器和存储器;所述交换单元的底层驱动数据获取模块用于执行以下操作;7. A device for realizing remote data collection, wherein the device is applied as a service board of a frame-type communication device, and the service board comprises a plurality of ports, a switching unit, a processor and a memory; The underlying driver data acquisition module is used to perform the following operations; 新建远程过程调用任务;Create a new remote procedure call task; 所述远程过程调用任务在本板数据获取周期到达时,调用所述本板订阅表项对应的数据获取函数获取需写入的数据;When the data acquisition cycle of the local board arrives, the remote procedure call task calls the data acquisition function corresponding to the subscription entry of the local board to acquire the data to be written; 所述远程过程调用任务在所述数据获取函数获取到数据时,将所述数据获取函数获取到的数据写入所述本板订阅表项并设置已写入标识;When the data acquisition function acquires the data, the remote procedure call task writes the data acquired by the data acquisition function into the local board subscription entry and sets the written flag; 所述远程过程调用任务在远程采集周期到达时,调用所述本板订阅表项对应的数据上报函数且所述数据上报函数基于所述本板订阅表项的写入标识校验所述本板订阅表项已被写入,所述数据上报函数将本板标识、所述本板订阅表项的每条表项记录的已写入数据及每条表项记录的已写入数据的指示索引封装在远程过程调用协议报文,发送所述远程过程调用协议报文到采集器。When the remote procedure call task arrives in the remote collection period, the data reporting function corresponding to the subscription entry of the local board is called, and the data reporting function verifies the board based on the write identifier of the subscription entry of the local board. The subscription entry has been written, and the data reporting function indexes the board identifier, the written data recorded in each entry of the board subscription entry, and the indication index of the written data recorded in each entry. The remote procedure call protocol message is encapsulated in the remote procedure call protocol message, and the remote procedure call protocol message is sent to the collector. 8.根据权利要求7所述的设备,其特征在于,所述底层驱动数据获取模块执行的所述远程过程调用任务在所述数据获取函数未获取到数据时,不修改所述本板订阅表项的未写入标识;8. The device according to claim 7, wherein the remote procedure call task executed by the underlying driver data acquisition module does not modify the subscription table of this board when the data acquisition function does not acquire data the unwritten flag of the item; 所述底层驱动数据获取模块执行的所述远程过程调用任务在远程采集周期到达时,调用所述本板订阅表项对应的数据上报函数且所述数据上报函数基于所述本板订阅表项的未写入标识校验所述本板订阅表项未被写入,则等待下一次远程采集周期。The remote procedure call task executed by the underlying driver data acquisition module calls the data reporting function corresponding to the local board subscription entry when the remote collection period arrives, and the data reporting function is based on the data reporting function of the local board subscription entry. If the flag is not written, it is verified that the subscription entry on this board has not been written, and the next remote collection cycle is waited. 9.根据权利要求8所述的设备,其特征在于,所述处理器执行所述存储器中的处理器可执行指令用于执行以下操作;9. The apparatus of claim 8, wherein the processor executes processor-executable instructions in the memory for performing the following operations; 接收由主控板配置的所述的远程采集周期;receiving the remote collection cycle configured by the main control board; 接收由所述主控板配置的所述指示索引;receiving the indication index configured by the main control board; 接收由所述主控板配置的增加订阅表项的操作动作;receiving an operation action of adding a subscription entry configured by the main control board; 接收由所述主控板配置的所述本板订阅表项;receiving the local board subscription entry configured by the main control board; 向所述底层驱动数据同步新建所述远程过程调用任务的所述远程采集周期、所述指示索引、接收由所述主控板配置的增加订阅表项的操作动作、所述本板订阅表项。Synchronously create the remote collection cycle of the remote procedure call task, the indication index, and the operation action of adding a subscription entry configured by the main control board to the underlying driver data, and the subscription entry of the board . 10.根据权利要求9所述的设备,其特征在于,所述本板订阅表项是端口丢包数订阅表项,端口超限订阅表项,端口队列丢包数订阅表项,端口队列超限订阅表项。10. The device according to claim 9, wherein the sub-board subscription entry is a port packet loss subscription entry, a port overrun subscription entry, a port queue packet loss subscription entry, and a port queue overrun subscription entry. Limited subscription entries. 11.根据权利要求10所述的设备,其特征在于,所述端口丢包数订阅表项、端口超限订阅表项、所述端口队列丢包数订阅表项以及端口队列超限订阅表项对应于丢包数据获取参数;11. The device according to claim 10, wherein the port packet loss number subscription entry, the port overrun subscription entry, the port queue packet loss number subscription entry and the port queue overrun subscription entry Corresponding to the parameters of packet loss data acquisition; 所述远程过程调用任务调用所述丢包数据获取参数获取需写入的数据包括以执行以下操作:The remote procedure call task invoking the packet loss data acquisition parameter to acquire the data to be written includes performing the following operations: 遍历每个本板业务模块和每个本板端口;Traverse each local board service module and each local board port; 基于每个本板业务模块的标识和每个本板端口的ID识别一个虚拟输出队列索引;Identify a virtual output queue index based on the identity of each local board service module and the ID of each local board port; 轮询识别的每个虚拟输出队列索引指向的多个队列是否有丢包数和超限数;Polling whether the multiple queues pointed to by each virtual output queue index identified have the number of dropped packets and the number of overruns; 若是,基于识别的每个虚拟输出队列索引指向的多个队列的丢包数和超限数,统计识别的每个虚拟输出队列索引对应的本板端口的丢包数和超限数;If so, based on the identified packet loss and overrun counts of multiple queues pointed to by each virtual output queue index, count the packet loss and overrun count of the port on the board corresponding to each identified virtual output queue index; 将识别的每个虚拟输出队列索引对应的本板端口的端口标识及丢包数写入所述端口丢包数订阅表项;Write the port identifier and packet loss number of the port on the board corresponding to each identified virtual output queue index into the port packet loss number subscription table entry; 将识别的每个虚拟输出队列索引对应的本板端口的端口标识及超限数写入所述端口超限订阅表项;Write the port identifier and the over-limit number of the port on the board corresponding to each identified virtual output queue index into the port over-limit subscription entry; 将识别的每个虚拟输出队列索引指向的多个队列的端口标识、队列标识及丢包数写入所述端口队列丢包数订阅表项;Write the port identifiers, queue identifiers and packet loss counts of the multiple queues pointed to by each virtual output queue index identified into the port queue packet loss count subscription table entry; 将识别的每个虚拟输出队列索引指向的多个队列的端口标识、队列标识及超限数写入所述端口队列超限订阅表项。Write the port identifiers, queue identifiers and overrun numbers of multiple queues pointed to by each identified virtual output queue index into the port queue overrun subscription entry. 12.根据权利要求11所述的设备,其特征在于,所述处理器执行所述存储器中的处理器可执行指令执行所述数据上报函数将本板标识、所述本板订阅表项的每条表项记录的已写入数据及每条表项记录的已写入数据的指示索引封装在远程过程调用协议报文的操作包括:12 . The device according to claim 11 , wherein the processor executes the processor-executable instructions in the memory to execute the data reporting function to identify the local board and each of the local board subscription entries. 13 . The written data recorded in the entry and the indication index of the written data recorded in each entry are encapsulated in the remote procedure call protocol message. The operations include: 所述远程过程调用任务调用所述端口丢包数订阅表项对应的数据上报函数,将所述业务板的本板标识、所述端口丢包数订阅表项的每条表项记录的端口标识和丢包数及其指示索引封装在所述远程过程调用协议报文;The remote procedure call task invokes the data reporting function corresponding to the port packet loss number subscription entry, and sends the local board identifier of the service board and the port identifier recorded in each entry of the port packet loss number subscription entry. And the number of lost packets and its indication index are encapsulated in the remote procedure call protocol message; 所述远程过程调用任务调用所述端口超限订阅表项对应的数据上报函数,将所述业务板的本板标识、所述端口超限订阅表项的每条表项记录的端口标识和超限数及其指示索引封装在所述远程过程调用协议报文;The remote procedure call task calls the data reporting function corresponding to the port over-limit subscription entry, and sends the local board identifier of the service board, the port identifier and the over-limit port identifier recorded in each entry of the port over-limit subscription entry. The limit and its indication index are encapsulated in the remote procedure call protocol message; 所述远程过程调用任务调用所述队列丢包数订阅表项对应的数据上报函数,将所述业务板的本板标识、所述端口丢包数订阅表项的每条表项记录的端口标识、队列标识和丢包数及其指示索引封装在所述远程过程调用协议报文;The remote procedure call task invokes the data reporting function corresponding to the queue packet loss number subscription entry, and sends the local board identifier of the service board and the port identifier recorded in each entry of the port packet loss number subscription entry. , the queue identifier and the number of lost packets and their indication index are encapsulated in the remote procedure call protocol message; 所述远程过程调用任务调用所述队列超限订阅表项对应的数据上报函数,将所述业务板的本板标识、所述端口超限订阅表项的每条表项记录的端口标识、队列标识和超限数及其指示索引封装在所述远程过程调用协议报文。The remote procedure call task calls the data reporting function corresponding to the queue overrun subscription entry, and sends the local board identifier of the service board, the port identifier recorded in each entry of the port overrun subscription entry, and the queue identifier. The identifier and the overrun number and its indication index are encapsulated in the RPC message.
CN202111148641.8A 2021-09-29 2021-09-29 A method and device for realizing remote data collection Active CN113961367B (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202111148641.8A CN113961367B (en) 2021-09-29 2021-09-29 A method and device for realizing remote data collection

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202111148641.8A CN113961367B (en) 2021-09-29 2021-09-29 A method and device for realizing remote data collection

Publications (2)

Publication Number Publication Date
CN113961367A true CN113961367A (en) 2022-01-21
CN113961367B CN113961367B (en) 2025-07-04

Family

ID=79463068

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202111148641.8A Active CN113961367B (en) 2021-09-29 2021-09-29 A method and device for realizing remote data collection

Country Status (1)

Country Link
CN (1) CN113961367B (en)

Cited By (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN119376884A (en) * 2024-10-18 2025-01-28 深圳市国电科技通信有限公司 Task scheduling method, device, electronic device and storage medium

Citations (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
WO2017054518A1 (en) * 2015-09-28 2017-04-06 中兴通讯股份有限公司 Service board device resource management method and apparatus, main control board and framed device
CN111049698A (en) * 2018-10-15 2020-04-21 华为技术有限公司 A method and device for collecting telemetry data
CN111522772A (en) * 2020-04-27 2020-08-11 杭州迪普科技股份有限公司 Method and device for configuring service board
CN111597061A (en) * 2020-05-25 2020-08-28 瑞斯康达科技发展股份有限公司 Method and device for remote procedure call of client or server
CN112818195A (en) * 2019-11-15 2021-05-18 腾讯科技(深圳)有限公司 Data acquisition method, device and system and computer storage medium
CN113419881A (en) * 2021-08-23 2021-09-21 中电烽友信息技术(武汉)有限公司 Local shared memory operation method and system based on universal blackboard

Patent Citations (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
WO2017054518A1 (en) * 2015-09-28 2017-04-06 中兴通讯股份有限公司 Service board device resource management method and apparatus, main control board and framed device
CN111049698A (en) * 2018-10-15 2020-04-21 华为技术有限公司 A method and device for collecting telemetry data
CN112818195A (en) * 2019-11-15 2021-05-18 腾讯科技(深圳)有限公司 Data acquisition method, device and system and computer storage medium
CN111522772A (en) * 2020-04-27 2020-08-11 杭州迪普科技股份有限公司 Method and device for configuring service board
CN111597061A (en) * 2020-05-25 2020-08-28 瑞斯康达科技发展股份有限公司 Method and device for remote procedure call of client or server
CN113419881A (en) * 2021-08-23 2021-09-21 中电烽友信息技术(武汉)有限公司 Local shared memory operation method and system based on universal blackboard

Non-Patent Citations (2)

* Cited by examiner, † Cited by third party
Title
卢来;邓文;: "基于云平台和分布式处理技术的实验室远程监控系统", 现代电子技术, no. 14, 14 July 2020 (2020-07-14), pages 63 - 66 *
曹润泽: "基于TCP/IP的数据采集与控制系统设计", 中国优秀硕士学位论文全文数据库 信息科技辑, no. 2016, 15 April 2016 (2016-04-15), pages 140 - 308 *

Cited By (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN119376884A (en) * 2024-10-18 2025-01-28 深圳市国电科技通信有限公司 Task scheduling method, device, electronic device and storage medium
CN119376884B (en) * 2024-10-18 2026-01-09 深圳市国电科技通信有限公司 Task scheduling methods, devices, electronic equipment and storage media

Also Published As

Publication number Publication date
CN113961367B (en) 2025-07-04

Similar Documents

Publication Publication Date Title
US12395449B2 (en) Packet transmission method and apparatus
US20070140263A1 (en) Virtual machine system and method of network communication between virtual machines
US20060193318A1 (en) Method and apparatus for processing inbound and outbound quanta of data
CN115051938B (en) OPC UA-TSN transmission delay test system and method
US10142228B2 (en) Device and method for retransmitting data in a network switch
CN101887379A (en) A Wireless Channel Simulation Method Based on Virtual Network Card
CN109842868B (en) Frame aggregation and network setting frame sending method and equipment
CN110198246B (en) Method and system for monitoring flow
CN107317802A (en) A kind of generating date dissemination system based on SOA and DDS
CN105988948B (en) A kind of method and apparatus of data transmission
CN118200253A (en) RDMA UD transmission-oriented reliable communication method, electronic equipment and readable medium
CN114363269B (en) Message transmission method, system, equipment and medium
CN114979058A (en) CAN multi-mailbox multiplexing processing method and system
CN103152289A (en) Hierarchical service quality scheduling method and device
CN103297350B (en) Implementing method and switching equipment of cell switching system
CN113961367A (en) Method and equipment for realizing remote data acquisition
CN116760510B (en) Message sending method, message receiving method, device and equipment
WO2016131299A1 (en) Packet reception method and apparatus for processor network interface inside device
CN101155086A (en) Network traffic statistics method for broadband and narrowband integrated access equipment
US20050261796A1 (en) System and method for improving equipment communication in semiconductor manufacturing equipment
CN104184823B (en) A kind of method and system for automating task scheduling
CN119847967B (en) Host expansion method, device, equipment and storage medium based on RS485 bus
CN110536467B (en) ZigBee networked industrial control system communication scheduling method and coordinator thereof
CN114666285B (en) Method, system, storage medium and computing device for scheduling Ethernet transmission queue
CN113050703A (en) Flow control method and device

Legal Events

Date Code Title Description
PB01 Publication
PB01 Publication
SE01 Entry into force of request for substantive examination
SE01 Entry into force of request for substantive examination
GR01 Patent grant
GR01 Patent grant