CN104270432A - Real-time data service system and data interaction method based on drilling industry - Google Patents
Real-time data service system and data interaction method based on drilling industry Download PDFInfo
- Publication number
- CN104270432A CN104270432A CN201410486622.XA CN201410486622A CN104270432A CN 104270432 A CN104270432 A CN 104270432A CN 201410486622 A CN201410486622 A CN 201410486622A CN 104270432 A CN104270432 A CN 104270432A
- Authority
- CN
- China
- Prior art keywords
- rds
- data
- client
- server
- signal
- 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
Links
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/12—Protocols specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/90—Details of database functions independent of the retrieved data types
- G06F16/95—Retrieval from the web
- G06F16/951—Indexing; Web crawling techniques
Landscapes
- Engineering & Computer Science (AREA)
- Databases & Information Systems (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Data Mining & Analysis (AREA)
- Health & Medical Sciences (AREA)
- Computing Systems (AREA)
- General Health & Medical Sciences (AREA)
- Medical Informatics (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
The invention relates to a real-time data service system based on the drilling industry. The system comprises an RDS server and a plurality of RDS client sides, one end of each RDS client side is connected with a device related with the drilling industry, the other end of each RDS client side is connected with the RDS server through a local area network, the RDS server creates a data model used for recording the devices and device signals in a main memory database, the RDS server receives data sent by the RDS client sides, the data are stored in the main memory database of the RDS server, and when other devices require to read the data through the RDS client sides, the RDS server inquires and reads the latest data from the main memory database and sends the data to the RDS client side needing the data; the devices can subscribe needed shared data on the RDS server, when the subscribed data are changed, the RDS server pushes the latest data to the RDS client sides which subscribe the data and accordingly the corresponding devices can obtain the latest value of the data. The data service system can achieve efficient real-time communication and supports accessing of various devices, the multiple devices can share data and a guarantee is provided for long-time stable operation of the devices and safe production in the drilling industry.
Description
?
Technical field
The present invention relates to a kind of data processing and shared system and method, especially based on drilling well industry data service system and method.
Background technology
Under the application background of drilling well training, monitoring, Long-distance Control and data record, industrial quarters needs a kind of technology to make the data sharing of equipment and equipment.Equipment comprises: drilling equipment, intelligent drilling control seat, handle, PC, handheld mobile device (as smart mobile phone), panel computer (as iPad), transducer (as distance, temperature sensor), monitoring camera, relational database, real-time data base, remote web server etc.
Also have several data treatment technology in prior art, but it respectively there are pluses and minuses, briefly enumerate being described as follows:
1, Microsoft Windows Communication Foundation (WCF)
This technology can meet the requirement of real time communication, but user need design and test suitable network topology structure.And this technology cannot meet the requirement supporting many equipment.WCF only supports the windows platform pre-installing .NET, cannot support part non-Windows platform device (as iOS device).
And this technology is to the support imperfection of data sharing.Main cause is the data definition (as XML Scheme or data definition API) that this technical requirement collaborative share is preset, and resolves shared data to enable shared both sides.This requirement causes the following two kinds to limit: 1) when certain renewal of the equipment data defines, the equipment of all the other connecting systems must also redefine corresponding data form; 2) for the new equipment of the unknown, user Chang Wufa preliminary setting data form.In industrial applications, the new equipment constantly occurred makes that investor must constantly upgrade-system be to tackle new demand, and consequence is then that system upgrade is loaded down with trivial details of a high price.
2, high-performance relational database
High-performance relational database (as Oracle TimesTen, Microsoft SQLServer 2014 etc.) part solves a difficult problem for data sharing.Database, by SQL or DLL (dynamic link library), can support multiple basic data type.Utilize the data modeling of relational database, we also can solve the difficult point of shared data definition.And data can be deposited in internal memory by high-performance data storehouse temporarily, solve the problem that different clients reads at a high speed and writes.
But high-performance data storehouse does not provide equipment access support.Can distinct device access data storehouse, depends on that can the operation platform of equipment supporting database connection protocol (as ODBC agreement).Therefore, the program cannot meet the requirement supporting many equipment.
High-performance data storehouse does not solve the difficult point of real time communication yet.Real-time data communication depends on the communication mode of client and database.And high-performance data storehouse cannot after Data Update, real-time informing client gets latest data.Therefore, the Real time data share of database often completes with the form of clients poll database.This scheme unusual poor efficiency under many appointed conditions, is often the bottleneck of whole system performance, cannot meets the requirement of industry to real-time performance.
3, technical grade real-time dataBase system
Technical grade real-time data base (as OSISoft The PI system) can Real-time Collection, process, analyzes data.Similar system can meet the requirement of real time communication.The various signals of equipment can be real-time feeding system.And the real-time data base of technical grade can support that plurality of devices accesses.Such as OSISoft The PI system provides the interface of hundreds of industrial standard, to access various equipment.
But real-time data base cannot meet the requirement of many collaborative share data.Real-time data base is not supported a certain equipment to read in real time or is pushed initial data to other equipment.This is because the application location difference of real-time data base causes.The purposes of real-time data base gathers and processes Treatment Analysis to real time data, instead of Real-Time Sharing initial data.
Based on the requirement of drilling well industry to safety in production, the communication between equipment and data sharing must in real time, and efficiently, the carrying out of long-time stable, therefore in the urgent need to the data service system of a innovation.
Summary of the invention
The present invention seeks in order to overcome the deficiencies in the prior art provide a kind of efficient, in real time, support that plurality of devices accesses and is applicable to data service system and the data interactive method of drilling well industry.
For achieving the above object, the technical solution adopted in the present invention is: a kind of based on drilling well industry Real-time Data Service system, it is characterized in that: it comprises RDS server, some RDS clients, each described RDS client one end is connected with equipment involved by drilling well industry, the other end is connected with described RDS server by local area network (LAN), creating in described RDS server memory has for recording RDS system mode (i.e. equipment, device signal, and the relationship of the two) data model, described data model comprises RDS client metadata, the metadata of device data unit, the metadata of RDS client and data cell relationship description, RDS client and data cell subscribe to the metadata configured, each described RDS client has unique identity code, described RDS client and the relationship description of device data unit are multi-to-multi, namely any one RDS client can operate and subscribe to an individual data cell at the most, and any one data cell can by one to multiple RDS client operation and subscription, described RDS server receives the data that a certain RDS client sends, and data are stored in its memory database, when other RDS client-requested read data, described RDS server is inquired about and is read data last look from memory database, and these data are sent to the RDS client of needs, and equipment can subscribe on described RDS server needed for shared data, after subscribed data variation, data last look pushes to by described RDS server subscribes to the RDS client of these data.
Further, the described information such as RDS client metadata record each RDS client device title, communication mode, network state, data statistics; The information such as type, title, state, data statistics of each data cell of metadata record of described data cell; It is read or write and the how translates data formats when this RDS client reads or write this data cell to certain data cell that described RDS client and data cell relationship description comprise each RDS client; Described RDS client and data cell subscribe to each RDS client of configuration definition to the data-flow quality control law of certain data cell.
Further, described RDS client is connected from different equipment, and its communication mode is corresponding difference also.
Further, when described equipment is relational database, the connected mode of described RDS client and equipment is based on ODBC, JDBC, ADO.NET; When described equipment is OSISoft the PI system, the api interface that the connected mode of described RDS client and equipment provides for PI; When described equipment is Drilling Control system, the communication modes of described RDS client and equipment based on WinAC agreement, OPC agreement.Described RDS client and drilling equipment communication mode are not limited to the above.
Further, the transmission data acquisition signal bag of described RDS server and RDS client, each signal bag is made up of control frame and load frame.Utilize control frame, described RDS server or RDS client can transmitting terminals belonging to identification signal bag.
The present invention also provides a kind of data interactive method of the Real-time Data Service system based on drilling well industry, it comprises, and RDS client writes data to RDS server, RDS server push Data Update to relevant RDS client, RDS client subscription data, RDS client initiatively read data, RDS server and a certain RDS client coordinate both connection status;
Described RDS client writes data to RDS server step and is followed successively by: described RDS client generates data cell descriptor in this locality, described descriptor is sent to described RDS server with signal packet mode, described RDS server reads descriptor and whether has these data in querying server memory database, as without this data cell, described RDS server creates and preserves this data in memory database, simultaneously, described RDS server sends a control signal to corresponding RDS client with signal packet mode, teaching process result;
Described RDS server push Data Update is followed successively by relevant RDS client step: after writing data, the client directory of described RDS server this data cell of query subscription in memory database, if inquire one or more client, described RDS server generates data cell descriptor in this locality, and this data cell is sent to all clients of inquiring about and obtaining with signal packet mode; If do not inquire any client, RDS server terminates this task;
The step of described RDS client subscription data is followed successively by: for the one or more data cells needing to subscribe to, RDS client generates data cell descriptor one by one in this locality, and be encapsulated as the packet that pulls subscription, RDS server is sent to signal packet mode, described RDS server read data packet, revise in memory database and preserve the subscribing relationship of RDS client and data cell and send a control signal to RDS client with signal packet mode, teaching process result;
Described RDS client initiatively reads data step and is followed successively by: described RDS client generates data cell descriptor in this locality and descriptor is sent to described RDS server with signal packet mode, described RDS server reads descriptor and whether has these data in querying server memory database, as without this data cell, RDS server controls signal to client with signal packet mode transmission representative " unknown data ", as there is this data cell, this value is also sent it back corresponding RDS client with signal packet mode by RDS server read value.
Further, also comprise On-line Fault Detection, step comprises: each described RDS client regularly sends a heartbeat with signal packet mode and controls signal to described RDS server, as as described in RDS server timeout do not receive RDS client send heartbeat control signal, RDS server supposes this RDS client break link.
Further, whether described RDS server exists this client-side information according in heartbeat control signal audit memory database, and if any this client-side information, RDS server transmits control signal response to RDS client with signal packet mode; As do not inquired this client, start RDS client identity identification step, as RDS client timeout does not receive the response signal of service end, the supposition of RDS client disconnects with RDS service end.
Further, the form that different RDS clients describes same data is different, and described RDS server is changed the form self adaptation of same data to ensure that distinct device obtains correct form.
Further, to each data cell, described RDS client can arrange the traffic control rule received when data cell upgrades.
Further, when described RDS client first connection is to RDS service end, or the off-line of RDS client timeout or RDS client and RDS service end are made mistakes in identification procedure, and described RDS service end requires again to identify RDS client
Because technique scheme is used, the present invention compared with prior art has following advantages: device clients, device data and device clients and device data relation therebetween can be inquired about and preserve to the data model in RDS server by utilizing internal memory of the present invention efficiently, guarantees the correct and swap data efficiently of distinct device.Utilization state management conversion, RDS server and client can coordinate connection status, guarantee long-time stable swap data.RDS server receives the data that RDS client sends, and data is stored in server memory database, and storage speed is fast, reaches the object of zero access data.When client-requested reads data, RDS server reads data last look from memory database, and these data are sent to client.Utilize the subscription function of RDS server, after subscribed data variation, data last look can be pushed to the client of subscribing to these data by RDS server, makes equipment can obtain the renewal of desired data in real time.The present invention supports that plurality of devices accesses, and realizes real-time many device datas and shares, thus meets the safe and highly efficient operation requirement of drilling well industry to equipment.
Accompanying drawing explanation
Accompanying drawing 1 is for the present invention is based on drilling well industry Real-time Data Service system architecture diagram;
Accompanying drawing 2 is RDS server memory metadata schema figure of the present invention;
Accompanying drawing 3 is RDS server and client side of the present invention state diagram.
Embodiment
Specifically implement to further illustrate to the present invention below in conjunction with accompanying drawing:
As shown in Figure 1, RDS system is made up of two class components: RDS server and some RDS clients.Each RDS client's side link one equipment, comprise drilling equipment, intelligent drilling controls seat, handle, PC, handheld mobile device (as smart mobile phone), panel computer (as iPad), transducer (as distance, temperature sensor), monitoring camera, relational database, real-time data base, remote web server etc.Each RDS client is connected to RDS server by local area network (LAN).
RDS client provides DLL (dynamic link library) (Application Programming Interface), to support Windows, and the platforms such as iOS, Linux.
For different equipment, the communication modes of RDS client's side link equipment has difference.As the relational database that equipment is common, the connected mode of RDS client and equipment may based on ODBC, JDBC, ADO.NET etc.If equipment is OSISoft the PI system, the api interface that the connected mode of RDS client and equipment provides for PI.If equipment is drilling equipment, the communication modes of RDS client and equipment may based on WinAC agreement, OPC agreement etc.
RDS server memory has metadata schema, and as shown in Figure 2, it comprises:
1) RDSClient---RDS client metadata.Its record client device title, communication mode (as IP address, port etc.), network state, data statistics etc.;
2) metadata of Variable---data cell.It describes this data unit type, title, state, data statistics etc.;
3) Contributing---the relationship description of RDS client and data cell.Comprise and describe RDS client to the action type of certain data, read or write; How translates data formats when RDS client reads or writes certain data cell.
4) subscription of Subscribing---RDS client and data cell configures.This defines the rule that data-flow quality controls.
Wherein, RDS client (RDS Client) comprises further with the relationship description of data cell (Variable):
When initiatively reading or writing (being described by Contributing).The pass of RDS client and data cell is multi-to-multi.Namely any one client can operate an individual data cell at the most, and any one data cell can by one to multiple RDS client operation;
When passive propelling movement upgrades (being described by Subscribing).The pass of RDS client and data cell is multi-to-multi.Namely any one client can subscribe to an individual data cell at the most, and any one data cell can be pushed to one to multiple RDS client.
In the present invention, server and client use signal bag to exchange.Each RDS signal bag is made up of two frames: control frame and load frame.
Control frame encapsulation client server identity code and RDS control signal, to describe the purposes of this signal bag.Control frame is a byte.
According to different control frames, load frame can encapsulate corresponding data.Such as: when control frame is ReplyPortSubscribe, load frame encapsulates the data describing RDS client data port and IP address.Load frame byte number is minimum is 0, is the byte number of load to the maximum.Have part control signal (as Heartbeat) not carry payload data, therefore the byte number of load is 0.
Meanwhile, in server memory data model, system needs can identify RDS client identity accurately.Each RDS client has unique identity code (ID).
Above Real-time Data Service system architecture of the present invention is illustrated, below the method for its data interaction is introduced further: (one) RDS client writes data to RDS server
Step 1:RDS client generates data cell (Variable) descriptor in this locality, comprising: title, type, value;
The descriptor of step 1 is sent to RDS server with signal packet mode by step 2:RDS client;
Step 3:RDS server reads descriptor, whether has these data in querying server memory database.As without this data cell, RDS server creates Data Data in memory database;
Step 4:RDS server preserves these data in memory database;
Step 5:RDS server sends a control signal to RDS client with signal packet mode, teaching process result.
(2) RDS server push Data Update is to relevant RDS client
After propelling movement renewal only can occur in and write data.
The client directory of step 6:RDS server this data cell of query subscription (Variable) in memory database.This data cell is provided by RDS client in step 1;
Step 7a: as inquired one or more client in step 6, RDS server generates data cell (Variable) descriptor in this locality, comprising: title, type, value.And this data cell is sent in step 6 all clients of inquiring about and obtaining with signal packet mode;
Step 7b: as do not inquired any client in step 6, RDS server terminates this task.
(3) RDS client subscription data
Step 1: for the one or more data cells (Variable) needing to subscribe to, RDS client for they generate data cell (Variable) descriptor one by one, comprises title in this locality;
Some description compositions list that step 2:RDS client will generate in step 1, and be encapsulated as the packet that pulls subscription;
Packet in step 3 is sent to RDS server with signal packet mode by step 3:RDS client;
Step 4:RDS server read data packet, revises and preserves the subscribing relationship of RDS client and data cell in memory database;
Step 5:RDS server sends a control signal to RDS client with signal packet mode, teaching process result.
(4) RDS client initiatively reads data
Step 1:RDS client generates data cell (Variable) descriptor in this locality, only include title;
The descriptor of step 1 is sent to RDS server with signal packet mode by step 2:RDS client
Step 3a:RDS server reads descriptor, whether has these data in audit memory database.As without this data cell, what RDS server sent representative " unknown data " with signal packet mode controls signal to client;
Step 3b:RDS server reads descriptor, whether has these data in audit memory database.As there is this data cell, RDS server reads data value, and data value is sent to client with signal packet mode.
In DRILLING APPLICATION, accurately online state contributes to improving operating personnel to the safe handling of equipment.Such as, in drilling process, pressure sensor possibility off-line also causes system senses pressure unchanged, and this situation needs to notify that this off-line fault of operating personnel is with the blowout avoiding hypertonia to cause in time.Therefore, the present invention also comprises RDS client with fixed intervals transmission heartbeat signal to detect online situation.Concrete steps are as follows:
Step 1:RDS client sends Heartbeat with signal packet mode and controls signal to RDS server;
This client-side information whether is there is in step 2:RDS server lookup memory database;
Step 3a: according to step 2 result.As inquired this client-side information, RDS server to transmit control signal response with signal packet mode;
Step 3b: according to step 2 result, inquires this client as failed, RDS server sends corresponding control signal to client terminal start-up RDS client identity identification step with signal packet mode;
As step 1 time-out is not activated, RDS server supposes that this client's side link disconnects.
As after step 1, RDS client timeout does not receive the response signal of service end, and RDS client will suppose to be connected with service end to disconnect.
When arbitrary situation during RDS client first connection to service end or client timeout off-line or client and service end is made mistakes in identification procedure, RDS service end can require identify customer end again.
Above-mentioned RDS server and mutual each process steps of RDS client to be illustrated, in these processes, can there is respective change in the connection status of RDS server and RDS client, the change of these states realizes according to current status and RDS control signal; By the transformation of connection status, RDS server and RDS client can understand partner state information, as RDS client state (as online or off-line), RDS server and this RDS client current connection state, network state etc., facilitate RDS server to flow control.Such as, when RDS client off-line, latest data can not be pushed to this client by RDS server, to save system resource and Internet resources.
For ensureing long-time steady operation, RDS server and RDS client need coordinate connection status.The connection status for RDS server and a RDS client shown in Fig. 3 how to change according to current state and control signal.Circled numbers represents the state at RDS server and this client place, on blue haircut line, instruction is the control signal that RDS server is sent to RDS client, instruction on black haircut line is the control signal that RDS client is sent to RDS server, and concrete control signal comprises:
Heartbeat: heartbeat signal; Who: request RDS client metadata signal; ReplyClientMeta:RDS client metadata response signal; RequestPortSubscribe: pull subscription data ports signal; ReplyPortSubscribe: subscription data port responses signal; AccessVariable: request is initiatively read or write data unit signal; Subscribe: the Data Update that pulls subscription signal; OK: successful operation.
If RDS system is when state 4, RDS client initiatively can only read the real-time update that data cannot obtain data.RDS system is when state 9, and RDS client initiatively can read data, also can upgrade by passive acquisition data-pushing.When free position, the time as corresponding in control signal is greater than TTL(Time To Live) value, system mode becomes state of termination, and namely system postulation RDS client cannot be connected with RDS server.
Real-time Data Service system of the present invention, achieves following technique effect:
1, many device datas are shared
A, multiple equipment can read or upgrade same data.Such as: when drilling well modeling, multiple program module needs to change same parameter.This parameter can be read by control system again;
B, when Data Update, many equipment can select obtain real-time update.Such as: in drilling platforms environment, engineer can install multiple sensors (as range sensor, temperature-sensitive detection is first-class).During the Data Update of transducer, system needs to send up-to-date data to relevant device.Such as, when range sensor detects equipment room apart from change, these up-to-date " distance " data need to be real-time transmitted to relevant device to ensure equipment collisionless, guarantee that oil security is produced; Further, renewal can not be obtained to " distance " data without the equipment of reading requirement.
The data format that c, distinct device are supported is different.Under the prerequisite not affecting existing system cloud gray model, the data format of new equipment can be supported.
2, plurality of devices access is supported
The operation platform of a, distinct device is different, and system can provide multi-platform support;
B, distinct device utilize the corresponding interface, connecting system.
3, efficient real time communication
A, equipment access or parting system, can not affect existing equipment communication and operation;
B, system share the overall average response time of data not higher than 10 milliseconds.This time is that an equipment utilization RDS client sends data to RDS server, and RDS server by this data retransmission to the total time interval of another equipment.
Above-described embodiment, only for technical conceive of the present invention and feature are described, its object is to person skilled in the art can be understood content of the present invention and implement according to this, can not limit the scope of the invention with this.All equivalences done according to Spirit Essence of the present invention change or modify, and all should be encompassed within protection scope of the present invention.
Claims (10)
1. one kind based on drilling well industry Real-time Data Service system, it is characterized in that: it comprises RDS server, some RDS clients, each described RDS client one end is connected with equipment involved by drilling well industry, the other end is connected with described RDS server by local area network (LAN), the data model of RDS system mode is created with management equipment and device signal in described RDS server memory database, described data model comprises: RDS client metadata, the metadata of device data unit, the metadata of RDS client and data cell relationship description, RDS client and data cell subscribe to the metadata configured, described metadata relationship model comprises: the relationship description of RDS client and device data unit is multi-to-multi, namely any one RDS client can operate/subscribe to an individual data cell at the most, and any one data cell can by one to multiple RDS client operation/subscription, described RDS server receives the data that a certain RDS client sends, and by data storing in internal memory, when other RDS client-requested read data, described RDS server is inquired about and is read data last look from memory database, and these data are sent to the RDS client of needs, and equipment can subscribe on described RDS server needed for shared data, after subscribed data variation, data last look pushes to by described RDS server subscribes to the RDS client of these data, makes relevant device obtain this last look.
2. according to claim 1 based on drilling well industry Real-time Data Service system, it is characterized in that: described RDS client metadata records the information such as each RDS client device title, communication mode, network state, data statistics; The metadata record of described data cell has the information such as type, title, state, data statistics of each data cell; It is read or write and the how translates data formats when this RDS client reads or write this data cell that described RDS client and data cell relationship description comprise each RDS client operation to certain data cell; Described RDS client and data cell are subscribed to each RDS client of configuration definition and how to be controlled certain data cell maintenance data current mass.
3. according to claim 1 based on drilling well industry Real-time Data Service system, it is characterized in that: described RDS client is connected from different equipment, and its communication mode is corresponding difference also.
4. according to claim 3 based on drilling well industry Real-time Data Service system, it is characterized in that: when described equipment is relational database, the connected mode of described RDS client and equipment is based on ODBC, JDBC, ADO.NET; When described equipment is OSISoft the PI system, the api interface that the connected mode of described RDS client and equipment provides for PI; When described equipment is Drilling Control system, the communication modes of described RDS client and equipment based on WinAC agreement, OPC agreement.
5. according to claim 1 based on drilling well industry Real-time Data Service system, it is characterized in that: the transmission data acquisition signal bag of described RDS server and RDS client, each signal bag is made up of control frame and load frame, according to control frame, and transmitting terminal belonging to this signal bag of identifiable design.
6., according to the method for any one described in claim 1 to 5 based on data interaction in drilling well industry Real-time Data Service system, it comprises, and RDS client writes data to RDS server, RDS server push Data Update initiatively reads data to relevant RDS client, RDS client subscription data, RDS client;
Described RDS client writes data to RDS server step and is followed successively by: described RDS client generates data cell descriptor in this locality, described descriptor is sent to described RDS server with signal packet mode, described RDS server reads descriptor and whether has this data cell in querying server memory database, as without this data cell, described RDS server creates and preserves this data cell in internal memory, simultaneously, described RDS server sends a control signal to corresponding RDS client with signal packet mode, teaching process result;
Described RDS server push Data Update is followed successively by relevant RDS client step: after writing data, the client directory of this data cell is subscribed in described RDS server lookup, if inquire one or more client, described RDS server generates data cell descriptor in this locality, and this data cell is sent to all clients of inquiring about and obtaining with signal packet mode; If do not inquire any client, RDS server terminates this task;
The step of described RDS client subscription data is followed successively by: for the one or more data cells needing to subscribe to, RDS client generates data cell descriptor one by one in this locality, and be encapsulated as and pull subscription packet and send to RDS server with signal packet mode, described RDS server read data packet, revise in memory database and preserve the subscribing relationship of RDS client and data cell and send a control signal to RDS client with signal packet mode, teaching process result;
Described RDS client initiatively reads data step and is followed successively by: described RDS client generates data cell descriptor in this locality and descriptor is sent to described RDS server with signal packet mode, described RDS server reads descriptor and whether has these data in querying server memory database, as without this data cell, RDS server controls signal to client with signal packet mode transmission representative " unknown data ", as there is this data cell, data value is also sent it back corresponding RDS client with signal packet mode by RDS server read value.
7. the method for data interaction in Real-time Data Service system according to claim 6, it is characterized in that: also comprise On-line Fault Detection, step comprises: each described RDS client regularly sends a heartbeat with signal packet mode and controls signal to described RDS server, if described RDS server timeout does not receive the heartbeat control signal of certain RDS client, RDS server supposes that this RDS client disconnects; If described RDS server receives certain RDS client heartbeat signal, then whether RDS server exists this client-side information according in this control signal audit memory database, as do not inquired this client, RDS startup of server RDS client identity identification step, as there is this client, RDS server transmits control signal response to this client; As RDS client timeout does not receive the response signal of service end, the supposition of RDS client disconnects with RDS service end.
8. the method based on data interaction in drilling well industry Real-time Data Service system according to claim 5, it is characterized in that: the form that different RDS clients describes same data is different, and described RDS server is changed the form self adaptation of same data to ensure that distinct device obtains correct form.
9. the method based on data interaction in drilling well industry Real-time Data Service system according to claim 5, is characterized in that: described RDS client arranges traffic control rule when receiving Data Update to each data.
10. the method based on data interaction in drilling well industry Real-time Data Service system according to claim 5, it is characterized in that: when described RDS client first connection is made mistakes in identification procedure to RDS service end or the off-line of RDS client timeout or RDS client and RDS service end, described RDS service end requires again to identify RDS client.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201410486622.XA CN104270432B (en) | 2014-09-22 | 2014-09-22 | Based on drilling well industry Real-time Data Service system and data interactive method |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201410486622.XA CN104270432B (en) | 2014-09-22 | 2014-09-22 | Based on drilling well industry Real-time Data Service system and data interactive method |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN104270432A true CN104270432A (en) | 2015-01-07 |
| CN104270432B CN104270432B (en) | 2018-07-17 |
Family
ID=52161921
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201410486622.XA Expired - Fee Related CN104270432B (en) | 2014-09-22 | 2014-09-22 | Based on drilling well industry Real-time Data Service system and data interactive method |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN104270432B (en) |
Cited By (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN105956006A (en) * | 2016-04-21 | 2016-09-21 | 贵州电网有限责任公司信息中心 | Structured query system for key value pair data storage |
| CN106156277A (en) * | 2016-06-24 | 2016-11-23 | 乐视控股（北京）有限公司 | For third-party data sharing update method and system |
| CN106294486A (en) * | 2015-06-04 | 2017-01-04 | 交通银行股份有限公司 | The processing method of finance market data and system |
| CN107294951A (en) * | 2017-05-04 | 2017-10-24 | 宁波伟立机器人科技股份有限公司 | robot industry management system data transmission method based on cloud service |
Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101616007A (en) * | 2008-06-24 | 2009-12-30 | 华为技术有限公司 | Implementation method, system and equipment of a MAP server |
| CN102253980A (en) * | 2011-06-23 | 2011-11-23 | 上海西本网络科技有限公司 | Data processing method and data processing system |
| CN102637137A (en) * | 2010-12-21 | 2012-08-15 | 微软公司 | Policy-based application delivery |
| CN103401837A (en) * | 2013-07-01 | 2013-11-20 | 北京科东电力控制系统有限责任公司 | Real-time data pushing method for SCADA (supervisory control and data acquisition) system |
-
2014
- 2014-09-22 CN CN201410486622.XA patent/CN104270432B/en not_active Expired - Fee Related
Patent Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101616007A (en) * | 2008-06-24 | 2009-12-30 | 华为技术有限公司 | Implementation method, system and equipment of a MAP server |
| CN102637137A (en) * | 2010-12-21 | 2012-08-15 | 微软公司 | Policy-based application delivery |
| CN102253980A (en) * | 2011-06-23 | 2011-11-23 | 上海西本网络科技有限公司 | Data processing method and data processing system |
| CN103401837A (en) * | 2013-07-01 | 2013-11-20 | 北京科东电力控制系统有限责任公司 | Real-time data pushing method for SCADA (supervisory control and data acquisition) system |
Non-Patent Citations (10)
| Title |
|---|
| 冯超英，郭建辉，罗鑫，等: "井场数据中心构建与应用", 《录井工程》 * |
| 刘文龙，陈园园: "石油测井多源数据管理平台设计与系统实现", 《测绘》 * |
| 帅训波: "基于元数据的油气信息管理系统", 《计算机系统应用》 * |
| 戴永寿，张欣欣，于云华，李立刚: "钻井井场信息共享系统的设计与研究", 《钻井工程》 * |
| 景宁，樊洪海，翟应虎，刘德智: "面向钻井工程的数据仓库解决方案研究", 《信息网络安全》 * |
| 朱正平，潘仁芳，马杰，李功权，等: "中国石油勘探开发信息化系统架构的优化方案及解决措施_以大港油田为例", 《东北石油大学学报》 * |
| 王魁生，查礼，屈展: "基于实时数据的钻井作业指导系统", 《计算机工程》 * |
| 虞海江，马建刚，叶丹，李建峰: "基于发布订阅模式的数据集成中间件系统设计实现", 《计算机系统应用》 * |
| 邹野: "钻井信息化管理设计与实现", 《大庆石油学院硕士研究生学位论文》 * |
| 高晓荣: "钻井井场信息系统的开发与应用研究", 《内蒙古石油化工》 * |
Cited By (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN106294486A (en) * | 2015-06-04 | 2017-01-04 | 交通银行股份有限公司 | The processing method of finance market data and system |
| CN106294486B (en) * | 2015-06-04 | 2020-06-05 | 交通银行股份有限公司 | Financial market data processing method and system |
| CN105956006A (en) * | 2016-04-21 | 2016-09-21 | 贵州电网有限责任公司信息中心 | Structured query system for key value pair data storage |
| CN106156277A (en) * | 2016-06-24 | 2016-11-23 | 乐视控股（北京）有限公司 | For third-party data sharing update method and system |
| CN107294951A (en) * | 2017-05-04 | 2017-10-24 | 宁波伟立机器人科技股份有限公司 | robot industry management system data transmission method based on cloud service |
Also Published As
| Publication number | Publication date |
|---|---|
| CN104270432B (en) | 2018-07-17 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| Hejazi et al. | Survey of platforms for massive IoT | |
| CN109889551B (en) | Method for accessing intelligent hardware to Internet of things cloud platform | |
| US9781189B2 (en) | Managed device-to-device communication in business computing systems | |
| CN110430260B (en) | Robot cloud platform based on big data cloud computing support and working method | |
| CN110933146B (en) | Data conversion method and device and server | |
| CN104660682A (en) | OPC data acquisition and monitoring intelligent terminal based on TD-LTE | |
| CN103297306B (en) | A kind of agriculture Internet of things system | |
| CN104639654A (en) | Integrated access system and integrated access method for mass electricity information acquisition terminals | |
| CN111638690B (en) | Data acquisition method, device, system and equipment based on general information model | |
| CN110995859A (en) | Intelligent transformer substation supporting platform system based on ubiquitous Internet of things | |
| CN112688997B (en) | RPA robot-based universal data acquisition and management method and system | |
| CN204598011U (en) | A kind of OPC data acquisition and monitoring intelligent terminal based on TD-LTE | |
| KR102345082B1 (en) | Cloud based iec61850 information processing method | |
| WO2023000726A1 (en) | Device reverse integration access method, device reverse integration management method and system, and computer device | |
| WO2021114816A1 (en) | Method and device for message processing based on robot operating system, and computer device | |
| CN109921986A (en) | A kind of multi-protocol data cut-in method, device, intelligent gateway and storage medium | |
| KR20190106368A (en) | Distributed data acquisition and distributed control command system for factory automation, and Distributed data collection and distributed control method for the same | |
| CN103167275A (en) | Network video monitoring system and steaming media data distribution method thereof | |
| CN104270432A (en) | Real-time data service system and data interaction method based on drilling industry | |
| CN106452922A (en) | Data center processing method applied to Internet of things | |
| CN103970530A (en) | Data acquisition and implementation method based on Intouch configuration technology of OPC interface | |
| CN105592164A (en) | Distributed system and method for data processing | |
| CN104202389A (en) | Monitoring method for storage space and running state in cloud environment and cloud storage system | |
| CN110398985B (en) | Distributed self-adaptive unmanned aerial vehicle measurement and control system and method | |
| CN114827293B (en) | Edge intelligent gateway management method and edge intelligent gateway |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| C06 | Publication | ||
| PB01 | Publication | ||
| C10 | Entry into substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant | ||
| CF01 | Termination of patent right due to non-payment of annual fee |
Granted publication date: 20180717 |
|
| CF01 | Termination of patent right due to non-payment of annual fee |