CN110062041A - A kind of method and device of the IOT equipment changing based on block chain - Google Patents

Abstract

The invention discloses a kind of method and devices of IOT equipment changing based on block chain, this method is suitable for IOT equipment alliance system, this method comprises: first server generates the first transaction request, first transaction request is sent to block catenary system, block catenary system calls equipment management contract to generate and store the first transaction log, and second server determines whether to subscribe to the first IOT equipment theme according to the first transaction log.When changing equipment in systems, first server only needs to be written the transaction of change facility information in block catenary system, then second server can be by subscribing to equipment management theme, obtain the information of change equipment, and for the corresponding actions that change facility information executes, whole system changes the binding or mapping movement of equipment without bridge, and it avoids adhering to inconsistence problems present in different financial institutions separately as MQ and bridge service, O&M cost is reduced, suitable for fast-developing IOT group network system.

Description

A method and device for changing IOT equipment based on blockchain

technical field

The embodiments of the present invention relate to the field of financial technology (Fintech), and in particular, to a method and apparatus for changing an IOT (Internet of Things, Internet of Things) device based on a blockchain (BlockChain).

Background technique

The MQTT (Message Queue Telemetry Transport) protocol is a message protocol based on the publish/subscribe paradigm under the ISO standard (ISO/IECPRF 20922). The MQTT protocol works on the TCP/IP (Transmission Control Protocol/Internet Protocol) protocol suite, and is a publish/subscribe message designed for remote devices with low hardware performance and under unsatisfactory network conditions. protocol.

In the field of financial technology, the IOT device alliance system based on the MQTT protocol can be shown in Figure 1. The internal networking of a financial institution can connect multiple IOT devices to MQ (Message Queue, message queue) through an MQTT cluster. The networking is to connect the MQ of this financial institution with the MQ of other financial institutions through a bridge. For example, MQ1 of financial institution 1 and MQ2 of financial institution 2 are connected through a bridge, which is used to subscribe event publications from MQ1 To MQ2 and subscribe events from MQ2 to publish to MQ1.

In the existing IOT equipment alliance system, once a financial institution changes equipment, such as adding equipment, deleting equipment or updating equipment, the equipment information needs to be sent to other financial institutions. Further, the bridge between financial institutions needs to be To complete the binding or mapping action of the changed device, and because MQ and bridge services belong to different financial institutions, the operation and maintenance cost is high.

SUMMARY OF THE INVENTION

Embodiments of the present invention provide a method and device for changing an IOT device based on a blockchain, which reduces the operation and maintenance cost of changing an IOT device in an IOT device alliance system constructed based on the MQTT protocol.

A method for changing an IOT device based on a blockchain provided by an embodiment of the present invention is applicable to an IOT device alliance system including multiple servers; each server is used to manage its own IOT device; The chain system conducts information exchange of IOT devices;

The method includes:

The first server generates a first transaction request including first IOT device information; the first IOT device information is the device information of the IOT device changed under the first server; the first server is one of the multiple servers. any of the;

The first server sends the first transaction request to the blockchain system; the first transaction request is used to instruct the blockchain system to call a device management contract to generate and store a first transaction log; the The first transaction log records the device management topic and the first IOT device information; any server in the IOT device alliance system is subscribed to the device management topic; the first transaction log is used for the second server to determine Whether to subscribe to the first IOT device topic indicated by the first IOT device information; the second server is any server in the IOT device alliance system except the first server.

In the above technical solution, a method for changing an IOT device suitable for an IOT device alliance system is provided. Specifically, changing a device in the system may be adding a device, deleting a device, updating a device, etc. in the system, and changing the device can be performed. It is defined as the first IOT device, and the first server is used to manage the first IOT device. The first server generates a first transaction request containing the information of the first IOT device, and sends it to the blockchain system, and the blockchain system receives the first transaction request, invokes the device management contract, and generates a first transaction that records the information of the first IOT device. log, and store the first transaction log in the blockchain system. The second server can obtain the first transaction log by subscribing to the device management topic, and determine whether to subscribe to the first IOT device topic according to the first transaction log. If the second server subscribes to the topic of the first IOT device, the second server can obtain the event published by the first IOT device. In the IOT device alliance system, after the second server obtains the event published by the first IOT device, the event can be It is sent to the corresponding IOT device, so that the IOT device corresponding to the second server receives the event published by the first IOT device. When changing the device in the system, the first server only needs to write the transaction of changing the device information in the blockchain system, then the second server can obtain the information of the changed device by subscribing to the device management topic, and execute the transaction for the changed device information. Action accordingly. The whole system does not require a bridge to change the binding or mapping of devices, and avoids inconsistencies due to the fact that MQ and bridge services belong to different financial institutions, reducing operation and maintenance costs, and is suitable for rapidly developing IOT networking systems.

Optionally, the method further includes:

The first server obtains a second transaction log from the blockchain system; the second transaction log is that the blockchain system invokes the device management contract based on a second transaction request sent by the second server Generated; the second IOT device information and the device management theme are recorded in the second transaction log, and the second IOT device information is the device information of the newly added IOT device under the second server;

The first server subscribes the second IOT device topic indicated by the second IOT device information to the blockchain system according to the second IOT device information in the second transaction log.

