[go: up one dir, main page]
More Web Proxy on the site http://driver.im/

CN113709250B - 一种基于订阅发送模式的跨域用户数据同步方法 - Google Patents

一种基于订阅发送模式的跨域用户数据同步方法 Download PDF

Info

Publication number
CN113709250B
CN113709250B CN202111010309.5A CN202111010309A CN113709250B CN 113709250 B CN113709250 B CN 113709250B CN 202111010309 A CN202111010309 A CN 202111010309A CN 113709250 B CN113709250 B CN 113709250B
Authority
CN
China
Prior art keywords
node
data
user
subscription
user data
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.)
Active
Application number
CN202111010309.5A
Other languages
English (en)
Other versions
CN113709250A (zh
Inventor
赵侃侃
谢荣平
戴佳男
朱晨
马毓凯
张晓兵
孙扬
丁仕明
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
CETC 28 Research Institute
Original Assignee
CETC 28 Research Institute
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by CETC 28 Research Institute filed Critical CETC 28 Research Institute
Priority to CN202111010309.5A priority Critical patent/CN113709250B/zh
Publication of CN113709250A publication Critical patent/CN113709250A/zh
Application granted granted Critical
Publication of CN113709250B publication Critical patent/CN113709250B/zh
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Classifications

    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/01—Protocols
    • H04L67/02—Protocols based on web technology, e.g. hypertext transfer protocol [HTTP]
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/01—Protocols
    • H04L67/10—Protocols in which an application is distributed across nodes in the network
    • H04L67/1095—Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/01—Protocols
    • H04L67/10—Protocols in which an application is distributed across nodes in the network
    • H04L67/1097—Protocols in which an application is distributed across nodes in the network for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS]
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/14—Session management
    • H04L67/146—Markers for unambiguous identification of a particular session, e.g. session cookie or URL-encoding
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/34—Network arrangements or protocols for supporting network services or applications involving the movement of software or configuration parameters 
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/50—Network services
    • H04L67/55—Push-based network services

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Information Retrieval, Db Structures And Fs Structures Therefor (AREA)

Abstract

本发明公开了一种基于订阅发送模式的跨域用户数据同步方法，该方法能够在特定的、具有安全限制的网络环境中进行跨域用户数据同步，在每个区域节点内部署一套用户管理服务，用于提供本区域的用户信息数据、角色信息数据以及权限信息数据的管理服务，提供统一的用户登录认证功能；且能够为本区域内的用户信息数据、角色信息数据以及权限信息数据提供全域唯一标识的管理与分配；每个区域之间，也就是跨域节点间，用户管理服务通过传输软件进行传输用户数据；基于订阅发送的模式，可以对用户数据进行订阅并按需拉取和推送更新，减少了冗余数据的传输，提高了传输效率，也实现了跨域的用户数据同步功能。

Description

