CN111258810A - Method, system, terminal equipment and storage medium for realizing data source switching - Google Patents

Abstract

The present invention provides a method, system, terminal device and storage medium for switching data sources. The method includes: detecting whether a host is down; upgrading a cold backup data source to a temporary primary data source and broadcasting notification when the host is down The application program enables the application program to provide SMS aggregation services based on the temporary main data source; when the host is not down, the application program provides SMS aggregation services based on the main data source. The present invention provides continuously available short message capability, so that data sources can be replaced without restarting, thereby providing users with a reliable and stable short message aggregation service.

Description

A method, system, terminal device and storage medium for realizing switching data source

technical field

The present invention relates to the technical field of data processing, in particular to an implementation method, system, terminal device and storage medium for switching data sources.

Background technique

General enterprises have the ability to send short messages, relying on third-party short message services or integrating third-party short message capabilities into short message aggregation services. The SMS aggregation service is an important basic service for the business services required by many users.

In order to improve the availability and stability of the SMS aggregation service, the SMS aggregation service will be deployed in dual computer rooms. Generally, under the dual-computer room architecture, there will be a cold standby database in the computer room. When the computer room is switched, the cold standby database will be upgraded to the main database. The application needs to modify the data source configuration, and restart the configuration to take effect. In this way, the SMS aggregation service needs to be restarted before loading the new data source, which leads to an increase in the unstable time of the SMS aggregation service and affects the user experience.

Therefore, how to provide a continuously available short message capability so that the data source can be replaced without restarting, so as to provide users with a reliable and stable short message aggregation service is an urgent problem to be solved.

SUMMARY OF THE INVENTION

The purpose of the present invention is to provide an implementation method, system, terminal device and storage medium for switching data sources, so as to realize the ability to provide continuously available short messages, so as to be able to replace data sources without restarting, thereby providing users with reliable and stable SMS aggregation service.

The technical scheme provided by the present invention is as follows:

The present invention provides an implementation method for switching data sources, comprising the steps of:

Check whether the host is down;

When the host is down, the cold standby data source is upgraded to a temporary primary data source and broadcast to notify the application, so that the application provides the short message aggregation service according to the temporary primary data source;

When the host is not down, the application provides a short message aggregation service according to the main data source.

Further, before the detection of whether the host is down, the steps include:

Obtain data source configuration information every preset time period;

The step of upgrading the cold standby data source to a temporary primary data source when the host is down and informing the application program by broadcasting, so that the application program provides the short message aggregation service according to the temporary primary data source includes the steps:

When the host is down, upgrade the cold backup data source to a temporary primary data source;

Initialize the main data source, and create a first data source object according to the newly acquired data source configuration information;

Perform data source configuration according to the cold standby data source configuration information in the newly acquired data source configuration information;

After the configuration is completed, the data source switching information is broadcast and sent, so that the application program switches to access the temporary main data source through the first data source object, so that the application program provides the short message aggregation service according to the temporary main data source.

Further, before the detection of whether the host is down, the steps include:

Obtain data source configuration information every preset time period;

The provision of the short message aggregation service by the application according to the main data source when the host is not down includes the steps:

Initialize the primary data source when the host is not down, and create a second data source object according to the newly acquired data source configuration information;

After the creation is completed, the object creation information is broadcast and sent, so that the application program accesses the main data source through the second data source object, so that the application program provides a short message aggregation service according to the main data source.

Further, the detecting whether the host is down includes the steps:

When the heartbeat message from the host is not received within a preset time period, it is determined that the host is down.

The present invention also provides an implementation system for switching data sources, including:

Detection module, used to detect whether the host is down;

a processing module, configured to upgrade the cold standby data source to a temporary primary data source when the host is down, and broadcast to notify the application program, so that the application program provides the short message aggregation service according to the temporary primary data source;

The processing module is further configured to provide the short message aggregation service by the application according to the main data source when the host is not down.

Further, it also includes:

The acquisition module is used to acquire the data source configuration information every preset time period;

The processing module includes:

a first processing unit, configured to upgrade the cold backup data source to a temporary primary data source when the host is down;

a first creation unit, used to initialize the main data source, and create a first data source object according to the newly acquired data source configuration information;

a configuration unit, configured to perform data source configuration according to the cold standby data source configuration information in the newly acquired data source configuration information;

The execution unit is configured to broadcast and send data source switching information after the configuration is completed, so that the application program switches to access the temporary main data source through the first data source object, so that the application program provides the temporary main data source according to the SMS aggregation service.

Further, the processing module includes:

a second creation unit, configured to initialize the main data source when the host is not down, and create a second data source object according to the newly acquired data source configuration information;

The second execution unit is configured to broadcast and send object creation information after the creation is completed, so that the application program can access the main data source through the second data source object, so that the application program can provide SMS aggregation according to the main data source Serve.

Further, the detection module is further configured to determine that the host is down when a heartbeat message from the host is not received within a preset time period.

The present invention also provides a terminal device, comprising a processor, a memory, and a computer program stored in the memory and running on the processor, where the processor is used to execute a computer program stored in the memory The program implements the operations performed by the described implementation method for switching data sources.

The present invention also provides a storage medium, characterized in that the storage medium stores at least one instruction, and the instruction is loaded and executed by a processor to implement the operations performed by the method for switching data sources.

