CN109889558A - Data transmission method, middleware and the system of internet of things oriented application - Google Patents
Data transmission method, middleware and the system of internet of things oriented application Download PDFInfo
- Publication number
- CN109889558A CN109889558A CN201711279406.8A CN201711279406A CN109889558A CN 109889558 A CN109889558 A CN 109889558A CN 201711279406 A CN201711279406 A CN 201711279406A CN 109889558 A CN109889558 A CN 109889558A
- Authority
- CN
- China
- Prior art keywords
- data
- application
- internet
- things
- instruction
- 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.)
- Pending
Links
- 230000005540 biological transmission Effects 0.000 title claims abstract description 86
- 238000000034 method Methods 0.000 title claims abstract description 34
- 238000013523 data management Methods 0.000 claims description 17
- 238000004891 communication Methods 0.000 claims description 11
- 230000004044 response Effects 0.000 claims description 10
- 238000004458 analytical method Methods 0.000 claims description 8
- 238000013480 data collection Methods 0.000 claims description 7
- 230000000977 initiatory effect Effects 0.000 claims description 3
- 238000004590 computer program Methods 0.000 description 12
- 230000006870 function Effects 0.000 description 12
- 230000008569 process Effects 0.000 description 4
- 238000010586 diagram Methods 0.000 description 3
- 238000007726 management method Methods 0.000 description 3
- 238000012545 processing Methods 0.000 description 3
- 239000008186 active pharmaceutical agent Substances 0.000 description 2
- 238000006243 chemical reaction Methods 0.000 description 2
- 238000001514 detection method Methods 0.000 description 2
- 230000004927 fusion Effects 0.000 description 2
- 230000003993 interaction Effects 0.000 description 2
- 230000008447 perception Effects 0.000 description 2
- 238000012795 verification Methods 0.000 description 2
- 238000013459 approach Methods 0.000 description 1
- 230000009286 beneficial effect Effects 0.000 description 1
- 230000001413 cellular effect Effects 0.000 description 1
- 239000012141 concentrate Substances 0.000 description 1
- 238000007405 data analysis Methods 0.000 description 1
- 238000013500 data storage Methods 0.000 description 1
- 238000011161 development Methods 0.000 description 1
- 230000000694 effects Effects 0.000 description 1
- 238000012482 interaction analysis Methods 0.000 description 1
- 230000002452 interceptive effect Effects 0.000 description 1
- 238000012423 maintenance Methods 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 238000012544 monitoring process Methods 0.000 description 1
- 230000003287 optical effect Effects 0.000 description 1
- 239000007787 solid Substances 0.000 description 1
- 239000002699 waste material Substances 0.000 description 1
Landscapes
- Computer And Data Communications (AREA)
Abstract
The invention discloses a kind of data transmission methods of internet of things oriented application, the following steps are included: receiving the request of data from application layer, the request of data is parsed, generate the instruction for meeting predetermined specifications, described instruction is executed to obtain data corresponding with described instruction, the data are back to the application layer.The present invention also provides the data transmission middlewares and system of a kind of application of internet of things oriented, and each resource, component or equipment are connected in same Internet of Things by general things-internet gateway, realize the cooperation of resource and data and share.
Description
Technical Field
The invention relates to the technical field of Internet of things, in particular to a data transmission method, middleware and system for Internet of things application.
Background
The internet of things (IoT) refers to a huge network formed by combining various information sensing devices, such as radio frequency identification devices, infrared sensors, global positioning systems, laser scanners, and the like, with the internet.
In the process of implementing the invention, the inventor finds that at least the following problems exist in the prior art:
at present, data interactive transmission can be performed between each device, but different devices, users' terminals, resources, other systems or components, which are used by the users, are independent from each other, and the process and operation for acquiring data between different types of individuals are extremely complicated, which consumes a large amount of time cost, but the acquiring effect is often poor.
In order to better meet the development requirements of the internet of things era, application program developers add internet of things functions into their own software, so that the functions of equipment connection, data storage, state management and the like are all consistent, and the methods and strategies of the developers are different, so that many functions are repeatedly developed, which causes great waste of social resources.
Disclosure of Invention
In view of the above problems, an object of the present invention is to provide a data transmission method, middleware, and system for internet of things application, in which resources, components, or devices are connected to the same internet of things through a general internet of things gateway, so as to implement cooperation and sharing of resources and data.
The embodiment of the invention provides a data transmission method for application of the Internet of things, which comprises the following steps:
receiving a data request from an application layer;
analyzing the data request to generate an instruction meeting a preset specification;
executing the instruction to obtain data corresponding to the instruction;
returning the data to the application layer.
Preferably, the executing the instruction to obtain the data corresponding to the instruction specifically includes:
executing the instruction to obtain data corresponding to the instruction from a network layer, and writing the data into a database; or
The instructions are executed to retrieve historical data corresponding to the instructions from a database.
Preferably, the method further comprises the following steps:
receiving data collected by the Internet of things equipment transmitted by a network layer through a uniform data management interface, and storing the data in a database in a distributed manner; the data management interface is compatible with ODBC and OLEDB interfaces.
Preferably, the data collected by the internet of things device transmitted by the network layer is received through the unified data management interface, and the data is stored in the database in a distributed manner, specifically:
sending a data stream starting instruction to the Internet of things equipment of the sensing layer through the network layer; the data flow starting instruction comprises a duplex data flow starting instruction and a half-duplex data flow starting instruction;
and collecting data transmitted by the Internet of things equipment of the sensing layer through a network layer according to the data stream starting instruction, and storing the data in a database in a distributed manner.
Preferably, the application layer comprises at least one work domain;
the work domain comprises at least one application object of the same type;
the application object at least comprises any one or more of intelligent equipment, devices, personal user terminals or office systems;
and communication is established between the application objects of the same working domain so as to realize information sharing.
Preferably, the method further comprises the following steps:
when detecting the creation operation of a working domain in an application layer, sending an instruction request to the newly-built working domain; the instruction request is used for triggering the newly-built working domain to send a response data packet, the instruction request comprises active connection and passive connection, and the working domain at least comprises any one or more of working domain ID, type, supported protocol and protocol parameters, session ID and session parameters;
and establishing the self connection of the newly-built working domain according to the response data packet and keeping the session.
Preferably, the method further comprises the following steps: and when a termination request from the working domain of the application layer is detected, deleting the session between the working domain and the self according to the termination request.
The embodiment of the invention also provides data transmission middleware for application of the Internet of things, which comprises the following components:
a request receiving unit for receiving a data request from an application layer;
the request analysis unit is used for analyzing the data request and generating an instruction which accords with a preset standard;
a request execution unit for executing the instruction to obtain data corresponding to the instruction;
and the request result returning unit is used for returning the data to the application layer.
Preferably, the request execution unit specifically includes:
executing the instruction to obtain data corresponding to the instruction from a network layer, and writing the data into a database; or
The instructions are executed to retrieve historical data corresponding to the instructions from a database.
Preferably, the method further comprises the following steps:
the data collection unit is used for receiving data collected by the Internet of things equipment transmitted by a network layer through a uniform data management interface and storing the data in a database in a distributed manner; the data management interface is compatible with ODBC and OLEDB interfaces.
Preferably, the data collection unit specifically includes:
the collecting instruction sending module is used for sending a data stream starting instruction to the Internet of things equipment of the sensing layer through the network layer; the data flow starting instruction comprises a duplex data flow starting instruction and a half-duplex data flow starting instruction;
and the data collection module is used for collecting data transmitted by the Internet of things equipment of the sensing layer through a network layer according to the data stream starting instruction and storing the data in a database in a distributed manner.
Preferably, the application layer comprises at least one work domain;
the work domain comprises at least one application object of the same type;
the application object at least comprises any one or more of intelligent equipment, devices, personal user terminals or office systems;
and communication is established between the application objects of the same working domain so as to realize information sharing.
Preferably, the method further comprises the following steps:
the detection unit is used for sending an instruction request to a newly-built working domain when the working domain creating operation in the application layer is detected; the instruction request is used for triggering the newly-built working domain to send a response data packet, the instruction request comprises active connection and passive connection, and the working domain at least comprises any one or more of working domain ID, type, supported protocol and protocol parameters, session ID and session parameters;
and the session establishing unit is used for establishing the connection between the newly-built working domain and the session establishing unit according to the response data packet and maintaining the session.
Preferably, the method further comprises the following steps: and the termination unit is used for deleting the session between the working domain and the self according to the termination request when the termination request from the working domain of the application layer is detected.
The embodiment of the invention also provides a data transmission system for the application of the Internet of things, which comprises an application layer and the data transmission middleware for the application of the Internet of things; wherein,
the application layer is used for initiating a data request to the data transmission middleware for the application of the Internet of things;
the data transmission middleware for the application of the Internet of things is used for receiving a data request from an application layer; analyzing the data request to generate an instruction meeting a preset specification; executing the instruction to obtain data corresponding to the instruction; returning the data to the application layer;
and the application layer is also used for receiving the data returned according to the data request.
The embodiment of the invention provides a data transmission method, middleware and system for application of the Internet of things, and has the following beneficial effects:
the embodiment of the invention receives a data request from an application layer, analyzes the data request to generate an instruction meeting a preset specification, then executes the instruction to acquire data corresponding to the instruction, and finally returns the data to the application layer. According to the embodiment of the invention, various resources, components, application systems or equipment are connected to the Internet of things through the general Internet of things gateway, so that the fusion and sharing of the resources and the data are realized, the complicated operation steps of acquiring data by different types of applications or equipment across fields are reduced, the corresponding data or required equipment can be conveniently and quickly acquired through the general Internet of things gateway, the resources are comprehensively utilized, and the time cost is reduced.
Drawings
In order to more clearly illustrate the technical solution of the present invention, the drawings needed to be used in the embodiments will be briefly described below, and it is obvious that the drawings in the following description are only some embodiments of the present invention, and it is obvious for those skilled in the art that other drawings can be obtained according to the drawings without creative efforts.
Fig. 1 is a schematic flow chart of a data transmission method for internet of things application according to a first embodiment of the present invention.
Fig. 2 is a schematic structural diagram of data transmission middleware for an application of the internet of things according to a fourth embodiment of the present invention.
Fig. 3 is a schematic diagram of a data transmission system for an application of the internet of things according to a fifth embodiment of the present invention.
Detailed Description
The technical solutions in the embodiments of the present invention will be clearly and completely described below with reference to the drawings in the embodiments of the present invention, and it is obvious that the described embodiments are only a part of the embodiments of the present invention, and not all of the embodiments. All other embodiments, which can be derived by a person skilled in the art from the embodiments given herein without making any creative effort, shall fall within the protection scope of the present invention.
The embodiment of the invention provides a data transmission method, a middleware and a system for application of the Internet of things. Each of which is described in detail below.
Referring to fig. 1, a first embodiment of the present invention provides a data transmission method for an application in the internet of things, which is executed by data transmission middleware for an application in the application service layer, and includes the following steps:
s11, receiving a data request from the application layer.
In the embodiment of the present invention, please refer to fig. 3, which is a schematic diagram of a system architecture of a data transmission system for internet of things application. And dividing the transmission process of the Internet of things into three-layer architecture of an application layer, a network layer and a sensing layer, wherein the data transmission middleware for the application of the Internet of things is positioned between the application layer and the network layer.
In an embodiment of the present invention, the application layer comprises at least one work domain; the work domain comprises at least one application object of the same type; the application object at least comprises any one or more of a smart device, a personal user terminal or an office system, namely the application object comprises a personal user terminal such as a mobile terminal, a system such as an ERP system, a mobile terminal, a PDM system or a CRM system, a regional object such as a smart park and the like; and communication is established between the application objects of the same working domain so as to realize information sharing. When the application object is to be added into the internet of things to realize data sharing, firstly, a working domain with the same type attribute is searched for and added into the internet of things, if the application object is not to be added into the internet of things, a working domain is created and added into the internet of things, each working domain is positioned on an application layer of the internet of things, one working domain corresponds to a group of application objects with safety boundary requirements, the type attributes of each application object in the working domain are the same, for example, the application objects belonging to an APP end of a mobile phone end are concentrated in the same working domain, the objects in the working domains are interconnected and communicated and share information, the working domains and the working domains are mutually isolated in an application pool mode and independently maintain respective life periods, when the data transmission middleware for the application of the internet of things detects the creation operation of the working domain in the application layer, an instruction request is sent to the newly-built working domain, and the instruction request is used for triggering the newly built working domain to, the instruction request comprises active connection and passive connection, the active connection means that the data transmission middleware for the application of the internet of things actively applies for a connection to a working domain, establishes handshake and maintains a session, and the passive connection means that the data transmission middleware for the application of the internet of things establishes a connection channel on the data transmission middleware for the application of the internet of things, starts a servo service and maintains the session for the equipment of the broadcast type internet of things, and then the data transmission middleware for the application of the internet of things establishes the connection between the newly-established working domain and the data transmission middleware according to the response data packet and maintains the session so as to support the data exchange between the working domain and the data transmission middleware through the session. It should be noted that, in the embodiment of the present invention, any actual application information is always transmitted between the communication devices along with some control information, which works according to a predetermined communication protocol to transmit the application information to the destination safely, reliably and efficiently. The handshake protocol is that two devices know each other before communicating and can then communicate with each other. The RS-232 traffic mode allows simple connection of three wires: tx, Rx, and ground. However, for data transmission, both parties must use the same baud rate for data timing. Although this approach is adequate for most applications, this use is limited for receiver overload situations. At this time, a handshake function of the serial port is required. This is typically used where the actual data is a control character, similar to the way GPIB uses command strings. The necessary lines are still three: tx, Rx and ground, since the control characters are not distinguished from the normal characters on the transmission line, the SetXModem function allows the user to enable or disable the use of two control characters XON and OXFF. These characters are sent by the receiving party in the communication, causing the sending party to pause. For example: it is assumed that the transmitting side transmits data at a high baud rate. During transmission, the receiver finds that the input buffer is full because the CPU is busy doing other work. To temporarily stop transmission, the receiving party sends XOFF, typically with a decimal value of 19, i.e. 13 hexadecimal, until the input buffer is empty. Once the receiver is ready to receive, it sends XON, typically with the value decimal 17, hexadecimal 11, to continue the communication. When the input buffer is half full, LabWindows sends XOFF. Furthermore, if the XOFF transmission is interrupted, LabWindows will send XOFF when the buffer reaches 75% and 90%. Obviously, the sender must follow this gatekeeper to ensure that the transmission continues.
In the embodiment of the present invention, the working domain at least includes any one or more of a working domain ID, a type, a supported protocol and protocol parameter, a session ID, and a session parameter; the response data packet comprises data and control information interacted with the data transmission middleware for the application of the Internet of things, each data comprises a data packet head and a data packet body, the data packet head at least comprises a source working domain ID, a destination server, version information, protocol information, secret string information, a verification mode, a data type, a stamp, time information and the like, and the data packet body at least comprises the data and the verification information.
In the embodiment of the invention, the data transmission middleware for the application of the Internet of things receives a data request from at least one application object in at least one working domain in an application layer; it should be noted that, in each work domain, each application object sends a data request to the management object of the work domain where the application object is located, and then the management object of the work domain implements a data interaction process with the internet of things and finally returns a data result to the corresponding data object.
And S12, analyzing the data request to generate an instruction meeting the preset specification.
In the embodiment of the present invention, the data transmission middleware for the application oriented to the internet of things receives a data request from an application layer, analyzes the data request into an analysis result of a predefined specification through its own function, and analyzes the data request into the analysis result of the predefined specification, where protocols or data specifications used by application objects of each working domain may be different, and after receiving the data request transmitted by each working domain, the data transmission middleware for the application oriented to the internet of things performs protocol conversion and data specification analysis, that is, the data transmission middleware for the application oriented to the internet of things performs protocol interaction and data analysis on the data request sent by the application objects of the working domains using different data specifications of different protocols into the analysis result of the predefined specification, that is, the data specification that can be interpreted by the data transmission middleware for the application oriented to the internet of things, the execution instruction comprises a real-time data acquisition instruction and a historical data acquisition instruction, the data transmission middleware for the application of the Internet of things judges whether the data to be acquired by the corresponding object in the working domain in the application layer is acquired by other application objects through analysis, if so, the historical data acquisition instruction is generated, and if not, the real-time data acquisition instruction is generated.
In the embodiment of the invention, the data transmission middleware for the application of the internet of things realizes active or passive interconnection, state and data acquisition, data distributed storage and a group of interfaces for application layer software or data workers to call by establishing a group of specifications and a group of standard WebAPI (application program interface) for accessing the internet of things equipment or devices and a historical database. The general Internet of things gateway comprises a group of specifications, a group of standard Web API command sets for application software to call to access various Internet of things devices and historical data, and a group of service set ports supporting access of the various Internet of things devices. These Web APIs are independent of internet of things devices or appliances of different vendors and support SQL (structured query language) to accomplish most of their tasks.
S13, executing the instruction to obtain the data corresponding to the instruction.
In the embodiment of the invention, the data transmission middleware for the application of the internet of things executes the instruction to acquire data corresponding to the instruction from a network layer and writes the data into a database; or executing the instruction to acquire historical data corresponding to the instruction from a database, specifically, when the execution instruction is a real-time data acquisition instruction, executing the real-time data acquisition instruction, acquiring data corresponding to the real-time data acquisition instruction from a network layer and storing the data in the database or a data file, and when the execution instruction is a historical data acquisition instruction, executing the historical data acquisition instruction, and acquiring data corresponding to the historical data acquisition instruction from the database or the data file.
S14, returning the data to the application layer.
In the embodiment of the invention, the data transmission middleware for the application of the internet of things returns the data to the corresponding application object in the working domain corresponding to the application layer.
In summary, the embodiment of the present invention receives a data request from an application layer, analyzes the data request, generates an instruction meeting a predetermined specification, executes the instruction to obtain data corresponding to the instruction, and finally returns the data to the application layer. According to the embodiment of the invention, various resources, components, application systems or equipment are connected to the Internet of things through the general Internet of things gateway, so that the fusion and sharing of the resources and the data are realized, the complicated operation steps of acquiring data by different types of applications or equipment across fields are reduced, the corresponding data or required equipment can be conveniently and quickly acquired through the general Internet of things gateway, the resources are comprehensively utilized, and the time cost is reduced.
In order to facilitate an understanding of the invention, some preferred embodiments of the invention will now be described.
Second embodiment of the invention:
on the basis of the first embodiment of the present invention, the present invention further includes:
receiving data collected by the Internet of things equipment transmitted by a network layer through a uniform data management interface, and storing the data in a database in a distributed manner; the data management interface is compatible with ODBC and OLEDB interfaces.
In an embodiment of the present invention, specifically, referring to fig. 2, the data transmission middleware for the application in the internet of things sends a data flow starting instruction to the internet of things device in the sensing layer through the network layer, where the data flow starting instruction includes a duplex data flow starting instruction and a half-duplex data flow starting instruction, and then collects data transmitted by the internet of things device in the sensing layer through the network layer according to the data flow starting instruction, and stores the data in a database in a distributed manner.
In the embodiment of the invention, the data transmission middleware for the application of the internet of things sends a duplex or semi-duplex data flow starting instruction to the internet of things equipment corresponding to the sensing layer, opens a data transmission channel and continuously monitors the state of the channel, and stores collected data in batch or in real time into a distributed data file or database.
In the embodiment of the invention, the data transmission middleware for the application of the internet of things provides an interface for data access for software of an application layer in a WebAPI mode, and the interface supports acquisition of data such as real-time state and operation of equipment of the internet of things, inquiry of historical data and real-time command control of the equipment of the internet of things; the universal gateway comprises a unified data management interface center and has unified interfaces compatible with ODBC, OLE DB and the like so as to realize distributed storage of data acquired from various Internet of things devices/devices into a database or a file of a third party and support return of real-time or historical data to a data request from an application layer.
In the embodiment of the invention, the general internet of things gateway can also realize exception and error processing, conversation keeping and monitoring, data acquisition/storage channel maintenance, full-work/semi-work control and the like.
Third embodiment of the invention:
on the basis of the second embodiment of the present invention, the present invention further includes:
and when a termination request from the working domain of the application layer is detected, deleting the session between the working domain and the self according to the termination request.
In the embodiment of the invention, if an application layer detects that all application objects in a working domain which carries out protocol conversion and data exchange through a data transmission middleware for application of the Internet of things are terminated in shared connection with the data transmission middleware for application of the Internet of things, the application layer initiates a termination request to a data transmission server based on a universal gateway, the data transmission middleware for application of the Internet of things detects the termination request of the application layer, and the session between the working domain and the application layer is deleted according to the termination request.
Referring to fig. 2, a fourth embodiment of the present invention further provides a data transmission middleware for an application in the internet of things, including the following steps:
a request receiving unit 11, configured to receive a data request from an application layer.
And the request analysis unit 12 is used for analyzing the data request and generating an instruction which meets a preset specification.
A request execution unit 13, configured to execute the instruction to obtain data corresponding to the instruction.
And a request result returning unit 14, configured to return the data to the application layer.
Preferably, the request execution unit 13 specifically includes:
executing the instruction to obtain data corresponding to the instruction from a network layer, and writing the data into a database; or
The instructions are executed to retrieve historical data corresponding to the instructions from a database.
Preferably, the method further comprises the following steps:
the data collection unit is used for receiving data collected by the Internet of things equipment transmitted by a network layer through a uniform data management interface and storing the data in a database in a distributed manner; the data management interface is compatible with ODBC and OLEDB interfaces.
Preferably, the data collection unit specifically includes:
the collecting instruction sending module is used for sending a data stream starting instruction to the Internet of things equipment of the sensing layer through the network layer; the data flow starting instruction comprises a duplex data flow starting instruction and a half-duplex data flow starting instruction.
And the data collection module is used for collecting data transmitted by the Internet of things equipment of the sensing layer through a network layer according to the data stream starting instruction and storing the data in a database in a distributed manner.
Preferably, the application layer comprises at least one work domain.
The work domain includes at least one application object of the same type.
The application object includes at least any one or more of a smart device, appliance, personal user terminal, or office system.
And communication is established between the application objects of the same working domain so as to realize information sharing.
Preferably, the method further comprises the following steps:
the detection unit is used for sending an instruction request to a newly-built working domain when the working domain creating operation in the application layer is detected; the instruction request is used for triggering the newly-built working domain to send a response data packet, the instruction request comprises active connection and passive connection, and the working domain at least comprises any one or more of working domain ID, type, supported protocol and protocol parameters, session ID and session parameters.
And the session establishing unit is used for establishing the connection between the newly-built working domain and the session establishing unit according to the response data packet and maintaining the session.
Preferably, the method further comprises the following steps:
and the termination unit is used for deleting the session between the working domain and the self according to the termination request when the termination request from the working domain of the application layer is detected.
Referring to fig. 3, a fifth embodiment of the present invention further provides a transmission system based on a universal gateway, including an application layer and the data transmission middleware oriented to the application of the internet of things as described above; wherein,
the application layer is used for initiating a data request to the data transmission middleware for the application of the Internet of things.
The data transmission middleware for the application of the Internet of things is used for receiving a data request from an application layer; analyzing the data request to generate an instruction meeting a preset specification; executing the instruction to obtain data corresponding to the instruction; returning the data to the application layer.
And the application layer is also used for receiving the data returned according to the data request.
Preferably, the data transmission middleware for the application of the internet of things is further configured to receive data collected by the internet of things device transmitted by the network layer through a unified data management interface, and store the data in a database in a distributed manner; the data management interface is compatible with ODBC and OLE DB interfaces.
Preferably, the transmission system based on the universal gateway further comprises a network layer and a perception layer; the data transmission middleware for the application of the Internet of things is also used for sending a data stream starting instruction to the Internet of things equipment of the sensing layer through the network layer; the data flow starting instruction comprises a duplex data flow starting instruction and a half-duplex data flow starting instruction.
And the perception layer is also used for transmitting data through the network layer according to the data stream starting instruction.
The data transmission middleware for the application of the Internet of things is also used for collecting data transmitted by the Internet of things equipment of the sensing layer through a network layer according to the data stream starting instruction and storing the data in a database in a distributed mode.
In the embodiment of the invention, the general internet of things gateway is positioned between a network layer and an application layer of a three-layer architecture of the internet of things, and supports multi-channel, full-work or semi-work connection with application objects of various work domains, namely various internet of things devices/devices. The general Internet of things gateway realizes the difference processing of application objects of all work domains, namely, the difference of various Internet of things devices or Internet of things devices is shielded, and application program developers only need to concentrate on details of business functions when accessing, controlling and analyzing data of the Internet of things devices without understanding access protocols of a large number of different Internet of things devices. It should be noted that the generic internet of things gateway may be integrated as an embedded component into any internet of things application software that needs to interact with internet of things devices or devices, or may reside as a separate service in an application server.
The data transmission middleware for the application of the internet of things provided by the sixth embodiment of the invention. The data transmission middleware for the application of the Internet of things comprises: a processor, a memory, and a computer program, such as a data transfer program for an internet of things-oriented application, stored in the memory and executable on the processor. When executing the computer program, the processor implements the steps in each of the above embodiments of the data transmission method for internet of things application, for example, step S11 shown in fig. 1.
Illustratively, the computer program may be partitioned into one or more modules/units that are stored in the memory and executed by the processor to implement the invention. The one or more modules/units may be a series of computer program instruction segments capable of performing specific functions, and the instruction segments are used for describing the execution process of the computer program in the data transmission middleware for the application of the internet of things.
The data transmission middleware for the application of the internet of things can comprise, but is not limited to, a processor and a memory. Those skilled in the art will appreciate that more or fewer components than those mentioned above may be included, or certain components may be combined, or different components may be included, for example, the data transmission middleware for the internet of things application may also include input and output devices, network access devices, buses, etc.
The Processor may be a Central Processing Unit (CPU), other general purpose Processor, a Digital Signal Processor (DSP), an Application Specific Integrated Circuit (ASIC), an off-the-shelf Programmable Gate Array (FPGA) or other Programmable logic device, discrete Gate or transistor logic, discrete hardware components, etc. The general-purpose processor may be a microprocessor, or the processor may be any conventional processor, and the processor is a control center of the data transmission middleware for the application of the internet of things, and various interfaces and lines are used to connect various parts of the data transmission middleware for the application of the internet of things.
The memory may be used to store the computer programs and/or modules, and the processor may implement various functions of the data transmission middleware for the internet of things application by executing or executing the computer programs and/or modules stored in the memory and calling data stored in the memory. The memory may mainly include a storage program area and a storage data area, wherein the storage program area may store an operating system, an application program required by at least one function (such as a sound playing function, an image playing function, etc.), and the like; the storage data area may store data (such as audio data, a phonebook, etc.) created according to the use of the cellular phone, and the like. In addition, the memory may include high speed random access memory, and may also include non-volatile memory, such as a hard disk, a memory, a plug-in hard disk, a Smart Media Card (SMC), a Secure Digital (SD) Card, a Flash memory Card (Flash Card), at least one magnetic disk storage device, a Flash memory device, or other volatile solid state storage device.
The module/unit integrated by the data transmission middleware for the application of the internet of things can be stored in a computer readable storage medium if the module/unit is realized in the form of a software functional unit and sold or used as an independent product. Based on such understanding, all or part of the flow of the method according to the embodiments of the present invention may also be implemented by a computer program, which may be stored in a computer-readable storage medium, and when the computer program is executed by a processor, the steps of the method embodiments may be implemented. Wherein the computer program comprises computer program code, which may be in the form of source code, object code, an executable file or some intermediate form, etc. The computer-readable medium may include: any entity or device capable of carrying the computer program code, recording medium, usb disk, removable hard disk, magnetic disk, optical disk, computer Memory, Read-Only Memory (ROM), Random Access Memory (RAM), electrical carrier wave signals, telecommunications signals, software distribution medium, and the like. It should be noted that the computer readable medium may contain content that is subject to appropriate increase or decrease as required by legislation and patent practice in jurisdictions, for example, in some jurisdictions, computer readable media does not include electrical carrier signals and telecommunications signals as is required by legislation and patent practice.
It should be noted that the above-described device embodiments are merely illustrative, where the units described as separate parts may or may not be physically separate, and the parts displayed as units may or may not be physical units, may be located in one place, or may be distributed on multiple network units. Some or all of the modules may be selected according to actual needs to achieve the purpose of the solution of the present embodiment. In addition, in the drawings of the embodiment of the apparatus provided by the present invention, the connection relationship between the modules indicates that there is a communication connection between them, and may be specifically implemented as one or more communication buses or signal lines. One of ordinary skill in the art can understand and implement it without inventive effort.
While the foregoing is directed to the preferred embodiment of the present invention, it will be understood by those skilled in the art that various changes and modifications may be made without departing from the spirit and scope of the invention.
Claims (10)
1. A data transmission method for Internet of things application is characterized by comprising the following steps:
receiving a data request from an application layer;
analyzing the data request to generate an instruction meeting a preset specification;
executing the instruction to obtain data corresponding to the instruction;
returning the data to the application layer.
2. The data transmission method oriented to the internet of things application of claim 1, wherein the executing the instruction to obtain the data corresponding to the instruction specifically comprises:
executing the instruction to obtain data corresponding to the instruction from a network layer, and writing the data into a database; or
The instructions are executed to retrieve historical data corresponding to the instructions from a database.
3. The data transmission method oriented to the internet of things application of claim 1, further comprising:
receiving data collected by the Internet of things equipment transmitted by a network layer through a uniform data management interface, and storing the data in a database in a distributed manner; the data management interface is compatible with ODBC and OLEDB interfaces.
4. The data transmission method oriented to the internet of things application of claim 2, wherein the data collected by the internet of things devices transmitted by the network layer is received through the unified data management interface, and is stored in the database in a distributed manner, specifically:
sending a data stream starting instruction to the Internet of things equipment of the sensing layer through the network layer; the data flow starting instruction comprises a duplex data flow starting instruction and a half-duplex data flow starting instruction;
and collecting data transmitted by the Internet of things equipment of the sensing layer through a network layer according to the data stream starting instruction, and storing the data in a database in a distributed manner.
5. The data transmission method oriented to the application of the internet of things according to claim 1, wherein the application layer comprises at least one work domain;
the work domain comprises at least one application object of the same type;
the application object at least comprises any one or more of intelligent equipment, devices, personal user terminals or office systems;
and communication is established between the application objects of the same working domain so as to realize information sharing.
6. The data transmission method oriented to the application of the internet of things of claim 4, further comprising:
when detecting the creation operation of a working domain in an application layer, sending an instruction request to the newly-built working domain; the instruction request is used for triggering the newly-built working domain to send a response data packet, the instruction request comprises active connection and passive connection, and the working domain at least comprises any one or more of working domain ID, type, supported protocol and protocol parameters, session ID and session parameters;
and establishing the connection between the newly-built working domain and the working domain according to the response data packet and keeping the conversation.
7. The data transmission method oriented to the application of the internet of things of claim 6, further comprising: and when a termination request from the working domain of the application layer is detected, deleting the session between the working domain and the self according to the termination request.
8. A data transmission middleware for application of the Internet of things is characterized by comprising:
a request receiving unit for receiving a data request from an application layer;
the request analysis unit is used for analyzing the data request and generating an instruction which accords with a preset standard;
a request execution unit for executing the instruction to obtain data corresponding to the instruction;
and the request result returning unit is used for returning the data to the application layer.
9. The data transmission middleware for the application of the internet of things according to claim 8, further comprising:
the data collection unit is used for receiving data collected by the Internet of things equipment transmitted by a network layer through a uniform data management interface and storing the data in a database in a distributed manner; the data management interface is compatible with ODBC and OLE DB interfaces.
10. A data transmission system for an application of the internet of things, which comprises an application layer and the data transmission middleware for the application of the internet of things as claimed in claim 8 or 9; wherein,
the application layer is used for initiating a data request to the data transmission middleware for the application of the Internet of things;
the data transmission middleware for the application of the Internet of things is used for receiving a data request from an application layer; analyzing the data request to generate an instruction meeting a preset specification; executing the instruction to obtain data corresponding to the instruction; returning the data to the application layer;
and the application layer is also used for receiving the data returned according to the data request.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201711279406.8A CN109889558A (en) | 2017-12-06 | 2017-12-06 | Data transmission method, middleware and the system of internet of things oriented application |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201711279406.8A CN109889558A (en) | 2017-12-06 | 2017-12-06 | Data transmission method, middleware and the system of internet of things oriented application |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN109889558A true CN109889558A (en) | 2019-06-14 |
Family
ID=66924324
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201711279406.8A Pending CN109889558A (en) | 2017-12-06 | 2017-12-06 | Data transmission method, middleware and the system of internet of things oriented application |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN109889558A (en) |
Cited By (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN110738466A (en) * | 2019-10-18 | 2020-01-31 | 软通动力信息技术有限公司 | kinds of park management system and method |
| CN111935240A (en) * | 2020-07-16 | 2020-11-13 | 四川爱联科技股份有限公司 | Internet of things data sharing method and device |
| CN112910985A (en) * | 2021-01-27 | 2021-06-04 | 南京中兴力维软件有限公司 | Protocol conversion method, device, equipment and storage medium based on intelligent contract |
| CN113950089A (en) * | 2021-09-27 | 2022-01-18 | 中电科思仪科技(安徽)有限公司 | Building mobile cellular network quality real-time monitoring cloud platform |
| CN114221785A (en) * | 2021-11-17 | 2022-03-22 | 佛山市宏图数据有限公司 | Non-inductive boundary data exchange method |
Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101908178A (en) * | 2010-08-13 | 2010-12-08 | 广州联奕信息科技有限公司 | Middleware applied to data switching and data switching method |
| CN103336813A (en) * | 2013-06-27 | 2013-10-02 | 南京邮电大学 | Data integrated management scheme for Internet of Things based on middleware framework |
| US20160182669A1 (en) * | 2014-12-22 | 2016-06-23 | Here Global B.V. | Optimal Coding Method for Efficient Matching Of Hierarchical Categories In Publish-Subscribe Systems |
-
2017
- 2017-12-06 CN CN201711279406.8A patent/CN109889558A/en active Pending
Patent Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101908178A (en) * | 2010-08-13 | 2010-12-08 | 广州联奕信息科技有限公司 | Middleware applied to data switching and data switching method |
| CN103336813A (en) * | 2013-06-27 | 2013-10-02 | 南京邮电大学 | Data integrated management scheme for Internet of Things based on middleware framework |
| US20160182669A1 (en) * | 2014-12-22 | 2016-06-23 | Here Global B.V. | Optimal Coding Method for Efficient Matching Of Hierarchical Categories In Publish-Subscribe Systems |
Non-Patent Citations (2)
| Title |
|---|
| 何聚厚，田娅薇: "《大学计算机应用基础》", 28 February 2007 * |
| 史陈新: "《中小学校园网网络操作系统的配置与应用》", 31 October 2014 * |
Cited By (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN110738466A (en) * | 2019-10-18 | 2020-01-31 | 软通动力信息技术有限公司 | kinds of park management system and method |
| CN111935240A (en) * | 2020-07-16 | 2020-11-13 | 四川爱联科技股份有限公司 | Internet of things data sharing method and device |
| CN112910985A (en) * | 2021-01-27 | 2021-06-04 | 南京中兴力维软件有限公司 | Protocol conversion method, device, equipment and storage medium based on intelligent contract |
| CN113950089A (en) * | 2021-09-27 | 2022-01-18 | 中电科思仪科技(安徽)有限公司 | Building mobile cellular network quality real-time monitoring cloud platform |
| CN114221785A (en) * | 2021-11-17 | 2022-03-22 | 佛山市宏图数据有限公司 | Non-inductive boundary data exchange method |
| CN114221785B (en) * | 2021-11-17 | 2023-11-24 | 佛山市宏图数据有限公司 | Non-inductive boundary data exchange method |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN109889558A (en) | Data transmission method, middleware and the system of internet of things oriented application | |
| CN102209076B (en) | Method and system for interaction between server and client | |
| WO2019134306A1 (en) | Message processing method, device, terminal apparatus, and readable storage medium | |
| US20170163478A1 (en) | Method,electronic device and system for updating client configuration in key-value pair database | |
| CN111416867A (en) | Method for processing messages between different devices, server and computer storage medium | |
| CN101854371A (en) | Method and device for calling and processing JavaScript object | |
| CN111786998A (en) | Authority management method and device based on micro-service calling and storage medium | |
| US10908970B1 (en) | Data interface for secure analytic data system integration | |
| CN104243611A (en) | Distribution thought based message service middleware system | |
| CN101388887A (en) | Network service processing method and system | |
| CN108228625B (en) | Push message processing method and device | |
| US20190370293A1 (en) | Method and apparatus for processing information | |
| CN107368334B (en) | Business plug-in interaction system and method | |
| CN107846609B (en) | Real-time transmission method, device and system for control room data | |
| CN106357654A (en) | Remote processing calling method and device and communication system | |
| CN110417875B (en) | Method, system, equipment and storage medium for docking between cloud servers | |
| CN110572476B (en) | Remote control method, device and equipment | |
| CN110661850B (en) | Edge calculation method, system, computer equipment and storage medium | |
| CN113014610B (en) | Remote access method, device and system | |
| CN105357238B (en) | A kind of method and device of Point-to-Point Data Transmission | |
| CN115052003B (en) | Data synchronization method, related device and medium | |
| CN108289165B (en) | Method and device for realizing camera control based on mobile phone and terminal equipment | |
| CN103428280A (en) | Mobile terminal based mobile service data acquisition method and system | |
| CN112383904B (en) | Pair-free quick peripheral calling method and device | |
| CN113553152A (en) | Job scheduling 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 | ||
| RJ01 | Rejection of invention patent application after publication | ||
| RJ01 | Rejection of invention patent application after publication |
Application publication date: 20190614 |