In the above technical solution, the first server can also obtain the second transaction log in the blockchain system by subscribing to the device management topic, and subscribe the second transaction log to the blockchain system according to the second IOT device information in the second transaction log. IoT device theme. When the second IOT device publishes the event to the blockchain system, the first server can obtain the published event, and further, the first server can send the published event to the IOT device corresponding to the first server to Realize the interconnection between IoT devices. In addition, when the first server subscribes to the topic of the second IOT device, there is no need to perform binding or mapping actions for the newly added device, which reduces the operation and maintenance cost of the newly added device in the IOT device alliance system.

Optionally, before the first server generates the first transaction request including the first IOT device information, the method further includes:

The first server generates the first IOT device topic according to the first IOT device information;

The first server generates and sends a first deployment request to the blockchain system according to the theme of the first IOT device; the first deployment request is used to instruct the blockchain system to deploy the first IOT The theme contract for the device theme;

The first server receives the first deployment result returned by the blockchain system, and the first deployment result is sent after the blockchain system completes the deployment of the theme contract of the first IOT device theme; The first deployment result includes the contract address of the theme contract of the first IOT device theme.

In the above technical solution, the first server can generate a first deployment request according to the theme of the first IOT device, and send it to the blockchain system. The blockchain system deploys the corresponding theme contract and the contract address of the theme contract to be deployed. Return to the first server to deploy the topic contract corresponding to the changing device in the blockchain system, and the second server can subscribe to the topic corresponding to the changing device. When the change device calls the corresponding topic contract in the blockchain system to publish the event, the second server subscribed to the theme contract can obtain the event published by the change device and send it to the IOT device corresponding to the second server to realize the change The interconnection of the device with other IoT devices. Further, if the first IOT device topic is generated before the first server generates the first transaction request, the first IOT device topic can be recorded in the first transaction request when the first transaction request is generated, and the blockchain system can record the first IOT device topic in the first transaction request according to the first transaction request. A transaction request generates a first transaction log recorded with a first IOT device topic, so that the second server can subscribe to the first IOT device topic from the blockchain system according to the first IOT device topic in the first transaction log, to The efficiency of the second server subscribing to the topic set by the first IOT is improved.

Optionally, before the first server generates the first deployment request, the method further includes:

The first server sends a second deployment request to the blockchain system; the second deployment request is used to instruct the blockchain system to deploy a system contract;

The first server receives the second deployment result returned by the blockchain system; the second deployment result is sent after the blockchain system completes the deployment of the system contract;

After the first server receives the first deployment result returned by the blockchain system, the method further includes:

The first server updates the correspondence between the first IOT device topic and the contract address of the topic contract of the first IOT device topic to the system contract.

In the above technical solution, before generating the first deployment request, the first server may also send a transaction request to the blockchain system for instructing the blockchain system to deploy the system contract, that is, the blockchain system is deploying the theme contract. Previously, system contracts could also be deployed first. After the blockchain system deploys the theme contract, it feeds back the contract address of the theme contract to the first server, and the first server can update the corresponding relationship between the theme and the contract address of the theme contract to the system contract, so that the system contract stores the current area The correspondence between the latest topics and contract addresses in the blockchain system is equivalent to storing the correspondence between the topics and contract addresses of all IOT devices in the current IOT device alliance system. When the first IOT device publishes an event, the first server can determine the contract address of the topic contract of the topic of the first IOT device to be called, so that the blockchain system can call the contract according to the address to complete the event publishing of the first IOT device . And the first IOT device publishes the event through the first server in the blockchain system, which can prevent the event from being tampered with and improve the security of publishing the event.

Correspondingly, an embodiment of the present invention also provides a blockchain-based device for changing an IOT device, including:

a processing unit, configured to generate a first transaction request including first IOT device information; the first IOT device information is the device information of the IOT device changed under the first server; the first server is one of the multiple servers any of the;

a transceiver unit, configured to send the first transaction request to the blockchain system; the first transaction request is used to instruct the blockchain system to call a device management contract to generate and store a first transaction log; the The first transaction log records the device management topic and the first IOT device information; any server in the IOT device alliance system is subscribed to the device management topic; the first transaction log is used for the second server to determine Whether to subscribe to the first IOT device topic indicated by the first IOT device information; the second server is any server in the IOT device alliance system except the first server.

Optionally, the processing unit is also used for:

Obtain a second transaction log from the blockchain system; the second transaction log is generated by the blockchain system calling the device management contract based on the second transaction request sent by the second server; the The second transaction log records the second IOT device information and the device management topic, and the second IOT device information is the device information of the newly added IOT device under the second server;

According to the second IOT device information in the second transaction log, the second IOT device topic indicated by the second IOT device information is subscribed to the blockchain system.

Optionally, the processing unit is also used for:

Before generating the first transaction request including the first IOT device information, generating the first IOT device subject according to the first IOT device information;

According to the subject of the first IOT device, generate and control the transceiver unit to send a first deployment request to the blockchain system; the first deployment request is used to instruct the blockchain system to deploy the first IOT The theme contract for the device theme;

Controlling the transceiver unit to receive the first deployment result returned by the blockchain system, where the first deployment result is sent after the blockchain system completes the deployment of the theme contract of the first IOT device theme; The first deployment result includes the contract address of the theme contract of the first IOT device theme.