The method, system, terminal device and storage medium for switching data sources provided by the present invention can provide continuously available short message capabilities, so that data sources can be replaced without restarting, thereby providing users with reliable and stable short messages Aggregation service.

Description of drawings

The preferred embodiments will be described below in a clear and easy-to-understand manner with reference to the accompanying drawings, and further description will be given of the above-mentioned characteristics, technical features, advantages and implementation methods of a method, system, terminal device and storage medium for switching data sources.

1 is a flow chart of an embodiment of a method for implementing switching data sources of the present invention;

2 is a flowchart of another embodiment of a method for implementing data source switching according to the present invention;

FIG. 3 is a flowchart of another embodiment of a method for implementing switching data sources of the present invention;

FIG. 4 is a flowchart of another embodiment of a method for realizing switching data sources of the present invention;

FIG. 5 is a flowchart of another embodiment of a method for implementing switching data sources of the present invention;

6 is a flow chart of another embodiment of a method for implementing switching data sources of the present invention;

7 is a schematic structural diagram of an embodiment of an implementation system for switching data sources according to the present invention;

Fig. 8 is the configuration flow schematic diagram of apollo configuration center of the present invention;

Fig. 9 is apollo configuration center configuration flow schematic diagram of the present invention;

FIG. 10 is a schematic structural diagram of an embodiment of a computer device of the present invention.

Detailed ways

In the following description, for the purpose of illustration rather than limitation, specific details such as a specific system structure and technology are set forth in order to provide a thorough understanding of the embodiments of the present application. However, it will be apparent to those skilled in the art that the present application may be practiced in other embodiments without these specific details. In other instances, detailed descriptions of well-known systems, devices, circuits, and methods are omitted so as not to obscure the description of the present application with unnecessary detail.

It is to be understood that, when used in this specification and the appended claims, the term "comprising" indicates the presence of the described feature, integer, step, operation, element and/or component, but does not exclude one or more other The presence or addition of features, integers, steps, operations, elements, components and/or collections.

In order to keep the drawings concise, the drawings only schematically show the parts related to the present invention, and they do not represent its actual structure as a product. In addition, in order to make the drawings concise and easy to understand, in some drawings, only one of the components having the same structure or function is schematically shown, or only one of them is marked. As used herein, "one" not only means "only one", but also "more than one".

It should also be further understood that, as used in this specification and the appended claims, the term "and/or" refers to and including any and all possible combinations of one or more of the associated listed items .

In specific implementation, the terminal devices described in the embodiments of the present application include, but are not limited to, other portable devices such as mobile phones, laptop computers or tablet computers with touch-sensitive surfaces (eg, touch screen displays and/or touch pads). .

The terminal device supports various applications such as one or more of the following: drawing applications, presentation applications, web creation applications, word processing applications, disc burning applications, spreadsheet applications, gaming applications, telephony Apps, Video Conferencing Apps, Email Apps, Instant Messaging Apps, Workout Support Apps, Photo Management Apps, Digital Camera Apps, Digital Video Camera Apps, Web Browsing Apps, Digital Music Player Apps and/or digital video player applications.

In addition, in the description of the present application, the terms "first", "second" and the like are only used to distinguish the description, and cannot be understood as indicating or implying relative importance.

In order to more clearly describe the embodiments of the present invention or the technical solutions in the prior art, the specific embodiments of the present invention will be described below with reference to the accompanying drawings. Obviously, the accompanying 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 creative efforts, and obtain other implementations.

An embodiment of the present invention, as shown in FIG. 1 , is an implementation method for switching data sources, including:

S100 detects whether the host is down;

Specifically, the short message aggregation service is a basic capability of a short message communication service provided for users, and usually refers to a short message sending service. SMS aggregation services include group SMS, SMS verification code, SMS notification, promotional SMS, marketing SMS, member notification SMS and other communication services. Among them, the SMS notification supports notification SMS sending in various scenarios. The promotion SMS supports the sending of SMS notifications in various business scenarios, such as supporting the mass messaging of business and supermarkets, mass messaging of real estate, mass messaging of education, mass messaging of e-commerce, mass messaging of credit cards, mass messaging of recruitment and other communication services such as mass messaging of industry messages.

When the host is down, the S200 upgrades the cold backup data source to a temporary primary data source and broadcasts it to the application, so that the application provides SMS aggregation services based on the temporary primary data source;

The S300 provides SMS aggregation services based on the main data source when the host is not down.

Specifically, in this embodiment, when the host is down, the cold backup data source is upgraded to a temporary primary data source and broadcasted to notify the application, so that the application provides the short message aggregation service according to the temporary primary data source, so that when the data source is switched, the short message The aggregation service does not need to be restarted, and the new data source is automatically loaded, which reduces the time of service instability, reduces the time to modify the configuration, and is friendly to operation and maintenance.

In addition, when the host is down, the cold backup data source is upgraded to a temporary primary data source and broadcast to the application, so that the application can provide SMS aggregation services based on the temporary primary data source, improve the efficiency of data source switching, and avoid the failure of the host when the actual downtime occurs. The situation of switching data sources in time ensures the stability of the SMS aggregation service and improves the user experience.

