CN106156277A - For third-party data sharing update method and system - Google Patents
For third-party data sharing update method and system Download PDFInfo
- Publication number
- CN106156277A CN106156277A CN201610474121.9A CN201610474121A CN106156277A CN 106156277 A CN106156277 A CN 106156277A CN 201610474121 A CN201610474121 A CN 201610474121A CN 106156277 A CN106156277 A CN 106156277A
- Authority
- CN
- China
- Prior art keywords
- party
- subscription
- data
- basic data
- characteristic information
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
Classifications
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/90—Details of database functions independent of the retrieved data types
- G06F16/95—Retrieval from the web
- G06F16/958—Organisation or management of web site content, e.g. publishing, maintaining pages or automatic linking
Landscapes
- Engineering & Computer Science (AREA)
- Databases & Information Systems (AREA)
- Theoretical Computer Science (AREA)
- Data Mining & Analysis (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Information Transfer Between Computers (AREA)
Abstract
本申请提供了一种用于第三方的数据共享更新方法,属于数据处理领域,包括:根据与多项基础数据相关的订阅项生成订阅列表;提供订阅接口供至少一个第三方调用订阅列表,记录各第三方的名称、各第三方采用的网络链接的特征信息、以及各第三方在订阅列表中选定的订阅项,确定各第三方的订阅关系;当某项基础数据完成更改时,确定相应的订阅项,并自各第三方的订阅关系中查询与该订阅项对应的第三方的名称和网络链接的特征信息,将变更通知发送给相应的第三方。本申请还提供了相应的系统。本申请可以将变更的数据实时通知给订阅该变更数据的第三方以便第三方能够及时读取变更后的数据,降低了因第三方无法实时感知和读取变更的订阅数据而造成的损失。
This application provides a data sharing update method for third parties, which belongs to the field of data processing, including: generating a subscription list based on subscription items related to multiple basic data; providing a subscription interface for at least one third party to call the subscription list, record The name of each third party, the characteristic information of the network link used by each third party, and the subscription items selected by each third party in the subscription list determine the subscription relationship of each third party; when a certain basic data is changed, determine the corresponding Subscription items, and query the name of the third party corresponding to the subscription item and the characteristic information of the network link from the subscription relationship of each third party, and send the change notification to the corresponding third party. The application also provides a corresponding system. This application can notify the changed data in real time to the third party who subscribes to the changed data so that the third party can read the changed data in time, reducing the loss caused by the third party not being able to perceive and read the changed subscription data in real time.
Description
技术领域technical field
本申请涉及数据处理领域,具体涉及一种用于第三方的数据共享更新方法及系统。This application relates to the field of data processing, in particular to a method and system for sharing and updating data of a third party.
背景技术Background technique
随着人类社会全面进入信息时代,数据成为与水、石油同等重要的战略资源,数据库已经成为数据组织和存储最重要的方式,对所有应用程序的访问几乎都会变相使用到数据库,于是数据库的响应速度也成为应用程序执行速度的重要瓶颈。在企业应用或互联网软件系统中,对于一些多个系统都用到的基础数据,业内普遍是把这些基础数据做到一个数据库中,其他要用到这些基础数据的系统都从该数据库里获取数据,从而可以降低系统间耦合,提高基础数据的可维护性。As human society has fully entered the information age, data has become an equally important strategic resource like water and oil, and databases have become the most important way of data organization and storage. Almost all access to applications will use the database in disguise, so the response of the database Speed also becomes an important bottleneck for application execution speed. In enterprise applications or Internet software systems, for some basic data used by multiple systems, the industry generally puts these basic data in a database, and other systems that need to use these basic data obtain data from this database. , so that the coupling between systems can be reduced and the maintainability of basic data can be improved.
在实现本申请的过程中,发明人发现现有技术至少存在以下问题:目前业内已经在普遍使用的数据共享或数据基础平台,主要是实现了基础数据的管理和维护,以及提供对外API接口服务来供第三方系统读取数据。这种技术方案的问题是,当基础数据有变更时,第三方系统无法实时感知并及时读取,对于那些数据时效性要求高的系统这是无法容忍的。In the process of realizing this application, the inventor found that the existing technology has at least the following problems: the data sharing or data basic platform that has been widely used in the industry at present mainly realizes the management and maintenance of basic data, and provides external API interface services For third-party systems to read data. The problem with this technical solution is that when the basic data changes, the third-party system cannot sense and read it in real time, which is intolerable for systems with high data timeliness requirements.
发明内容Contents of the invention
本申请实施例提供一种用于第三方的数据共享更新方法及系统,用以解决上述阐述的现有技术中的至少一个问题。Embodiments of the present application provide a data sharing and updating method and system for a third party, so as to solve at least one problem in the prior art described above.
一方面本申请提供了一种用于第三方的数据共享更新方法,包括:On the one hand, this application provides a data sharing update method for a third party, including:
根据与多项基础数据相关的订阅项生成订阅列表;Generate a subscription list based on subscription items related to multiple basic data;
提供订阅接口供至少一个第三方调用所述订阅列表,记录各第三方的名称、各第三方采用的网络链接的特征信息、以及各第三方在订阅列表中选定的订阅项,确定各第三方的订阅关系;Provide a subscription interface for at least one third party to call the subscription list, record the name of each third party, the characteristic information of the network link used by each third party, and the subscription items selected by each third party in the subscription list, and determine the subscription list of each third party subscription relationship;
当某项基础数据完成更改时,确定相应的订阅项,并自所述各第三方的订阅关系中查询与该订阅项对应的第三方的名称和网络链接的特征信息,根据查询到的第三方的名称和网络链接的特征信息将变更通知发送给相应的第三方。When a certain basic data is changed, determine the corresponding subscription item, and query the name of the third party corresponding to the subscription item and the characteristic information of the network link from the subscription relationship of each third party, according to the queried third party The name and characteristic information of the web link will send the change notification to the corresponding third party.
另一方面本申请提供了一种用于第三方的数据共享更新系统,包括:On the other hand, this application provides a data sharing update system for a third party, including:
基础数据模块,用于根据与多项基础数据相关的订阅项生成订阅列表;The basic data module is used to generate a subscription list according to subscription items related to multiple basic data;
订阅关系模块,用于提供订阅接口供至少一个第三方调用所述订阅列表,记录各第三方的名称、各第三方采用的网络链接的特征信息、以及各第三方在订阅列表中选定的订阅项,并确定各第三方的订阅关系;A subscription relationship module, configured to provide a subscription interface for at least one third party to call the subscription list, record the name of each third party, the characteristic information of the network link used by each third party, and the subscription selected by each third party in the subscription list items, and determine the subscription relationship of each third party;
变更通知模块,用于在某项基础数据完成更改时,确定相应的订阅项,并自所述各第三方的订阅关系中查询与该订阅项对应的第三方的名称和网络链接的特征信息,根据查询到的第三方的名称和网络链接的特征信息将变更通知发送给相应的第三方。The change notification module is used to determine the corresponding subscription item when a certain basic data is changed, and query the name of the third party corresponding to the subscription item and the characteristic information of the network link from the subscription relationship of each third party, According to the inquired name of the third party and characteristic information of the network link, the change notice is sent to the corresponding third party.
本申请实施例提供的用于第三方的数据共享更新方法及系统,通过将待更改的基础数据对应的订阅项生成订阅列表,并提供订阅接口供第三方调用该订阅列表来确定各第三方的订阅关系,当待更改的基础数据中某一项基础数据完成更改时,则根据该基础数据对应的订阅项以及订阅列表确定的第三方的订阅关系查询到与该订阅项对应的第三方,将变更通知发送给与该订阅项对应的第三方,即可完成对第三方的数据共享更新的过程。本申请所示实施例能够在基础数据发生更改的同时,根据所确定的订阅关系查询到订阅该基础数据的第三方并向所述第三方发送变更通知,可以将变更的数据实时地通知给订阅该变更的数据的第三方以便第三方能够及时读取变更后的数据,降低了因第三方无法实时感知和读取变更的订阅数据而造成的损失。The data sharing update method and system for third parties provided by the embodiments of the present application generate a subscription list for the subscription items corresponding to the basic data to be changed, and provide a subscription interface for the third party to call the subscription list to determine the third party's Subscription relationship. When a basic data item in the basic data to be changed is changed, the third party corresponding to the subscription item is queried according to the subscription item corresponding to the basic data and the subscription relationship of the third party determined by the subscription list. The change notification is sent to the third party corresponding to the subscription item, and the process of sharing and updating the third party's data can be completed. The embodiment shown in this application can query the third party who subscribes to the basic data according to the determined subscription relationship while the basic data is changed, and send a change notification to the third party, and can notify the subscriber of the changed data in real time The third party of the changed data enables the third party to read the changed data in a timely manner, reducing the loss caused by the inability of the third party to perceive and read the changed subscription data in real time.
附图说明Description of drawings
为了更清楚地说明本申请实施例的技术方案,下面将对实施例描述中所需要使用的附图作一简单地介绍,显而易见地,下面描述中的附图是本申请的一些实施例,对于本领域普通技术人员来讲,在不付出创造性劳动的前提下,还可以根据这些附图获得其他的附图。In order to more clearly illustrate the technical solutions of the embodiments of the present application, the following will briefly introduce the drawings that need to be used in the description of the embodiments. Obviously, the drawings in the following description are some embodiments of the present application. For Those of ordinary skill in the art can also obtain other drawings based on these drawings without making creative efforts.
图1是本申请一实施例的用于第三方的数据共享更新方法的流程图;FIG. 1 is a flowchart of a third-party data sharing update method according to an embodiment of the present application;
图2是本申请一实施例的用于第三方的数据共享更新系统的结构示意图;FIG. 2 is a schematic structural diagram of a third-party data sharing update system according to an embodiment of the present application;
图3是本申请一实施例的图2所示系统基于图1所示方法工作的原理图;Fig. 3 is a schematic diagram of the system shown in Fig. 2 according to an embodiment of the present application based on the method shown in Fig. 1;
图4为本申请实施例提供的一种用于第三方的数据共享平台400的结构示意图。FIG. 4 is a schematic structural diagram of a third-party data sharing platform 400 provided by an embodiment of the present application.
具体实施方式detailed description
为使本申请实施例的目的、技术方案和优点更加清楚,下面将结合本申请实施例中的附图,对本申请实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例是本申请一部分实施例,而不是全部的实施例。基于本申请中的实施例,本领域普通技术人员在没有作出创造性劳动前提下所获得的所有其他实施例,都属于本申请保护的范围。In order to make the purposes, technical solutions and advantages of the embodiments of the present application clearer, the technical solutions in the embodiments of the present application will be clearly and completely described below in conjunction with the drawings in the embodiments of the present application. Obviously, the described embodiments It is a part of the embodiments of this application, not all of them. Based on the embodiments in this application, all other embodiments obtained by persons of ordinary skill in the art without creative efforts fall within the protection scope of this application.
需要说明的是,在不冲突的情况下,本申请中的实施方式及实施方式中的特征可以相互组合。It should be noted that, in the case of no conflict, the implementations in the present application and the features in the implementations can be combined with each other.
本发明可用于众多通用或专用的计算系统环境或配置中。例如:个人计算机、服务器计算机、手持设备或便携式设备、平板型设备、多处理器系统、基于微处理器的系统、置顶盒、可编程的消费电子设备、网络PC、小型计算机、大型计算机、包括以上任何系统或设备的分布式计算环境等等。The invention is applicable to numerous general purpose and special purpose computing system environments or configurations. Examples: personal computers, server computers, handheld or portable devices, tablet-type devices, multiprocessor systems, microprocessor-based systems, set-top boxes, programmable consumer electronics, network PCs, minicomputers, mainframe computers, including A distributed computing environment for any of the above systems or devices, etc.
本发明可以在由计算机执行的计算机可执行指令的一般上下文中描述,例如程序模块。一般地,程序模块包括执行特定任务或实现特定抽象数据类型的例程、程序、对象、组件、数据结构等等。也可以在分布式计算环境中实践本发明,在这些分布式计算环境中,由通过通信网络而被连接的远程处理设备来执行任务。在分布式计算环境中,程序模块可以位于包括存储设备在内的本地和远程计算机存储介质中。The invention may be described in the general context of computer-executable instructions, such as program modules, being executed by a computer. Generally, program modules include routines, programs, objects, components, data structures, etc. that perform particular tasks or implement particular abstract data types. The invention may also be practiced in distributed computing environments where tasks are performed by remote processing devices that are linked through a communications network. In a distributed computing environment, program modules may be located in both local and remote computer storage media including storage devices.
最后,还需要说明的是,在本文中,诸如第一和第二等之类的关系术语仅仅用来将一个实体或者操作与另一个实体或操作区分开来,而不一定要求或者暗示这些实体或操作之间存在任何这种实际的关系或者顺序。而且,术语“包括”、“包含”,不仅包括那些要素,而且还包括没有明确列出的其他要素,或者是还包括为这种过程、方法、物品或者设备所固有的要素。在没有更多限制的情况下,由语句“包括......”限定的要素,并不排除在包括所述要素的过程、方法、物品或者设备中还存在另外的相同要素。Finally, it should also be noted that in this text, relational terms such as first and second etc. are only used to distinguish one entity or operation from another, and do not necessarily require or imply that these entities or operations, any such actual relationship or order exists. Moreover, the terms "comprising" and "comprising" not only include those elements, but also include other elements not explicitly listed, or also include elements inherent in such a process, method, article, or device. Without further limitations, an element defined by the word "comprising..." does not exclude the presence of additional same elements in the process, method, article or device comprising said element.
图1是本申请一实施例的用于第三方的数据共享更新方法的流程图。如图1所示,该方法包括:Fig. 1 is a flow chart of a third-party data sharing update method according to an embodiment of the present application. As shown in Figure 1, the method includes:
S101:根据与多项基础数据相关的订阅项生成订阅列表;S101: Generate a subscription list according to subscription items related to multiple pieces of basic data;
S102:提供订阅接口供至少一个第三方调用所述订阅列表,记录各第三方的名称、各第三方采用的网络链接的特征信息、以及各第三方在订阅列表中选定的订阅项,确定各第三方的订阅关系;S102: Provide a subscription interface for at least one third party to call the subscription list, record the name of each third party, the characteristic information of the network link used by each third party, and the subscription items selected by each third party in the subscription list, and determine the Subscription relationships with third parties;
S103:当某项基础数据完成更改时,确定相应的订阅项,并自所述各第三方的订阅关系中查询与该订阅项对应的第三方的名称和网络链接的特征信息,根据查询到的第三方的名称和网络链接的特征信息将变更通知发送给相应的第三方。S103: When a certain basic data is changed, determine the corresponding subscription item, and query the name of the third party corresponding to the subscription item and the feature information of the network link from the subscription relationship of each third party, according to the queried The name of the third party and the characteristic information of the web link will send the change notification to the respective third party.
本申请实施例提供的用于第三方的数据共享更新方法,通过将待更改的基础数据对应的订阅项生成订阅列表,并提供订阅接口供第三方调用该订阅列表来确定各第三方的订阅关系,当待更改的基础数据中某一项基础数据完成更改时,则根据该基础数据对应的订阅项以及订阅列表确定的第三方的订阅关系查询到与该订阅项对应的第三方,将变更通知发送给与该订阅项对应的第三方,即可完成对第三方的数据共享更新的过程。本申请所示实施例能够在基础数据发生更改的同时,根据所确定的订阅关系查询到订阅该基础数据的第三方并向所述第三方发送变更通知,可以将变更的数据实时地通知给订阅该变更的数据的第三方以便第三方能够及时读取变更后的数据,降低了因第三方无法实时感知和读取变更的订阅数据而造成的损失。The data sharing update method for third parties provided by the embodiment of the present application generates a subscription list for the subscription items corresponding to the basic data to be changed, and provides a subscription interface for third parties to call the subscription list to determine the subscription relationship of each third party , when one of the basic data to be changed is completed, the third party corresponding to the subscription item is queried according to the subscription item corresponding to the basic data and the subscription relationship of the third party determined by the subscription list, and the change notification is notified. Send it to the third party corresponding to the subscription item to complete the process of sharing and updating the data of the third party. The embodiment shown in this application can query the third party who subscribes to the basic data according to the determined subscription relationship while the basic data is changed, and send a change notification to the third party, and can notify the subscriber of the changed data in real time The third party of the changed data enables the third party to read the changed data in a timely manner, reducing the loss caused by the inability of the third party to perceive and read the changed subscription data in real time.
作为图1所示实施例的进一步说明,图1所示实施例中,基础数据的存储结构为键值对。本实施例中,键值对的取值方式是用key,key是字符串,可以随时定义,因此不管运用什么技术从键值对中取值的方式都是是统一的,使用键值对会将传输数据的业务属性封闭在键值对内部,便于操作。同时,键值对存储技术几乎包含在所有的主流技术里,因此利用该数据结构作为传输介质具有可以跨平台的优势。As a further description of the embodiment shown in FIG. 1 , in the embodiment shown in FIG. 1 , the storage structure of the basic data is a key-value pair. In this embodiment, the way to get the value of the key-value pair is to use key, which is a string and can be defined at any time. Therefore, no matter what technology is used, the way to get the value from the key-value pair is uniform. Using the key-value pair will The business attributes of the transmitted data are enclosed in key-value pairs for easy operation. At the same time, key-value pair storage technology is included in almost all mainstream technologies, so using this data structure as a transmission medium has the advantage of being cross-platform.
作为本申请所示方法的一可选实施例,本申请可选实施例中,第三方采用的网络链接的特征信息为长链接。长链接只需要进行一回三次握手从而建立TCP链接,就可以进行多次通信,因此本实施例采用长链接作为与第三方的网络链接,避免了每一次通信的过程都需要建立连接导致时间延长的问题,减少了网络的堵塞,增加了第三方感知和读取变更数据的实时性。As an optional embodiment of the method shown in the present application, in the optional embodiment of the present application, the feature information of the network link used by the third party is a long link. The long link only needs to perform a three-way handshake to establish a TCP link, and multiple communications can be performed. Therefore, this embodiment uses a long link as a network link with a third party, which avoids the need to establish a connection for each communication process, resulting in prolonged time. It reduces network congestion and increases the real-time performance of third-party perception and reading of change data.
在本申请一些实施例中,在S103当某项基础数据完成更改时,确定相应的订阅项,并自所述各第三方的订阅关系中查询与该订阅项对应的第三方的名称和网络链接的特征信息,根据查询到的第三方的名称和网络链接的特征信息将变更通知发送给相应的第三方之后包括:In some embodiments of the present application, in S103, when a certain basic data is changed, the corresponding subscription item is determined, and the name and network link of the third party corresponding to the subscription item are queried from the subscription relationship of each third party After sending the change notice to the corresponding third party according to the name of the third party queried and the characteristic information of the network link, it includes:
S104:通过所述第三方采用的网络链接接收所述第三方返回的反馈信息以确认所述基础数据在所述第三方中是否更新成功。S104: Receive feedback information returned by the third party through the network link adopted by the third party to confirm whether the basic data is successfully updated in the third party.
本实施例采用了反馈机制以进一步增大第三方及时感知和读取更改数据的实时性。This embodiment adopts a feedback mechanism to further increase the real-time performance of the third party's timely perception and reading of the changed data.
作为本申请所示方法的一可选实施例,本申请可选实施例中,各第三方采用的网络链接定期更新。本实施例通过对各第三方采用的网络链接定期更新,避免了因网络堵塞等原因造成的与第三方的网络连接断开,从而减少了第三方无法及时感知和读取更改数据的可能性。As an optional embodiment of the method shown in this application, in the optional embodiment of this application, the network links used by each third party are regularly updated. In this embodiment, by regularly updating the network links adopted by each third party, the disconnection of the network connection with the third party due to reasons such as network congestion is avoided, thereby reducing the possibility that the third party cannot perceive and read the changed data in time.
需要说明的是,对于前述的各方法实施例,为了简单描述,故将其都表述为一系列的动作合并,但是本领域技术人员应该知悉,本申请并不受所描述的动作顺序的限制,因为依据本申请,某些步骤可以采用其他顺序或者同时进行。其次,本领域技术人员也应该知悉,说明书中所描述的实施例均属于优选实施例,所涉及的动作和模块并不一定是本申请所必须的。It should be noted that, for the sake of simple description, all the aforementioned method embodiments are described as a series of combined actions, but those skilled in the art should know that the present application is not limited by the described action sequence. Depending on the application, certain steps may be performed in other orders or simultaneously. Secondly, those skilled in the art should also know that the embodiments described in the specification belong to preferred embodiments, and the actions and modules involved are not necessarily required by this application.
在上述实施例中,对各个实施例的描述都各有侧重,某个实施例中没有详述的部分,可以参见其他实施例的相关描述。In the foregoing embodiments, the descriptions of each embodiment have their own emphases, and for parts not described in detail in a certain embodiment, reference may be made to relevant descriptions of other embodiments.
图2是本申请一实施例的用于第三方的数据共享更新系统的结构示意图。本申请所述的用于第三方的数据共享更新方法可以基于本实施例中的用于第三方的数据共享更新系统实施。如图2所示,该系统包括基础数据模块201、订阅关系模块202和变更通知模块203。Fig. 2 is a schematic structural diagram of a third-party data sharing and updating system according to an embodiment of the present application. The data sharing and updating method for third parties described in this application can be implemented based on the data sharing and updating system for third parties in this embodiment. As shown in FIG. 2 , the system includes a basic data module 201 , a subscription relationship module 202 and a change notification module 203 .
基础数据模块201用于根据与多项基础数据相关的订阅项生成订阅列表;The basic data module 201 is used to generate a subscription list according to subscription items related to multiple basic data;
订阅关系模块202用于提供订阅接口供至少一个第三方调用所述订阅列表,记录各第三方的名称、各第三方采用的网络链接的特征信息、以及各第三方在订阅列表中选定的订阅项,并确定各第三方的订阅关系;The subscription relationship module 202 is used to provide a subscription interface for at least one third party to call the subscription list, record the name of each third party, the characteristic information of the network link used by each third party, and the subscription list selected by each third party in the subscription list. items, and determine the subscription relationship of each third party;
变更通知模块203用于在某项基础数据完成更改时,确定相应的订阅项,并自所述各第三方的订阅关系中查询与该订阅项对应的第三方的名称和网络链接的特征信息,根据查询到的第三方的名称和网络链接的特征信息将变更通知发送给相应的第三方。The change notification module 203 is used to determine the corresponding subscription item when a certain basic data is changed, and query the name of the third party corresponding to the subscription item and the characteristic information of the network link from the subscription relationship of each third party, According to the inquired name of the third party and characteristic information of the network link, the change notice is sent to the corresponding third party.
本申请实施例提供的用于第三方的数据共享更新系统,通过基础数据模块201将数据库中待更改的基础数据对应的订阅项生成订阅列表,并通过订阅关系模块202提供订阅接口供第三方调用该订阅列表来确定各第三方的订阅关系,当待更改的基础数据中某一项基础数据完成更改时,则通过变更关系模块203根据该基础数据对应的订阅项以及订阅列表确定的第三方的订阅关系查询到与该订阅项对应的第三方,将变更通知发送给与该订阅项对应的第三方,即可完成对第三方的数据共享更新的过程。本申请所示实施例能够在基础数据发生更改的同时,根据所确定的订阅关系查询到订阅该基础数据的第三方并向所述第三方发送变更通知,可以将变更的数据实时地通知给订阅该变更的数据的第三方以便第三方能够及时读取变更后的数据,降低了因第三方无法实时感知和读取变更的订阅数据而造成的损失。The data sharing update system for third parties provided by the embodiment of the present application uses the basic data module 201 to generate a subscription list for the subscription items corresponding to the basic data to be changed in the database, and provides a subscription interface for third-party calls through the subscription relationship module 202 The subscription list is used to determine the subscription relationship of each third party. When a certain item of basic data in the basic data to be changed is changed, the third party’s subscription relationship determined according to the subscription item corresponding to the basic data and the subscription list is changed through the change relationship module 203. The subscription relationship queries the third party corresponding to the subscription item, and sends the change notification to the third party corresponding to the subscription item to complete the process of sharing and updating the data of the third party. The embodiment shown in this application can query the third party who subscribes to the basic data according to the determined subscription relationship while the basic data is changed, and send a change notification to the third party, and can notify the subscriber of the changed data in real time The third party of the changed data enables the third party to read the changed data in a timely manner, reducing the loss caused by the inability of the third party to perceive and read the changed subscription data in real time.
作为本申请所示系统的一可选实施例,本申请可选实施例中,基础数据的存储结构为键值对。本实施例中,键值对的取值方式是用key,key是字符串,可以随时定义,因此不管运用什么技术从键值对中取值的方式都是是统一的,使用键值对会将传输数据的业务属性封闭在键值对内部,便于操作。同时,键值对存储技术几乎包含在所有的主流技术里,因此利用该数据结构作为传输介质具有可以跨平台的优势。As an optional embodiment of the system shown in the present application, in the optional embodiment of the present application, the storage structure of the basic data is a key-value pair. In this embodiment, the way to get the value of the key-value pair is to use key, which is a string and can be defined at any time. Therefore, no matter what technology is used, the way to get the value from the key-value pair is uniform. Using the key-value pair will The business attributes of the transmitted data are enclosed in key-value pairs for easy operation. At the same time, key-value pair storage technology is included in almost all mainstream technologies, so using this data structure as a transmission medium has the advantage of being cross-platform.
作为本申请所示系统的一可选实施例,本申请可选实施例中,第三方采用的网络链接的特征信息为长链接。长链接只需要进行一回三次握手从而建立TCP链接,就可以进行多次通信,因此本实施例采用长链接作为与第三方的网络链接,避免了每一次通信的过程都需要建立连接导致时间延长的问题,减少了网络的堵塞,增加了第三方感知和读取变更数据的实时性。As an optional embodiment of the system shown in the present application, in the optional embodiment of the present application, the feature information of the network link used by the third party is a long link. The long link only needs to perform a three-way handshake to establish a TCP link, and multiple communications can be performed. Therefore, this embodiment uses a long link as a network link with a third party, which avoids the need to establish a connection for each communication process, resulting in prolonged time. It reduces network congestion and increases the real-time performance of third-party perception and reading of change data.
在本申请一些实施例中,图2所示系统实施例还包括变更确认模块204,用于通过所述第三方采用的网络链接接收所述第三方返回的反馈信息以确认所述基础数据在所述第三方中是否更新成功。In some embodiments of the present application, the system embodiment shown in FIG. 2 further includes a change confirmation module 204, configured to receive feedback information returned by the third party through the network link adopted by the third party to confirm that the basic data is in the Whether the above-mentioned third party is updated successfully.
本实施例采用了反馈机制以进一步增大第三方及时感知和读取更改数据的实时性。This embodiment adopts a feedback mechanism to further increase the real-time performance of the third party's timely perception and reading of the changed data.
作为本申请所示方法的一可选实施例,本申请可选实施例中,所述各第三方采用的网络链接定期更新。本实施例通过对各第三方采用的网络链接定期更新,避免了因网络堵塞等原因造成的与第三方的网络连接断开,从而减少了第三方无法及时感知和读取更改数据的可能性。As an optional embodiment of the method shown in this application, in an optional embodiment of this application, the network links used by each third party are regularly updated. In this embodiment, by regularly updating the network links adopted by each third party, the disconnection of the network connection with the third party due to reasons such as network congestion is avoided, thereby reducing the possibility that the third party cannot perceive and read the changed data in time.
图3是本申请一实施例的图2所示系统基于图1所示方法工作的原理图。如图3所示,图2所示系统基于图3所示的数据共享平台工作。该数据共享平台还包括基础数据库和订阅关系库,基础数据库为包含所有基础数据的数据库,订阅关系库则为包含根据与所有基础数据相关的订阅项生成的订阅列表的数据库。FIG. 3 is a working principle diagram of the system shown in FIG. 2 based on the method shown in FIG. 1 according to an embodiment of the present application. As shown in Fig. 3, the system shown in Fig. 2 works based on the data sharing platform shown in Fig. 3 . The data sharing platform also includes a basic database and a subscription relational library. The basic database is a database containing all basic data, and the subscription relational library is a database containing a subscription list generated according to subscription items related to all basic data.
基础数据模块直接操作于基础数据库,以对基础数据进行增、删、改、查等数据读写操作。同时还维护以基础数据作为订阅项的订阅列表,更新订阅列表的数据并保存到订阅关系库中。The basic data module directly operates on the basic database to perform data read and write operations such as addition, deletion, modification, and query on the basic data. At the same time, it also maintains the subscription list with the basic data as the subscription item, updates the data of the subscription list and saves it in the subscription relationship library.
订阅关系模块提供订阅接口(例如,API)供n个第三方(业务系统)调用,该API的参数有:第三方名称、第三方在订阅列表中选定的订阅项。第三方在调用本模块时,该模块会自动记录下该第三方采用的网络链接的特征信息,并将第三方的名称、采用的网络链接的特征信息和第三方在订阅列表中选定的订阅项保存到订阅关系库中,完成订阅关系的建立。The subscription relationship module provides a subscription interface (for example, API) for n third parties (business systems) to call. The parameters of the API include: the name of the third party, and the subscription item selected by the third party in the subscription list. When a third party calls this module, the module will automatically record the characteristic information of the network link adopted by the third party, and record the name of the third party, the characteristic information of the network link adopted and the subscription selected by the third party in the subscription list The item is saved to the subscription relationship library to complete the establishment of the subscription relationship.
当基础数据模块对基础数据的更改操作完成时,会将基础数据的名称和内容(键值)和其修改信息通知给变更通知模块,变更通知模块根据该键值从订阅关系模块中查询所有订阅该键值的第三方,之后基于查询到的第三方的网络链接,将数据变更内容通知给第三方。When the basic data module changes the basic data, it will notify the change notification module of the name and content (key value) of the basic data and its modification information, and the change notification module will query all subscriptions from the subscription relationship module according to the key value The third party of the key value will then notify the third party of the data change content based on the queried third party's network link.
本申请实施例中可以通过硬件处理器(hardware processor)来实现相关功能模块。In this embodiment of the present application, a hardware processor (hardware processor) may be used to implement related functional modules.
图4为本申请实施例提供的一种用于第三方的数据共享平台400的结构示意图,本申请具体实施例并不对用于第三方的数据共享平台400的具体实现做限定。如图4所示,该用于第三方的数据共享平台400可以包括:FIG. 4 is a schematic structural diagram of a third-party data sharing platform 400 provided by the embodiment of the present application. The specific embodiment of the present application does not limit the specific implementation of the third-party data sharing platform 400 . As shown in Figure 4, the data sharing platform 400 for the third party may include:
处理器(processor)410、通信接口(Communications Interface)420、存储器(memory)430、以及通信总线440。其中:A processor (processor) 410 , a communication interface (Communications Interface) 420 , a memory (memory) 430 , and a communication bus 440 . in:
处理器410、通信接口420、以及存储器430通过通信总线440完成相互间的通信。The processor 410 , the communication interface 420 , and the memory 430 communicate with each other through the communication bus 440 .
通信接口420,用于与比如客户端等的网元通信。The communication interface 420 is used for communicating with network elements such as clients.
处理器410,用于执行程序432,具体可以执行上述方法实施例中的相关步骤。The processor 410 is configured to execute the program 432, and may specifically execute relevant steps in the foregoing method embodiments.
具体地,程序432可以包括程序代码,所述程序代码包括计算机操作指令。Specifically, the program 432 may include program codes including computer operation instructions.
处理器410可能是一个中央处理器CPU,或者是特定集成电路ASIC(ApplicationSpecific Integrated Circuit),或者是被配置成实施本申请实施例的一个或多个集成电路。The processor 410 may be a central processing unit CPU, or an ASIC (Application Specific Integrated Circuit), or one or more integrated circuits configured to implement the embodiments of the present application.
上述实施例的数据共享平台中:In the data sharing platform of the above-mentioned embodiment:
存储器,用于存放计算机操作指令;memory for storing computer operation instructions;
处理器,用于执行所述存储器存储的计算机操作指令,以执行:a processor configured to execute said memory stored computer operation instructions to perform:
根据与多项基础数据相关的订阅项生成订阅列表;Generate a subscription list based on subscription items related to multiple basic data;
提供订阅接口供至少一个第三方调用所述订阅列表,记录各第三方的名称、各第三方采用的网络链接的特征信息、以及各第三方在订阅列表中选定的订阅项,确定各第三方的订阅关系;Provide a subscription interface for at least one third party to call the subscription list, record the name of each third party, the characteristic information of the network link used by each third party, and the subscription items selected by each third party in the subscription list, and determine the subscription list of each third party subscription relationship;
当某项基础数据完成更改时,确定相应的订阅项,并自所述各第三方的订阅关系中查询与该订阅项对应的第三方的名称和网络链接的特征信息,根据查询到的第三方的名称和网络链接的特征信息将变更通知发送给相应的第三方。When a certain basic data is changed, determine the corresponding subscription item, and query the name of the third party corresponding to the subscription item and the characteristic information of the network link from the subscription relationship of each third party, according to the queried third party The name and characteristic information of the web link will send the change notification to the corresponding third party.
以上所描述的实施例仅仅是示意性的,其中所述作为分离部件说明的单元可以是或者也可以不是物理上分开的,作为单元显示的部件可以是或者也可以不是物理单元,即可以位于一个地方,或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部模块来实现本实施例方案的目的。本领域普通技术人员在不付出创造性的劳动的情况下,即可以理解并实施。The above-described embodiments are only illustrative, and the units described as separate components may or may not be physically separated, and the components shown as units may or may not be physical units, that is, they may be located in a place, or can also be distributed to multiple network elements. Part or all of the modules can be selected according to actual needs to achieve the purpose of the solution of this embodiment. It can be understood and implemented by those skilled in the art without any creative efforts.
通过以上的实施例的描述,本领域的技术人员可以清楚地了解到各实施例可借助软件加必需的通用硬件平台的方式来实现,当然也可以通过硬件。基于这样的理解,上述技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来,该计算机软件产品可以存储在计算机可读存储介质中,如ROM/RAM、磁碟、光盘等,包括若干指令用以使得一台计算机设备(可以是个人计算机,服务器,或者网络设备等)执行各个实施例或者实施例的某些部分所述的方法。Through the above description of the embodiments, those skilled in the art can clearly understand that each embodiment can be implemented by means of software plus a necessary general-purpose hardware platform, and of course also by hardware. Based on this understanding, the essence of the above technical solution or the part that contributes to the prior art can be embodied in the form of software products, and the computer software products can be stored in computer-readable storage media, such as ROM/RAM, magnetic discs, optical discs, etc., including several instructions to make a computer device (which may be a personal computer, server, or network device, etc.) execute the methods described in various embodiments or some parts of the embodiments.
本领域内的技术人员应明白,本申请的实施例可提供为方法、系统、或计算机程序产品。因此,本申请可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且,本申请可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器和光学存储器等)上实施的计算机程序产品的形式。Those skilled in the art should understand that the embodiments of the present application may be provided as methods, systems, or computer program products. Accordingly, the present application may take the form of an entirely hardware embodiment, an entirely software embodiment, or an embodiment combining software and hardware aspects. Furthermore, the present application may take the form of a computer program product embodied on one or more computer-usable storage media (including but not limited to disk storage and optical storage, etc.) having computer-usable program code embodied therein.
本申请是参照根据本申请实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器,使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。The present application is described with reference to flowcharts and/or block diagrams of methods, apparatus (systems), and computer program products according to embodiments of the present application. It should be understood that each procedure and/or block in the flowchart and/or block diagram, and a combination of procedures and/or blocks in the flowchart and/or block diagram can be realized by computer program instructions. These computer program instructions may be provided to a general purpose computer, special purpose computer, embedded processor, or processor of other programmable data processing equipment to produce a machine such that the instructions executed by the processor of the computer or other programmable data processing equipment produce a An apparatus for realizing the functions specified in one or more procedures of the flowchart and/or one or more blocks of the 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 operate in a specific manner, such that the instructions stored in the computer-readable memory produce an article of manufacture comprising instruction means, the instructions The device realizes the function specified in one or more procedures of the flowchart and/or one or more blocks of the block diagram. These computer program instructions can also be loaded onto a computer or other programmable data processing device, causing a series of operational steps to be performed on the computer or other programmable device to produce a computer-implemented process, thereby The instructions provide steps for implementing the functions specified in the flow chart or blocks of the flowchart and/or the block or blocks of the block diagrams.
最后应说明的是:以上实施例仅用以说明本申请的技术方案,而非对其限制;尽管参照前述实施例对本申请进行了详细的说明,本领域的普通技术人员应当理解:其依然可以对前述各实施例所记载的技术方案进行修改,或者对其中部分技术特征进行等同替换;而这些修改或者替换,并不使相应技术方案的本质脱离本申请各实施例技术方案的精神和范围。Finally, it should be noted that: the above embodiments are only used to illustrate the technical solutions of the present application, rather than limiting them; although the present application has been described in detail with reference to the foregoing embodiments, those of ordinary skill in the art should understand that: it can still Modifications are made to the technical solutions described in the foregoing embodiments, or equivalent replacements are made to some of the technical features; and these modifications or replacements do not make the essence of the corresponding technical solutions deviate from the spirit and scope of the technical solutions of the various embodiments of the present application.
Claims (10)
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201610474121.9A CN106156277A (en) | 2016-06-24 | 2016-06-24 | For third-party data sharing update method and system |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201610474121.9A CN106156277A (en) | 2016-06-24 | 2016-06-24 | For third-party data sharing update method and system |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN106156277A true CN106156277A (en) | 2016-11-23 |
Family
ID=57349829
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201610474121.9A Pending CN106156277A (en) | 2016-06-24 | 2016-06-24 | For third-party data sharing update method and system |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN106156277A (en) |
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107800764A (en) * | 2017-09-11 | 2018-03-13 | 新奥泛能网络科技股份有限公司 | Data sharing method, system, computer read/write memory medium and server |
| CN108764354A (en) * | 2018-05-31 | 2018-11-06 | 北京百度网讯科技有限公司 | Method and device for handling information |
Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102185865A (en) * | 2011-05-16 | 2011-09-14 | 中兴通讯股份有限公司 | Method and device for reporting statistical RSS (really simple syndication) service information |
| US20130311598A1 (en) * | 2012-05-16 | 2013-11-21 | Apple Inc. | Cloud-based data item sharing and collaboration among groups of users |
| CN104156798A (en) * | 2014-07-08 | 2014-11-19 | 四川中电启明星信息技术有限公司 | System data real-time push framework adopting enterprise authority source and method |
| CN104270432A (en) * | 2014-09-22 | 2015-01-07 | 苏州耐克斯特能源开采技术有限公司 | Real-time data service system and data interaction method based on drilling industry |
-
2016
- 2016-06-24 CN CN201610474121.9A patent/CN106156277A/en active Pending
Patent Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102185865A (en) * | 2011-05-16 | 2011-09-14 | 中兴通讯股份有限公司 | Method and device for reporting statistical RSS (really simple syndication) service information |
| US20130311598A1 (en) * | 2012-05-16 | 2013-11-21 | Apple Inc. | Cloud-based data item sharing and collaboration among groups of users |
| CN104156798A (en) * | 2014-07-08 | 2014-11-19 | 四川中电启明星信息技术有限公司 | System data real-time push framework adopting enterprise authority source and method |
| CN104270432A (en) * | 2014-09-22 | 2015-01-07 | 苏州耐克斯特能源开采技术有限公司 | Real-time data service system and data interaction method based on drilling industry |
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107800764A (en) * | 2017-09-11 | 2018-03-13 | 新奥泛能网络科技股份有限公司 | Data sharing method, system, computer read/write memory medium and server |
| CN108764354A (en) * | 2018-05-31 | 2018-11-06 | 北京百度网讯科技有限公司 | Method and device for handling information |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US11423041B2 (en) | Maintaining data lineage to detect data events | |
| CN110019350B (en) | Data query method and device based on configuration information | |
| CN111753019B (en) | A data partitioning method and device for data warehouse | |
| CN110765187A (en) | Data source route management method and device | |
| US8494888B2 (en) | Offline modification of business data | |
| EP2883172A1 (en) | High performance real-time relational database system and methods for using same | |
| CN110019539A (en) | A kind of method and apparatus that the data of data warehouse are synchronous | |
| US20120224482A1 (en) | Credit feedback system for parallel data flow control | |
| CN111984686A (en) | Data processing method and device | |
| US20180074797A1 (en) | Transform a data object in a meta model based on a generic type | |
| JP2021525907A (en) | Frequent pattern analysis of distributed systems | |
| US11687567B2 (en) | Trigger based analytics database synchronization | |
| CN107665237A (en) | Data structure sorter, the distribution subscription system of unstructured data and method | |
| CN113434312A (en) | Data blood relationship processing method and device | |
| CN105550238A (en) | Architecture system of database appliance | |
| CN110795135B (en) | A method and device for implementing annotation configuration | |
| CN106156277A (en) | For third-party data sharing update method and system | |
| CN109947736B (en) | Method and system for real-time computing | |
| CN105915587A (en) | Content push method, content push system and buffer memory server | |
| CN113190558A (en) | A data processing method and system | |
| CN114138758A (en) | A method, device and readable medium for data cleaning and merging based on multi-source system | |
| CN108696559A (en) | Method for stream processing and device | |
| CN111782351A (en) | A method and device for distributed task scheduling | |
| US9734185B2 (en) | Mechanism for communication in a distributed database | |
| US8990836B2 (en) | Integrating software solution units |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| C06 | Publication | ||
| PB01 | Publication | ||
| C10 | Entry into substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| WD01 | Invention patent application deemed withdrawn after publication | ||
| WD01 | Invention patent application deemed withdrawn after publication |
Application publication date: 20161123 |