一种基于订阅发送模式的跨域用户数据同步方法
技术领域
本发明属于计算机技术领域，具体涉及一种基于订阅发送模式的跨域用户数据同步方法。
背景技术
近年来，各类基于数据订阅发布模式的消息中间件已被广泛应用于各类信息系统中，用于处理应用系统内部的消息收发。消息中间件是基于队列与消息传递技术，在网络环境中提供异步或同步、可靠地消息传输的支撑性软件系统。
在特定的网络环境中，在每个区域内部署一套用户管理服务，用于提供本区域内的用户信息、角色信息、权限信息、登录认证等功能的服务。每个区域之间，也就是跨域场景，在特定的网络环境下，由于安全考虑，只允许开放特定的一个或几个端口用于数据交互，普通的HTTP请求无法进行跨域场景的服务访问。因此，现有的消息中间件并不适用于这种特定的具有安全限制的网络环境。目前，用于实现跨域用户数据同步的方案依靠导出用户数据至离线文件中，再通过人工或可实现跨域传输文件的软件将该离线用户数据文件发送至目的域，再在目的域通过导入离线用户数据文件的方式，将源域的用户数据导入至该域内的用户服务。这种方案虽然可实现跨域用户数据的同步，但无法对全域的用户数据形成统一的编配管理，操作繁琐，跨域用户数据同步困难。
发明内容
发明目的：本发明所要解决的技术问题是针对现有技术中，在具有安全限制的网络环境下，跨域用户数据同步困难的问题，提供一种基于订阅发送模式的跨域用户数据同步方法。
为了解决上述技术问题，本发明公开了一种基于订阅发送模式的跨域用户数据同步方法，包括如下步骤：
步骤S1：以当前用户所在区域的节点作为发送节点，其他区域的节点作为订阅节点，在每个节点内部署用户管理服务；
所述用户管理服务用于提供本区域的用户数据目录，所述用户数据目录包括用户信息数据、角色信息数据以及权限信息数据；所述用户管理服务能够为本区域内的用户信息数据、角色信息数据以及权限信息数据提供统一的管理功能以及全域唯一标识的管理与分配；所述用户管理服务还能够提供统一的用户登录认证功能；
各节点的用户管理服务通过指定的传输软件提供的接口进行用户数据传输；
步骤S2：用户在发送节点的用户管理服务内配置其他订阅节点的通信属性，配置完成后，发送节点拉取并形成全域用户数据目录；所述全域用户数据目录为全部区域的用户数据目录的集合；
步骤S3：用户在步骤S2中生成的全域用户数据目录中选择对应订阅节点内需要拉取的用户数据，并向该订阅节点发送订阅用户数据请求，且发送节点将该次订阅用户数据请求记录至本节点内的订阅订单中；
步骤S4：订阅节点收到步骤S3中发送节点发送的订阅用户数据请求，解析后通过传输软件发送对应用户数据至发送节点，且订阅节点将此次发送信息记录至本节点内的发送订单中；
步骤S5：发送节点收到步骤S4中订阅节点发送的用户数据后，将用户数据持久化至本节点；
步骤S6：订阅节点内用户数据发生变化，订阅节点发送用户数据变化信息至发送节点，或者发送节点订阅用户数据变化信息。
进一步地，步骤S1中，所述全域唯一标识共14位；其中，前5位为地域标识，地域标识的前2位代表大地域划分，如东部、西部、南部、北部等，使用数字标识；后3位为大地域下的小区域划分，使用数字标识；第6位标识数据类型，Y代表用户信息数据、J代表角色数据、Q代表权限数据；后8位由当前时间为输入生成的8位随机字符串；用户管理服务可通过解析该全域唯一标识，判断该数据属于的区域、类型等信息。
进一步地，订阅节点与发送节点间通过传输软件进行数据传输，所述传输软件基于UDP传输协议，数据传输时，只需指定目的端IP地址以及传输软件的端口号。
进一步地，所述步骤S2中，用户在发送节点登录用户管理服务，通过用户管理服务的管理页面配置其他订阅节点的通信属性，所述通信属性为传输软件进行UDP传输时所需的目的端IP地址和消息标识号。
进一步地，所述步骤S3中，利用键值对来表示订阅用户数据请求，键为订阅节点ID以及订阅数据类型，值为所需订阅数据在所属订阅节点内的全域唯一标识ID；订阅订单记录了发送节点向订阅节点发送的所有订阅用户数据请求的记录，订阅订单为键值对的集合。
进一步地，所述订阅数据类型包括：用户信息数据、角色信息数据以及权限信息数据；用户信息数据包括用户名称、用户登录名、用户性别以及用户民族；角色信息数据包括角色名称以及角色描述；权限信息数据包括权限类型、权限名称以及权限描述信息。
进一步地，所述步骤S4包括：
步骤S41：订阅节点收到步骤S3中发送节点通过传输软件发送过来的订阅用户数据请求；
步骤S42：订阅节点对收到的订阅用户数据请求进行解析，根据订阅数据类型以及所需订阅数据在所属订阅节点内的全域唯一标识ID，搜索本节点内对应的数据；
步骤S43：订阅节点将搜索到的数据通过传输软件传输至发送节点；
步骤S44：订阅节点将此次发送信息记录至本节点内的发送订单中；所述发送信息包括订阅数据类型、发送节点ID、所需订阅数据在本节点内的全域唯一标识ID以及所需订阅数据在本节点内的更新时间；所述发送订单记录了本订阅节点向发送节点发送的所有发送信息，发送订单为发送信息的集合。
进一步地，步骤S4中，发送节点的用户管理服务接收到来自订阅节点的用户数据，将其新增至本节点内；新增完成后，将新增成功回执消息发送至发送订阅节点，确认新增完成；若两次新增数据不成功，标记该条数据为推送失败记录，可由用户手动进行发送或取消订阅的操作。
进一步地，所述步骤S6包括：
(1)订阅节点更新或删除了对应用户数据，更新或删除后的用户数据在本订阅节点内的全域唯一标识ID在发送订单中进行遍历，匹配后将会启动新的线程执行发送更新或删除数据消息至发送节点；
(2)订阅节点内新增了用户数据，若发送节点需要拉取该条新增用户数据，则需重复步骤S2至S5，进行订阅操作。
进一步地，步骤S6中，若订阅节点内的该条用户数据信息进行了更新，在更新成功后，根据该条数据的全域唯一标识扫描发送订单内的记录，将相关数据通过订单内记录的节点信息发送至发送节点的用户管理服务或其他订阅该条记录的发送节点中，并标识该条数据的操作类型为更新操作。
进一步地，步骤S6中，发送节点收到来自订阅节点的更新或删除数据消息后，将更新的用户数据更新至本节点内或删除本节点内的对应用户数据，完成后发送回执消息至订阅节点，确认更新或删除完成。
进一步地，步骤S6中，若订阅节点收到发送节点发送的确认更新或删除完成消息，则更新或删除操作完成，否则订阅节点会重新向发送节点发送更新或删除数据消息；若两次以上更新或删除数据不成功，则标记该条数据为推送失败记录，可由用户手动进行更新或删除操作。
进一步地，步骤S6中，若订阅节点内新增了某条用户数据，若发送节点需要拉取该条新增用户数据，则需要在订阅节点中重新进行订阅操作。
进一步地，步骤S6中，当发送节点的用户管理服务不再需要之前订阅的用户数据，则在发送节点中选择需要退订的用户数据，进行退订操作后，发送节点内相关的用户数据将不再保留，并删除发送节点相关的订阅订单，同时将退订信息发送至订阅节点，订阅节点也将删除相关的发送订单。
进一步地，所述节点内的用户只对本节点的用户数据具有操作权限，即属地操作权限。
有益效果：在具有安全限制的网络环境中，各节点间只能通过指定的传输软件进行通信，这限制了各个节点间的正常通信，各个节点间的用户数据无法通过普通的HTTP等方式进行汇总和同步。因此，本发明提供了基于订阅发送模式下的用户数据同步的方式，通过用户管理服务使用传输软件作为通信手段，实现了各节点间跨域用户数据的同步。此外，基于订阅发送的模式进行的用户数据同步能够最大程度的与用户服务业务的解耦，订阅、发送功能通过新起的线程进行，不影响本节点内的正常业务的流转处理。基于订阅发送的模式进行的用户数据同步可有效的利用带宽资源，将用户数据进行按需的订阅和发送、同步推送功能。最后，所述属地修改的用户数据权限可有效的避免用户数据的修改冲突，并能够保护用户数据的安全性。
附图说明
图1是本发明提供的一种基于订阅发送模式的跨域用户数据同步方法的示意图；
图2是本发明具体实施方式提供的一种基于订阅发送模式的跨域用户数据同步方法流程图；
图3是本发明具体实施例中的订阅发送流程图。
具体实施方式
下面结合附图和具体实施方式对本发明做更进一步的具体说明。
如图1所示，本发明提出的一种基于订阅发送模式的跨域用户数据同步方法，包括如下步骤：
步骤S1：以当前用户所在区域的节点作为发送节点，其他区域的节点作为订阅节点，在每个节点内部署用户管理服务；
所述用户管理服务用于提供本区域的用户数据目录，所述用户数据目录包括用户信息数据、角色信息数据以及权限信息数据；所述用户管理服务能够为本区域内的用户信息数据、角色信息数据以及权限信息数据提供统一的管理功能以及全域唯一标识的管理与分配；所述用户管理服务还能够提供统一的用户登录认证功能；
各节点的用户管理服务通过指定的传输软件提供的接口进行用户数据传输；
步骤S2：用户在发送节点的用户管理服务内配置其他订阅节点的通信属性，配置完成后，发送节点拉取并形成全域用户数据目录；所述全域用户数据目录为全部区域的用户数据目录的集合；
步骤S3：用户在步骤S2中生成的全域用户数据目录中选择对应订阅节点内需要拉取的用户数据，并向该订阅节点发送订阅用户数据请求，且发送节点将该次订阅用户数据请求记录至本节点内的订阅订单中；
步骤S4：订阅节点收到步骤S3中发送节点发送的订阅用户数据请求，解析后通过传输软件发送对应用户数据至发送节点，且订阅节点将此次发送信息记录至本节点内的发送订单中；
步骤S5：发送节点收到步骤S4中订阅节点发送的用户数据后，将用户数据持久化至本节点；
步骤S6：订阅节点内用户数据发生变化，订阅节点发送用户数据变化信息至发送节点，或者发送节点订阅用户数据变化信息。
以节点A为发送节点，节点B作为订阅节点，结合如图2所示的流程图，对本发明所述方法做详细说明。
在本节点A内的用户管理服务配置其他节点的通信属性，具体为：通过用户管理服务的管理页面和命令行配置其他发送节点的通信属性，所述通信属性为传输软件进行UDP传输时所需的目的端IP地址和消息标识号，配置完成后，能够通过其通信属性获取用户数据目录以及用户数据的跨域发送，在节点A内生成全域用户数据目录；
在节点A的用户管理服务的全域用户数据目录中订阅需要拉取的节点B的用户数据，记录该订阅用户数据请求为一条订阅订单记录；
节点A的用户管理服务依托已配置的节点B的通信属性，将订阅用户数据请求发送至节点B；
节点B的用户管理服务接收到来自节点A的订阅用户数据请求，将该条请求记录至发送订单中，并将节点A选择的用户数据信息发送至节点A；
节点A的用户管理服务接收到来自节点B的用户数据，将其新增至本节点内；新增完成后，将新增成功回执消息发送至节点B，确认新增完成；若两次新增数据不成功，标记该条数据为推送失败记录，可由用户手动进行发送或取消订阅的操作；
若节点B将该条用户数据信息进行了修改，修改成功后，根据该条数据的全域唯一标识ID遍历发送订单内的记录，将相关数据通过订单内记录的节点信息发送至节点A的用户管理服务或其他订阅该条记录的节点中，并标识该条数据的操作类型为更新操作；
节点A的用户管理服务接收到来自节点B的更新用户数据信息，将更新的用户数据更新至本节点内，更新成功后发送回执消息至节点B，确认更新完成；
若节点B的用户管理服务收到了节点A发送的确认更新完成消息，则更新推送流程完成，否则将尝试重新发送更新消息，若两次尝试失败则标记该条更新数据未发送成功；
若节点B新增了某条用户数据，若节点A需要拉取该条记录，则需要在节点A重新进行订阅操作；
当节点A的用户管理服务不再需要之前订阅的用户数据，则在节点A选择需要退订的用户数据，进行退订操作后，节点A内相关的用户数据将不再保留，并删除节点A相关的订阅订单，同时将退订信息发送至节点B，节点B也将删除相关的发送订单。
实施例1
在节点A使用节点B内的用户“张三”进行跨域登录的执行步骤如下：
步骤1，用户在节点A登录用户管理服务，在用户管理服务的界面中配置节点B的通信属性，获取节点B的用户数据目录，形成全域用户数据目录；
步骤2，在节点A的用户管理服务中的全域用户数据目录中选择节点B内的用户“张三”；
步骤3，节点B的用户管理服务接收到订阅请求，将“张三”的用户数据通过传输软件发送至节点A的用户管理服务内；
步骤4，节点A的用户管理服务接收到节点B发送来的“张三”的数据，将该数据存储至本节点内；
步骤5，用户可通过跨域的“张三”用户在节点A进行登录。
实施例2
用户数据订阅发送流程的执行步骤如下，如图3所示：
步骤1，节点A(节点A的ID为01001)内的用户管理服务向节点B(节点B的ID为01002)内的用户管理服务发起订阅用户数据(用户数据ID分别为
01002Y12345678、01002Y23456789)请求，节点A将此次订阅用户数据请求记录至节点A内的订阅订单中，其订阅订单包含订阅数据类型(User，用户信息数据)、订阅节点ID(节点B的ID为01002)以及所需订阅数据在所属订阅节点内的全域唯一标识ID(分别为01002Y12345678、01002Y23456789)；
节点A的用户管理服务向节点C(节点C的ID为01003)内的用户管理服务发起订阅角色信息数据(ID为01003J12345678)、权限信息数据(ID为01003Q12345678)的请求，节点A的用户管理服务将此次订阅用户数据请求记录至节点A用户管理服务内的订阅订单中，其订阅订单包含订阅数据类型(分别为Role，角色信息数据；Resource，权限信息数据)、订阅节点ID(节点C的ID01003)以及所需订阅数据在所属订阅节点内的全域唯一标识ID(分别为01003J12345678、01003Q12345678)；
步骤2，节点B的用户管理服务接收到请求后，解析从节点A发送的订阅用户数据请求，根据订阅数据类型、所需订阅数据在所属订阅节点内的全域唯一标识ID，搜索本域内对应的数据，返回至节点A；同时记录该发送记录至节点B用户管理服务的发送订单内，其发送订单包含订阅数据类型(User，用户信息数据)、发送节点ID(节点A的ID为01001)、以及所需订阅数据在所属订阅节点内的全域唯一标识ID(分别为01002Y12345678、01002Y23456789)；
节点C的用户管理服务接收到请求后，解析从节点A发送的订阅用户数据请求，根据订阅数据类型、所需订阅数据在所属订阅节点内的全域唯一标识ID，搜索本节点内对应的数据，返回至节点A；同时记录该发送记录至节点C用户管理服务的发送订单内，其发送订单包含订阅数据类型(分别为Role，角色信息数据；Resource，权限信息数据)、发送节点ID(节点A的ID01001)，以及所需订阅数据在所属订阅节点内的全域唯一标识ID(分别为01003J12345678、01003Q12345678)；
步骤3，节点A的用户管理服务接收到节点B返回的用户数据，将其存储至本地；节点A的用户管理服务接收到节点C返回的用户数据，将其存储至本地。
本发明提供了一种基于订阅发送模式的跨域用户数据同步方法，具体实现该技术方案的方法和途径很多，以上所述仅是本发明的优选实施方式，应当指出，对于本技术领域的普通技术人员来说，在不脱离本发明原理的前提下，还可以做出若干改进和润饰，这些改进和润饰也应视为本发明的保护范围。本实施例中未明确的各组成部分均可用现有技术加以实现。

