CN106933989A - A kind of method of Web realease information system - Google Patents
A kind of method of Web realease information system Download PDFInfo
- Publication number
- CN106933989A CN106933989A CN201710094319.9A CN201710094319A CN106933989A CN 106933989 A CN106933989 A CN 106933989A CN 201710094319 A CN201710094319 A CN 201710094319A CN 106933989 A CN106933989 A CN 106933989A
- Authority
- CN
- China
- Prior art keywords
- message
- node
- subscription
- metaevent
- client
- 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.)
- Granted
Links
- 238000000034 method Methods 0.000 title claims abstract description 35
- 230000008569 process Effects 0.000 claims abstract description 21
- 239000012634 fragment Substances 0.000 claims abstract description 7
- 230000005540 biological transmission Effects 0.000 claims description 18
- 230000014509 gene expression Effects 0.000 claims description 11
- 230000001788 irregular Effects 0.000 claims description 10
- 238000013507 mapping Methods 0.000 claims description 10
- 238000012546 transfer Methods 0.000 claims description 10
- 238000007726 management method Methods 0.000 claims description 8
- 238000013499 data model Methods 0.000 claims description 7
- 230000006870 function Effects 0.000 claims description 6
- 239000007787 solid Substances 0.000 claims description 6
- 239000000203 mixture Substances 0.000 claims description 5
- 239000004744 fabric Substances 0.000 claims description 3
- 238000009472 formulation Methods 0.000 claims description 3
- 238000003780 insertion Methods 0.000 claims description 3
- 230000037431 insertion Effects 0.000 claims description 3
- 230000000903 blocking effect Effects 0.000 claims description 2
- 238000002347 injection Methods 0.000 claims description 2
- 239000007924 injection Substances 0.000 claims description 2
- 241001425476 Apiosporina morbosa Species 0.000 claims 1
- 238000013550 semantic technology Methods 0.000 abstract description 3
- 239000003795 chemical substances by application Substances 0.000 description 14
- 238000005516 engineering process Methods 0.000 description 8
- 230000008878 coupling Effects 0.000 description 6
- 238000010168 coupling process Methods 0.000 description 6
- 238000005859 coupling reaction Methods 0.000 description 6
- 230000003993 interaction Effects 0.000 description 3
- 230000008859 change Effects 0.000 description 2
- 238000004891 communication Methods 0.000 description 2
- 230000009286 beneficial effect Effects 0.000 description 1
- 230000008901 benefit Effects 0.000 description 1
- 238000013500 data storage Methods 0.000 description 1
- 230000001419 dependent effect Effects 0.000 description 1
- 238000001514 detection method Methods 0.000 description 1
- 238000004821 distillation Methods 0.000 description 1
- 230000000694 effects Effects 0.000 description 1
- 238000000605 extraction Methods 0.000 description 1
- 230000006872 improvement Effects 0.000 description 1
- 230000002452 interceptive effect Effects 0.000 description 1
- 238000012423 maintenance Methods 0.000 description 1
- 230000004044 response Effects 0.000 description 1
- 238000005096 rolling process Methods 0.000 description 1
- 239000000243 solution Substances 0.000 description 1
- 230000002123 temporal effect Effects 0.000 description 1
- 238000012360 testing method Methods 0.000 description 1
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/90—Details of database functions independent of the retrieved data types
- G06F16/95—Retrieval from the web
- G06F16/953—Querying, e.g. by the use of web search engines
- G06F16/9535—Search customisation based on user profiles and personalisation
-
- 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/56—Provisioning of proxy services
Landscapes
- Engineering & Computer Science (AREA)
- Databases & Information Systems (AREA)
- Theoretical Computer Science (AREA)
- Data Mining & Analysis (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Information Transfer Between Computers (AREA)
Abstract
The present invention relates to a kind of method of Web realease information system, Web realease information system includes multiple issue clients, agency network, publish/subscribe module, multiple subscription clients and management cluster；Publish/subscribe module includes message memory, message fragment device, user's subscription manager, message distributor；Methods described includes the related critical process of system；The present invention is in order to solve the problems, such as computer understanding information resources, semantic technology is organically combined with distribution subscription system, issue client is understood in the angle of semantic layer and the original idea of client is subscribed to, the event of issue is set more accurately to match the requirement of subscriber, the quality matched with issue is subscribed to so as to improve, the performance of whole system is improved.
Description
Technical field
The present invention relates to computer network field, it is related to a kind of method of Web realease information system.
Background technology
As internet turns into ubiquitous calculating and storage service platform, the data for how data source being produced are quick
Ground, be distributed to the key technical problem that the large-scale consumer colony with different interest is current urgent need to resolve exactly.It is based on
The publish/subscribe of content is because the communication mode of its loose coupling is applied to large scale distributed system and has provided the user powerful
Semantic meaning representation ability, just as the Main Patterns for realizing data distribution.
In order to realize the elastic expansible publish/subscribe service based on content, the technological challenge for currently facing mainly includes
Following two aspects：Represented with event and give out information and subscribe to message, it is right that event matches technology can be filtered out effectively
The uninterested subscriber of event, so as to reduce data distribution delay；Efficient event route technology is to ensure data distribution reality
The key factor of when property, however, uploading bandwidth has performance bottleneck in long data block distribution.
The content of the invention
In view of this, the present invention provides a kind of a kind of Web realease information system for solving or partly solving the above problems
Method.
To reach the effect of above-mentioned technical proposal, the technical scheme is that：A kind of side of Web realease information system
Method, comprises the steps of：
Web realease information system includes multiple issue clients, agency network, publish/subscribe module, multiple subscription clients
And management cluster；Publish/subscribe module includes message memory, message fragment device, user's subscription manager, message distribution
Device；Method includes the related critical process of system；
Agency network is made up of multiple sub-networks, and sub-network is the network that a host node is constituted with node, each node
It is divided into two layers, the priority of ground floor memory node, the second layer is scratchpad area (SPA), stores what is subscribed in scratchpad area (SPA)
, be attached for node by the priority of the priority of node by sort key word, subclassification number and a counter, and priority is high
Node first connect, be attached using virtual link, virtual link can at any time disconnect and set up among the nodes at any time
Annexation；Each sub-network is that what is represented is a classification of subscription, and a pass for classification of subscription is stored in the master node
Keyword and classification number, and the keyword of the subscription of each classification is assigned in each node, the priority of node is to divide
The foundation of the order distributed during with the keyword subscribed to；
The process that critical process gives out information to publish/subscribe module comprising issue client, it is specific as follows：
In multiple, issue client will be given out information before being transferred to publish/subscribe module, and secondary searching is carried out to giving out information
Rope, the keyword subscribed to the presence or absence of a certain class during once search gives out information for search, to host node during search
It is called, when the host node that multiple keywords meet is found, keyword meets more host nodes as the master for meeting condition
Node, and classification number is distributed to give out information, the sub-network where meeting the host node of condition is won, and will give out information broadcast
To all nodes under it, all nodes are according to priority matched, and are matched with the sort key word subscribed to, and are matched
The counter stored in node adds one, and subclassification number of being reallocated on the basis of classification number, and counter is used to record node quilt
The number of times of matching, will give out information send publish/subscribe module to together with classification number and subclassification number；Master to meeting condition
The node in sub-network where node is adjusted priority in real time, and the foundation of adjustment is the Digital size in counter,
Numeral is bigger, and the priority of node is higher, and the priority of the node that will be matched is adjusted, and is adjusted if first time, directly
It is adjacent with front and rear in the case of remaining before first node of the sub-network where connecing the host node for being inserted into and meeting condition
The numeral of the counter of node is compared, and takes dichotomy that the scope of insertion position is gradually reduced, and the node that will be matched is inserted
Enter, make the position before the big node arrangement in a sub-network of numeral in counter；
Critical process also includes how to set up the data model of system；
Expression logical AND storage format of the data model of system comprising message, first, issue is divided into by the type of message
Message and two kinds of message of subscription, give out information and include the content of the title and issue that need issue, subscribe to message package and contain subscription
Client needs the content subscribed to；
Give out information and all represent logical expressions with same in itself with subscription message, represent logical AND of the logic by metaevent
The logic composition of complicated event, the logic of complicated event is made up of the logic of metaevent, and the logic of metaevent W is as follows：
W=(e, n, b, j, P, T, l)
Wherein, e is the expression variable of metaevent, and n is the statement of metaevent, for representing the premise bar that metaevent occurs
Part, precondition represents that b is the binary coding of metaevent, and for being different from other metaevents, j is in first thing with first order logic
Part description to give out information when, be the classification number and subclassification number of node, metaevent for subscribe to message when, be subscribe to visitor
The filter condition that family is specified, P is the hierarchical model of timed colored Petri nets, by one by multiple timed colored Petri nets groups
Into for logically specifically describing metaevent, T is the timestamp of metaevent, initial time and knot for representing metaevent
Beam time, l is interval for the duration of metaevent；
Complicated event is to carry out operative combination on the basis of metaevent to form, and is expressed as follows：
F=(o (W1, Wn),T1,l1)
Wherein, W1, WnIt is metaevent, o is operator, T1It is the timestamp of complicated event, it is complicated for representing
The initial time of event and end time, the initial time of complicated event is metaevent W1, WnInitial time most
Big value, the end time of complicated event is metaevent W1, WnEnd time minimum value, l1It is holding for complicated event
Continuous time interval, is metaevent W1, WnDuration interval minimum value；The logic of operator is | |t、
-、=, W1||tW2Represent metaevent W1With metaevent W2There is and have a generation, and the time for occurring is limited to
In time cycle t, if not limiting the time of generation, t=∞；Represent metaevent W1With metaevent W2Both send out
Give birth to, and the time for occurring is limited to time cycle t1If not limiting the time of generation, t1=∞, if two metaevents are same
Shi Fasheng, t1=0；-W1Represent metaevent W1Will not occur；Represent metaevent W1After generation, elapsed time t2First thing afterwards
Part W2Occur again, if metaevent W1With metaevent W2Close to generation, t2=0；Represent metaevent W1Metaevent during generation
W2Occur, the time difference that both occur is t3；W1=W2Represent metaevent W1With metaevent W2It is equal, in such cases both two
Scale coding is equal；
In message memory, give out information and stored in the form of storage format；
Storage format is stored in the form of index structure, and index structure includes a Hash mapping and connection table, Hash
Mapping includes pointer and a pointer lattice, is classification number and subclassification number in pointer lattice, and pointer points to a connection table, even
The metaevent and complicated event being included under classification number and subclassification number in table are connect, pointer is Function Mapping, uses Hash letter
Number calculates Function Mapping relation between classification number and subclassification number and metaevent and complicated event；The storage order of storage format
It is to be sorted with the order of the length of timestamp；
Message fragment device is processed the index structure in message memory, by the metaevent in index structure and again
Miscellaneous Event Distillation, is that the metaevent and complicated event under each classification number and subclassification number are arranged by initial time, with
Round dot represented, and head and the tail are connected with solid wire, constitute full curve figure, if what round dot represented is metaevent, on solid wire
Mark if what round dot represented is complicated event, marks to constitute complicated event with the binary coding of metaevent on solid wire
Metaevent and operator, all divided on full curve figure with the square of one centimetre of the length of side, it is right as curve lattice
In in each curve lattice, all in the presence of a non-close irregular polygon, each non-close irregular polygon protrusion is calculated
The coordinate value of the central point of shape, the computation rule of coordinate value is to set up coordinate in curve lattice, with the foursquare lower left corner
Corner points are the origin of coordinates, a length of vertical coordinate axis of the lower length of side and the left side and abscissa of the curve lattice of connection coordinate origin
Axle, used as object is calculated, coordinate value is by abscissa for the coordinate value using the central point of the shape of non-close irregular polygon protrusion
With ordinate separate computations, set up the burster of message fragment device, as packet container, i-th packet container just
Beginning variables Ai=0, wherein, i=1, n, as the numbering of the container of packet, n is the even number of any formulation, is calculated
The average value E and its coordinate with central point of the coordinate value of the central point of the shape of all non-close irregular polygon protrusions
The absolute difference W of the average value of value, since i=1, successively by AiPlus the non-close irregular polygon on the curve lattice of place
The absolute difference of the average value of the average value of the coordinate value of the central point of the shape of protrusion and the coordinate value of central point, AiValue one
It is straight to increase, i.e. Ai+1=Ai+Ai+1, the middle position fiducial value of full curve figure is calculated, middle position fiducial value is taken the seat of all central points
The average value of the sum of absolute difference that is scale value and subtracting all coordinate values for removing central point, by AiValue successively with middle position fiducial value
It is compared, finds A immediate with middle position fiducial valueiValue, as boundary, by AiIt is divided into two groups, to two groups of data point
Do not seek two grades of middle position fiducial values, two grades of middle position fiducial values take the coordinate value of all central points in packet and subtract and all go to center
The average value of the sum of the absolute difference of the coordinate value of point, continues to find and two grades of immediate A of middle position fiducial valueiValue, by two
The data of group are divided into 4 groups, and circulation performs said process, and n groups are divided into until final, and n groups press every group of population size sequence of data,
The container of packet is put into respectively, the data of the container of every component group are decomposed, that is, be broken down into the unit in the curve lattice for representing
Event and complicated event, obtain being divided into the metaevent and complicated event of n groups；
Subscribe to client and be sent to publish/subscribe module by message is subscribed to, it is when occurring conflicting, i.e., many during transmission
Individual subscription message is sent simultaneously, causes the blocking of transmission, and management cluster election is subscribed to the manager of client, subscribes to the management of client
Specifying for person has randomness, i.e., when subscribing to the transmission of message every time, the manager of the subscription client of formulation is not necessarily identical, orders
The manager for readding client is chosen from the subscription client of subscription message is sent, and a problem base, problem are deposited in cluster is managed
Problem and answer in storehouse are imported in advance from external data base, and are classified according to classification number, according to dividing for subscription message
Class-mark selectes the problem base of classification, randomly selects a problem and is sent to the subscription client for sending and subscribing to message, is asked in preferentially answering
The subscription client for inscribing answer is chosen for the manager of subscription problem, and the manager of the subscription problem of selection is used as this subscription message
Transmission keeper, with send limit priority, when simultaneously send subscribe to message subscription client be less than 3 when, order
The manager for readding problem directly specifies the order of the reception for sending the subscription client for subscribing to message simultaneously, disappears when subscription is sent simultaneously
When the subscription client of breath is more than 3, with specifying preferentially by three rights of subscription client of reception subscription message, send out at the same time
Three management for subscribing to clients and subscription problem for preferentially being received subscription message are removed in the subscription client for sending subscription message
After person, the manager's of the client that renews one's subscription specifies, and circulates this process, until all while sending the subscription client for subscribing to message
Priority is all designated, so as to subscribe to message according to its reception；
User's subscription manager is extracted the metaevent and complicated event of n groups, subscribes to message via network transmission
Layer is transferred to user's subscription manager, and user's subscription manager is responsible for matching and subscribes to message and give out information, user's subscription management
Comprising call unit, multiple match messages units in device, call unit is responsible for message call matching unit carries out specific matching
Process, is equipped with packaged matching class in multiple match messages units, the mistake of specific matching is carried out by instantiating matching class
The execution of journey, sets between match messages unit and call unit and abstract matches service interface, different abstract matching services
Interface is used to injecting different instantiations matching classes, the invocation of procedure of the injection scripted code that can be run, the script that can be run
Code depends on the input of dynamic data, and dynamic data is the parametrization of classification number and subclassification number, in the process of running, by
Issue client and subscribe to client and subscribe to message and give out information classification number and theme and determine execution which abstract match service and connect
Mouthful, it is achieved thereby that the double-direction control between issue client and subscription client；
Message distributor is responsible for the subscription message that will match and is given out information, and it is right to set up matching, will match to being mapped to
One circular node space, circular node space is an annulus, multiple nodes is uniformly distributed on annulus, by the suitable of initial time
Sequence will subscribe to message and distribute to each node with giving out information, and node includes black node and white node, and black node is represented
Both message is subscribed to, white node is represented and given out information, by matching to black node is got up with white Node connectedness, if that is,
There is matching relationship, both are connected, set up logical expression conjunctive normal form, black node is possible to a pair of appearance with white node
Many situations, corresponding multiple nodes are the minor of conjunction, and the minor of conjunction is equal to corresponding single node, in order to avoid multiple
White node is repeatedly assigned same black node, after subscription message is matched in user's subscription manager, as
Black node join circle node space, the black node of each new addition is broadcast to the white node of other matchings,
The white node matched somebody with somebody quantity representative matching scale, black node prioritizing selection under same classification number in timestamp scope
Interior white node, timestamp and the timestamp of black node of the white node of selection certainly exist the overlap of maximum magnitude, choosing
The white node selected is represented and distributes to giving out information for black node, when a black node had been allocated, then need not
Sub-distribution again, black node is rejected from conjunctive normal form and circular node space, regular check normal form, if node
The scope of timestamp mistake, the node is rejected from circular node space and conjunctive normal form, if this node belongs to equal sign
Unique minor on side, whole conjunctive normal form is all deleted, and allocated giving out information for white node representative is passed by network
Defeated layer is sent to user subscriber；
The message tree that transport network layer is made up of message terminal, turns all in store dynamic table in station in the message,
After message terminal receives one to give out information or subscribe to message, search whether to be given out information with this in dynamic table
Or the message subscribing person of subscription match messages, subscription client of the message subscribing person comprising needs transmission subscription message and reception
The subscription client for giving out information, if the person that there is message subscribing in dynamic table, message terminal just give out information corresponding or
Person subscribes to message and is forwarded to corresponding message subscribing person, in the running of Web realease information system, by message terminal
It is divided into main message terminal and secondary message terminal, main message terminal is the root of message tree, all message terminals
In give out information or subscribe to message all by main message terminal, main message terminal does not deposit dynamic table, in system operation
In set up dynamic table automatically, other message terminals in addition to main message terminal can only to message tree in connect it is upper
The secondary message terminal of layer sends message, needs one issue of transfer to disappear when the message terminal on the leaf of message tree is received
When breath or subscription message, the subscription user logging that the subscription client or reception that will send subscription message give out information to dynamic table
In, and transfer application is generated, given out information with record or subscribe to the sender and recipient of message, constitute the message
First message or complex message, transfer application are submitted to the secondary message terminal of last layer layer by layer, in being delivered to main message
Turn station cut-off, the transmission of message is responsible for by main message terminal.
Useful achievement of the invention is：The present invention in order to solve the problems, such as computer understanding information resources, by semantic technology
Organically combined with distribution subscription system, issue client is understood in the angle of semantic layer and the original idea of client is subscribed to, made hair
The event of cloth can more accurately match the requirement of subscriber, so as to improve the quality subscribed to and matched with issue, improve whole system
Performance.
Brief description of the drawings
Fig. 1 is the structure chart of Web realease information system of the invention.
Specific embodiment
In order that the technical problems to be solved by the invention, technical scheme and beneficial effect become more apparent, below tie
Embodiment and accompanying drawing are closed, the present invention will be described in detail.It should be noted that specific embodiment described herein is only
It is used to explain the present invention, is not intended to limit the present invention, can realize that the product of said function belongs to equivalent and improvement, wraps
It is contained within protection scope of the present invention.Specific method is as follows：
Embodiment 1：Web realease information system is based on a kind of information interaction system in network technology.At present, it is based on
The application architecture of network is substantially the pattern using client/server (C/S).And in this framework, employ two
The autonomous machine of equality, when a side needs the service of an other side, asks the side for servicing as client to the service of offer
Service end initiate one request, service end respond this request and result is returned to client.Even if this task
Execution and need not before one request result premised on, client needed one before the response results of service end are obtained
Directly it is waited for, it is impossible to continue down to perform other tasks.This C/S models are fairly simple, and can meet big
Partial application requirement, can reduce the degree of coupling between the different system for needing to cooperate, and improve between each system
Cohesion degree.But this model can't resolve the problem of reality.Due to the particularity of network computing environment, with scale
Greatly, the feature such as decentralised control, autonomy, dynamic, loose couplings.Above several technologies have obtained effective solution by various means
Certainly, but do not solve the problems, such as to carry out information exchange using loose couplings.Loose couplings requirement from spatially, the time is upper, control
The target of regulation is all reached on system stream.And publish/subscribe system solves this problem, therefore, the present invention uses publish/subscribe
System is used as the basic of technology.
Publish/subscribe system is that a kind of user employs the mode of " publish/subscribe " and realizes interactive middleware system,
Generally it is made up of user (Client) and Event Notification Service (Notification Service).User is generally divided into two kinds：
The producer of information is commonly referred to publisher (Publisher), and the consumer of information is commonly referred to subscriber (Subscriber).
The information of interaction is referred to as event (Event) between the publisher of information and the consumer of information.Event Notification Service is also referred to as
Event agent.In publish/subscribe system model, subscriber by subscription table up to the interest to particular event, and can register
To event agent.Publisher can issue event to event agent.Event agent is the bridge of publisher and subscriber's contact, pipe
Manage the registration subscribed to and quit the subscription of, event is matched with subscription, and the event for meeting subscription is sent in the form of notifying to phase
The subscriber for answering.
Enter the interaction of row information between the producer of information and the consumer of information by a middleware.The life of information
Product person sends information to middleware, and the consumer of information then defines one " subscription condition ", represents in system to middleware
Which information it is interested, and middleware then ensure the information that will be issued in time, be reliably transmitted to it is all interested in it
Information consumer.Due to it so that the consumer of the producer of information and information is in space, three sides of time and controlling stream
Face is all fully solved, so the need for it can well meet extensive, highly dynamic network computing environment.
The topmost advantage of publish/subscribe system is the loose coupling between publisher and subscriber.First, publisher and order
The location of the person of readding need not be concerned about that whom other side is, and, realize decoupling spatially.Secondly, publisher and subscriber without
Running status need to be simultaneously in, temporal decoupling is realized.Additionally, publisher waits subscriber to process without obstruction disappearing
Breath, subscriber waits for the arrival of news without obstruction, realizes the decoupling in controlling stream.Publish/subscribe system also has following excellent
Point：
1) scalability：User adds or exits and need not change system.
2) anonymity：Publisher and subscriber are without disclosing the information of oneself.
3) multi-point：One event can simultaneously be sent to multiple subscribers.
The main key technology for using is including data model, matching algorithm and Routing Protocol etc. in distribution subscription system.Its
In, data model defines event and the subscription condition that system can be supported；Matching algorithm is used for when an event is published,
How system is quickly found all subscribers interested in it；Routing Protocol is used to find a kind of appropriate path, will
The event being published efficiently and reliably sends each subscriber to.
The present invention employs agency network in publishing side, and agency network is made up of node；
Transmission node is layered, traditional proxy node division is lightweight agent node and node.Transmission node master
Service is provided towards issue/transmission end, data message, security information, information transfer and data storage etc., event can be managed
The services such as matching, Route Selection, storage allocation manager are put into node layer so that separated with logic area.Increasing agent node can be with
The component Configuration of terminal is reduced, the demand of issue/transmission end is responded in real time；Setting node can further improve Xie Pro, carry
High efficiency, reduces routing cost, reduces communication traffic, reduces data redundancy etc..
Set for the distribution subscription structure of sub-network formula, when event exchange is carried out in units of sub-network, must
The uniformity and uniqueness of data need be kept in race, and common agent node is used to cache event, the clothes of corresponding terminal
Business, it is difficult to grasp the information of other agent nodes in sub-network in real time.The setting of node is distribution subscription internal detection information
One interface, when completing information exchange every time, it is necessary to advanced row event matches between sub-network node, then reinforms respective son
Node in network is communicated.
The inside of sub-network is similar to traditional agent node and equally stores issue and topic of subscription Keyword List, specifically
Event content then disperses in the agent node being stored in race.Stored on node topic keyword have it is following it is excellent account for subscription require prior to
When issue event reaches the node in sub-network, event can preferentially be sent to required subnet according to the source for subscribing to request
Network, makes agent node full out obtain event interested.
When the distribution subscription issue event of buffer structure requires to reach node prior to subscribing to, subscribing to request can navigate at once
The actual content of agent node storage, directly calculates the data link of realease agent node and subscription agent node, makes subscriber
Quickly obtain data.
The interest keyword of node is stored in memory database, under the support of database index, can be to whole event
Matching, the retrieval of various ways are carried out, the fuzzy matching of dependent event is drawn.
Data model of the invention be divided into give out information and subscribe to two kinds of message, the expression logical AND storage format of message
Embodiment 2：
Categorical attribute is set up according to classification number in the matching class, the categorical attribute is the allusion quotation for representing the classification number
Type word, typical word is the crucial predicate for wherein including, by the metaevent of the n groups under each classification number and
The complicated event, sets up multiple data groups, and each described data group represents a classification number, comprising n numbers
According to group, a metaevent or the complicated event are deposited in each unit in the data group, described in first
First unit of data group deposits the categorical attribute, to the subscription message, is ordered according to it is included first
The filter condition that client specifies is read, the extraction of classificating word is carried out, being the keyword that includes of the inside finds the data for meeting
Group, when the metaevent that the metaevent and the complicated event in the data group are expressed as with the subscription message
Or the parameter in complicated event is all matched except parameter j one by one, works as matching, counter adds one；
Each predicate that Alpha test is subscribed to, i.e. each key-value pair in contrast event and corresponding predicate in subscription
Whether match, and use rolling counters forward, second stage judges whether count results are identical with predicate number is subscribed to, if identical
Represent and subscribe to and event matches.Subscription for predicate conjunction form proposes matching process, and the key data structure of algorithm includes
One bit vector and a cluster vector, wherein bit vector be used for map correspondence event predicate, and cluster vector according to subscribe to only
One keyword is distinguished, and each element of cluster vector is a subscription cluster list being grouped according to subscription predicate number, and each cluster
Specific subscription index information is stored in list.After event is reached, map that to first on predicate index vector, then look for
To the cluster for meeting the predicate.Because event is conjunction expression formula, need to only be looked on less than or equal to the packet of the event predicate number
Ask.Algorithm uses the space-time locality for subscribing to row storage and processor prefetching technique to maximize processor cache.In addition,
Algorithm uses many attribute hash indexs to reduce the number of comparisons that subscription predicate is inquired about, and reduces query time.
In metaevent and complicated event, the connection data structure to it is decomposed, including PartA and PartB two
Part.
Comprising attribute-name and event to label, corresponding to the connection of " node of one arc of node one " in triple, it leads PartA
The structure is wanted to be:
Event is made to chained list (NPL):The event connected by attribute is to (NP) chained list.NP is formed by connecting with two event tags
Character string represent that preceding, rear, centre is separated with " one " object event tag main body event tag.
Attribute Hash table (HMProp):To node pair, key is the uRIRef of attribute to attribute mapping, and value is connected for attribute
Node to chained list (NPL).
PartB is the type for identifying resource node, corresponding to comprising ulf:The triple of tyPe attributes.Its primary structure
For:
Make event type chained list (NTL):Represent the List of event type.Because an event might have multiple types,
So preserving event type information using a List.
Node type Hash table (HMNT):Mapping event is to event type information.Key is event tag name, and value is thing
Part type chained list (NTL).
The message tree being made up of message terminal in transport network layer, employs dynamic table due to can be in the fortune of system
Automatically generated in row, therefore the maintenance of dynamic table is avoided the need for by manually being intervened.In message tree, if specify one disappeared
Breath terminal A1, as main message terminal, is message transfer the distance definition of other message terminals to main message terminal
Stand to the number of the message center of main message terminal needs process.Such as one message terminal is not required to main message terminal
Will by other message terminals, therefore, it to the distance of main message terminal be 1, because another message terminal is arrived
Needed by a message terminal up to main message terminal, thus to main message center distance be exactly be 2.According to this rule
Then carry out by breadth First spanning tree, the root node of tree is exactly this main message terminal, with the more big then depth of its distance
It is deeper.
If at this moment sending one to a message terminal subscribes to the application that message id is 50, another message terminal
After receiving this application, the application that subscription message id is 50 is added in the dynamic table of this message terminal, then up
Layer node i.e. the subscription application that father node one message id of transmission is 50, it is first after message terminal receives subscription application
Lookup in dynamic table is arrived first, if having there is this have subscribed, stops following operation；Otherwise this subscription application is added
To in dynamic table, then an application for subscribing to same message is sent to sender；After message terminal receives application, together
Whether sample is also first to search dynamic table, sees had subscribed to this message, and otherwise just this subscription is added in dynamic table；
If this message terminal is root node, therefore just no longer subscribes to this message to other message terminals, so far whole net
Network is in stable state again.
The preferred embodiments of the invention is the foregoing is only, claims of the invention are not limited to.
Simultaneously it is described above, for those skilled in the technology concerned it would be appreciated that and implement, therefore other be based on institute of the present invention
The equivalent change that disclosure is completed, should be included in the covering scope of the claims.
Useful achievement of the invention is：The present invention in order to solve the problems, such as computer understanding information resources, by semantic technology
Organically combined with distribution subscription system, issue client is understood in the angle of semantic layer and the original idea of client is subscribed to, made hair
The event of cloth can more accurately match the requirement of subscriber, so as to improve the quality subscribed to and matched with issue, improve whole system
Performance.
Claims (1)
1. a kind of method of Web realease information system, it is characterised in that include：
The Web realease information system includes multiple issue clients, agency network, publish/subscribe module, multiple subscription clients
And management cluster；The publish/subscribe module includes message memory, message fragment device, user's subscription manager, message point
Hair device；Methods described includes the related critical process of system；
The agency network is made up of multiple sub-networks, and the sub-network is the network that a host node is constituted with node, each
The node is divided into two layers, and ground floor stores the priority of the node, and the second layer is scratchpad area (SPA), is deposited temporarily described
Sort key word, subclassification number and a counter of subscription are stored in storage area, will by the priority of the priority of the node
The node is attached, and the priority node high is first connected, and is attached using virtual link, the virtual link energy
It is enough to disconnect at any time and establish a connection between the nodes at any time；Each described sub-network is that represent is the one of subscription
Individual classification, stores the keyword and classification number of a classification of subscription in the host node, and ordering each classification
The keyword read is assigned in each described node, and the priority of the node is distributed when being and distributing the keyword of the subscription
The foundation of order；
The process that the critical process gives out information to the publish/subscribe module comprising the issue client, specifically such as
Under：
Multiple it is described issue clients will give out information before being transferred to the publish/subscribe module, to it is described give out information into
Row binary search, with the presence or absence of the keyword subscribed to described in a certain class during once search gives out information described in search, in search
During the host node is called, it is described when the host node that the keyword for finding multiple subscription meets
The keyword of subscription meets more host nodes as the host node for meeting condition, and the classification number is distributed to described
Give out information, the sub-network where the host node for meeting condition is won, described giving out information is broadcast to the place
All nodes under sub-network, and all nodes are ordered by the order for formulating matching from big to small of its priority with described
The sort key word read is matched, and the counter stored in the node for matching plus one, and in the base of the classification number
Reallocated on plinth the subclassification number, the counter is used to record the number of times that the node is matched, and is given out information described
The publish/subscribe module is sent to together with the classification number and the subclassification number；To the host node for meeting condition
Node in the sub-network at place is adjusted priority in real time, and the foundation of adjustment is the Digital size in the counter,
Numeral is bigger, and the priority of the node is higher, and the priority to the node for matching is adjusted, if for the first time
Adjustment, first node of the sub-network where the node for matching is directly inserted into the host node for meeting condition
Before, in the case of remaining, by the counter of the numeral of the counter of the node for the matching node adjacent with before and after it
Numeral is compared, and takes dichotomy that the scope of insertion position is gradually reduced, and by the node insertion for matching, makes counter
The big node of middle numeral is arranged in the position before in the sub-network at the place；
The critical process also includes how to set up the data model of system；
Expression logical AND storage format of the data model of the system comprising message, first, issue is divided into by the type of message
Message includes the content of the title and issue that need issue, the subscription message with two kinds of message, described giving out information is subscribed to
Comprising the content that the subscription client needs to subscribe to；
It is described give out information with it is described subscription message in itself all with it is same it is described represent logical expressions, the expression logic is by unit
The logic composition of the logical AND complicated event of event, the logic of the complicated event is made up of the logic of the metaevent, described
The logic of metaevent W is as follows：
W=(e, n, b, j, P, T, l)
Wherein, e is the expression variable of the metaevent, and n is the statement of the metaevent, for representing what the metaevent occurred
Precondition, the precondition represents that b is the binary coding of the metaevent, for being different from other with first order logic
Metaevent, j the metaevent describe for described giving out information when, be the classification number and the subclassification of the node
Number, it is the subscription filter condition specified of client when the metaevent is for the subscription message, P is the time to colour Petri
The hierarchical model of net, is made up of by one multiple timed colored Petri nets, for logically specifically describing the metaevent, T
It is the timestamp of the metaevent, initial time and end time for representing the metaevent, l is holding for the metaevent
Continuous time interval；
The complicated event is to carry out operative combination on the basis of the metaevent to form, and is expressed as follows：
F=(o (W1, Wn),T1,l1)
Wherein, W1, WnIt is metaevent, o is operator, T1It is the timestamp of the complicated event, it is described for representing
The initial time of complicated event and end time, the initial time of the complicated event is metaevent W1, WnStarting
The maximum of time, the end time of the complicated event is metaevent W1, WnEnd time minimum value, l1For
The duration of the complicated event is interval, is metaevent W1, WnDuration interval minimum value；The operation
The logic of symbol isRepresent metaevent W1With metaevent W2There is and has a hair
Give birth to, and the time for occurring is limited in time cycle t, if not limiting the time of generation, t=∞；Represent unit
Event W1With metaevent W2Both occur, and the time for occurring is limited to time cycle t1If, do not limit generation when
Between, t1=∞, if two metaevents occur simultaneously, t1=0；Represent metaevent W1Will not occur；Represent first thing
Part W1After generation, elapsed time t2Metaevent W afterwards2Occur again, if metaevent W1With metaevent W2Close to generation, t2=0；Table
Show metaevent W1Metaevent W during generation2Occur, the time difference that both occur is t3；W1=W2Represent metaevent W1With first thing
Part W2Equal, both binary codings are equal in such cases；
In message memory, described giving out information stored in the form of the storage format；
The storage format is stored in the form of index structure, and the index structure includes a Hash mapping and connection table,
The Hash mapping includes pointer and a pointer lattice, is the classification number and the subclassification number in the pointer lattice,
The pointer points to a connection table, and the institute under the classification number and the subclassification number is included in the connection table
State metaevent and the complicated event, the pointer is Function Mapping, the classification number and described is calculated using hash function
Function Mapping relation between subclassification number and the metaevent and the complicated event；The storage order of the storage format be with
The order sequence of the length of the timestamp；
The message fragment device to the message memory in the index structure process, by the index structure
The metaevent and the complicated event are extracted, and are the described first thing under each described classification number and the subclassification number
Part and the complicated event are arranged by the initial time, are represented with round dot, and head and the tail are connected with solid wire, are constituted continuous
Curve map, if what the round dot represented is metaevent, marks with the binary coding of the metaevent, if institute on solid wire
State that round dot represents is the complicated event, and the metaevent to constitute the complicated event and described is marked on solid wire
Operator, all divides with the square of one centimetre of the length of side on the full curve figure, as curve lattice, for each institute
State in curve lattice, all in the presence of a non-close irregular polygon, calculate each non-close irregular polygon protrusion
The coordinate value of the central point of shape, the computation rule of coordinate value is to set up coordinate in the curve lattice, with described foursquare
The corner points in the lower left corner are the origin of coordinates, connect a length of perpendicular seat of the lower length of side and the left side of the curve lattice of the origin of coordinates
Parameter and axis of abscissas, it is right as calculating using the coordinate value of the central point of the shape of non-close irregular polygon protrusion
As abscissa and ordinate separate computations are set up the burster of the message fragment device by the coordinate value, as packet
Container, i-th initializaing variable A of the container of packeti=0, wherein, i=1, n, as the volume of the container of packet
Number, n is the even number of any formulation, calculates the coordinate value of the central point of the shape of all non-close irregular polygon protrusions
Average value E and its absolute difference W with the average value of the coordinate value of the central point, since i=1, successively by AiPlus
The average value of the coordinate value of the central point of the shape of the non-close irregular polygon protrusion on the upper place curve lattice and institute
State the absolute difference of the average value of the coordinate value of central point, AiValue increase always, i.e. Ai+1=Ai+Ai+1, calculate the continuous song
The middle position fiducial value of line chart, the middle position fiducial value take by the coordinate value of all central points and subtract and all remove the central point
The average value of the sum of the absolute difference of coordinate value, by AiValue be compared with the middle position fiducial value successively, find with it is described
The immediate A of middle position fiducial valueiValue, as boundary, by AiIt is divided into two groups, two groups of data is asked with two grades of middle position ratios respectively
Relatively it is worth, it is that two grades of middle position fiducial values take the coordinate value of all central points in packet and subtract all seats for removing the central point
The average value of the sum of the absolute difference of scale value, continues to find and the immediate A of two grades of middle position fiducial valuesiValue, by two groups
Data be divided into 4 groups, circulation performs said process, and n groups are divided into until final, and n groups are divided by every group of population size sequence of data
The container of the packet is not put into, the data of the container that will be grouped described in every group are decomposed, that is, be broken down into the song for representing
The metaevent and the complicated event in line lattice, obtain being divided into the metaevent and the complicated event of n groups；
The subscription message is sent to the publish/subscribe module by the subscription client, during transmission, when appearance is rushed
Dash forward, i.e., multiple subscription message send simultaneously, cause the blocking of transmission, the pipe of subscription client described in the management cluster election
Reason person, specifying for the manager of the subscription client has randomness, i.e., during the transmission of each subscription message, the institute of formulation
The manager for stating subscription client is not necessarily identical, the subscription of the manager for subscribing to client from the transmission subscription message
Chosen in client, deposit a problem base in the management cluster, problem and answer in described problem storehouse are from external number
Imported in advance according to storehouse, and classified according to the classification number, the classification number according to the subscription message selectes classification
Described problem storehouse, randomly selects a problem and is sent to the subscription client for sending the subscription message, in preferentially answering
The subscription client of problem answers is chosen for the manager of the subscription client, the manager of the subscription client of selection
As the keeper of the transmission that message is subscribed to this described, with the limit priority for sending, disappear when the subscription is sent simultaneously
When the subscription client for ceasing is less than 3, the manager of the subscription client is directly specified described to disappear while sending the subscription
The order of the reception of the subscription client of breath, when the subscription client of the subscription message is sent more than 3 simultaneously, tool
There are three rights of subscription client specified and preferentially received subscription message, the subscription of the subscription message is sent at the same time
After the managers for preferentially being received the three subscription clients and the subscription client that subscribe to message are removed in client, continue
The manager's for subscribing to client specifies, and circulates this process, until all while sending the subscription for subscribing to message
Client is designated priority, so as to according to its reception subscription message；
User's subscription manager is extracted the metaevent and the complicated event of the n groups, the subscription
Message is transferred to user's subscription manager via the transport network layer, and it is described that user's subscription manager is responsible for matching
Message is subscribed to be given out information with described, it is described comprising call unit, multiple match messages units in user's subscription manager
Call unit is responsible for the process for calling the match messages unit to carry out specific matching, is all filled in multiple match messages units
There is packaged matching class, by instantiating the execution that the matching class carries out the process of specific matching, in the match messages
Set between unit and the call unit it is abstract match service interface, different described abstract matching service interfaces are used to inject
The different instantiations matching class, the invocation of procedure of the injection scripted code that can be run, the scripted code for running
The input of dynamic data is depended on, the dynamic data is the parametrization of the classification number and the subclassification number, in operation
During, determine which is performed according to the title of the classification number and the issue by the issue client and the subscription client
The individual abstract matching service interface, it is achieved thereby that the double-direction control between the issue client and the subscription client；
The subscription message that the message distributor is responsible for matching gives out information with described, between set up matching it is right, will
To being mapped to a circular node space, the circular node space is an annulus, and multiple knots are uniformly distributed on annulus for matching
Point, each node is distributed to by the order of initial time by the subscription message with described giving out information, i.e., replace institute with node
State subscription message to be given out information with described, the node includes black node and white node, and the black node represents described
Subscribe to message, the white node represent it is described give out information, by the matching to the black node and the white are tied
Point is coupled together, if that is, both have matching relationship, both is connected, and logical expression conjunctive normal form is set up according to it, described
Black node is possible to one-to-many situation occur with the white node, and corresponding multiple nodes are the minor of conjunctive normal form,
The minor of the conjunctive normal form is equal to the corresponding single node, in order to avoid the multiple white node is repeatedly assigned same
One black node, after the subscription message is matched in user's subscription manager, as the black
Circular node space described in node join, the black node of each new addition is broadcast to the white of other matchings
Node, the scale of the quantity representative matching of the described white node of matching, the black node prioritizing selection is in same classification number
Under the white node in the timestamp scope, the timestamp of the described white node of selection and the black knot
The timestamp of point certainly exists the overlap of maximum magnitude, and the described white node of the selection is represented distributes to the black node
Give out information, when a black node had been allocated, then need not sub-distribution again, by the black node from institute
State rejecting, conjunctive normal form described in regular check, if the timestamp of node in conjunctive normal form and the circular node space
Scope mistake, the node is rejected from the circular node space and the conjunctive normal form, if this node belongs to
The minor of unique conjunctive normal form on number side, the whole conjunctive normal form is all deleted, what allocated described white node was represented
Described giving out information is sent to the subscription client by the transport network layer；
The message tree that the transport network layer is made up of message terminal, in all in store dynamic of the message terminal
Table, after the message terminal receives one to give out information or subscribe to message, has searched whether in the dynamic table
The message subscribing person that match messages are given out information or subscribed to this, the message subscribing person disappears comprising needing to send the subscription
The subscription client given out information described in the subscription client of breath and reception, if there is described disappearing in the dynamic table
Breath subscriber, the message terminal just it is corresponding described give out information or the subscription message be forwarded to it is corresponding described
Message subscribing person, in the running of the Web realease information system, main message transfer is divided into by the message terminal
Stand and secondary message terminal, the main message terminal is the root of the message tree, the hair in all message terminals
Cloth message subscribes to message all by the main message terminal, and the main message terminal does not deposit the dynamic table, in institute
State and set up the dynamic table automatically in system operation, other message terminals in addition to the main message terminal can only
Message, the message transfer on the leaf of the message tree are sent to the secondary message terminal on the upper strata connected in the message tree
Station is received when needing transfer one to give out information or subscribe to message, will be sent the subscription client of this subscription message or be received this
The subscription user logging for giving out information generates transfer application in the dynamic table, is given out information or this with recording this
The sender and recipient that subscribe to message pass the transfer application, constitute the metaevent or complicated event of the message layer by layer
The secondary message terminal of last layer is given, until being delivered to main message terminal cut-off, is responsible for disappearing by the main message terminal
The transmission of breath.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201710094319.9A CN106933989B (en) | 2017-02-22 | 2017-02-22 | System and method for publishing information on network |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201710094319.9A CN106933989B (en) | 2017-02-22 | 2017-02-22 | System and method for publishing information on network |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN106933989A true CN106933989A (en) | 2017-07-07 |
| CN106933989B CN106933989B (en) | 2021-01-05 |
Family
ID=59423604
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201710094319.9A Expired - Fee Related CN106933989B (en) | 2017-02-22 | 2017-02-22 | System and method for publishing information on network |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN106933989B (en) |
Cited By (14)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107590231A (en) * | 2017-09-06 | 2018-01-16 | 北京大有中城科技有限公司 | A kind of implementation method for solving to be actually needed by platform things chain |
| CN108197138A (en) * | 2017-11-21 | 2018-06-22 | 北京邮电大学 | The method and system for the matching subscription information that releases news in publish/subscribe system |
| CN108491535A (en) * | 2018-03-29 | 2018-09-04 | 北京小米移动软件有限公司 | The classification storage method and device of information |
| WO2019075674A1 (en) * | 2017-10-18 | 2019-04-25 | 华为技术有限公司 | Multicast packet transmission method, network device, and system |
| CN109739667A (en) * | 2019-01-10 | 2019-05-10 | 广州华多网络科技有限公司 | A kind of consuming method of message, device and equipment |
| CN109787858A (en) * | 2018-12-29 | 2019-05-21 | 福建天泉教育科技有限公司 | A kind of method and terminal of batch issuing service |
| CN111444451A (en) * | 2019-01-17 | 2020-07-24 | 珠海金山办公软件有限公司 | Document acquisition method and device, electronic equipment and readable storage medium |
| CN111669427A (en) * | 2020-04-20 | 2020-09-15 | 北京邮电大学 | A software-defined network publish-subscribe system and method |
| CN112307318A (en) * | 2019-08-02 | 2021-02-02 | 中国移动通信有限公司政企客户分公司 | Content publishing method, system and device |
| CN113641139A (en) * | 2021-08-05 | 2021-11-12 | 珠海格力电器股份有限公司 | System, controller, control system, and storage medium capable of realizing asynchronous programming |
| CN114844948A (en) * | 2021-12-14 | 2022-08-02 | 合肥哈工轩辕智能科技有限公司 | Client cache optimization method and device of real-time distribution system |
| CN114880324A (en) * | 2022-04-28 | 2022-08-09 | 西北工业大学 | A message exchange device with space constraints |
| CN118233365A (en) * | 2024-05-23 | 2024-06-21 | 中国电子科技集团公司第十五研究所 | Multi-point real-time data distribution method and device, electronic equipment and storage medium |
| CN118488099A (en) * | 2024-05-30 | 2024-08-13 | 广东保伦电子股份有限公司 | A message publishing method and device based on MQTT |
Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20060031076A1 (en) * | 2004-08-03 | 2006-02-09 | Hui Lei | Apparatus and method of semantic-based publish-subscribe system |
| CN101090337A (en) * | 2006-06-12 | 2007-12-19 | 国际商业机器公司 | System and method for scalable distribution of semantic web updates |
| CN101193077A (en) * | 2006-11-30 | 2008-06-04 | 国际商业机器公司 | Method and system for subscribing matching |
-
2017
- 2017-02-22 CN CN201710094319.9A patent/CN106933989B/en not_active Expired - Fee Related
Patent Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20060031076A1 (en) * | 2004-08-03 | 2006-02-09 | Hui Lei | Apparatus and method of semantic-based publish-subscribe system |
| CN101090337A (en) * | 2006-06-12 | 2007-12-19 | 国际商业机器公司 | System and method for scalable distribution of semantic web updates |
| CN101193077A (en) * | 2006-11-30 | 2008-06-04 | 国际商业机器公司 | Method and system for subscribing matching |
Cited By (20)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107590231A (en) * | 2017-09-06 | 2018-01-16 | 北京大有中城科技有限公司 | A kind of implementation method for solving to be actually needed by platform things chain |
| WO2019075674A1 (en) * | 2017-10-18 | 2019-04-25 | 华为技术有限公司 | Multicast packet transmission method, network device, and system |
| CN108197138A (en) * | 2017-11-21 | 2018-06-22 | 北京邮电大学 | The method and system for the matching subscription information that releases news in publish/subscribe system |
| CN108491535A (en) * | 2018-03-29 | 2018-09-04 | 北京小米移动软件有限公司 | The classification storage method and device of information |
| CN108491535B (en) * | 2018-03-29 | 2023-04-07 | 北京小米移动软件有限公司 | Information classified storage method and device |
| CN109787858A (en) * | 2018-12-29 | 2019-05-21 | 福建天泉教育科技有限公司 | A kind of method and terminal of batch issuing service |
| CN109739667A (en) * | 2019-01-10 | 2019-05-10 | 广州华多网络科技有限公司 | A kind of consuming method of message, device and equipment |
| CN111444451A (en) * | 2019-01-17 | 2020-07-24 | 珠海金山办公软件有限公司 | Document acquisition method and device, electronic equipment and readable storage medium |
| CN111444451B (en) * | 2019-01-17 | 2024-01-30 | 珠海金山办公软件有限公司 | Document acquisition method and device, electronic equipment and readable storage medium |
| CN112307318A (en) * | 2019-08-02 | 2021-02-02 | 中国移动通信有限公司政企客户分公司 | Content publishing method, system and device |
| CN112307318B (en) * | 2019-08-02 | 2024-03-08 | 中移(成都)信息通信科技有限公司 | Content publishing method, system and device |
| CN111669427A (en) * | 2020-04-20 | 2020-09-15 | 北京邮电大学 | A software-defined network publish-subscribe system and method |
| CN113641139A (en) * | 2021-08-05 | 2021-11-12 | 珠海格力电器股份有限公司 | System, controller, control system, and storage medium capable of realizing asynchronous programming |
| CN114844948A (en) * | 2021-12-14 | 2022-08-02 | 合肥哈工轩辕智能科技有限公司 | Client cache optimization method and device of real-time distribution system |
| CN114844948B (en) * | 2021-12-14 | 2024-05-31 | 合肥哈工轩辕智能科技有限公司 | Client cache optimization method and device of real-time distribution system |
| CN114880324A (en) * | 2022-04-28 | 2022-08-09 | 西北工业大学 | A message exchange device with space constraints |
| CN118233365A (en) * | 2024-05-23 | 2024-06-21 | 中国电子科技集团公司第十五研究所 | Multi-point real-time data distribution method and device, electronic equipment and storage medium |
| CN118233365B (en) * | 2024-05-23 | 2024-08-06 | 中国电子科技集团公司第十五研究所 | Multi-point real-time data distribution method and device, electronic equipment and storage medium |
| CN118488099A (en) * | 2024-05-30 | 2024-08-13 | 广东保伦电子股份有限公司 | A message publishing method and device based on MQTT |
| CN118488099B (en) * | 2024-05-30 | 2025-03-25 | 广东保伦电子股份有限公司 | A message publishing method and device based on MQTT |
Also Published As
| Publication number | Publication date |
|---|---|
| CN106933989B (en) | 2021-01-05 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN106933989A (en) | A kind of method of Web realease information system | |
| US8849754B2 (en) | Managing topical overlap during publication and subscription | |
| CN101719842B (en) | A Distributed Network Security Early Warning Method Based on Cloud Computing Environment | |
| CN101119321B (en) | Network flux classification processing method and apparatus | |
| CN104796326B (en) | A kind of group creating method and device of enterprise IM | |
| Berra et al. | Architecture for distributed multimedia database systems | |
| CN108881354A (en) | A kind of pushed information storage method, device, server and computer storage medium | |
| CN108733681A (en) | Information processing method and device | |
| CN106713018A (en) | Message queue business data scheduling method and message queue implementation method | |
| CN110166220B (en) | Slicing method for slicing according to hash value of partition key | |
| CN109656688B (en) | Method, system and server for realizing distributed business rules | |
| DE102017125649A1 (en) | Method for data communication using random network addresses and a corresponding device | |
| CN107277086A (en) | Transaction processing system, method for processing business and service updating method | |
| CN105869057A (en) | Comment storage device, comment reading method and apparatus, and comment writing method and apparatus | |
| CN110138652A (en) | A kind of session updates method, apparatus and client device | |
| CN114793244B (en) | Resource processing method, device, equipment and medium for block chain | |
| CN106713428A (en) | Business operation support system applied to Internet-of-things self-management platform | |
| CN106713019A (en) | Design method of service operation support system applied to Internet of Things self-management platform | |
| CN101902347B (en) | Anonymous meeting terminal enrollment method and device | |
| CN113703895B (en) | Method, system, device, equipment and storage medium for carousel of signboard | |
| CN110019786A (en) | Topic sending method, the topic list ordering method and device of Web Community | |
| CN111259062B (en) | Method and device capable of guaranteeing sequence of statement result set of full-table query of distributed database | |
| CN111294553B (en) | Method, device, equipment and storage medium for processing video monitoring service signaling | |
| CN105849719A (en) | Augmented reality | |
| CN106326296A (en) | Data query method and device |
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 | ||
| CF01 | Termination of patent right due to non-payment of annual fee |
Granted publication date: 20210105 Termination date: 20210222 |
|
| CF01 | Termination of patent right due to non-payment of annual fee |