RU2760243C2 - System and method for improving request for creating distributed group of resources based on time delay - Google Patents
System and method for improving request for creating distributed group of resources based on time delay Download PDFInfo
- Publication number
- RU2760243C2 RU2760243C2 RU2020102290A RU2020102290A RU2760243C2 RU 2760243 C2 RU2760243 C2 RU 2760243C2 RU 2020102290 A RU2020102290 A RU 2020102290A RU 2020102290 A RU2020102290 A RU 2020102290A RU 2760243 C2 RU2760243 C2 RU 2760243C2
- Authority
- RU
- Russia
- Prior art keywords
- request
- container
- time delay
- lqnj
- identifier
- Prior art date
Links
Images
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/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/22—Indexing; Data structures therefor; Storage structures
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/22—Indexing; Data structures therefor; Storage structures
- G06F16/2228—Indexing structures
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/24—Querying
- G06F16/245—Query processing
- G06F16/2453—Query optimisation
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/24—Querying
- G06F16/245—Query processing
- G06F16/2453—Query optimisation
- G06F16/24534—Query rewriting; Transformation
- G06F16/24537—Query rewriting; Transformation of operators
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/24—Querying
- G06F16/245—Query processing
- G06F16/2458—Special types of queries, e.g. statistical queries, fuzzy queries or distributed queries
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/24—Querying
- G06F16/245—Query processing
- G06F16/2458—Special types of queries, e.g. statistical queries, fuzzy queries or distributed queries
- G06F16/2471—Distributed queries
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/24—Querying
- G06F16/245—Query processing
- G06F16/2458—Special types of queries, e.g. statistical queries, fuzzy queries or distributed queries
- G06F16/2477—Temporal data queries
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- Data Mining & Analysis (AREA)
- General Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- Databases & Information Systems (AREA)
- Computational Linguistics (AREA)
- Software Systems (AREA)
- Probability & Statistics with Applications (AREA)
- Mathematical Physics (AREA)
- Fuzzy Systems (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
- Computer And Data Communications (AREA)
Abstract
Description
Настоящая заявка испрашивает приоритет заявки на патент КНР № 201710841537.4, поданной 18 сентября 2017 г. и озаглавленной «Query Enhancement System and Method for Constructing Elastic Field Based on Time Delay», содержание которой включено в настоящий документ посредством ссылки во всей своей полноте.This application claims the priority of PRC Patent Application No. 201710841537.4, filed September 18, 2017, entitled "Query Enhancement System and Method for Constructing Elastic Field Based on Time Delay," the contents of which are incorporated herein by reference in their entirety.
Область техники, к которой относится изобретениеThe technical field to which the invention relates
Настоящее изобретение относится к области сетевой технологии и технологии связи по сети и в частности относится к системе и способу улучшения запроса для создания распределяемой группы ресурсов на основании временной задержки.The present invention relates to the field of network technology and communication technology over a network, and in particular relates to a system and method for enhancing a request for creating an allocable resource group based on a time delay.
Предпосылки создания изобретенияBackground of the invention
В известном уровне техники распределенный запрос (query) включает в себя: запрос по диапазону (Range query), агрегирующий запрос, запрос Skyline и запрос Top-k (верхних k элементов). Причем запрос по диапазону (Range query) означает поиск всех ресурсов с одним или множеством значений атрибута, которые находятся в определенном непрерывном интервале, например, идентификация атрибута может быть получена посредством чувствительного к положению алгоритма хеширования на основе Chord, и может применяться сопоставление между одним атрибутом и множеством атрибутов в технологии заполняющей пространство кривой (SFC); агрегирующий запрос относится к запросу некоторой агрегирующей информации, такой как количество, сумма, максимальное значение и среднее значение, некоторых атрибутов в группе ресурсов; и запрос Skyline означает выбор одного поднабора из заданного набора S, в котором любая точка в поднаборе не управляется другими точками в S, и взаимосвязь, предусматривающая управление, любых двух точек типа «p превосходит q» означает, что p превосходит q по меньшей мере в некотором измерении и что p не подчиняется q в других измерениях.In the prior art, a distributed query includes: a Range query, an aggregate query, a Skyline query, and a Top-k query (top k items). Moreover, a Range query means searching for all resources with one or many attribute values that are in a certain continuous interval, for example, an attribute identification can be obtained through a position-sensitive hashing algorithm based on Chord, and a mapping between one attribute can be applied. and multiple attributes in space filling curve (SFC) technology; an aggregation request refers to a request for some aggregation information, such as the number, sum, maximum value, and average value, of some attributes in a resource group; and a Skyline query means selecting one subset from a given set S, in which any point in the subset is not controlled by other points in S, and a controllable relationship of any two points of type "p is greater than q" means that p is greater than q by at least some dimension and that p does not obey q in other dimensions.
В обычном случае применения распределенного запроса система преобразования взаимосвязи, предусматривающей сопоставление, между именем и адресом представляет собой обязательную ссылку при передаче данных в информационно-ориентированной сети (ICN), и характеристики системы преобразования непосредственно влияют на общие характеристики информационно-ориентированной сети (ICN). Посредством механизма именования информационно-ориентированной сети (ICN) каждый субъект в сети получает уникальный идентификатор субъекта (EUID), не зависящий от положения и обладания признаками самопроверки, такими как имя, и посредством динамического связывания между EUID и сетевыми адресами (NA) EUID реализуется связь между субъектами в информационно-ориентированной сети (ICN). Преобразование имен в основном предназначено для установления и поддержания взаимосвязи, предусматривающей сопоставление, между именем содержимого, опубликованным поставщиком содержимого, и сетевым адресом (сетевыми адресами), а также нахождения надлежащего поставщика содержимого и его сетевого адреса посредством извлечения имени содержимого. Однако решения известного уровня техники имеют следующие проблемы:In a typical distributed query application, the mapping system of the mapping relationship between name and address is a mandatory reference in information-oriented network (ICN) communications, and the characteristics of the mapping system directly affect the overall performance of the information-oriented network (ICN). Through the Information-Oriented Network (ICN) naming mechanism, each entity in the network is assigned a unique entity identifier (EUID), independent of position and self-validation features such as name, and through dynamic linking between EUIDs and EUID network addresses (NA), communication is realized between actors in an information-oriented network (ICN). Name translation is primarily intended to establish and maintain a mapping relationship between the content name published by the content provider and the network address (s), and to find the correct content provider and its network address by extracting the content name. However, prior art solutions have the following problems:
1) хотя пространство содержимого вкладывается или укладывается слоями посредством контейнера или структурированной методики согласно характеристикам сети, однако существующий способ разделения не зависит от времени отклика и требований приложения системы, в то время как независимость структурных служебных характеристик, очевидно, не может непосредственно удовлетворять требованиям временной задержки;1) although the content space is nested or stacked in layers by a container or structured technique according to the characteristics of the network, the existing partitioning method does not depend on the response time and the requirements of the system application, while the independence of the structural performance characteristics obviously cannot directly satisfy the time delay requirements ;
2) в среде, которая имеет более высокое требование к мобильности и безопасности, способ применения эластичного масштабируемого запроса согласно требованиям времени отклика или требованиям к характеристикам не может быть предоставлен, и эффективность и точность поиска не могут быть обеспечены при повышении коэффициента использования ресурсов.2) In an environment that has a higher requirement for mobility and security, a method for applying elastic scalable query according to the response time or performance requirements cannot be provided, and the search efficiency and accuracy cannot be ensured while the resource utilization rate is increased.
Кроме того, в существующих способах применения распределенного запроса время отклика запроса обычно связано с масштабом узла, размером участка запроса и количеством атрибутов ресурсов в запросе (то есть пространственный размер), однако результаты запроса не могут быть возвращены в пределах фиксированной временной задержки. Для устранения вышеуказанных проблем необходимо предоставить систему и способ улучшения запроса для создания распределяемой группы ресурсов на основании временной задержки, чтобы удовлетворять требованиям к обработке обращения, заключающимся в возврате результатов запроса в пределах заданной низкой временной задержки в некоторых случаях применения.In addition, in current distributed query applications, the query response time is usually related to the scale of the node, the size of the query chunk, and the number of resource attributes in the query (i.e., the spatial size), however, query results cannot be returned within a fixed time delay. In order to overcome the above problems, it is necessary to provide a system and method for improving the query to create an allocable resource group based on time lag in order to satisfy the request processing requirement of returning query results within a predetermined low time lag in some use cases.
Таким образом, технический результат, на достижение которого направлено заявленное изобретение, заключается в предоставлении системы улучшения запроса для создания распределяемой группы ресурсов на основании временной задержки, с помощью которой эффективно устраняются проблемы организации распределения и запроса, предпочтительно обрабатываются случаи применения с требованиями заданной низкой временной задержки в информационно-ориентированной сети (ICN) и реализуется распределенный ближайший запрос с учетом позиционной взаимосвязи от ближнего к дальнему.Thus, the technical result to which the claimed invention is directed is to provide a request enhancement system for creating an allocated resource group based on a time delay, with the help of which the problems of organizing distribution and request are effectively eliminated, preferably applications with the requirements of a given low time delay are handled. in an information-oriented network (ICN) and a distributed nearest request is implemented taking into account the positional relationship from near to far.
Сущность изобретенияThe essence of the invention
Цель настоящего изобретения заключается в следующем: для устранения вышеуказанных проблем, существующих в имеющихся системе и способе улучшения запроса, в настоящем изобретении предлагается система улучшения запроса для создания распределяемой группы ресурсов на основании временной задержки, с помощью которой эффективно устраняются проблемы организации распределения и запроса, предпочтительно обрабатываются случаи применения с требованиями заданной низкой временной задержки в информационно-ориентированной сети (ICN) и реализуется распределенный ближайший запрос с учетом позиционной взаимосвязи от ближнего к дальнему.The object of the present invention is as follows: in order to eliminate the above problems existing in the existing system and method for improving the request, the present invention proposes a request enhancement system for creating an allocated resource group based on a time delay, by which the problems of organizing distribution and request are effectively eliminated, preferably processing applications requiring a given low latency in an information-oriented network (ICN), and implementing a distributed nearest request based on near-to-far positional relationship.
Для достижения вышеуказанной цели в настоящем изобретении предлагается система улучшения запроса для создания распределяемой группы ресурсов на основании временной задержки, предусматривающая следующее: сетевые узлы логически разделены для получения группы контейнеров, состоящей из множества контейнеров; причем множество контейнеров имеют вложенную взаимосвязь, то есть множество контейнеров составляют группу контейнеров, и каждый контейнер дополнительно содержит: узел управления, используемый для организации узлов, поддержания соседства и обслуживания запросов в контейнере; причем логическое разделение относится к перераспределению набора физических узлов согласно заданному правилу контейнера для образования набора логических узлов, вследствие чего узлы, которые не находятся в одном и том же физическом объеме, также могут образовывать взаимосвязь в виде соседства; организация узлов относится к структурированному управлению узлами в контейнере для образования логической топологической структуры; поддержание соседства относится к поддержанию состояния непосредственного соединения в логической топологической структуре; и обслуживание запросов относится к извлечению базы данных после приема обращения для возврата запрашиваемого содержимого.To achieve the above object, the present invention proposes a request enhancement system for creating an allocable resource group based on a time delay, comprising: the network nodes are logically separated to obtain a container group consisting of a plurality of containers; moreover, the plurality of containers have a nested relationship, that is, the plurality of containers constitute a group of containers, and each container further comprises: a control node used to organize nodes, maintain neighborhood and serve requests in the container; moreover, logical separation refers to the reallocation of a set of physical nodes according to a predetermined container rule to form a set of logical nodes, whereby nodes that are not in the same physical volume can also form a relationship in the form of a neighborhood; organization of nodes refers to the structured management of nodes in a container to form a logical topological structure; Neighborhood maintenance refers to maintaining a direct connection state in a logical topological structure; and servicing requests refers to retrieving the database after receiving the request to return the requested content.
Система улучшения запроса для создания распределяемой группы ресурсов на основании временной задержки, в частности, предусматривает следующее: на основании набора индексов временной задержки {Ti} сетевые узлы логически разделены, причем каждый индекс временной задержки Ti соответствует слою контейнера уровня Ci без пересечения и с полным покрытием, контейнеры уровня Ci имеют вложенную взаимосвязь между собой, то есть множество контейнеров уровня Ci составляют контейнер уровня Ci+1, причем Ti<Ti+1, 1≤i≤I-1, где I представляет собой количество слоев вложенных контейнеров, а Ti представляет собой фактический индекс временной задержки запроса.The query enhancement system for creating an allocated resource group based on time delay, in particular, provides the following: based on a set of time delay indices {Ti}, the network nodes are logically separated, with each time delay index Ti corresponding to a container layer of the Ci level without intersection and with full coverage , containers of level Ci have a nested relationship with each other, that is, many containers of level Ci constitute a container of level Ci + 1, where Ti <Ti + 1, 1≤i≤I-1, where I is the number of layers of nested containers, and Ti is is the actual index of the time delay for the request.
Топология управления системы улучшения запроса для создания распределяемой группы ресурсов на основании временной задержки представляет собой древовидную структуру, и корневой узел представляет собой узел управления контейнера уровня CI; любой локальный узел запроса, доступ к которому осуществляется посредством обращения с запросом, обозначен как LQNj и образует участок распределяемой группы ресурсов вместе с контейнером уровня Ci, содержащим локальный узел запроса (LQNj), и соседними элементами контейнера, чтобы удовлетворять требованиям запроса, заключающимся в том, что набор индексов временной задержки {Ti} должен быть меньше любого заданного верхнего предела временной задержки Ts.The control topology of the request enhancement system for creating an allocable resource group based on the time delay is a tree structure, and the root node is a CI-level container control node; any local request node that is accessed through a request is denoted as LQNj and forms a portion of the resource group to be allocated together with a Ci-level container containing the local request node (LQNj) and neighboring container elements to satisfy the request's requirement that that the set of time delay indices {Ti} should be less than any given upper limit of the time delay Ts.
Требование запроса, заключающееся в том, что набор индексов временной задержки {Ti} должен быть меньше любого заданного верхнего предела временной задержки Ts, в частности, предусматривает следующее:The query requirement that the set of time delay indices {Ti} must be less than any given upper limit of the time delay Ts, specifically provides for the following:
a) когда Ts<T1 и i=1, запрашивание в LQNj, принимающем обращение с запросом, контейнере уровня C1, содержащем LQNj, и соседних элементах контейнера;a) when Ts <T1 and i = 1, a request in the LQNj receiving the request reference, the C1 container containing the LQNj, and the neighboring elements of the container;
b) когда Ti≤Ts<Ti+1, запрашивание в контейнере уровня Ci, содержащем LQNj, и его соседних элементах;b) when Ti≤Ts <Ti + 1, querying in the Ci level container containing LQNj and its neighbors;
c) когда Ts≥TI, i=I, запрашивание в контейнере уровня CI, содержащем LQNj.c) when Ts≥TI, i = I, request in the CI container containing LQNj.
На основании системы улучшения запроса для создания распределяемой группы ресурсов на основании временной задержки в настоящем изобретении также раскрывается способ улучшения запроса для создания распределяемой группы ресурсов на основании временной задержки, включающий: подвергание сетевых узлов логическому разделению без пересечения и с полным покрытием на каждом слое для получения группы контейнеров, состоящей из множества контейнеров, причем множество контейнеров имеют вложенную взаимосвязь, и соответственно выполнения потока запросов без требований заданной низкой временной задержки и потока ближайших запросов с требованиями заданной низкой временной задержки; причемBased on a request enhancement system for creating an allocated resource group based on a time delay, the present invention also discloses a method for improving a request for creating an allocated resource group based on a time delay, including: subjecting network nodes to logical separation without intersection and with full coverage on each layer to obtain a group of containers consisting of a plurality of containers, the plurality of containers having a nested relationship, and, accordingly, executing a flow of requests without requiring a predetermined low latency and a flow of nearby requests with requirements of a predetermined low latency; moreover
поток запросов без требований заданной низкой временной задержки реализуют посредством применения существующей технологии запроса;the flow of requests without the requirement of a predetermined low latency is realized by using the existing request technology;
поток запросов с требованием заданной низкой временной задержки применяет способ распределенного ближайшего запроса для ближайшего запроса, вследствие чего то, что фактический индекс временной задержки запроса Ti меньше требований определенного верхнего предела временной задержки Ts, в частности, предусматривает следующее:The flow of requests requiring a predetermined low latency time adopts the distributed nearest request method for the nearest request, whereby the fact that the actual request time lag index Ti is less than the requirements of a certain upper limit of the time delay Ts, in particular, provides the following:
этап 1), когда Ti<Ts, прием определенным локальным узлом запроса (LQNj) обращения с запросом при требованиях заданной низкой временной задержки, направляемого на определенный уникальный идентификатор (ID) субъекта, где Ti представляет собой фактический индекс временной задержки запроса, а Ts представляет собой верхний предел временной задержки;step 1) when Ti <Ts, receiving by a certain local node a request (LQNj) a request request for a given low latency requirement directed to a specific subject unique identifier (ID), where Ti is the actual query latency index and Ts is is the upper limit of the time delay;
этап 2), когда i=1, оценивание того, удовлетворяется ли Ts<T1, причем, если Ts<T1, переход к следующему этапу; если Ts больше T1 или равен ему, переход сразу к этапу 4);step 2), when i = 1, evaluating whether Ts <T1 is satisfied, and if Ts <T1, go to the next step; if Ts is greater than or equal to T1, go directly to step 4);
этап 3), когда Ts<T1 и i=1, запрашивание в LQNj, принимающем обращение с запросом, контейнере уровня C1, содержащем LQNj, и соседних элементах контейнера; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, непосредственный возврат результатов запроса; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, возврат отрицательного результата запроса;step 3), when Ts <T1 and i = 1, requesting the LQNj receiving the request access, the C1 container containing the LQNj, and the neighboring elements of the container; in case of a successful request for the network address (s) corresponding to the identifier, direct return of the query results; in case of unsuccessful request for the network address corresponding to the identifier, return a negative result of the request;
этап 4), для любого условия, удовлетворяющего 1≤i≤I-1, проверка того, удовлетворяется ли Ti≤Ts<Ti+1: если Ti≤Ts<Ti+1 удовлетворяется, переход к следующему этапу, если Ti≤Ts<Ti+1 не удовлетворяется, переход сразу к этапу 7);step 4), for any condition satisfying 1≤i≤I-1, check if Ti≤Ts <Ti + 1: if Ti≤Ts <Ti + 1 is satisfied, go to the next step if Ti≤Ts < Ti + 1 is not satisfied, go directly to step 7);
этап 5), когда Ti≤Ts<Ti+1, переадресация обращения с запросом на узел запроса контейнера уровня Ci, содержащего LQNj, и обозначение контейнера как Cik, и выполнение предварительного запроса в Cik и его списке соседних элементов {Cim}; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, переход к следующему этапу; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, возврат отрицательного результата запроса;step 5) when Ti≤Ts <Ti + 1, forwarding the request to the request node of the Ci level container containing LQNj and designating the container as Cik, and performing a preliminary query in Cik and its neighbor list {Cim}; in case of a successful request for the network address (s) corresponding to the identifier, go to the next stage; in case of unsuccessful request for the network address corresponding to the identifier, return a negative result of the request;
этап 6), запрашивание в Cik и его списке соседних элементов {Cim}; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, непосредственный возврат результатов запроса, в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, возврат отрицательного результата запроса;step 6) requesting Cik and its neighbor list {Cim}; in the case of a successful request for the network address (network addresses) corresponding to the identifier, direct return of the query results, in the case of an unsuccessful request for the network address corresponding to the identifier, return a negative result of the request;
этап 7), выполнение предварительного запроса в контейнере уровня CI, содержащем LQNj; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, переход к следующему этапу; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, переход сразу к этапу 9);step 7), executing the preliminary request in the container of the CI level containing the LQNj; in case of a successful request for the network address (s) corresponding to the identifier, go to the next stage; in case of unsuccessful request for the network address corresponding to the identifier, go directly to step 9);
этап 8), запрашивание в контейнере уровня CI, содержащем LQNj; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, непосредственный возврат результатов запроса; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, переход к следующему этапу;step 8), requesting in the container of the CI level containing the LQNj; in case of a successful request for the network address (s) corresponding to the identifier, direct return of the query results; in case of unsuccessful request for the network address corresponding to the identifier, go to the next stage;
этап 9), запрашивание списка соседних элементов {CIm} контейнера уровня CI, содержащего LQNj, посредством междоменного обмена; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, в определенном контейнере уровня CI, обозначение контейнера как CIp и переход к следующему этапу; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, возврат отрицательного результата запроса; иstep 9) requesting the neighbor list {CIm} of the CI layer container containing the LQNj through inter-domain exchange; in case of successful request of the network address (s) corresponding to the identifier in a certain container of the CI level, designating the container as CIp and proceeding to the next stage; in case of unsuccessful request for the network address corresponding to the identifier, return a negative result of the request; and
этап 10), переадресация обращения с запросом на CIp и запрашивание в CIp; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, непосредственный возврат результатов запроса; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, возврат отрицательного результата запроса;Step 10), forwarding the CIp request and requesting the CIp; in case of a successful request for the network address (s) corresponding to the identifier, direct return of the query results; in case of unsuccessful request for the network address corresponding to the identifier, return a negative result of the request;
предпочтительно на этапе 3) запрос выполняют в LQNj, принимающем обращение с запросом, контейнере уровня C1, содержащем LQNj, и локальной хеш-таблице (HT) в соседних элементах;preferably in step 3) the query is executed in the LQNj receiving the request reference, the C1 container containing the LQNj, and the local hash table (HT) in the neighbors;
предпочтительно на этапе 5) запрос выполняют в фильтре Блума (BF) в Cik и его списке соседних элементов {Cim};preferably in step 5) the query is performed on a Bloom filter (BF) in Cik and its neighbor list {Cim};
предпочтительно на этапе 6) запрос выполняют в распределенной хеш-таблице (DHT) в Cik и его списке соседних элементов {Cim};preferably in step 6) the query is performed on a distributed hash table (DHT) in Cik and its neighbor list {Cim};
предпочтительно на этапе 7) предварительный запрос выполняют в фильтре Блума (BF) в контейнере уровня CI, содержащем LQNj;preferably in step 7) the preliminary request is performed in a Bloom filter (BF) in a container of the CI layer containing LQNj;
предпочтительно на этапе 8) запрос выполняют в распределенной хеш-таблице (DHT) в контейнере уровня CI, содержащем LQNj;preferably in step 8) the query is performed on a distributed hash table (DHT) in a CI-level container containing LQNj;
предпочтительно на этапе 9) запрос выполняют в фильтре Блума (BF) в списке соседних элементов {CIm} контейнера уровня CI, содержащего LQNj; иpreferably in step 9) the query is performed in a Bloom filter (BF) in the neighbor list {CIm} of the CI layer container containing LQNj; and
предпочтительно запрос выполняют в распределенной хеш-таблице (DHT) в CIp.preferably the query is performed on a distributed hash table (DHT) in the CIp.
В вышеуказанном техническом решении, что касается потока ближайших запросов с требованиями заданной низкой временной задержки, для экономии затрат на обслуживание список соседних элементов {C1m} C1k может быть сокращен до контейнера уровня C1 без соседних элементов, и конкретный поток запросов предусматривает следующее:In the above technical solution, regarding the flow of nearest requests with the requirements of a given low latency, in order to save maintenance costs, the list of neighbors {C1m} C1k can be reduced to a C1 level container with no neighbors, and the specific flow of requests includes the following:
этап 1), когда Ti<Ts, прием определенным локальным узлом запроса (LQNj) обращения с запросом с требованиями заданной низкой временной задержки, направляемого на определенный уникальный идентификатор (ID) субъекта, где Ti представляет собой фактический индекс временной задержки запроса, а Ts представляет собой верхний предел временной задержки;step 1) when Ti <Ts, receiving by a certain local node a request (LQNj) a request requesting a given low time delay request directed to a certain unique identifier (ID) of the subject, where Ti is the actual time delay index of the request, and Ts is is the upper limit of the time delay;
этап 2), когда i=1, оценивание того, удовлетворяется ли Ts<T1: если Ts<T1, переход к следующему этапу; если Ts больше T1 или равен ему, переход сразу к этапу 4);step 2) when i = 1, judging whether Ts <T1 is satisfied: if Ts <T1, go to the next step; if Ts is greater than or equal to T1, go directly to step 4);
этап 3), когда Ts<T1 и i=1, запрашивание в LQNj, принимающем обращение с запросом, контейнере уровня C1, содержащем LQNj, и его соседних элементах; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, непосредственный возврат результатов запроса; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, возврат отрицательного результата запроса;step 3), when Ts <T1 and i = 1, requesting the LQNj receiving the request reference, the C1 container containing the LQNj and its neighbors; in case of a successful request for the network address (s) corresponding to the identifier, direct return of the query results; in case of unsuccessful request for the network address corresponding to the identifier, return a negative result of the request;
этап 4), для любого условия, удовлетворяющего 1≤i≤I-1, проверка того, удовлетворяется ли Ti≤Ts<Ti+1: если Ti≤Ts<Ti+1 удовлетворяется, переход к следующему этапу, если Ti≤Ts<Ti+1 не удовлетворяется, переход сразу к этапу 7);step 4), for any condition satisfying 1≤i≤I-1, check if Ti≤Ts <Ti + 1: if Ti≤Ts <Ti + 1 is satisfied, go to the next step if Ti≤Ts < Ti + 1 is not satisfied, go directly to step 7);
этап 5), когда Ti≤Ts<Ti+1, переадресация обращения с запросом на узел запроса контейнера уровня Ci, содержащего LQNj, и обозначение контейнера как Cik, и выполнение предварительного запроса в Cik и его списке соседних элементов {Cim}; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, переход к следующему этапу; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, возврат отрицательного результата запроса;step 5) when Ti≤Ts <Ti + 1, forwarding the request to the request node of the Ci level container containing LQNj and designating the container as Cik, and performing a preliminary query in Cik and its neighbor list {Cim}; in case of a successful request for the network address (s) corresponding to the identifier, go to the next stage; in case of unsuccessful request for the network address corresponding to the identifier, return a negative result of the request;
этап 6), запрашивание в Cik и его списке соседних элементов {Cim}; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, непосредственный возврат результатов запроса, в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, возврат отрицательного результата запроса;step 6) requesting Cik and its neighbor list {Cim}; in the case of a successful request for the network address (network addresses) corresponding to the identifier, direct return of the query results, in the case of an unsuccessful request for the network address corresponding to the identifier, return a negative result of the request;
этап 7), выполнение предварительного запроса в контейнере уровня CI, содержащем LQNj; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, переход к следующему этапу; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, переход сразу к этапу 9); иstep 7), executing the preliminary request in the container of the CI level containing the LQNj; in case of a successful request for the network address (s) corresponding to the identifier, go to the next stage; in case of unsuccessful request for the network address corresponding to the identifier, go directly to step 9); and
этап 8), запрашивание в контейнере уровня CI, содержащем LQNj; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, непосредственный возврат результатов запроса; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, переход к следующему этапу;step 8), requesting in the container of the CI level containing the LQNj; in case of a successful request for the network address (s) corresponding to the identifier, direct return of the query results; in case of unsuccessful request for the network address corresponding to the identifier, go to the next stage;
предпочтительно на этапе 5) запрос выполняют в фильтре Блума (BF) в Cik и его списке соседних элементов {Cim};preferably in step 5) the query is performed on a Bloom filter (BF) in Cik and its neighbor list {Cim};
предпочтительно на этапе 6) запрос выполняют в распределенной хеш-таблице (DHT) в Cik и его списке соседних элементов {Cim};preferably in step 6) the query is performed on a distributed hash table (DHT) in Cik and its neighbor list {Cim};
предпочтительно на этапе 7) предварительный запрос выполняют в фильтре Блума (BF) в контейнере уровня CI, содержащем LQNj;preferably in step 7) the preliminary request is performed in a Bloom filter (BF) in a container of the CI layer containing LQNj;
предпочтительно на этапе 8) запрос выполняют в распределенной хеш-таблице (DHT) в контейнере уровня CI, содержащем LQNj.preferably in step 8) the query is performed on a distributed hash table (DHT) in a CI layer container containing LQNj.
Настоящее изобретение имеет следующие преимущества: оно направлено на различные чувствительные к временной задержке применения, предусматривающие низкую временную задержку и высокую надежность, в настоящем изобретении раскрываются система и способ улучшения запроса для создания распределяемой группы ресурсов на основании временной задержки, и благодаря ему удовлетворяют требованиям к обработке обращения, заключающимся в возврате результатов запроса в пределах заданной низкой временной задержки. Посредством распределенного ближайшего запроса с учетом позиционной взаимосвязи от ближнего к дальнему и посредством обработке согласно приоритету случаев применения с низкой временной задержкой общее время запроса может быть существенно сокращено.The present invention has the following advantages: it is directed to various time-sensitive applications providing low latency and high reliability, the present invention discloses a system and method for enhancing a request for creating an allocated resource group based on a time delay, and thereby satisfying processing requirements call, which consists in returning the results of a query within a specified low time delay. By distributed closest request considering the positional relationship from near to far and by processing according to the priority of low latency applications, the total request time can be significantly reduced.
Краткое описание графических материаловBrief description of graphic materials
На фиг. 1 представлена структурная схема системы улучшения запроса для создания распределяемой группы ресурсов на основании временной задержки согласно настоящему изобретению.FIG. 1 is a block diagram of a request enhancement system for creating an allocable resource group based on a time delay in accordance with the present invention.
Подробное описание вариантов осуществленияDetailed Description of Embodiments
Как показано на фиг. 1, в настоящем изобретении предлагается система улучшения запроса для создания распределяемой группы ресурсов на основании временной задержки, предусматривающая следующее: сетевые узлы логически разделены для получения группы контейнеров, состоящей из множества контейнеров; причем множество контейнеров имеют вложенную взаимосвязь, то есть множество контейнеров составляют группу контейнеров, и каждый контейнер дополнительно содержит: узел управления, используемый для организации узлов, поддержания соседства и обслуживания запросов в контейнере; причем логическое разделение относится к перераспределению набора физических узлов согласно заданному правилу контейнера для образования набора логических узлов, вследствие чего узлы, которые не находятся в одном и том же физическом объеме, также могут образовывать взаимосвязь в виде соседства; организация узлов относится к структурированному управлению узлами в контейнере для образования логической топологической структуры; поддержание соседства относится к поддержанию состояния непосредственного соединения в логической топологической структуре; и обслуживание запросов относится к извлечению базы данных после приема обращения для возврата запрашиваемого содержимого.As shown in FIG. 1, the present invention proposes a request enhancement system for creating an allocable resource group based on a time delay, comprising: network nodes are logically separated to obtain a container group consisting of a plurality of containers; moreover, the plurality of containers have a nested relationship, that is, the plurality of containers constitute a group of containers, and each container further comprises: a control node used to organize nodes, maintain neighborhood and serve requests in the container; moreover, logical separation refers to the reallocation of a set of physical nodes according to a predetermined container rule to form a set of logical nodes, whereby nodes that are not in the same physical volume can also form a relationship in the form of a neighborhood; organization of nodes refers to the structured management of nodes in a container to form a logical topological structure; Neighborhood maintenance refers to maintaining a direct connection state in a logical topological structure; and servicing requests refers to retrieving the database after receiving the request to return the requested content.
Система улучшения запроса для создания распределяемой группы ресурсов на основании временной задержки, в частности, предусматривает следующее: на основании набора индексов временной задержки {Ti} сетевые узлы логически разделены, причем каждый индекс временной задержки Ti соответствует слою контейнера уровня Ci без пересечения и с полным покрытием, контейнеры уровня Ci имеют вложенную взаимосвязь между собой, то есть множество контейнеров уровня Ci составляют контейнер уровня Ci+1, причем Ti<Ti+1, 1≤i≤I-1, где I представляет собой количество слоев вложенных контейнеров, а Ti представляет собой фактический индекс временной задержки запроса.The query enhancement system for creating an allocated resource group based on time delay, in particular, provides the following: based on a set of time delay indices {Ti}, the network nodes are logically separated, with each time delay index Ti corresponding to a container layer of the Ci level without intersection and with full coverage , containers of level Ci have a nested relationship with each other, that is, many containers of level Ci constitute a container of level Ci + 1, where Ti <Ti + 1, 1≤i≤I-1, where I is the number of layers of nested containers, and Ti is is the actual index of the time delay for the request.
Топология управления системы улучшения запроса для создания распределяемой группы ресурсов на основании временной задержки представляет собой древовидную структуру, и корневой узел представляет собой узел управления контейнера уровня CI; любой локальный узел запроса, доступ к которому осуществляется посредством обращения с запросом, обозначен как LQNj и образует участок распределяемой группы ресурсов вместе с контейнером уровня Ci, содержащим локальный узел запроса (LQNj), и соседними элементами контейнера, чтобы удовлетворять требованиям запроса, заключающимся в том, что индекс временной задержки {Ti} должен быть меньше любого заданного верхнего предела временной задержки Ts.The control topology of the request enhancement system for creating an allocable resource group based on the time delay is a tree structure, and the root node is a CI-level container control node; any local request node that is accessed through a request is denoted as LQNj and forms a portion of the resource group to be allocated together with a Ci-level container containing the local request node (LQNj) and neighboring container elements to satisfy the request's requirement that that the time delay index {Ti} should be less than any predetermined upper limit of the time delay Ts.
Требование запроса, заключающееся в том, что набор индексов временной задержки {Ti} должен быть меньше любого заданного верхнего предела временной задержки Ts, в частности, предусматривает следующее:The query requirement that the set of time delay indices {Ti} must be less than any given upper limit of the time delay Ts, specifically provides for the following:
a) когда Ts<T1 и i=1, запрашивание в LQNj, принимающем обращение с запросом, контейнере уровня C1, содержащем LQNj, и соседних элементах контейнера;a) when Ts <T1 and i = 1, a request in the LQNj receiving the request reference, the C1 container containing the LQNj, and the neighboring elements of the container;
b) когда Ti≤Ts<Ti+1, запрашивание в контейнере уровня Ci, содержащем LQNj, и его соседних элементах; иb) when Ti≤Ts <Ti + 1, querying in the Ci level container containing LQNj and its neighbors; and
c) когда Ts≥TI, i=I, запрашивание в контейнере уровня CI, содержащем LQNj.c) when Ts≥TI, i = I, request in the CI container containing LQNj.
На основании системы улучшения запроса для создания распределяемой группы ресурсов на основании временной задержки в настоящем изобретении также раскрывается способ улучшения запроса для создания распределяемой группы ресурсов на основании временной задержки, включающий: подвергание сетевых узлов логическому разделению без пересечения и с полным покрытием на каждом слое для получения группы контейнеров, состоящей из множества контейнеров, причем множество контейнеров имеют вложенную взаимосвязь, и соответственно выполнения потока запросов без требований заданной низкой временной задержки и потока ближайших запросов с требованиями заданной низкой временной задержки; причемBased on a request enhancement system for creating an allocated resource group based on a time delay, the present invention also discloses a method for improving a request for creating an allocated resource group based on a time delay, including: subjecting network nodes to logical separation without intersection and with full coverage on each layer to obtain a group of containers consisting of a plurality of containers, the plurality of containers having a nested relationship, and, accordingly, executing a flow of requests without requiring a predetermined low latency and a flow of nearby requests with requirements of a predetermined low latency; moreover
поток запросов без требований заданной низкой временной задержки реализуют посредством применения существующей технологии запроса;the flow of requests without the requirement of a predetermined low latency is realized by using the existing request technology;
поток запросов с требованиями заданной низкой временной задержки применяет способ распределенного ближайшего запроса для ближайшего запроса, вследствие чего то, что фактический индекс временной задержки запроса Ti меньше требований определенного верхнего предела временной задержки Ts, в частности, предусматривает следующее:The flow of requests with the requirements of a given low time delay applies the distributed nearest request method for the nearest request, whereby the fact that the actual time delay index of the request Ti is less than the requirements of a certain upper limit of the time delay Ts, in particular, provides the following:
этап 1), когда Ti<Ts, прием определенным локальным узлом запроса (LQNj) обращения с запросом при требованиях заданной низкой временной задержки, направляемого на определенный уникальный идентификатор (ID) субъекта, где Ti представляет собой фактический индекс временной задержки запроса, а Ts представляет собой верхний предел временной задержки;step 1) when Ti <Ts, receiving by a certain local node a request (LQNj) a request request for a given low latency requirement directed to a specific subject unique identifier (ID), where Ti is the actual query latency index and Ts is is the upper limit of the time delay;
этап 2), когда i=1, оценивание того, удовлетворяется ли Ts<T1, причем, если Ts<T1, переход к следующему этапу; если Ts больше T1 или равен ему, переход сразу к этапу 4);step 2), when i = 1, evaluating whether Ts <T1 is satisfied, and if Ts <T1, go to the next step; if Ts is greater than or equal to T1, go directly to step 4);
этап 3), когда Ts<T1 и i=1, запрашивание в LQNj, принимающем обращение с запросом, контейнере уровня C1, содержащем LQNj, и его соседних элементах; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, непосредственный возврат результатов запроса; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, возврат отрицательного результата запроса;step 3), when Ts <T1 and i = 1, requesting the LQNj receiving the request reference, the C1 container containing the LQNj and its neighbors; in case of a successful request for the network address (s) corresponding to the identifier, direct return of the query results; in case of unsuccessful request for the network address corresponding to the identifier, return a negative result of the request;
этап 4), для любого условия, удовлетворяющего 1≤i≤I-1, проверка того, удовлетворяется ли Ti≤Ts<Ti+1: если Ti≤Ts<Ti+1 удовлетворяется, переход к следующему этапу, если Ti≤Ts<Ti+1 не удовлетворяется, переход сразу к этапу 7);step 4), for any condition satisfying 1≤i≤I-1, check if Ti≤Ts <Ti + 1: if Ti≤Ts <Ti + 1 is satisfied, go to the next step if Ti≤Ts < Ti + 1 is not satisfied, go directly to step 7);
этап 5), когда Ti≤Ts<Ti+1, переадресация обращения с запросом на узел запроса контейнера уровня Ci, содержащего LQNj, и обозначение контейнера как Cik, и выполнение предварительного запроса в Cik и его списке соседних элементов {Cim}; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, переход к следующему этапу; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, возврат отрицательного результата запроса;step 5) when Ti≤Ts <Ti + 1, forwarding the request to the request node of the Ci level container containing LQNj and designating the container as Cik, and performing a preliminary query in Cik and its neighbor list {Cim}; in case of a successful request for the network address (s) corresponding to the identifier, go to the next stage; in case of unsuccessful request for the network address corresponding to the identifier, return a negative result of the request;
этап 6), запрашивание в Cik и его списке соседних элементов {Cim}; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, непосредственный возврат результатов запроса, в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, возврат отрицательного результата запроса;step 6) requesting Cik and its neighbor list {Cim}; in the case of a successful request for the network address (network addresses) corresponding to the identifier, direct return of the query results, in the case of an unsuccessful request for the network address corresponding to the identifier, return a negative result of the request;
этап 7), выполнение предварительного запроса в контейнере уровня CI, содержащем LQNj; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, переход к следующему этапу; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, переход сразу к этапу 9);step 7), executing the preliminary request in the container of the CI level containing the LQNj; in case of a successful request for the network address (s) corresponding to the identifier, go to the next stage; in case of unsuccessful request for the network address corresponding to the identifier, go directly to step 9);
этап 8), запрашивание в контейнере уровня CI, содержащем LQNj; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, непосредственный возврат результатов запроса; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, переход к следующему этапу;step 8), requesting in the container of the CI level containing the LQNj; in case of a successful request for the network address (s) corresponding to the identifier, direct return of the query results; in case of unsuccessful request for the network address corresponding to the identifier, go to the next stage;
этап 9), запрашивание списка соседних элементов {CIm} контейнера уровня CI, содержащего LQNj, посредством междоменного обмена; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, в определенном контейнере уровня CI, обозначение контейнера как CIp и переход к следующему этапу; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, возврат отрицательного результата запроса; иstep 9) requesting the neighbor list {CIm} of the CI layer container containing the LQNj through inter-domain exchange; in case of successful request of the network address (s) corresponding to the identifier in a certain container of the CI level, designating the container as CIp and proceeding to the next stage; in case of unsuccessful request for the network address corresponding to the identifier, return a negative result of the request; and
этап 10), переадресация обращения с запросом на CIp и запрашивание в CIp; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, непосредственный возврат результатов запроса; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, возврат отрицательного результата запроса;Step 10), forwarding the CIp request and requesting the CIp; in case of a successful request for the network address (s) corresponding to the identifier, direct return of the query results; in case of unsuccessful request for the network address corresponding to the identifier, return a negative result of the request;
предпочтительно на этапе 3) запрос выполняют в LQNj, принимающем обращение с запросом, контейнере уровня C1, содержащем LQNj, и локальной хеш-таблице (HT) в соседних элементах;preferably in step 3) the query is executed in the LQNj receiving the request reference, the C1 container containing the LQNj, and the local hash table (HT) in the neighbors;
предпочтительно на этапе 5) запрос выполняют в фильтре Блума (BF) в Cik и его списке соседних элементов {Cim};preferably in step 5) the query is performed on a Bloom filter (BF) in Cik and its neighbor list {Cim};
предпочтительно на этапе 6) запрос выполняют в распределенной хеш-таблице (DHT) в Cik и его списке соседних элементов {Cim};preferably in step 6) the query is performed on a distributed hash table (DHT) in Cik and its neighbor list {Cim};
предпочтительно на этапе 7) предварительный запрос выполняют в фильтре Блума (BF) в контейнере уровня CI, содержащем LQNj;preferably in step 7) the preliminary request is performed in a Bloom filter (BF) in a container of the CI layer containing LQNj;
предпочтительно на этапе 8) запрос выполняют в распределенной хеш-таблице (DHT) в контейнере уровня CI, содержащем LQNj;preferably in step 8) the query is performed on a distributed hash table (DHT) in a CI-level container containing LQNj;
предпочтительно на этапе 9) запрос выполняют в фильтре Блума (BF) в списке соседних элементов {CIm} контейнера уровня CI, содержащего LQNj; иpreferably in step 9) the query is performed in a Bloom filter (BF) in the neighbor list {CIm} of the CI layer container containing LQNj; and
предпочтительно запрос выполняют в распределенной хеш-таблице (DHT) в CIp.preferably the query is performed on a distributed hash table (DHT) in the CIp.
В вышеуказанном техническом решении, что касается потока ближайших запросов с требованиями заданной низкой временной задержки, для экономии затрат на обслуживание список соседних элементов {C1m} C1k может быть сокращен до контейнера уровня C1 без соседних элементов, и конкретный поток запросов предусматривает следующее:In the above technical solution, regarding the flow of nearest requests with the requirements of a given low latency, in order to save maintenance costs, the list of neighbors {C1m} C1k can be reduced to a C1 level container with no neighbors, and the specific flow of requests includes the following:
этап 1), когда Ti<Ts, прием определенным локальным узлом запроса (LQNj) обращения с запросом при требованиях заданной низкой временной задержки, направляемого на определенный уникальный идентификатор (ID) субъекта, где Ti представляет собой текущий фактический индекс временной задержки запроса, а Ts представляет собой верхний предел временной задержки;step 1) when Ti <Ts, receiving by a certain local node a request (LQNj) a request request for a given low time delay requirement directed to a specific subject unique identifier (ID), where Ti is the current actual request time delay index, and Ts is the upper limit of the time delay;
этап 2), когда i=1, оценивание того, удовлетворяется ли Ts<T1: если Ts<T1, переход к следующему этапу; если Ts больше T1 или равен ему, переход сразу к этапу 4);step 2) when i = 1, judging whether Ts <T1 is satisfied: if Ts <T1, go to the next step; if Ts is greater than or equal to T1, go directly to step 4);
этап 3), когда Ts<T1 и i=1, запрашивание в LQNj, принимающем обращение с запросом, контейнере уровня C1, содержащем LQNj, и соседних элементах контейнера; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, непосредственный возврат результатов запроса; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, возврат отрицательного результата запроса;step 3), when Ts <T1 and i = 1, requesting the LQNj receiving the request access, the C1 container containing the LQNj, and the neighboring elements of the container; in case of a successful request for the network address (s) corresponding to the identifier, direct return of the query results; in case of unsuccessful request for the network address corresponding to the identifier, return a negative result of the request;
этап 4), для любого условия, удовлетворяющего 1≤i≤I-1, проверка того, удовлетворяется ли Ti≤Ts<Ti+1: если Ti≤Ts<Ti+1 удовлетворяется, переход к следующему этапу, если Ti≤Ts<Ti+1 не удовлетворяется, переход сразу к этапу 7);step 4), for any condition satisfying 1≤i≤I-1, check if Ti≤Ts <Ti + 1: if Ti≤Ts <Ti + 1 is satisfied, go to the next step if Ti≤Ts < Ti + 1 is not satisfied, go directly to step 7);
этап 5), когда Ti≤Ts<Ti+1, переадресация обращения с запросом на узел запроса контейнера уровня Ci, содержащего LQNj, и обозначение контейнера как Cik, и выполнение предварительного запроса в Cik и его списке соседних элементов {Cim}; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, переход к следующему этапу; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, возврат отрицательного результата запроса;step 5) when Ti≤Ts <Ti + 1, forwarding the request to the request node of the Ci level container containing LQNj and designating the container as Cik, and performing a preliminary query in Cik and its neighbor list {Cim}; in case of a successful request for the network address (s) corresponding to the identifier, go to the next stage; in case of unsuccessful request for the network address corresponding to the identifier, return a negative result of the request;
этап 6), запрашивание в Cik и его списке соседних элементов {Cim}; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, непосредственный возврат результатов запроса, в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, возврат отрицательного результата запроса;step 6) requesting Cik and its neighbor list {Cim}; in the case of a successful request for the network address (network addresses) corresponding to the identifier, direct return of the query results, in the case of an unsuccessful request for the network address corresponding to the identifier, return a negative result of the request;
этап 7), выполнение предварительного запроса в контейнере уровня CI, содержащем LQNj; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, переход к следующему этапу; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, переход сразу к этапу 9);step 7), executing the preliminary request in the container of the CI level containing the LQNj; in case of a successful request for the network address (s) corresponding to the identifier, go to the next stage; in case of unsuccessful request for the network address corresponding to the identifier, go directly to step 9);
этап 8), запрашивание в контейнере уровня CI, содержащем LQNj; в случае успешного запрашивания сетевого адреса (сетевых адресов), соответствующего (соответствующих) идентификатору, непосредственный возврат результатов запроса; в случае безуспешного запрашивания сетевого адреса, соответствующего идентификатору, переход к следующему этапу;step 8), requesting in the container of the CI level containing the LQNj; in case of a successful request for the network address (s) corresponding to the identifier, direct return of the query results; in case of unsuccessful request for the network address corresponding to the identifier, go to the next stage;
предпочтительно на этапе 5) запрос выполняют в фильтре Блума (BF) в Cik и его списке соседних элементов {Cim};preferably in step 5) the query is performed on a Bloom filter (BF) in Cik and its neighbor list {Cim};
предпочтительно на этапе 6) запрос выполняют в распределенной хеш-таблице (DHT) в Cik и его списке соседних элементов {Cim};preferably in step 6) the query is performed on a distributed hash table (DHT) in Cik and its neighbor list {Cim};
предпочтительно на этапе 7) предварительный запрос выполняют в фильтре Блума (BF) в контейнере уровня CI, содержащем LQNj;preferably in step 7) the preliminary request is performed in a Bloom filter (BF) in a container of the CI layer containing LQNj;
предпочтительно на этапе 8) запрос выполняют в распределенной хеш-таблице (DHT) в контейнере уровня CI, содержащем LQNj.preferably in step 8) the query is performed on a distributed hash table (DHT) in a CI layer container containing LQNj.
В заключение, следует понимать, что вышеуказанные варианты осуществления используются исключительно для объяснения технических решений настоящего изобретения, а не ограничения настоящего изобретения. Хотя настоящее изобретение было подробно описано со ссылкой на варианты осуществления, специалистам в данной области техники будет понятно, что любые модификации или эквивалентные замены, внесенные в технические решения настоящего изобретения, не выходят за рамки сущности и объема технических решений настоящего изобретения и входят в объем формулы настоящего изобретения.In conclusion, it should be understood that the above embodiments are used solely to explain the technical solutions of the present invention and not to limit the present invention. Although the present invention has been described in detail with reference to the embodiments, it will be understood by those skilled in the art that any modifications or equivalent substitutions made to the technical solutions of the present invention are within the spirit and scope of the technical solutions of the present invention and are included in the scope of the claims of the present invention.
Claims (37)
Applications Claiming Priority (3)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201710841537.4A CN109947764B (en) | 2017-09-18 | 2017-09-18 | A query enhancement system and method for constructing elastic field based on delay |
| CN201710841537.4 | 2017-09-18 | ||
| PCT/CN2017/117698 WO2019052075A1 (en) | 2017-09-18 | 2017-12-21 | Query enhancement system and method for constructing elastic field based on time delay |
Publications (3)
| Publication Number | Publication Date |
|---|---|
| RU2020102290A RU2020102290A (en) | 2021-07-21 |
| RU2020102290A3 RU2020102290A3 (en) | 2021-07-21 |
| RU2760243C2 true RU2760243C2 (en) | 2021-11-23 |
Family
ID=65722365
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| RU2020102290A RU2760243C2 (en) | 2017-09-18 | 2017-12-21 | System and method for improving request for creating distributed group of resources based on time delay |
Country Status (9)
| Country | Link |
|---|---|
| US (1) | US11386103B2 (en) |
| EP (1) | EP3686757A4 (en) |
| JP (1) | JP6992168B2 (en) |
| KR (1) | KR102367540B1 (en) |
| CN (1) | CN109947764B (en) |
| AU (1) | AU2017431351B2 (en) |
| RU (1) | RU2760243C2 (en) |
| SG (1) | SG11202000879VA (en) |
| WO (1) | WO2019052075A1 (en) |
Families Citing this family (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN109729514B (en) * | 2017-10-30 | 2020-07-17 | 中国科学院声学研究所 | Method for quickly inquiring dynamic position information of mobile network entity |
| CN111651478A (en) * | 2020-06-10 | 2020-09-11 | 孙明松 | Operation and maintenance information query system and method |
| CN112965980B (en) * | 2021-03-12 | 2025-02-18 | 深圳赛安特技术服务有限公司 | Information storage method and device |
| CN115499285B (en) * | 2021-06-18 | 2023-11-24 | 中国科学院声学研究所 | Method for constructing name resolution system provided by distributed hierarchical time delay |
Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20080195584A1 (en) * | 2007-02-09 | 2008-08-14 | Microsoft Corporation | Communication Efficient Spatial Search in a Sensor Data Web Portal |
| CN103207897A (en) * | 2013-03-15 | 2013-07-17 | 北京京东世纪贸易有限公司 | Distributed storage query system, operation method thereof and operation device |
| RU2611967C2 (en) * | 2011-06-14 | 2017-03-01 | МАЙКРОСОФТ ТЕКНОЛОДЖИ ЛАЙСЕНСИНГ, ЭлЭлСи | Enriching database query responses using data from external data sources |
| CN106844666A (en) * | 2017-01-20 | 2017-06-13 | 北京理工大学 | A kind of time series data querying method of self adaptation |
Family Cites Families (14)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US7747757B2 (en) * | 2000-11-17 | 2010-06-29 | Computer Associates Think, Inc. | Distributed network query |
| EP1594278A1 (en) * | 2004-05-04 | 2005-11-09 | Hitachi, Ltd. | Method and apparatus for disseminating, storing and collecting information in a communication network |
| US8331263B2 (en) * | 2006-01-23 | 2012-12-11 | Microsoft Corporation | Discovery of network nodes and routable addresses |
| JP5800422B2 (en) * | 2011-11-07 | 2015-10-28 | 国立大学法人広島大学 | Associative memory |
| JP5740652B2 (en) * | 2012-03-28 | 2015-06-24 | 株式会社日立製作所 | Computer system and subsystem management method |
| JP5944537B2 (en) * | 2013-01-31 | 2016-07-05 | 株式会社日立製作所 | Communication path management method |
| CN103401953B (en) * | 2013-07-18 | 2016-07-06 | 东南大学 | A kind of based on double-deck voice communication node addressing method end to end |
| EP3198838A1 (en) | 2014-09-25 | 2017-08-02 | Interdigital Patent Holdings, Inc. | Procedures for content aware caching and radio resource management for multi-point coordinated transmission |
| CN105721182B (en) * | 2014-12-03 | 2018-11-13 | 中国科学院声学研究所 | A kind of management structure clash method of tree structured network |
| US10277668B1 (en) * | 2015-04-06 | 2019-04-30 | EMC IP Holding Company LLC | Beacon-based distributed data processing platform |
| CN107926074B (en) * | 2015-07-08 | 2020-07-07 | 康维达无线有限责任公司 | M2M cluster management |
| CN105049550A (en) * | 2015-08-14 | 2015-11-11 | 电子科技大学 | D1HT+Chord based name and address separation mapping system |
| US10868742B2 (en) * | 2017-03-29 | 2020-12-15 | Juniper Networks, Inc. | Multi-cluster dashboard for distributed virtualization infrastructure element monitoring and policy control |
| US10547521B1 (en) * | 2017-03-29 | 2020-01-28 | Juniper Networks, Inc. | Network dashboard with multifaceted utilization visualizations |
-
2017
- 2017-09-18 CN CN201710841537.4A patent/CN109947764B/en active Active
- 2017-12-21 JP JP2020515243A patent/JP6992168B2/en active Active
- 2017-12-21 KR KR1020207002421A patent/KR102367540B1/en active Active
- 2017-12-21 EP EP17925418.0A patent/EP3686757A4/en not_active Ceased
- 2017-12-21 RU RU2020102290A patent/RU2760243C2/en active
- 2017-12-21 SG SG11202000879VA patent/SG11202000879VA/en unknown
- 2017-12-21 WO PCT/CN2017/117698 patent/WO2019052075A1/en not_active Ceased
- 2017-12-21 US US16/632,900 patent/US11386103B2/en active Active
- 2017-12-21 AU AU2017431351A patent/AU2017431351B2/en not_active Ceased
Patent Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20080195584A1 (en) * | 2007-02-09 | 2008-08-14 | Microsoft Corporation | Communication Efficient Spatial Search in a Sensor Data Web Portal |
| RU2611967C2 (en) * | 2011-06-14 | 2017-03-01 | МАЙКРОСОФТ ТЕКНОЛОДЖИ ЛАЙСЕНСИНГ, ЭлЭлСи | Enriching database query responses using data from external data sources |
| CN103207897A (en) * | 2013-03-15 | 2013-07-17 | 北京京东世纪贸易有限公司 | Distributed storage query system, operation method thereof and operation device |
| CN106844666A (en) * | 2017-01-20 | 2017-06-13 | 北京理工大学 | A kind of time series data querying method of self adaptation |
Also Published As
| Publication number | Publication date |
|---|---|
| SG11202000879VA (en) | 2020-04-29 |
| AU2017431351B2 (en) | 2021-03-11 |
| US20200167357A1 (en) | 2020-05-28 |
| RU2020102290A (en) | 2021-07-21 |
| EP3686757A1 (en) | 2020-07-29 |
| KR20200019994A (en) | 2020-02-25 |
| JP2020533922A (en) | 2020-11-19 |
| JP6992168B2 (en) | 2022-01-13 |
| WO2019052075A1 (en) | 2019-03-21 |
| KR102367540B1 (en) | 2022-02-24 |
| CN109947764A (en) | 2019-06-28 |
| CN109947764B (en) | 2020-12-22 |
| RU2020102290A3 (en) | 2021-07-21 |
| US11386103B2 (en) | 2022-07-12 |
| EP3686757A4 (en) | 2021-06-16 |
| AU2017431351A1 (en) | 2020-02-06 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| RU2760243C2 (en) | System and method for improving request for creating distributed group of resources based on time delay | |
| CN104065568B (en) | Web server cluster routing method | |
| CN104281701B (en) | Multiscale Distributed Spatial data query method and system | |
| CN108920552B (en) | A distributed indexing method for multi-source big data streams | |
| EP2804114A1 (en) | Database controller, method, and program for managing a distributed data store | |
| CN105117497B (en) | Ocean big data principal and subordinate directory system and method based on Spark cloud network | |
| KR101928529B1 (en) | Code Distributed Hash Table based MapReduce System and Method | |
| CN100496004C (en) | Structured peer-to-peer network system and its load query, transfer and resource seeking method | |
| CN103617276A (en) | Method for storing distributed hierarchical RDF data | |
| CN102843426A (en) | Method and system for sharing Web cached resource based on intelligent father node | |
| CN110287391A (en) | Hadoop-based multi-level trajectory data storage method, storage medium and terminal | |
| CN106209989A (en) | Spatial data concurrent computational system based on spark platform and method thereof | |
| CN102946320A (en) | Distributed supervision method and system for user behavior log forecasting network | |
| CN105657064A (en) | Swift load balancing method based on virtual node storage optimization | |
| Shao et al. | An efficient load-balancing mechanism for heterogeneous range-queriable cloud storage | |
| CN102378407B (en) | Object name resolution system and method in internet of things | |
| Al Jawarneh et al. | Cost-effective strategies for provisioning NoSQL storage services in support for industry 4.0 | |
| CN104092735A (en) | Cloud computing data access method and system based on binary tree | |
| CN106326245A (en) | Hive data warehouse-based fast association realization method and device | |
| CN110275885A (en) | Hadoop-based multi-level trajectory data storage device | |
| KR101512647B1 (en) | Method For Choosing Query Processing Engine | |
| CN109831542B (en) | A method and system for processing flat fixed-length names | |
| Zhang et al. | An efficient in-memory R-tree construction scheme for spatio-temporal data stream | |
| CN113553324A (en) | Application-effect distributed multidimensional index DAER-Tree | |
| Zhou et al. | HDKV: supporting efficient high‐dimensional similarity search in key‐value stores |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| FZ9A | Application not withdrawn (correction of the notice of withdrawal) |
Effective date: 20210906 |