Claims (8)

1.一种基于订阅发送模式的跨域用户数据同步方法，其特征在于，包括如下步骤：
步骤S1：以当前用户所在区域的节点作为发送节点，其他区域的节点作为订阅节点，在每个节点内部署用户管理服务；
所述用户管理服务用于提供本区域的用户数据目录，所述用户数据目录包括用户信息数据、角色信息数据以及权限信息数据；所述用户管理服务能够为本区域内的用户信息数据、角色信息数据以及权限信息数据提供统一的管理功能以及全域唯一标识的管理与分配；所述用户管理服务还能够提供统一的用户登录认证功能；
各节点的用户管理服务通过指定的传输软件提供的接口进行用户数据传输；
步骤S2：用户在发送节点的用户管理服务内配置其他订阅节点的通信属性，配置完成后，发送节点拉取并形成全域用户数据目录；所述全域用户数据目录为全部区域的用户数据目录的集合；
步骤S3：用户在步骤S2中生成的全域用户数据目录中选择对应订阅节点内需要拉取的用户数据，并向该订阅节点发送订阅用户数据请求，且发送节点将该次订阅用户数据请求记录至本节点内的订阅订单中；
步骤S4：订阅节点收到步骤S3中发送节点发送的订阅用户数据请求，解析后通过传输软件发送对应用户数据至发送节点，且订阅节点将此次发送信息记录至本节点内的发送订单中；
步骤S5：发送节点收到步骤S4中订阅节点发送的用户数据后，将用户数据持久化至本节点；
步骤S6：订阅节点内用户数据发生变化，订阅节点发送用户数据变化信息至发送节点，或者发送节点订阅用户数据变化信息；
所述步骤S6包括：
订阅节点更新或删除了对应用户数据，更新或删除后的用户数据在本订阅节点内的全域唯一标识ID在发送订单中进行遍历，匹配后将会启动新的线程执行发送更新或删除数据消息至发送节点；
订阅节点内新增了用户数据，若发送节点需要拉取该条新增用户数据，则需重复步骤S2至S5，进行订阅操作；
步骤S6中，若订阅节点内的该条用户数据信息进行了更新，在更新成功后，根据该条数据的全域唯一标识扫描发送订单内的记录，将相关数据通过订单内记录的节点信息发送至发送节点的用户管理服务或其他订阅该条记录的发送节点中，并标识该条数据的操作类型为更新操作；
所述发送节点收到来自订阅节点的更新或删除数据消息后，将更新的用户数据更新至本节点内或删除本节点内的对应用户数据，完成后发送回执消息至订阅节点，确认更新或删除完成。
2.根据权利要求1所述的一种基于订阅发送模式的跨域用户数据同步方法，其特征在于，订阅节点与发送节点间通过传输软件进行数据传输，所述传输软件基于UDP传输协议，数据传输时，只需指定目的端IP地址以及传输软件的端口号。
3.根据权利要求1所述的一种基于订阅发送模式的跨域用户数据同步方法，其特征在于，所述步骤S2中，用户在发送节点登录用户管理服务，通过用户管理服务提供的管理页面配置其他订阅节点的通信属性，所述通信属性为传输软件进行UDP传输时所需的目的端IP地址和消息标识号。
4.根据权利要求1所述的一种基于订阅发送模式的跨域用户数据同步方法，其特征在于，所述步骤S3中，利用键值对来表示订阅用户数据请求，键为订阅节点ID以及订阅数据类型，值为所需订阅数据在所属订阅节点内的全域唯一标识ID；订阅订单记录了发送节点向订阅节点发送的所有订阅用户数据请求的记录，订阅订单为键值对的集合。
5.根据权利要求4所述的一种基于订阅发送模式的跨域用户数据同步方法，其特征在于，所述订阅数据类型包括：用户信息数据、角色信息数据以及权限信息数据；用户信息数据包括用户名称、用户登录名、用户性别以及用户民族；角色信息数据包括角色名称以及角色描述；权限信息数据包括权限类型、权限名称以及权限描述信息。
6.根据权利要求1所述的一种基于订阅发送模式的跨域用户数据同步方法，其特征在于，步骤S4包括：
步骤S41：订阅节点收到步骤S3中发送节点通过传输软件发送过来的订阅用户数据请求；
步骤S42：订阅节点对收到的订阅用户数据请求进行解析，根据订阅数据类型以及所需订阅数据在所属订阅节点内的全域唯一标识ID，搜索本节点内对应的数据；
步骤S43：订阅节点将搜索到的数据通过传输软件传输至发送节点；
步骤S44：订阅节点将此次发送信息记录至本节点内的发送订单中；所述发送信息包括订阅数据类型、发送节点ID、所需订阅数据在本节点内的全域唯一标识ID以及所需订阅数据在本节点内的更新时间；所述发送订单记录了本订阅节点向发送节点发送的所有发送信息，发送订单为发送信息的集合。
7.根据权利要求1所述的一种基于订阅发送模式的跨域用户数据同步方法，其特征在于，若订阅节点收到发送节点发送的确认更新或删除完成消息，则更新或删除操作完成，否则订阅节点会重新向发送节点发送更新或删除数据消息；若两次以上更新或删除数据不成功，则标记该条数据为推送失败记录，可由用户手动进行更新或删除操作。
8.根据权利要求1所述的一种基于订阅发送模式的跨域用户数据同步方法，其特征在于，所述节点内的用户只对本节点的用户数据具有操作权限。
CN202111010309.5A 2021-08-31 2021-08-31 一种基于订阅发送模式的跨域用户数据同步方法 Active CN113709250B (zh)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202111010309.5A CN113709250B (zh) 2021-08-31 2021-08-31 一种基于订阅发送模式的跨域用户数据同步方法

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202111010309.5A CN113709250B (zh) 2021-08-31 2021-08-31 一种基于订阅发送模式的跨域用户数据同步方法