An embodiment of the present invention, as shown in FIG. 2 , is a method for implementing data source switching, including:

S010 obtains data source configuration information every preset time period;

S100 detects whether the host is down;

S210 upgrades the cold backup data source to the temporary primary data source when the host is down;

S220 initializes the main data source, and creates a first data source object according to the newly acquired data source configuration information;

S230 performs data source configuration according to the cold standby data source configuration information in the newly acquired data source configuration information;

S240, after the configuration is completed, the data source switching information is broadcast and sent, so that the application program switches to access the temporary main data source through the first data source object, so that the application program provides the short message aggregation service according to the temporary main data source;

The S300 provides SMS aggregation services based on the main data source when the host is not down.

Specifically, the parts in this embodiment that are the same as the above-mentioned embodiments will not be repeated here. In this embodiment, the data source configuration information is obtained every preset time period, and the obtained data source configuration information includes druidProperties (main data source configuration), namespace (apollo space name where the standby data source configuration is located), name (property source configuration) name), prefix (attribute prefix), key (attribute key for switching the data source switch).

As shown in Figure 8 and Figure 9, when the host is down, modify the data source configuration corresponding to the namespace of the Apollo configuration center, that is, write the namespace (the name of the apollo space where the standby data source configuration is located) into the Apollo configuration center,

New a Builder means creating a first data source object. Specifically, initializing the builder according to the above data source configuration information and the corresponding method of the Builder, and calling the build() method to create the first data source object, so that the application can be like a common data source. The newly created first data source object is also used, where the first data source object is a cold standby data source upgraded to a temporary primary data source.

Modify key=true, this step is to switch the main data source to the cold standby data source, ApolloHotReplaceSwitchListener listens to the change of the key, and calls the handle method of ApolloDruidSourceHandler to switch the data source. The broadcast informs the application configuration to switch to the cold standby database, create a new builder, initialize the builder according to the above information and the corresponding method of the builder, and call the build() method to create the first data source object. backup data source.

When the host is down, upgrade the cold standby data source to a temporary primary data source and broadcast it to the application, so that the application can provide SMS aggregation services according to the temporary primary data source, so that the SMS aggregation service does not need to be restarted when the data source is switched, and the new SMS aggregation service is automatically loaded. Data source, reduce the time of service instability, reduce the time to modify the configuration, and be friendly to operation and maintenance.

In addition, when the host is down, the cold backup data source is upgraded to a temporary primary data source and broadcast to the application, so that the application can provide SMS aggregation services based on the temporary primary data source, improve the efficiency of data source switching, and avoid the failure of the host when the actual downtime occurs. The situation of switching data sources in time ensures the stability of the SMS aggregation service and improves the user experience.

An embodiment of the present invention, as shown in FIG. 3 , is a method for implementing data source switching, including:

S010 obtains data source configuration information every preset time period;

S100 detects whether the host is down;

When the host is down, the S200 upgrades the cold backup data source to a temporary primary data source and broadcasts it to the application, so that the application provides SMS aggregation services based on the temporary primary data source;

S310 initializes the main data source when the host is not down, and creates a second data source object according to the newly acquired data source configuration information;

After S320 is created, the object creation information is broadcast and sent, so that the application program accesses the main data source through the second data source object, so that the application program provides the short message aggregation service according to the main data source.

Specifically, the parts in this embodiment that are the same as the above-mentioned embodiments will not be repeated here. In this embodiment, the data source configuration information is obtained every preset time period, and the obtained data source configuration information includes druidProperties (main data source configuration), namespace (apollo space name where the standby data source configuration is located), name (property source configuration) name), prefix (attribute prefix), key (attribute key for switching the data source switch).

As shown in Figure 8 and Figure 9, New a Builder is to create a new data source object. Specifically, the builder is initialized according to the above data source configuration information and the corresponding method of the Builder, and the build() method is called to create a second data source object, so as to make the application The program can use the newly created second data source object like a common data source, where the second data source object is upgraded to the primary data source.

Modify key=false, this step is to roll back the main data source, ApolloHotReplaceSwitchListener listens to the change of the key, and calls the rollback method of ApolloDruidSourceHandler to roll back the main data source according to druidProperties.

Specifically, in this embodiment, when the host is down, the cold backup data source is upgraded to a temporary primary data source and broadcasted to notify the application, so that the application provides the short message aggregation service according to the temporary primary data source, so that when the data source is switched, the short message The aggregation service does not need to be restarted, and the new data source is automatically loaded, which reduces the time of service instability, reduces the time to modify the configuration, and is friendly to operation and maintenance.

In addition, when the host is down, the cold backup data source is upgraded to a temporary primary data source and broadcast to the application, so that the application can provide SMS aggregation services based on the temporary primary data source, improve the efficiency of data source switching, and avoid the failure of the host when the actual downtime occurs. The situation of switching data sources in time ensures the stability of the SMS aggregation service and improves the user experience.

An embodiment of the present invention, as shown in FIG. 4 , is a method for implementing data source switching, including:

S010 obtains data source configuration information every preset time period;

When S110 does not receive a heartbeat message from the host within a preset time period, it is determined that the host is down;

S210 upgrades the cold backup data source to the temporary primary data source when the host is down;