Optionally, the processing unit is also used for:

Before generating the first deployment request, control the transceiver unit to send a second deployment request to the blockchain system; the second deployment request is used to instruct the blockchain system to deploy a system contract;

Controlling the transceiver unit to receive the second deployment result returned by the blockchain system; the second deployment result is sent after the blockchain system completes the deployment of the system contract;

The processing unit is also used to:

After controlling the transceiver unit to receive the first deployment result returned by the blockchain system, update the correspondence between the first IOT device topic and the contract address of the topic contract of the first IOT device topic to the system contract.

Correspondingly, an embodiment of the present invention also provides a computing device, including:

memory for storing program instructions;

The processor is configured to call the program instructions stored in the memory, and execute the above method for changing the IOT device based on the blockchain according to the obtained program.

Correspondingly, an embodiment of the present invention also provides a computer-readable non-volatile storage medium, including computer-readable instructions, when the computer reads and executes the computer-readable instructions, the computer executes the above-mentioned blockchain-based The method of changing the IOT device.

Description of drawings

In order to illustrate the technical solutions in the embodiments of the present invention more clearly, the following briefly introduces the accompanying drawings used in the description of the embodiments. Obviously, the drawings in the following description are only some embodiments of the present invention. For those of ordinary skill in the art, other drawings can also be obtained from these drawings without any creative effort.

1 is a schematic diagram of a first IOT device alliance system provided by an embodiment of the present invention;

2 is a schematic diagram of a second type of IOT device alliance system provided by an embodiment of the present invention;

3 is a schematic diagram of a third IOT device alliance system provided by an embodiment of the present invention;

4 is a schematic diagram of a fourth IOT device alliance system provided by an embodiment of the present invention;

5 is a schematic flowchart of a method for changing an IOT device according to an embodiment of the present invention;

6 is a schematic diagram of an IOT device alliance system under a specific scenario provided by an embodiment of the present invention;

FIG. 7 is a schematic structural diagram of an apparatus for changing an IOT device according to an embodiment of the present invention.

Detailed ways

In order to make the objectives, technical solutions and advantages of the present invention clearer, the present invention will be further described in detail below with reference to the accompanying drawings. Obviously, the described embodiments are only a part of the embodiments of the present invention, not all of the embodiments. Based on the embodiments of the present invention, all other embodiments obtained by those of ordinary skill in the art without creative efforts shall fall within the protection scope of the present invention.

The embodiment of the present invention provides a blockchain-based IOT device alliance system. The IOT device alliance system introduces blockchain technology on the basis of the MQTT protocol, and is changed from the blockchain-based IOT device provided by the embodiment of the present invention. method is applicable. The IOT device alliance system includes multiple servers, each of which is used to manage its own IOT device. The server here is understood as a publish and subscribe server used for message publishing and message subscription. Multiple publish and subscribe servers implement IOT through the blockchain system. Device information interaction.

Figure 2 exemplarily shows a blockchain-based IOT device alliance system, including multiple publish and subscribe servers, each publish and subscribe server corresponds to its own IOT device cluster, and each publish and subscribe server is used to manage its corresponding The IOT device in the IOT device cluster, the publish-subscribe server and the IOT device cluster are connected through the MQTT cluster, and the MQTT cluster is used for protocol conversion. Further, a publish-subscribe server and the IOT device cluster and MQTT cluster corresponding to the publish-subscribe server belong to the same financial institution. That is to say, multiple financial institutions are involved in the IOT device alliance system, and each financial institution includes IOT. The device cluster, the MQTT cluster, and the publish-subscribe server have a corresponding relationship, wherein the IOT device cluster includes at least one IOT device, and the MQTT cluster includes at least one proxy server, and the proxy server can be the server of the open source message broker software Mosquitto. The publish-subscribe server between the two financial institutions is connected through the blockchain system. The publish-subscribe server can write the publishing events of the IOT device into the blockchain system, and can also read events from the blockchain system and send them to the IOT device. . Referring to FIG. 2 as an example, financial institution 1 includes IOT device cluster 1, MQTT cluster 1 and publish-subscribe server 1, financial institution 2 includes IOT device cluster 2, MQTT cluster 2 and publish-subscribe server 2, publish-subscribe server 1 and publish-subscribe server 2. The subscription servers 2 are connected through the blockchain system, and the information exchange of the IOT devices between the two financial institutions is realized through the blockchain system.

The publish-subscribe server can access the blockchain system through certificates and public and private keys, and access the MQTT cluster through account numbers and passwords, thus ensuring information security within and between financial institutions.

A device management contract is stored in the blockchain system. The device management contract can be a pre-established contract in the blockchain system. The device management contract corresponds to a fixed device management topic, and each publish-subscribe server will subscribe to the device management topic. , that is to say, any event written to the device management topic will be acquired by any publish/subscribe server in the IOT device alliance system. For example, if the device management topic is "com.aaaaaa.iot", any publisher/subscriber server in the IOT device alliance system subscribes to the topic "com.aaaaaa.iot", if a publisher/subscriber server writes the event corresponding to the topic " com.aaaaaa.iot 1", other Publish Subscribers can subscribe to the event "com.aaaaaa.iot 1".