Publications (2)

Publication Number Publication Date
CN113709250A CN113709250A (zh) 2021-11-26
CN113709250B true CN113709250B (zh) 2023-09-15

Family

ID=78657665

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202111010309.5A Active CN113709250B (zh) 2021-08-31 2021-08-31 一种基于订阅发送模式的跨域用户数据同步方法

Country Status (1)

Country Link
CN (1) CN113709250B (zh)

Families Citing this family (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN115174352A (zh) * 2022-07-08 2022-10-11 中国电信股份有限公司 基于网络配置协议的事件通知发送方法及装置、介质
CN116566805B (zh) * 2023-07-10 2023-09-26 中国人民解放军国防科技大学 一种面向体系容灾抗毁的节点跨域调度方法、装置
CN117097443B (zh) * 2023-10-20 2024-01-19 中国电子科技集团公司第二十八研究所 一种具有关键数据发送反馈功能的信息系统及其发送方法

Citations (17)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN102843432A (zh) * 2012-08-30 2012-12-26 西可通信技术设备（河源）有限公司 适用于多客户端数据共享和同步更新的网络通信系统
CN103944924A (zh) * 2014-05-15 2014-07-23 重庆邮电大学 一种基于RESTful的泛在网发布订阅中间件模型
CN106210053A (zh) * 2016-07-12 2016-12-07 国家电网公司 一种电力系统广域消息管理方法
CN107370809A (zh) * 2017-07-13 2017-11-21 广州市百果园信息技术有限公司 数据同步方法及数据搜索系统
CN109325008A (zh) * 2018-09-07 2019-02-12 国电南瑞科技股份有限公司 面向消息中间件的跨域数据同步方法与系统
CN109766322A (zh) * 2018-12-30 2019-05-17 三盟科技股份有限公司 一种数据共享交换方法及系统
CN109960710A (zh) * 2019-01-16 2019-07-02 平安科技（深圳）有限公司 数据库之间的数据同步方法和系统
CN109981772A (zh) * 2019-03-22 2019-07-05 西安电子科技大学 一种基于区块链的多域数据共享交换平台架构
CN110166296A (zh) * 2019-05-23 2019-08-23 南京大学 一种面向载人深空探测的信息中心网络架构的方法
CN110266783A (zh) * 2019-06-13 2019-09-20 中国铁道科学研究院集团有限公司通信信号研究所 一种基于dds的铁路ctc系统通信平台
CN110309231A (zh) * 2019-07-12 2019-10-08 焦点科技股份有限公司 一种跨机房的数据同步方法及系统
CN110688254A (zh) * 2019-09-06 2020-01-14 北京达佳互联信息技术有限公司 一种数据同步方法、装置、电子设备及存储介质
CN111177254A (zh) * 2019-12-05 2020-05-19 武汉达梦数据库有限公司 一种异构关系型数据库之间数据同步的方法和装置
CN111444029A (zh) * 2020-03-05 2020-07-24 中国司法大数据研究院有限公司 一种基于文件交换的跨域微服务调用方法及系统
CN111716353A (zh) * 2020-05-20 2020-09-29 西安交通大学 一种基于发布/订阅模式的数字孪生虚实同步运行方法
CN112148679A (zh) * 2020-09-21 2020-12-29 江苏锐创软件技术有限公司 基于多种数据平台的数据交互方法、系统、装置及存储介质
CN112667928A (zh) * 2020-12-11 2021-04-16 北京中数创新科技股份有限公司 一种基于Handle系统的前缀及标识数据安全订阅方法及系统

Family Cites Families (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US7305420B2 (en) * 2005-05-25 2007-12-04 Microsoft Corporation Synchronizing modifiable documents with multiple clients using document subsections

Patent Citations (17)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN102843432A (zh) * 2012-08-30 2012-12-26 西可通信技术设备（河源）有限公司 适用于多客户端数据共享和同步更新的网络通信系统
CN103944924A (zh) * 2014-05-15 2014-07-23 重庆邮电大学 一种基于RESTful的泛在网发布订阅中间件模型
CN106210053A (zh) * 2016-07-12 2016-12-07 国家电网公司 一种电力系统广域消息管理方法
CN107370809A (zh) * 2017-07-13 2017-11-21 广州市百果园信息技术有限公司 数据同步方法及数据搜索系统
CN109325008A (zh) * 2018-09-07 2019-02-12 国电南瑞科技股份有限公司 面向消息中间件的跨域数据同步方法与系统
CN109766322A (zh) * 2018-12-30 2019-05-17 三盟科技股份有限公司 一种数据共享交换方法及系统
CN109960710A (zh) * 2019-01-16 2019-07-02 平安科技（深圳）有限公司 数据库之间的数据同步方法和系统
CN109981772A (zh) * 2019-03-22 2019-07-05 西安电子科技大学 一种基于区块链的多域数据共享交换平台架构
CN110166296A (zh) * 2019-05-23 2019-08-23 南京大学 一种面向载人深空探测的信息中心网络架构的方法
CN110266783A (zh) * 2019-06-13 2019-09-20 中国铁道科学研究院集团有限公司通信信号研究所 一种基于dds的铁路ctc系统通信平台
CN110309231A (zh) * 2019-07-12 2019-10-08 焦点科技股份有限公司 一种跨机房的数据同步方法及系统
CN110688254A (zh) * 2019-09-06 2020-01-14 北京达佳互联信息技术有限公司 一种数据同步方法、装置、电子设备及存储介质
CN111177254A (zh) * 2019-12-05 2020-05-19 武汉达梦数据库有限公司 一种异构关系型数据库之间数据同步的方法和装置
CN111444029A (zh) * 2020-03-05 2020-07-24 中国司法大数据研究院有限公司 一种基于文件交换的跨域微服务调用方法及系统
CN111716353A (zh) * 2020-05-20 2020-09-29 西安交通大学 一种基于发布/订阅模式的数字孪生虚实同步运行方法
CN112148679A (zh) * 2020-09-21 2020-12-29 江苏锐创软件技术有限公司 基于多种数据平台的数据交互方法、系统、装置及存储介质
CN112667928A (zh) * 2020-12-11 2021-04-16 北京中数创新科技股份有限公司 一种基于Handle系统的前缀及标识数据安全订阅方法及系统

Non-Patent Citations (2)

* Cited by examiner, † Cited by third party
Title
数据订阅分发技术的研究与实现;李耿;朱美正;;计算机工程与设计(第12期);全文 *
跨领域信息交换与共享研究;戴剑伟;冯勤群;;兵工自动化(第09期);全文 *

Also Published As

Publication number Publication date
CN113709250A (zh) 2021-11-26

Similar Documents

Publication Publication Date Title
CN113709250B (zh) 一种基于订阅发送模式的跨域用户数据同步方法
US7680884B2 (en) System and implementation method of controlled multicast
CN101252581A (zh) 数据通信系统及会话管理服务器
CN101771723A (zh) 数据同步方法
KR101240552B1 (ko) 미디어 키 관리 및 상기 미디어 키를 이용한 피어-투-피어 메시지 송수신 시스템 및 방법
US20050039048A1 (en) Efficient new e-mail discovery
CN106648903A (zh) 调用分布式文件系统的方法和装置
CN109548022B (zh) 一种移动终端用户远程接入本地网络的方法
CN103546380A (zh) 一种基于策略路由的报文转发方法和装置
CN102394948B (zh) Dhcp地址分配方法及dhcp服务器
US20050144289A1 (en) Connection control system, connection control equipment and connection management equipment
JP5257968B2 (ja) 情報共有方法、情報共有ネットワークシステム、情報共有サーバおよびプログラム
US8826026B2 (en) Systems and methods for tracking electronic files in computer networks using electronic signatures
US20080189248A1 (en) Multi-site common directory and method for using the multi-site common directory
JP2000148611A (ja) イントラネットとデータベースサーバおよびそのデータ転送方法
JP4628938B2 (ja) データ通信システム、端末装置およびｖｐｎ設定更新方法
KR102226915B1 (ko) 소프트웨어 정의 네트워크에서 플로우 룰 데이터베이스를 운영하는 방법, 장치 및 컴퓨터 프로그램
US20120066293A1 (en) Data relay system, relay device, and computer readable medium
WO2019128804A1 (zh) 群管理、群数据管理方法和装置、群管理系统、存储介质
CN110809033B (zh) 报文转发方法、装置及交换服务器
JP3482863B2 (ja) 電子メール管理システム
CN107888383B (zh) 登录认证方法及装置
CN115190168B (zh) 一种边缘服务器管理系统及服务器集群
CN105610599A (zh) 用户数据管理方法及装置
CN102143125B (zh) Cpm会谈历史记录的访问方法及消息存储服务器

Legal Events

Date Code Title Description
PB01 Publication
PB01 Publication
SE01 Entry into force of request for substantive examination
SE01 Entry into force of request for substantive examination
GR01 Patent grant
GR01 Patent grant