S220 initializes the main data source, and creates a first data source object according to the newly acquired data source configuration information;

S230 performs data source configuration according to the cold standby data source configuration information in the newly acquired data source configuration information;

S240, after the configuration is completed, the data source switching information is broadcast and sent, so that the application program switches to access the temporary main data source through the first data source object, so that the application program provides the short message aggregation service according to the temporary main data source;

The S300 provides SMS aggregation services based on the main data source when the host is not down.

Specifically, the parts in this embodiment that are the same as the above-mentioned embodiments will not be repeated here. In the implementation scenario of the embodiment of the present invention, the server may perform heartbeat detection on the host. The server may be a node with a heartbeat detection mechanism and capable of receiving heartbeat messages, and the host may be a node with a heartbeat detection mechanism and capable of sending heartbeat messages.

In the implementation scenario of the embodiment of the present invention, the host may send a heartbeat message to the server at regular intervals. The time when the server receives a heartbeat message from the host is the start time. If the server receives the next heartbeat message from the host within the heartbeat timeout period, it is determined that the host is in a normal working state. If the server does not receive a heartbeat message within the heartbeat timeout period To the next heartbeat message from the host, it is determined that the host is down. The host down can be considered as the host has stopped working, or it can be considered as the host's working efficiency is significantly lower than the normal working efficiency, because this situation is related to the host stopping. The work situation can be regarded as the same situation and treated the same.

In the implementation scenario of the embodiment of the present invention, the server may also send a request message to the host, and the host will send a heartbeat message to the server after receiving the request message when there is no downtime. The time when the request message is sent from the server is the start time. If the server receives a heartbeat message from the host within the heartbeat timeout period, it is determined that the host is in a normal working state. If the server does not receive a heartbeat message from the host within the heartbeat timeout period, It is determined that the host is down.

Through this embodiment, the host downtime detection is carried out by means of the heartbeat mechanism, so as to avoid artificial subjective judgment of whether the host is down. Since the background automatically and intelligently determines whether the detection host is down, once it is detected that the host is down, the data source can be switched. Improve the accuracy and efficiency of data source switching, avoid the situation that the host cannot switch data sources in time when the host actually goes down, thereby ensuring the stability of the SMS aggregation service and improving the user experience.

An embodiment of the present invention, as shown in FIG. 5 , is a method for implementing data source switching, including:

S010 obtains data source configuration information every preset time period;

When S110 does not receive a heartbeat message from the host within a preset time period, it is determined that the host is down;

When the host is down, the S200 upgrades the cold backup data source to a temporary primary data source and broadcasts it to the application, so that the application provides SMS aggregation services based on the temporary primary data source;

S310 initializes the main data source when the host is not down, and creates a second data source object according to the newly acquired data source configuration information;

After S320 is created, the object creation information is broadcast and sent, so that the application program accesses the main data source through the second data source object, so that the application program provides the short message aggregation service according to the main data source.

Specifically, the parts in this embodiment that are the same as the above-mentioned embodiments will not be repeated here.

An embodiment of the present invention, as shown in FIG. 6 , is a method for implementing data source switching, including:

S010 obtains data source configuration information every preset time period;

When S110 does not receive a heartbeat message from the host within a preset time period, it is determined that the host is down;

S210 upgrades the cold backup data source to the temporary primary data source when the host is down;

S220 initializes the main data source, and creates a first data source object according to the newly acquired data source configuration information;

S230 performs data source configuration according to the cold standby data source configuration information in the newly acquired data source configuration information;

S240, after the configuration is completed, the data source switching information is broadcast and sent, so that the application program switches to access the temporary main data source through the first data source object, so that the application program provides the short message aggregation service according to the temporary main data source;

S310 initializes the main data source when the host is not down, and creates a second data source object according to the newly acquired data source configuration information;

After S320 is created, the object creation information is broadcast and sent, so that the application program accesses the main data source through the second data source object, so that the application program provides the short message aggregation service according to the main data source.

Specifically, the parts in this embodiment that are the same as the above-mentioned embodiments will not be repeated here.

Exemplarily, as shown in Figure 8 and Figure 9, the Apollo configuration center, the Apollo configuration center is an open source configuration management center, an open source configuration management center, which can centrally manage the configuration and configuration modification of different environments and clusters After that, it can be pushed to the application side in real time, and has the characteristics of standardized permissions and process governance.

Apollo Configuration Center provides a unified interface to centrally manage the configuration of different environments, clusters, and namespaces.

The same code is deployed in different clusters and can have different configurations, such as the address of zookeeper.

The namespace can easily support multiple different applications to share the same configuration, and also allow applications to override the shared configuration.

After the user modifies the configuration in the Apollo configuration center and publishes it, the client can receive the latest configuration in real time (1 second) and notify the application.

All configuration releases have a version concept, which can easily support configuration rollback.