The IOT device alliance system provided by the embodiment of the present invention realizes the connection of the publish and subscribe servers of multiple financial institutions by using the blockchain technology, that is, the publish and subscribe servers of each financial institution are connected to the blockchain system, and any The publish-subscribe servers of both financial institutions can communicate through the blockchain system.

Compared with the IOT device alliance system shown in Figure 1, the IOT device alliance system based on blockchain technology has a simple networking method and is easy to maintain. For example, there are currently four IOT devices in financial institutions for networking. If the networking method in Figure 1 is adopted, the IOT device alliance system becomes the architecture shown in Figure 3. For the convenience of description, the IOT device alliance system is used. The MQTT cluster in Figure 3 is omitted. In Figure 3, when the MQ of each financial institution is connected to the foreign financial institution, it must pass through the bridge. For example, the bridge 23 needs to be connected between the MQ2 of the financial institution 2 and the MQ3 of the financial institution 3. For the IOT device alliance system provided by the embodiment of the present invention, as shown in FIG. 4 , the publish-subscribe server of each financial institution is connected to the blockchain system, eliminating the need for bridging between MQs. Compared with the mesh networking shown in Figure 1, the star networking of the IOT device alliance system based on blockchain technology is simple and easy to maintain.

In addition, the blockchain-based IOT device alliance system provided by the embodiment of the present invention is more suitable for the rapidly developing IOT networking system than the IOT device alliance system shown in FIG. 1 . For example, the financial institution 3 in FIG. 3 adds an IOT device, the bridges connected to MQ3 all need to perform the binding or mapping action of the newly added device. Specifically, the bridge 34, the bridge 13, and the bridge 23 perform the binding or mapping action of the newly added device. However, when the blockchain-based IOT device alliance system provided by the embodiment of the present invention is used, there is no need to perform binding or mapping actions for the newly added devices, and only the information of the newly added devices needs to be written into the blockchain system, and other financial institutions The subscription server can complete the subscription action. Specifically, in Figure 4, the financial institution 3 adds new equipment, and the publish and subscribe server 3 writes the information of the newly added device into the blockchain system, then publish and subscribe server 1, publish and subscribe server 2, The publish-subscribe server 4 can subscribe to the information of the newly added device, and the specific implementation process is explained in the following embodiments.

Based on the above description, FIG. 5 exemplarily shows a flow of a method for changing an IOT device based on a blockchain provided by an embodiment of the present invention. The flow may be executed by an apparatus for changing an IOT device based on a blockchain. The apparatus may be located in a publish-subscribe server, or may be the publish-subscribe server.

For the convenience of description, in the following embodiments, the publish and subscribe servers are referred to as servers for short. This process involves the publish and subscribe servers of two financial institutions (a first financial institution and a second financial institution), which are defined as the first server and the second financial institution, respectively. Servers, the first server is any one of multiple servers in the IoT device alliance system, and the second server is any server except the first server. Among them, the first financial institution understands that there is a financial institution that changes the IOT device, and the change of the IOT device may include addition, deletion, parameter modification, connection relationship change, etc. Used to add the newly added IOT device to the corresponding IOT device cluster. The first server and the second server are connected through the blockchain system, and the process involves the execution subject being the first server, the second server and the blockchain system.

As shown in Figure 5, the process specifically includes:

Step 501, the first server generates a first transaction request including the information of the first IOT device.

The first IOT device information is understood as device information of the IOT device changed under the first server. Specifically, when there is a newly added IOT device under the first server, the first server may receive an add instruction containing the information of the first IOT device, and generate a first transaction request according to the information of the first IOT device in the add instruction. The first transaction request includes first IOT device information, and the first IOT device information may include a device identifier of the IOT device, a device category, a device parameter, a financial institution to which it belongs, and the like. The addition instruction can be issued by the operation and maintenance personnel or sent by the IOT device to be added.

In this embodiment of the present invention, before generating the first transaction request, the first server may also generate a first IOT device topic corresponding to the first IOT device information according to the first IOT device information, and generate a first IOT device topic according to the first IOT device topic. A deployment request, where the first deployment request is used to instruct the blockchain system to deploy the theme contract of the first IOT device theme. The first server sends the first deployment request to the blockchain system, the blockchain system deploys the theme contract of the theme of the first IOT device according to the first deployment request, and sends the first deployment result to the first server after the deployment is completed, wherein , the first deployment result includes the contract address of the theme contract of the first IOT device theme. The first server receives the first deployment result returned by the blockchain system, and the first server includes the first IOT device topic and the contract address of the topic contract of the first IOT device topic.

In the above embodiment, before generating the first deployment request, the first server may also generate a second deployment request and send it to the blockchain system, where the second deployment request is used to instruct the blockchain system to deploy the system contract, and the blockchain After receiving the second deployment request, the system deploys the system contract, and returns the second deployment result to the first server. Among them, the system contract can be empty in the initial state. Further, after receiving the contract address of the theme contract of the first IOT device theme, the first server can update the correspondence between the first IOT device theme and the contract address of the theme contract of the first IOT device theme to the system contract. . That is to say, the corresponding relationship between the two is stored in the system contract, and after the theme contract of the first IOT device theme is added to the blockchain system, it is updated.

Step 502, the first server sends the first transaction request to the blockchain system.