Once the host is down, the operation and maintenance personnel will switch the configuration and publish the data source in the Apollo configuration center. The Apollo configuration center will notify the host that there is a configuration update, and the host will pull the latest configuration from the Apollo configuration center to update the data source information. Then the Apollo configuration center updates the local configuration and notifies the application. Through the method of data source hot replacement, the SMS aggregation service does not need to be restarted, and the new data source is automatically loaded. In this embodiment, because the Apollo configuration center monitors the attribute information of the configuration data source switch (that is, the attribute key for switching the data source switch), it can be actively pushed to the application program of the cluster scale, and the delay is low, so that the application program can obtain the information at runtime. New data source configuration, creating a new data source to replace the old data source, so that the host can read the data information of the cold standby data source switched to the temporary primary data source without restarting the application, and then according to the data of the cold standby data source Information provides SMS aggregation services. Improve the accuracy and efficiency of data source switching, avoid the situation that the host cannot switch data sources in time when the host actually goes down, thereby ensuring the stability of the SMS aggregation service and improving the user experience.

The above embodiment only exemplifies the Apollo configuration center. The Apollo configuration center can be replaced by the Zookeeper configuration center, the redis configuration center, or the nacos configuration center as needed.

An embodiment of the present invention, as shown in FIG. 7 , is a system for realizing switching of data sources, including:

The detection module 10 is used to detect whether the host is down;

The processing module 20 is used to upgrade the cold standby data source to a temporary primary data source when the host is down and broadcast to notify the application program, so that the application program provides the short message aggregation service according to the temporary primary data source;

The processing module 20 is further configured to provide the short message aggregation service according to the main data source by the application when the host is not down.

Specifically, the short message aggregation service is a basic capability of a short message communication service provided for users, and usually refers to a short message sending service. SMS aggregation services include group SMS, SMS verification code, SMS notification, promotional SMS, marketing SMS, member notification SMS and other communication services. Among them, the SMS notification supports notification SMS sending in various scenarios. The promotion SMS supports the sending of SMS notifications in various business scenarios, such as supporting the mass messaging of business and supermarkets, mass messaging of real estate, mass messaging of education, mass messaging of e-commerce, mass messaging of credit cards, mass messaging of recruitment and other communication services such as mass messaging of industry messages.

Specifically, in this embodiment, when the host is down, the cold backup data source is upgraded to a temporary primary data source and broadcasted to notify the application, so that the application provides the short message aggregation service according to the temporary primary data source, so that when the data source is switched, the short message The aggregation service does not need to be restarted, and the new data source is automatically loaded, which reduces the time of service instability, reduces the time to modify the configuration, and is friendly to operation and maintenance.

In addition, when the host is down, the cold backup data source is upgraded to a temporary primary data source and broadcast to the application, so that the application can provide SMS aggregation services based on the temporary primary data source, improve the efficiency of data source switching, and avoid the failure of the host when the actual downtime occurs. The situation of switching data sources in time ensures the stability of the SMS aggregation service and improves the user experience.

Based on the foregoing embodiment, it further includes: an acquisition module, configured to acquire data source configuration information every preset time period;

The processing module 20 includes:

The first processing unit is used to upgrade the cold backup data source to the temporary primary data source when the host is down;

a first creation unit, used to initialize the main data source, and create a first data source object according to the newly acquired data source configuration information;

a configuration unit, configured to configure the data source according to the cold standby data source configuration information in the newly acquired data source configuration information;

The execution unit is used to broadcast and send the data source switching information after the configuration is completed, so that the application program can access the temporary main data source through the first data source object switch, so that the application program can provide the short message aggregation service according to the temporary main data source;

Specifically, the parts in this embodiment that are the same as the above-mentioned embodiments will not be repeated here. In this embodiment, the data source configuration information is obtained every preset time period, and the obtained data source configuration information includes druidProperties (main data source configuration), namespace (apollo space name where the standby data source configuration is located), name (property source configuration) name), prefix (attribute prefix), key (attribute key for switching the data source switch).

As shown in Figure 8 and Figure 9, when the host is down, modify the data source configuration corresponding to the namespace of the Apollo configuration center, that is, write the namespace (the name of the apollo space where the standby data source configuration is located) into the Apollo configuration center,

New a Builder means creating a first data source object. Specifically, initializing the builder according to the above data source configuration information and the corresponding method of the Builder, and calling the build() method to create the first data source object, so that the application can be like a common data source. The newly created first data source object is also used, where the first data source object is a cold standby data source upgraded to a temporary primary data source.

Modify key=true, this step is to switch the main data source to the cold standby data source, ApolloHotReplaceSwitchListener listens to the change of the key, and calls the handle method of ApolloDruidSourceHandler to switch the data source. The broadcast informs the application configuration to switch to the cold standby database, create a new builder, initialize the builder according to the above information and the corresponding method of the builder, and call the build() method to create the first data source object. backup data source.

When the host is down, upgrade the cold standby data source to a temporary primary data source and broadcast it to the application, so that the application can provide SMS aggregation services according to the temporary primary data source, so that the SMS aggregation service does not need to be restarted when the data source is switched, and the new SMS aggregation service is automatically loaded. Data source, reduce the time of service instability, reduce the time to modify the configuration, and be friendly to operation and maintenance.

In addition, when the host is down, the cold backup data source is upgraded to a temporary primary data source and broadcast to the application, so that the application can provide SMS aggregation services based on the temporary primary data source, improve the efficiency of data source switching, and avoid the failure of the host when the actual downtime occurs. The situation of switching data sources in time ensures the stability of the SMS aggregation service and improves the user experience.

The processing module 20 includes:

The second creation unit is used to initialize the main data source when the host is not down, and create a second data source object according to the newly acquired data source configuration information;

The second execution unit is configured to broadcast and send the object creation information after the creation is completed, so that the application program can access the main data source through the second data source object, so that the application program can provide the short message aggregation service according to the main data source.

Specifically, the parts in this embodiment that are the same as the above-mentioned embodiments will not be repeated here. In this embodiment, the data source configuration information is obtained every preset time period, and the obtained data source configuration information includes druidProperties (main data source configuration), namespace (apollo space name where the standby data source configuration is located), name (property source configuration) name), prefix (attribute prefix), key (attribute key for switching the data source switch).

As shown in Figure 8 and Figure 9, when the host is down, modify the data source configuration corresponding to the namespace of the Apollo configuration center, that is, write the namespace (the name of the apollo space where the standby data source configuration is located) into the Apollo configuration center,

New a Builder means creating a first data source object. Specifically, initializing the builder according to the above data source configuration information and the corresponding method of the Builder, and calling the build() method to create the first data source object, so that the application can be like a common data source. The newly created first data source object is also used, where the first data source object is a cold standby data source upgraded to a temporary primary data source.

Modify key=true, this step is to switch the main data source to the cold standby data source, ApolloHotReplaceSwitchListener listens to the change of the key, and calls the handle method of ApolloDruidSourceHandler to switch the data source. The broadcast informs the application configuration to switch to the cold standby database, create a new builder, initialize the builder according to the above information and the corresponding method of the builder, and call the build() method to create the first data source object. backup data source.

When the host is down, upgrade the cold standby data source to a temporary primary data source and broadcast it to the application, so that the application can provide SMS aggregation services according to the temporary primary data source, so that the SMS aggregation service does not need to be restarted when the data source is switched, and the new SMS aggregation service is automatically loaded. Data source, reduce the time of service instability, reduce the time to modify the configuration, and be friendly to operation and maintenance.

In addition, when the host is down, the cold backup data source is upgraded to a temporary primary data source and broadcast to the application, so that the application can provide SMS aggregation services based on the temporary primary data source, improve the efficiency of data source switching, and avoid the failure of the host when the actual downtime occurs. The situation of switching data sources in time ensures the stability of the SMS aggregation service and improves the user experience.

Based on the foregoing embodiment, the detection module 10 is further configured to determine that the host is down when the heartbeat message from the host is not received within a preset time period.

Specifically, the parts in this embodiment that are the same as the above-mentioned embodiments will not be repeated here. In the implementation scenario of the embodiment of the present invention, the server may perform heartbeat detection on the host. The server may be a node with a heartbeat detection mechanism and capable of receiving heartbeat messages, and the host may be a node with a heartbeat detection mechanism and capable of sending heartbeat messages.

In the implementation scenario of the embodiment of the present invention, the host may send a heartbeat message to the server at regular intervals. The time when the server receives a heartbeat message from the host is the start time. If the server receives the next heartbeat message from the host within the heartbeat timeout period, it is determined that the host is in a normal working state. If the server does not receive a heartbeat message within the heartbeat timeout period To the next heartbeat message from the host, it is determined that the host is down. The host down can be considered as the host has stopped working, or it can be considered as the host's working efficiency is significantly lower than the normal working efficiency, because this situation is related to the host stopping. The work situation can be regarded as the same situation and treated the same.

In the implementation scenario of the embodiment of the present invention, the server may also send a request message to the host, and the host will send a heartbeat message to the server after receiving the request message when there is no downtime. The time when the request message is sent from the server is the start time. If the server receives a heartbeat message from the host within the heartbeat timeout period, it is determined that the host is in a normal working state. If the server does not receive a heartbeat message from the host within the heartbeat timeout period, It is determined that the host is down.

Through this embodiment, the host downtime detection is carried out by means of the heartbeat mechanism, so as to avoid artificial subjective judgment of whether the host is down. Since the background automatically and intelligently determines whether the detection host is down, once it is detected that the host is down, the data source can be switched. Improve the accuracy and efficiency of data source switching, avoid the situation that the host cannot switch data sources in time when the host actually goes down, thereby ensuring the stability of the SMS aggregation service and improving the user experience.

Those skilled in the art can clearly understand that, for the convenience and conciseness of description, only the division of the above-mentioned program modules is used as an example for illustration. The internal structure of the device is divided into different program units or modules to complete all or part of the functions described above. Each program module in the embodiment may be integrated in one processing unit, or each unit may exist physically alone, or two or more units may be integrated in one processing unit, and the above-mentioned integrated units may be implemented in the form of hardware. , can also be implemented in the form of software program units. In addition, the specific names of each program module are only for the convenience of distinguishing from each other, and are not used to limit the protection scope of the present application.

An embodiment of the present invention, as shown in FIG. 10 , a terminal device 100 includes a processor 110 and a memory 120 , wherein the memory 120 is used to store a computer program 121 ; The stored computer program 121 implements the implementation method of switching data sources in any of the corresponding method embodiments in FIG. 1 to FIG. 6 above.