Step 503, the blockchain system invokes the device management contract to generate and store the first transaction log.

In this embodiment of the present invention, the first transaction request may further include a device management topic corresponding to the device management contract in the blockchain system, and the first transaction request is used to instruct the blockchain system to call the device management contract to generate and store The first transaction log. After the blockchain system invokes the device management contract, a first transaction log is generated and stored in the blockchain system. The first transaction log records the device management topic and the first IOT device information. Since any server in the IoT device alliance system subscribes to the device management topic, it can be determined that the first transaction log generated by the blockchain system can be used by other servers (servers other than the first server in the IoT device alliance system) Obtaining, that is, the first transaction log can be obtained by the second server, is equivalent to the blockchain system sending the first transaction log to the second server.

Step 504, the blockchain system sends the first transaction log to the second server.

Step 505, the second server determines, according to the first transaction log, whether to subscribe to the first IOT device topic indicated by the first IOT device information.

The second server can determine the first IOT device topic indicated by the first IOT device information according to the information of the first IOT device, and determine whether to subscribe to the first IOT device topic, if so, it can send the block to the block according to the first IOT device topic The chain system sends a monitoring request, that is, once the first IOT device publishes the event of the corresponding topic to the blockchain system, it can be monitored by the second server, and the second server can obtain the event from the blockchain system. Of course, if the second server determines not to subscribe to the topic of the first IOT device, the first transaction log may be ignored, and the event published by the first IOT device will not be obtained.

In this embodiment of the present invention, before generating the first transaction request, the first server may also generate the first IOT device topic according to the first IOT device information, and when generating the first transaction request, record the first IOT device topic in the In the first transaction request, the blockchain system generates a first transaction log that records the subject of the first IOT device according to the first transaction request. That is to say, the first transaction log may also record the subject of the first IOT device, and the The server may directly determine whether to subscribe to the first IOT device topic according to the first IOT device topic, thereby improving the efficiency of the second server subscribing to the first IOT device topic.

Further, with reference to FIG. 6 , the following explanation is made for the second server to determine whether to subscribe to the subject of the first IOT device. FIG. 6 is a schematic diagram of an IOT device alliance system under a specific scenario provided by an embodiment of the present invention. The IOT of financial institution 1 The devices include transaction statistics devices, and the IOT devices of financial institutions 2 include payment devices used for transactions, such as card payment devices and scan code payment devices. In this IOT device alliance system, the transaction statistics device subscribes to the device theme and scan of the card payment device. Device theme for code payment devices. At this time, if the newly added IOT device of the financial institution 2 is a face-scanning payment device, the first server (publish and subscribe server 2) receives the addition instruction containing the device information of the face-scanning payment device, generates a first transaction request and sends it to the district The blockchain system, the blockchain system calls the device management contract to generate a first transaction log that records the device information of the face-swiping payment device. After the second server (publish and subscribe server 1) obtains the first transaction log, it determines the financial institution 1 Whether the transaction statistics device needs to subscribe to the device topic of the face-swiping payment device, and if so, send a monitoring request to the blockchain system to monitor events published by the face-swiping payment device.

In this embodiment of the present invention, the first transaction log may further include the category of the IOT device, the financial institution to which the IOT device belongs, and performance parameters of the IOT device, etc., so as to be used by the second server for judgment. The second server can judge whether to subscribe to the topic of the first IOT device through the internal logic of the second server; it can also send the first transaction log to the IOT device under the second server, and the IOT device under the second server can use its own Logic judges whether it is necessary to obtain the events published by the first IOT device, and feed back the judgment result to the second server; it can also display the relevant information in the first transaction log to the operation and maintenance personnel, and the operation and maintenance personnel manually judge and feed back to the second server. second server.

The first IOT device publishes an event corresponding to the theme, and the event published here may be understood as transaction parameters, device parameters, control instructions, etc. sent by the first IOT device. For example, when the face-swiping payment device publishes the event of the device theme, it can publish the transaction amount, transaction card, etc.

The above embodiment specifically describes that the first server generates the first transaction request, and sends the first transaction request to the blockchain system, and the blockchain system calls the device management contract to generate and store the first IOT device information recorded thereon. A transaction log for the second server to determine whether to subscribe to the topic of the first IOT device. In addition, the first server can also obtain the second transaction log in the blockchain system, and determine whether to subscribe to the second IOT device topic according to the second transaction log, as described in the following embodiments.

The first server subscribes to the device management topic, and when a transaction log corresponding to the device management topic is added to the blockchain system, the first server obtains the transaction log. Specifically, after adding an IOT device to the second server, the second server generates a second transaction request according to the device information of the newly added IOT device, where the second transaction request includes the second IOT device information, and the second IOT device information is the first transaction request. Device information of the newly added IOT device under the second server. The second server sends the second transaction request to the blockchain system, and the blockchain system calls the device management contract to generate a second transaction log and stores it in the blockchain system, wherein the second transaction log records the second IOT Device information, after determining that there is a new second transaction log in the blockchain system, the first server determines whether to subscribe to the second IOT device topic indicated by the second IOT device information according to the second transaction log, and if so, according to The second IOT device topic sends a monitoring request to the blockchain system, where the monitoring request is used to acquire new events published by the second IOT device.