The terminal device 100 may be a desktop computer, a notebook, a palmtop computer, a tablet computer, a mobile phone, a human-computer interaction screen, and other devices. The terminal device 100 may include, but is not limited to, the processor 110 and the memory 120 . Those skilled in the art can understand that FIG. 10 is only an example of the terminal device 100, and does not constitute a limitation on the terminal device 100, and may include more or less components than the one shown, or combine some components, or different components For example, the terminal device 100 may further include an input/output interface, a display device, a network access device, a communication bus, a communication interface, and the like. The communication interface and the communication bus may also include an input/output interface, wherein the processor 110, the memory 120, the input/output interface and the communication interface communicate with each other through the communication bus. The memory 120 stores a computer program 121, and the processor 110 is configured to execute the computer program 121 stored in the memory 120 to implement the method for switching data sources in any of the corresponding method embodiments in FIG. 1 to FIG. 6 above.

The processor 110 may be a central processing unit (Central Processing Unit, CPU), or other general-purpose processors, a digital signal processor (Digital Signal Processor, DSP), an application specific integrated circuit (Application Specific Integrated Circuit, ASIC), Field-Programmable Gate Array (FPGA) or other programmable logic devices, discrete gate or transistor logic devices, discrete hardware components, etc. A general purpose processor may be a microprocessor or the processor may be any conventional processor or the like.

The memory 120 may be an internal storage unit of the terminal device 100, such as a hard disk or a memory of the terminal device. The memory may also be an external storage device of the terminal device, for example: a plug-in hard disk equipped on the terminal device, a smart memory card (Smart Media Card, SMC), a secure digital (Secure Digital, SD) card, Flash card (Flash Card) and so on. Further, the memory 120 may also include both an internal storage unit of the terminal device 100 and an external storage device. The memory 120 is used to store the computer program 121 and other programs and data required by the terminal device 100 . The memory may also be used to temporarily store data that has been output or is to be output.

A communication bus is a circuit that connects the described elements and enables transmission between these elements. For example, the processor 110 receives commands from other elements through a communication bus, decrypts the received commands, and performs computation or data processing according to the decrypted commands. The memory 120 may include program modules such as kernel, middleware, Application Programming Interface (API), and applications. The program module may be composed of software, firmware or hardware, or at least two of them. The input/output interface forwards commands or data entered by the user through the input/output interface (eg, sensor, keyboard, touch screen). The communication interface connects the terminal device 100 with other network devices, user equipment, and networks. For example, the communication interface may be wired or wirelessly connected to a network to connect to external other network devices or user equipment. Wireless communication may include at least one of: Wireless Fidelity (WiFi), Bluetooth (BT), Near Field Communication Technology (NFC), Global Positioning System (GPS), cellular communication, and the like. The wired communication may include at least one of: Universal Serial Bus (USB), High Definition Multimedia Interface (HDMI), Asynchronous Transfer Standard Interface (RS-232), and the like. The network may be a telecommunication network and a communication network. The communication network can be a computer network, the Internet, the Internet of Things, a telephone network. The terminal device 100 may be connected to a network through a communication interface, and the protocol used by the terminal device 100 to communicate with other network devices may be supported by at least one of an application, an application programming interface (API), middleware, a kernel and a communication interface.

An embodiment of the present invention is a storage medium, where at least one instruction is stored in the storage medium, and the instruction is loaded and executed by a processor to implement the above-mentioned implementation method for switching data sources in any one of FIGS. 1-6 . operate. For example, the storage medium may be read only memory (ROM), random access memory (RAM), compact disk read only (CD-ROM), magnetic tapes, floppy disks, optical data storage devices, and the like.

They can be implemented with program code executable by a computing device, so that they can be stored in a storage device and executed by the computing device, or they can be separately fabricated into individual integrated circuit modules, or a plurality of modules or steps in them Made into a single integrated circuit module to achieve. As such, the present invention is not limited to any particular combination of hardware and software.

In the above-mentioned embodiments, the description of each embodiment has its own emphasis. For parts that are not described or recorded in detail in a certain embodiment, reference may be made to the relevant descriptions of other embodiments.

Those of ordinary skill in the art can realize that the units and algorithm steps of each example described in conjunction with the embodiments disclosed herein can be implemented in electronic hardware, or a combination of computer software and electronic hardware. Whether these functions are performed in hardware or software depends on the specific application and design constraints of the technical solution. Skilled artisans may implement the described functionality using different methods for each particular application, but such implementations should not be considered beyond the scope of this application.

In the embodiments provided in this application, it should be understood that the disclosed apparatus/terminal device and method may be implemented in other manners. For example, the apparatus/terminal device embodiments described above are only illustrative. For example, the division of the modules or units is only a logical function division. In actual implementation, there may be other division methods, for example, multiple divisions may be used. Units or components may be combined or may be integrated into another system, or some features may be omitted, or not implemented. On the other hand, the shown or discussed mutual coupling or direct coupling or communication connection may be through some interfaces, indirect coupling or communication connection of devices or units, which may be in electrical, mechanical or other forms.

The units described as separate components may or may not be physically separated, and components displayed as units may or may not be physical units, that is, may be located in one place, or may be distributed to multiple network units. Some or all of the units may be selected according to actual needs to achieve the purpose of the solution in this embodiment.

In addition, each functional unit in each embodiment of the present application may be integrated into one processing unit, or each unit may exist physically alone, or two or more units may be integrated into one unit. The above-mentioned integrated units may be implemented in the form of hardware, or may be implemented in the form of software functional units.