Further, after the first server determines to subscribe to the topic of the second IOT device, the MQTT cluster corresponding to the first server can perform corresponding configuration according to the topic of the second IOT device, so that the first server obtains new events published by the second IOT device. Afterwards, the first server may send the newly added event to the IOT device under the first server through the MQTT cluster. And the IOT device under the first server may also be configured accordingly based on the theme of the second IOT device, so as to implement related operations after receiving a new event published by the second IOT device.

In this embodiment of the present invention, the specific implementation of the first server acquiring the second transaction log to determine whether to subscribe to the topic of the second IOT device is similar to the specific implementation of the second server acquiring the first transaction log to determine whether to subscribe to the topic of the first IOT device. This will not be repeated here.

The second server may be at least one, and the second server may be different servers in different embodiments. Assuming that the IOT device alliance system includes four publish and subscribe servers A, B, C, and D, in one embodiment, if there is a new device in the IOT device cluster corresponding to the A publish and subscribe server, then the A publish and subscribe server is understood as The first server, the three publish and subscribe servers B, C, and D are all understood as the second server. Further, the publish and subscribe server A generates the first transaction request and sends it to the blockchain system, and the blockchain system generates the first transaction. log, the first transaction log can be subscribed by three publish and subscribe servers B, C and D. If at this time, two publish and subscribe servers B and D determine to subscribe to the topic of the newly added device, it can be determined that B and D Each publish-subscribe server sends monitoring requests to the blockchain system respectively. In another embodiment, the A publish and subscribe server is the first server, the A publish and subscribe server subscribes to the second transaction log, and the second transaction log is the area after the B publish and subscribe server sends the second transaction request to the blockchain system is generated by the blockchain system, then the B publish and subscribe server is the second server in this embodiment.

In addition, the IOT device under the first server can also be deleted. After the first server receives the deletion instruction, it generates a first transaction request according to the information of the IOT device to be deleted in the deletion instruction, wherein the first transaction request includes The first IOT device information, where the first IOT device information is the IOT device information to be deleted. Specifically, the first server generates a first transaction request, and sends the first transaction request to the blockchain system, and the blockchain system invokes the device management contract to generate and store the first transaction log corresponding to the device management topic. The log includes first IOT device information. The second server obtains the first transaction log, and unsubscribes the first IOT device topic from the blockchain system according to the first transaction log. Of course, the modification of an IOT device may include not only adding and deleting devices, but also updating devices, such as device parameter modification, connection relationship change, etc., which is equivalent to that the first server receives a modification instruction, and the modification instruction is used to instruct the IOT Equipment addition, deletion or parameter change, etc.

In addition, after the first server sends a transaction request to the blockchain system, the second server can subscribe or unsubscribe from the topic of the first IOT device, and the first server can also subscribe or unsubscribe from the topic of the first IOT device. For example, as shown in Figure 6, there is a new device in financial institution 2 that is a face-scanning payment device. After the first server sends the first transaction request to the blockchain system, the blockchain system generates a first transaction log, and the first transaction log is generated. The second server subscribes to the device topic of the face-swiping payment device, and sends it to the transaction statistics device after acquiring the publishing event of the face-swiping payment device. In addition, the first server can also determine whether it needs to subscribe to the face-swiping payment device according to the first transaction log. The device topic of the device. If the first server determines that the code-scanning payment device needs to obtain the publication event of the face-scanning payment device, the first server can also subscribe to the device topic of the face-scanning payment device, and obtains the release event of the face-scanning payment device. After the event, it will be sent to the scan code payment device. That is to say, the first server can also determine whether to subscribe or unsubscribe from the first IOT device topic according to the first IOT device topic indicated by the first IOT device information in the first transaction log. The first IOT device information in the instruction directly determines whether to subscribe or unsubscribe from the first IOT device topic.

In the above technical solution, a method for changing an IOT device suitable for an IOT device alliance system is provided. Specifically, changing a device in the system may be adding a device, deleting a device, updating a device, etc. in the system, and changing the device can be performed. It is defined as the first IOT device, and the first server is used to manage the first IOT device. The first server generates a first transaction request containing the information of the first IOT device, and sends it to the blockchain system, and the blockchain system receives the first transaction request, invokes the device management contract, and generates a first transaction that records the information of the first IOT device. log, and store the first transaction log in the blockchain system. The second server can obtain the first transaction log by subscribing to the device management topic, and determine whether to subscribe to the first IOT device topic according to the first transaction log. If the second server subscribes to the topic of the first IOT device, the second server can obtain the event published by the first IOT device. In the IOT device alliance system, after the second server obtains the event published by the first IOT device, the event can be It is sent to the corresponding IOT device, so that the IOT device corresponding to the second server receives the event published by the first IOT device. When changing the device in the system, the first server only needs to write the transaction of changing the device information in the blockchain system, then the second server can obtain the information of the changed device by subscribing to the device management topic, and execute the transaction for the changed device information. Action accordingly. The whole system does not require a bridge to change the binding or mapping of devices, and avoids inconsistencies due to the fact that MQ and bridge services belong to different financial institutions, reducing operation and maintenance costs, and is suitable for rapidly developing IOT networking systems.

Based on the same inventive concept, FIG. 7 exemplarily shows the structure of an apparatus for changing an IOT device based on a blockchain provided by an embodiment of the present invention, and the apparatus can execute the flow of a method for changing an IOT device based on the blockchain. .

The device includes:

A processing unit 701, configured to generate a first transaction request including first IOT device information; the first IOT device information is the device information of the IOT device changed under the first server; the first server is the multiple servers any one of;

A transceiver unit 702, configured to send the first transaction request to the blockchain system; the first transaction request is used to instruct the blockchain system to call a device management contract to generate and store a first transaction log; The first transaction log records the device management topic and the first IOT device information; any server in the IOT device alliance system is subscribed to the device management topic; the first transaction log is used for the second server Determine whether to subscribe to the first IOT device topic indicated by the first IOT device information; the second server is any server other than the first server in the IOT device alliance system.

Optionally, the processing unit 701 is further configured to:

Obtain a second transaction log from the blockchain system; the second transaction log is generated by the blockchain system calling the device management contract based on the second transaction request sent by the second server; the The second transaction log records the second IOT device information and the device management topic, and the second IOT device information is the device information of the newly added IOT device under the second server;

According to the second IOT device information in the second transaction log, the second IOT device topic indicated by the second IOT device information is subscribed to the blockchain system.

Optionally, the processing unit 701 is further configured to:

Before generating the first transaction request including the first IOT device information, generating the first IOT device subject according to the first IOT device information;

According to the first IOT device topic, generate and control the transceiver unit 702 to send a first deployment request to the blockchain system; the first deployment request is used to instruct the blockchain system to deploy the first deployment request The theme contract for the theme of the IOT device;

Controlling the transceiver unit 702 to receive the first deployment result returned by the blockchain system, where the first deployment result is sent after the blockchain system completes the deployment of the theme contract of the first IOT device theme; The first deployment result includes the contract address of the subject contract of the first IOT device subject.

Optionally, the processing unit 701 is further configured to:

Before generating the first deployment request, control the transceiver unit 702 to send a second deployment request to the blockchain system; the second deployment request is used to instruct the blockchain system to deploy a system contract;

Control the transceiver unit 702 to receive the second deployment result returned by the blockchain system; the second deployment result is sent after the blockchain system completes the deployment of the system contract;

The processing unit 701 is also used for:

After controlling the transceiver unit 702 to receive the first deployment result returned by the blockchain system, update the correspondence between the first IOT device topic and the contract address of the topic contract of the first IOT device topic to the the system contract.

Based on the same inventive concept, an embodiment of the present invention also provides a computing device, including:

memory for storing program instructions;

The processor is configured to call the program instructions stored in the memory, and execute the above method for changing the IOT device based on the blockchain according to the obtained program.

Based on the same inventive concept, an embodiment of the present invention also provides a computer-readable non-volatile storage medium, including computer-readable instructions, when the computer reads and executes the computer-readable instructions, the computer executes the above-mentioned region-based A method for changing the IOT device of the blockchain.

The present invention is described with reference to flowchart illustrations and/or block diagrams of methods, apparatus (systems), and computer program products according to embodiments of the invention. It will be understood that each flow and/or block in the flowchart illustrations and/or block diagrams, and combinations of flows and/or blocks in the flowchart illustrations and/or block diagrams, can be implemented by computer program instructions. These computer program instructions may be provided to the processor of a general purpose computer, special purpose computer, embedded processor or other programmable data processing device to produce a machine such that the instructions executed by the processor of the computer or other programmable data processing device produce Means for implementing the functions specified in a flow or flow of a flowchart and/or a block or blocks of a block diagram.

These computer program instructions may also be stored in a computer-readable memory capable of directing a computer or other programmable data processing apparatus to function in a particular manner, such that the instructions stored in the computer-readable memory result in an article of manufacture comprising instruction means, the instructions The apparatus implements the functions specified in the flow or flow of the flowcharts and/or the block or blocks of the block diagrams.

These computer program instructions can also be loaded on a computer or other programmable data processing device to cause a series of operational steps to be performed on the computer or other programmable device to produce a computer-implemented process such that The instructions provide steps for implementing the functions specified in the flow or blocks of the flowcharts and/or the block or blocks of the block diagrams.

Although preferred embodiments of the present invention have been described, additional changes and modifications to these embodiments may occur to those skilled in the art once the basic inventive concepts are known. Therefore, the appended claims are intended to be construed to include the preferred embodiment and all changes and modifications that fall within the scope of the present invention.

It will be apparent to those skilled in the art that various modifications and variations can be made in the present invention without departing from the spirit and scope of the invention. Thus, provided that these modifications and variations of the present invention fall within the scope of the claims of the present invention and their equivalents, the present invention is also intended to include these modifications and variations.

Claims (10)

1. a kind of Internet of Things IOT equipment changing method based on block chain, which is characterized in that suitable for including multiple servers IOT equipment alliance system；Each server is for managing respective IOT equipment；The multiple server passes through block catenary system Carry out the information exchange of IOT equipment；

The described method includes:

First server generates the first transaction request comprising the first IOT facility information；The first IOT facility information is described The facility information of the IOT equipment changed under first server；The first server is any of the multiple server；