If the integrated modules/units are implemented in the form of software functional units and sold or used as independent products, they may be stored in a storage medium. Based on this understanding, the present invention realizes all or part of the processes in the methods of the above embodiments, and can also be completed by sending instructions to the relevant hardware through the computer program 121. The computer program 121 can be stored in a storage medium, and the computer program 121 can be stored in a storage medium. When executed by the processor, 121 may implement the steps of the foregoing method embodiments. The computer program 121 may be in the form of source code, object code, executable file or some intermediate form, and so on. The storage medium may include: any entity or device capable of carrying the computer program 121, a recording medium, a U disk, a removable hard disk, a magnetic disk, an optical disk, a computer memory, a read-only memory (ROM, Read-Only Memory), a random memory Access memory (RAM, Random Access Memory), electric carrier signal, telecommunication signal and software distribution medium, etc. It should be noted that the content contained in the storage medium can be appropriately increased or decreased according to the requirements of legislation and patent practice in the jurisdiction, for example: in some jurisdictions, according to legislation and patent practice, computer-readable storage The medium excludes electrical carrier signals and telecommunication signals.

It should be noted that the above embodiments can be freely combined as required. The above are only the preferred embodiments of the present invention. It should be pointed out that for those skilled in the art, without departing from the principles of the present invention, several improvements and modifications can be made. It should be regarded as the protection scope of the present invention.

Claims (10)

1. An implementation method for switching data sources is characterized by comprising the following steps:

detecting whether a host is down;

when a host is down, a cold standby data source is upgraded to a temporary main data source and an application program is informed of the update of the cold standby data source through broadcasting, so that the application program provides short message aggregation service according to the temporary main data source;

and when the host is not down, the application program provides short message aggregation service according to the main data source.

2. The method for implementing switching data sources according to claim 1, wherein the detecting whether the host is down includes the steps of:

acquiring data source configuration information every other preset time period;

the method comprises the following steps of upgrading a cold standby data source to a temporary main data source when a host is down, and broadcasting and informing an application program, so that the application program provides short message aggregation service according to the temporary main data source, wherein the short message aggregation service comprises the following steps:

when the host is down, the cold standby data source is upgraded to a temporary main data source;

initializing a main data source, and creating a first data source object according to newly acquired data source configuration information;

performing data source configuration according to the cold standby data source configuration information in the newly acquired data source configuration information;

and broadcasting and sending data source switching information after the configuration is completed, so that the application program can access the temporary main data source through switching of the first data source object, and the application program can provide short message aggregation service according to the temporary main data source.

3. The method for implementing switching data sources according to claim 1, wherein the detecting whether the host is down includes the steps of:

acquiring data source configuration information every other preset time period;

the application program provides short message aggregation service according to the main data source when the host is not down, and the method comprises the following steps:

initializing a main data source when the host is not down, and creating a second data source object according to newly acquired data source configuration information;

and broadcasting object creation information after creation is completed so that the application program can access the main data source through the second data source object and provide short message aggregation service according to the main data source.

4. The method for implementing switching data sources according to any one of claims 1 to 3, wherein the detecting whether the host is down includes the steps of:

and when the heartbeat messages from the host are not received within the preset time, determining that the host is down.

5. An implementation system for switching data sources, comprising:

the detection module is used for detecting whether the host is down;

the processing module is used for upgrading the cold standby data source into a temporary main data source and broadcasting and informing an application program when the host is down, so that the application program provides short message aggregation service according to the temporary main data source;

and the processing module is also used for providing short message aggregation service for the application program according to the main data source when the host is not down.

6. The system for switching data sources according to claim 5, further comprising:

the acquisition module is used for acquiring data source configuration information every other preset time period;

the processing module comprises:

the first processing unit is used for upgrading the cold standby data source into a temporary main data source when the host is down;

the first creating unit is used for initializing the main data source and creating a first data source object according to the newly acquired data source configuration information;

the configuration unit is used for configuring the data source according to the cold standby data source configuration information in the newly acquired data source configuration information;

and the execution unit is used for broadcasting and sending data source switching information after the configuration is completed, so that the application program can access the temporary main data source through the switching of the first data source object, and the application program can provide short message aggregation service according to the temporary main data source.

7. The system according to claim 6, wherein the processing module comprises:

the second creating unit is used for initializing the main data source when the host is not down and creating a second data source object according to the newly acquired data source configuration information;

and the second execution unit is used for broadcasting the object creation information after creation is completed so that the application program can access the main data source through the second data source object and provide short message aggregation service according to the main data source.

8. An implementation system for switching data sources according to any one of claims 6 to 7, characterized in that:

the detection module is further configured to determine that the host is down when the heartbeat message from the host is not received within a preset time period.

9. A terminal device, comprising a processor, a memory and a computer program stored in the memory and operable on the processor, wherein the processor is configured to execute the computer program stored in the memory to implement the operations performed by the method for implementing switching data sources according to any one of claims 1 to 4.

10. A storage medium, wherein at least one instruction is stored in the storage medium, and the instruction is loaded and executed by a processor to implement the operation performed by the implementation method for switching a data source according to any one of claims 1 to 4.

Images