First transaction request is sent to the block catenary system by the first server；First transaction request is used for Indicate that the block catenary system calls equipment management contract to generate and store the first transaction log；First transaction log record There are equipment management theme and the first IOT facility information；Any server in the IOT equipment alliance system, which is subscribed to, to be had The equipment management theme；First transaction log determines whether to subscribe to the first IOT equipment letter for second server Cease the first IOT equipment theme of instruction；The second server is that the first server is removed in the IOT equipment alliance system Any server in addition.

2. the method as described in claim 1, which is characterized in that the method also includes:

The first server obtains the second transaction log from the block catenary system；Second transaction log is the area Block catenary system calls the equipment management contract to generate based on the second transaction request that the second server is sent；Described Record has the 2nd IOT facility information and the equipment management theme in two transaction logs, and the 2nd IOT facility information is described The facility information of the IOT equipment increased newly under second server；

The first server is ordered according to the 2nd IOT facility information in second transaction log, Xiang Suoshu block catenary system Read the 2nd IOT equipment theme indicated by the 2nd IOT facility information.

3. the method as described in claim 1, which is characterized in that it includes the first IOT facility information that the first server, which generates, The first transaction request before, further includes:

The first server generates the first IOT equipment theme according to the first IOT facility information；

The first server generates according to the first IOT equipment theme and sends the first deployment to the block catenary system Request；The first deployment request is used to indicate the theme contract that the block catenary system disposes the first IOT equipment theme；

The first server receives the first deployment that the block catenary system returns as a result, first deployment is the result is that described What block catenary system was completed to send after the deployment of the theme contract of the first IOT equipment theme；The first deployment result packet Include the contract address of the theme contract of the first IOT equipment theme.

4. method as claimed in claim 3, which is characterized in that before the first server generates the first deployment request, Further include:

The first server sends the second deployment request to the block catenary system；The second deployment request is used to indicate institute State block catenary system deployment system contract；

The first server receives the second deployment result that the block catenary system returns；Second deployment is the result is that described What block catenary system was completed to send after the deployment of the system contract；

After the first deployment result that the first server receives that the block catenary system returns, further includes:

The first server is by the contract of the first IOT equipment theme and the theme contract of the first IOT equipment theme The corresponding relationship of address is updated to the system contract.

5. a kind of device of the IOT equipment changing based on block chain characterized by comprising

Processing unit, for generating the first transaction request comprising the first IOT facility information；The first IOT facility information is The facility information of the IOT equipment changed under first server；The first server is any of the multiple server；

Transmit-Receive Unit, for first transaction request to be sent to the block catenary system；First transaction request is used for Indicate that the block catenary system calls equipment management contract to generate and store the first transaction log；First transaction log record There are equipment management theme and the first IOT facility information；Any server in the IOT equipment alliance system, which is subscribed to, to be had The equipment management theme；First transaction log determines whether to subscribe to the first IOT equipment letter for second server Cease the first IOT equipment theme of instruction；The second server is that the first server is removed in the IOT equipment alliance system Any server in addition.

6. device as claimed in claim 5, which is characterized in that the processing unit is also used to:

The second transaction log is obtained from the block catenary system；Second transaction log is that the block catenary system is based on institute The second transaction request for stating second server transmission calls the equipment management contract to generate；Remember in second transaction log Record has the 2nd IOT facility information and the equipment management theme, and the 2nd IOT facility information is new under the second server The facility information of the IOT equipment of increasing；

According to the 2nd IOT facility information in second transaction log, Xiang Suoshu block catenary system is subscribed to the 2nd IOT and is set 2nd IOT equipment theme indicated by standby information.

7. device as claimed in claim 5, which is characterized in that the processing unit is also used to:

It is described generate the first transaction request comprising the first IOT facility information before, according to the first IOT facility information, Generate the first IOT equipment theme；

According to the first IOT equipment theme, generates and control the Transmit-Receive Unit to block catenary system transmission first Administration's request；The first deployment request is used to indicate the theme conjunction that the block catenary system disposes the first IOT equipment theme About；

It controls the Transmit-Receive Unit and receives the first deployment of the block catenary system return as a result, described first disposes the result is that institute It states and sends after the deployment for the theme contract that block catenary system completes the first IOT equipment theme；The first deployment result The contract address of theme contract including the first IOT equipment theme.

8. device as claimed in claim 7, which is characterized in that the processing unit is also used to:

Before the first deployment of generation request, controls the Transmit-Receive Unit and asked to the second deployment of block catenary system transmission It asks；The second deployment request is used to indicate the block catenary system deployment system contract；

It controls the Transmit-Receive Unit and receives the second deployment result that the block catenary system returns；Second deployment is the result is that institute State what block catenary system was completed to send after the deployment of the system contract；

The processing unit is also used to:

After controlling the Transmit-Receive Unit and receiving the first deployment result that the block catenary system returns, by the first IOT The corresponding relationship of the contract address of the theme contract of equipment theme and the first IOT equipment theme is updated to the system and closes About.

9. a kind of calculating equipment characterized by comprising

Memory, for storing program instruction；

Processor requires 1 to 4 according to the program execution benefit of acquisition for calling the program instruction stored in the memory Described in any item methods.

10. a kind of computer-readable non-volatile memory medium, which is characterized in that including computer-readable instruction, work as computer When reading and executing the computer-readable instruction, so that computer executes such as the described in any item methods of Claims 1-4.