CN107592364A - A kind of distributed message exchange method and system - Google Patents
A kind of distributed message exchange method and system Download PDFInfo
- Publication number
- CN107592364A CN107592364A CN201710867141.7A CN201710867141A CN107592364A CN 107592364 A CN107592364 A CN 107592364A CN 201710867141 A CN201710867141 A CN 201710867141A CN 107592364 A CN107592364 A CN 107592364A
- Authority
- CN
- China
- Prior art keywords
- message
- service
- multicast
- information
- passage
- 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
Landscapes
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
The invention discloses a kind of distributed message exchange method and system.The embodiment of the present invention is divided into different functional entitys, reduces the coupling between each functional entity, realized the decentralization of message exchange and make it that exploitation maintenance is more convenient each function modularization in a manner of micro services for designing message switching system.Cause information real-time to exchange by the way of UDP multicasts, improve efficiency and performance.
Description
Technical field
The present invention relates to the communication technology, more particularly to Distributed Communication Technology, disappears more particularly, to a kind of distribution
Cease exchange method and system.
Background technology
With the extensive use of the development of information technology, and distributed system, in distributed software system.In message
Between part play vital role in the crucial application of many industries, utilize the message passing mechanism of high efficient and reliable to carry out
Platform-independent data exchange, and the integrated of distributed system is carried out based on data communication.By providing message transmission and disappearing
Queuing model is ceased, it can be in the communication between extension process under distributed environment.
Message-oriented middleware is applicable to the distributed environment of reliable data transmission.What it is using message-oriented middleware mechanism is
In system, the event of other side is activated by transmitting message between different objects, completes corresponding operation.News release end will disappear
Breath is sent to message server, and message server in some queues, again forwards message message deposit suitable when
Give information consumption end.
This scheme needs a message server (broker) as Centroid to do data exchange, and wherein message takes
Business device (broker) realizes most of functions such as service discovery, message duration, message route.This causes message server to seem
Heaviness, maintainable, scalability is poor.Also, each function is concentrated in message server so that mutually being closed between each function
Connection property is high, if message server breaks down, then whole data exchange can all be gone wrong, and news release end can not be sent out again
Message is sent, information consumption end can not also receive message again.This causes the reliability of message switching system to reduce.Furthermore each message
TCP connections are used between consumption terminal and message server, when information consumption end is more, message server needs to be processed by TCP
The message of communication is more, and this causes system to decline in performances such as the efficiency of message exchange.
The content of the invention
In view of this, the invention discloses a kind of distributed message exchange method and system, in make it that message exchange is gone
The heart, and then more easily can be developed and be safeguarded, and improve the efficiency and performance of message exchange.
First aspect, there is provided a kind of distributed message exchange method, including：
News release end sends multicast address to directory agent according to the configuration information being pre-configured with and corresponding service is marked
Know with registration service；
Service identifiers of the information consumption end in the configuration information being pre-configured with to the directory agent subscription service with
Multicast address corresponding to acquisition, and according to the multicast address incoming multicast passage；
The news release end passes through multicast channel issuing service message corresponding to the multicast address of registration；
The information consumption end receives service message in the multicast channel of subscription；
The service message persistence that passage record end receives the service message of all multicast channels and will received；
The information consumption end sends a request for the history service message of ordered service to passage record end.
Further, methods described also includes before the registration service of the news release end：
The news release end carries out authentication to obtain the authority of transmission service message to certificate server；And
The passage records end and carries out authentication to certificate server to obtain the authority of reception service message；
Methods described also includes before the subscription service of the information consumption end：
The information consumption end and passage record end carry out authentication to obtain the service of reception to certificate server respectively
The authority of message.
Preferably, methods described also includes：
Corresponding configuration information is respectively configured to the news release end, the information consumption end and led to by configuration management end
Trace record end.
Preferably, methods described also includes：
Health parameters are applied in the monitoring system of monitoring management end, the application health parameters include process status, message
Handling capacity, service registry and the Loss Rate of the success rate of subscription and message of transmitting-receiving.
Further, methods described also includes：
Service message is disappeared as described in being transferred to the first multicast subgroup where the news release end using Message Agent
Cease the second multicast subgroup where consumption terminal.
Further, the multicast channel is UDP multicast channels.
Second aspect, there is provided a kind of distributed message switching system, including：
Directory agent, it is configured as managing registered or multicast address that is subscribing to and corresponding service identifiers；
News release end, it is configured as sending multicast address and correspondingly to directory agent according to the configuration information that is pre-configured with
Service identifiers with registration service, and pass through multicast channel issuing service message corresponding to the multicast address of registration；
Information consumption end, the service identifiers being configured as in the configuration information being pre-configured with are ordered to the directory agent
Read and service to obtain corresponding multicast address, and according to the multicast address incoming multicast channel reception service message；And
Passage records end, is configured as receiving the service message of all multicast channels and service message received is lasting
Change.
Further, the information consumption end is additionally configured to send a request for passage record end ordered
The history service message of service.
Further, the system also includes：
Certificate server, it is configured as reflecting to the news release end, the information consumption end and passage record end
Power certification authorizes the information consumption end and passage record termination to authorize the authority that the information consumption end sends service message
Receive the authority of service message.
Preferably, the system also includes：
Configuration management end, it is configured as corresponding configuration information being respectively configured to the news release end, the message
Consumption terminal and passage record end.
Preferably, the system also includes：
Monitoring management end, the health parameters of applying being configured as in monitoring system, the application health parameters include process
State, the handling capacity of information receiving and transmitting, service registry and the success rate of subscription and the Loss Rate of message.
Further, the system also includes：
Message Agent, for service message to be sent to positioned at other sons as the first subnet where the news release end
The Message Agent of net.
In embodiments of the present invention, distributed message switching system using the thought of micro services by each functional unit, point
For different functional entitys.This decentralization for realizing message exchange make it that the flexibility of system and scalability are more preferable.And
And reduce the coupling between each functional entity so that it is more convenient that exploitation is safeguarded, and then adds the reliability of system.It is described
System causes message real-time to exchange by the way of UDP cast communications, improves the performance of message exchange efficiency and system.
Brief description of the drawings
By the description to the embodiment of the present invention referring to the drawings, above-mentioned and other purpose of the invention, feature and
Advantage will be apparent from, in the accompanying drawings：
Fig. 1 is the schematic diagram of the distributed message switching system of first embodiment of the invention；
Fig. 2 is the flow chart of the distributed message exchange method of first embodiment of the invention；
Fig. 3 is the schematic diagram of the distributed message switching system of second embodiment of the invention；
Fig. 4 is the flow chart of the distributed message exchange method of second embodiment of the invention；
Fig. 5 is the schematic diagram of the distributed message switching system of third embodiment of the invention；
Fig. 6 is the flow chart of the distributed message exchange method of third embodiment of the invention；
Fig. 7 is the schematic diagram of the distributed message switching system of fourth embodiment of the invention；
Fig. 8 is the flow chart of the distributed message exchange method of fourth embodiment of the invention.
Embodiment
Below based on embodiment, present invention is described, but the present invention is not restricted to these embodiments.Under
It is detailed to describe some specific detail sections in the literary detailed description to the present invention.Do not have for a person skilled in the art
The description of these detail sections can also understand the present invention completely.In order to avoid obscuring the essence of the present invention, known method, mistake
The not narration in detail of journey, flow, element and circuit.
In addition, it should be understood by one skilled in the art that provided herein accompanying drawing be provided to explanation purpose, and
What accompanying drawing was not necessarily drawn to scale.
Unless the context clearly requires otherwise, otherwise entire disclosure is similar with the " comprising " in claims, "comprising" etc.
Word should be construed to the implication included rather than exclusive or exhaustive implication；That is, it is containing for " including but is not limited to "
Justice.
In the description of the invention, it is to be understood that term " first ", " second " etc. are only used for describing purpose, without
It is understood that to indicate or implying relative importance.In addition, in the description of the invention, unless otherwise indicated, the implication of " multiple "
It is two or more.
Fig. 1 is the schematic diagram of the distributed message switching system of first embodiment of the invention.As shown in figure 1, described first
The distributed message switching system of embodiment includes news release end 1, information consumption end 2, certificate server 3, the and of directory agent 4
Passage records end 5.The news release end 1, information consumption end 2, certificate server 3, directory agent 4 and 5, end of passage record
In same UDP multicast subgroups, UDP cast communications can be passed through between each other.UDP(User Datagram Protocol,
UDP) it is in OSI (Open System Interconnection, open system interconnection) reference model
Connectionless transport layer protocol, there is provided towards the simple unreliable information transmission service of affairs, IETF RFC 768 be UDP just
Formula specification.UDP is 17 in the protocol number of IP messages.In a network, udp protocol connectionless communication, and transmission packet is not entered
Row Reliability Assurance.Based on udp protocol, it is possible to achieve unicast, broadcast and cast communication.
In the present embodiment, news release end 1 is configured as being sent to directory agent 4 according to the configuration information being pre-configured with
Multicast address and corresponding service identifiers pass through multicast channel issuing service corresponding to the multicast address of registration with registration service
Message.The service identifiers that information consumption end 2 is configured as in the configuration information being pre-configured with are subscribed to the directory agent 4
Service to obtain corresponding multicast address, and according to the multicast address incoming multicast channel reception service message.It should be understood that
In one subnet, there may be multiple news release ends 1 and information consumption end 2.Certificate server 3 is configured as to news release
End 1, information consumption end 2 and passage record end 5 carry out authentication to authorize the power that the information consumption end 1 sends service message
Limit, authorizes the information consumption end 2 and passage record end 5 receives the authority of service message.Directory agent 4 is configured as pipe
Manage registered or multicast address that is subscribing to and corresponding service identifiers.Passage record end 5 is configured as receiving all multicast channels
Service message and the service message persistence that will receive.Preferably, passage record end 5 can subscribe to institute to directory agent 4
Some services are to realize the reception of the service message to all multicast channels.Meanwhile persistence is in lasting shape by routine data
The mechanism changed between state and instantaneous state.Specifically, persistence by data (object in such as internal memory) with file or data
The form in storehouse is saved in can be in the storage device of persistence (such as disk).
Fig. 2 is the flow chart of the distributed message exchange method of first embodiment of the invention.As shown in Fig. 2 in step
S110, news release end 1 send identity information to certificate server 3 and carry out authentication, obtain and sent in this multicast subgroup
The authority of service message.Passage records end 5 and information consumption end 2 and authenticated respectively to the transmission identity information of certificate server 3
Certification, obtain in the inscribed authority for receiving service message of this multicast subgroup.
Specifically, news release end 1 can carry out authentication with login authentication server 3, after authentication passes through, certification clothes
Business device 3 issues corresponding 1 one electronic signatures in news release end or digital certificates with so that news release end 1 is obtained in this multicast
The authority of service message is sent in subnet.Similarly, information consumption end 2 can carry out authentication with login authentication server 3,
After authentication passes through, certificate server 3 issues corresponding 2 one electronic signatures in information consumption end or digital certificates with so that message disappears
Expense end 2 is obtained in the inscribed authority for receiving service message of this multicast subgroup.Passage record end 5 can be carried out with login authentication server 3
Authentication, after authentication passes through, certificate server 3 issues corresponding 5 one electronic signatures in passage record end or digital certificates
To cause passage record end 5 to obtain in the inscribed authority for receiving service message of this multicast subgroup.It is readily appreciated that, certificate server 3 is sent out
It is different to distinguish to give the electronic signature or digital certificates difference of news release end 1, information consumption end 2 with passage record end 5
Authority.
It should be understood that the authentication at news release end 1, information consumption end 2 and passage record end 5 is behaviour independently
Make.Passage record end 5 just carries out authentication in system initialization.News release end 1 and information consumption end 2 can need
Authenticated when issue or reception service message.
In step S120, news release end 1 according to the configuration information being pre-configured with to directory agent 4 send multicast address and
Corresponding service identifiers are with registration service.
In the present embodiment, the configuration information at news release end 1 includes the multicast address for being available for its issuing service message
With corresponding service identifiers.
Multicast address is the IP address of multicast group.During unicast data transmission, the path of packet transmission be from
Source address is routed to destination address, utilizes the principle of " hop-by-hop " to transmit in an ip network.But in IP multicast rings, packet
Destination address is not one, but one group, form a multicast group.Wish that the member for receiving multicast needs to be added to a multicast
In group, and after addition, the data for flowing to multicast address immediately begin to transmit to the member of addition, all in multicast group
Member can receive packet.Member in multicast group is dynamic, and main frame can join and depart from multicast at any time
Group, and main frame can add in multiple multicast groups simultaneously.
The different News Category of different service identifiers, service identifiers correspond with multicast address, by the multicast of bottom
Passage by the service that news release end 1 and information consumption end 2 use with can be mapped.Thus, issuing service and subscription are passed through
Service, it is possible to carry out message exchange with realizing decentralization.
In step S130, service identifiers of the information consumption end 2 in the configuration information being pre-configured with are ordered to directory agent 4
Read and service to obtain corresponding multicast address, and the multicast channel according to corresponding to accessing multicast address.Passage records end 5 according to pre-
The configuration information first configured subscribes to all services to obtain corresponding all multicast address to directory agent 4, and according to multicast
Location is respectively connected to corresponding multicast channel.
Specifically, information consumption end 2 can obtain a corresponding multicast address after subscription service.Messenger service end 2
Multicast group corresponding to multicast address can be added by sending message to the router for being used as hardware facility, so as to which incoming multicast leads to
Road.
The configuration information at Message Record end 5 includes all service identifiers, therefore can subscribe in directory agent 4 and own
Service.Message Record end 5 is circulative to send subscription information to directory agent 4, to subscribe to all services in real time.
It should be understood that news release end 1 and the passage record subscription service of end 5 are operations independently, can't mutually make
About.News release end 1 is when service message corresponding to its needs, according to the service identifiers subscription service configured.And lead to
Trace record end 5 needs real-time scanning directory agency 4 to subscribe to whole services.
In step S140, news release end 1 is to the multicast channel issuing service message corresponding to the multicast address of registration.
In step S150, information consumption end 2 receives service message in the multicast channel ordered by it.Passage records end 5
Receive the service message in all multicast channels in multicast subgroup, and by received service message persistence.
In an optional embodiment, information consumption end 2 can send request to obtain by recording end 5 to passage
The history message of service ordered by information consumption end 2.
Passage record end 5 can be disappeared by subscribing to all service messages into multicast channel with receiving all services
Breath, passage record end 5 can also be transmitted the message to TCP communication by all news release ends 1.When information consumption end 2 adds
After entering multicast channel, message sending end 1 finishes news release, and now message consumer 2 can record end 5 to passage and ask
Seek history message.Further, since UDP communications are insecure, service message has the possibility of loss in transmission process, therefore disappears
Breath consumption terminal 2 may omit ordered service message.Now, information consumption end 2 can record end 5 to passage and ask history
Message.
Specifically, the information of request history message is sent to passage record end 5 in step S160, information consumption end 2.
In step S170, Message Record end 5 sends its history service message asked to information consumption end 2.
Information consumption end 2 can pass through group after by multicast channel corresponding to configuration information subscription service and addition
The request that communication sends request history message to passage record end is broadcast, other communication modes (such as TCP communication) can also be passed through
Send the request of request history message.It should be understood that in multicast group, multicast member can shield the unwanted information of institute.
It should be understood that above step numbering not represents the order between step, above-mentioned the step of being related to different executive agents
It can be changed according to actual conditions.For example, may be in the case where there be multiple information consumption ends 2 at an information consumption end 2
It is added into subnet, and is authenticated, the step such as service subscription and message sink.Meanwhile a news release end 1 is being carried out
It can add in the multicast at multiple information consumption ends 2 after certification, registration service, then be given out information.This implementation
Example uses the thought of micro services, by certification, services the functional units such as issue, service subscription, service management and message duration,
It is divided into different micro- functional entitys, reduces the coupling between each functional entity, realizes the decentralization of message exchange and make
It is more convenient that maintenance must be developed.Cause information real-time to exchange by the way of UDP multicasts, improve the efficiency and property of system
Energy.
Fig. 3 is the schematic diagram of the distributed message switching system of second embodiment of the invention.As shown in figure 3, described second
The distributed message switching system of embodiment includes news release end 1, information consumption end 2, certificate server 3, configuration management end
4th, directory agent 5, passage record end 6 and monitoring management end 7.The news release end 1, information consumption end 2, certificate server 3,
Configuration management end 4, directory agent 5, passage record end 6 and monitoring management end 7 be located in same UDP multicast subgroups, it is mutual it
Between can pass through UDP cast communications.
In the present embodiment, news release end 1 is configured as according to the configuration information configured to the transmission group of directory agent 5
Address and corresponding service identifiers are broadcast with registration service, and disappear to multicast channel issuing service corresponding to the multicast address of registration
Breath.Information consumption end 2 is configured as service identifiers in the configuration information configured to the subscription service of directory agent 5 to obtain
Take corresponding multicast address, and according to the multicast address incoming multicast passage to receive service message.The quilt of institute's certificate server 3
It is configured to send message publishing side 1, information consumption end 2 and passage the record progress of end 6 authentication with grant message consumption terminal 1
The authority of service message, grant message consumption terminal 2 and passage record end 6 receive the authority of service message.Configuration management end 4 by with
It is set to corresponding configuration information being respectively configured and records end 6 to news release end 1, information consumption end 2 and passage.News release end
1 configuration information includes multicast address and corresponding service identifiers.The configuration information at information consumption end 2 includes being obtained service
Service identifiers.The configuration information at passage record end 6 includes the service identifiers of all services.Directory agent 5 is configured as managing
Registered or the multicast address subscribed to and corresponding service identifiers.Passage record end 6 is configured as receiving all multicast channels
Service message and the service message persistence that will be received.Passage record end 6 is additionally configured to the message to request history message
Consumption terminal 2 sends corresponding history message.Monitoring management end 7 is configured as the health parameters of applying in monitoring system, described to answer
Include process status, the handling capacity of information receiving and transmitting, service registry and the success rate of subscription and the Loss Rate of message with health parameters
Deng.Fig. 4 is the flow chart of the distributed message exchange method of second embodiment of the invention.As shown in figure 4, in step S210, disappear
Cease publishing side 1 and send identity information progress authentication to certificate server 3, obtain and service message is sent in this multicast subgroup
Authority.Passage records end 6 and information consumption end 2 and sends identity information progress authentication to certificate server 3 respectively, obtains
In the inscribed authority for receiving service message of this multicast subgroup.
Specifically, news release end 1 can carry out authentication with login authentication server 3, after authentication passes through, certification clothes
Business device 3 issues corresponding 1 one electronic signatures in news release end or digital certificates with so that news release end 1 is obtained in this multicast
The authority of service message is sent in subnet.Similarly, information consumption end 2 can carry out authentication with login authentication server 3,
After authentication passes through, certificate server 3 issues corresponding 2 one electronic signatures in information consumption end or digital certificates with so that message disappears
Expense end 2 is obtained in the inscribed authority for receiving service message of this multicast subgroup.Passage record end 5 can be carried out with login authentication server 3
Authentication, after authentication passes through, certificate server 3 issues corresponding 5 one electronic signatures in passage record end or digital certificates
To cause passage record end 5 to obtain in the inscribed authority for receiving service message of this multicast subgroup.It is readily appreciated that, certificate server 3 is sent out
It is different to distinguish to give the electronic signature or digital certificates difference of news release end 1, information consumption end 2 with passage record end 5
Authority.
It should be understood that the authentication at news release end 1, information consumption end 2 and passage record end 5 is behaviour independently
Make.Passage record end 5 just carries out authentication in system initialization.News release end 1 and information consumption end 2 can need
Authenticated when issue or reception service message.
In step S220, configuration management end 4 is respectively configured to news release end 1, information consumption end 2 and passage record end 6
Corresponding configuration information.
Specifically, issuing service class needed for acquisition is sent to configuration management end 4 by the news release end 1 of authentication
The request of the configuration information of type, configuration management end 4 respond request and give the configuration information of news release end 1.The configuration at news release end 1
Information includes the service identifiers of required issuing service type and corresponding multicast address.Similarly, disappearing by authentication
Cease consumption terminal 2 and the request for obtaining the required configuration information for receiving service type is sent to configuration management end, configuration management end 4 is responded
Ask to give the configuration information of information consumption end 2.The configuration information at information consumption end 2 includes the required service mark for receiving service type
Know.Sent by the Message Record end 6 of authentication to configuration management end 4 obtain can receive all service types match somebody with somebody confidence
The request of breath, configuration management end 4 respond request and record the configuration information of end 6 to passage.The configuration information at passage record end 6 includes institute
There are service identifiers corresponding to service type.All configuration informations are managed by using configuration management end 4, are easy to configuration information
Unified management and upgrading, improve the performance of system.
It should be understood that it is independently to enter that the operation of configuration information is asked at news release end 1, information consumption end 2 and passage record end 6
Capable, and asynchronous and non-interference.Passage record end 6 needs just to ask configuration information in system initialization.Message is sent out
Cloth end 1 and information consumption end 2 can configure corresponding configuration information in request whenever necessary.
In step S230, news release end 1 sends multicast address and corresponding service according to configuration information to directory agent 5
Mark is with registration service.
Service identifiers correspond with multicast address, by the multicast channel of bottom with can be disappeared by news release end 1 and message
The service that expense end 2 uses is mapped.Thus, issuing service and subscription service are passed through, it is possible to carry out with realizing decentralization
Message exchange.
In step S240, service identifiers of the information consumption end 2 in configuration information are to the subscription service of directory agent 5 to obtain
Take corresponding multicast address, and the multicast channel according to corresponding to multicast address access.Passage records end 5 according to being pre-configured with
Configuration information subscribe to all services to directory agent 4 with all multicast address corresponding to obtaining, and distinguished according to multicast address
Multicast channel corresponding to access.
Specifically, information consumption end 2 can obtain a corresponding multicast address after subscription service.Messenger service end 2
Multicast group corresponding to multicast address can be added by sending message to the router for being used as hardware facility, so as to which incoming multicast leads to
Road.The request for being sent to directory agent 5 and subscribing to all services is circulated at Message Record end 6, to subscribe to all services in real time.
It should be understood that news release end 1 and the passage record subscription service of end 6 are operations independently, not while and not
Can mutually it restrict.Clothes are subscribed to according to the service identifiers configured in news release end 1 when service message corresponding to its needs
Business.And passage record end 6 needs real-time scanning directory agency 5 to subscribe to whole services.
In step S250, news release end 1 is to the multicast channel issuing service message corresponding to the multicast address of registration.
In step S260, information consumption end 2 receives service message in the multicast channel ordered by it.Passage records end 6
Receive the service message in all multicast channels in multicast subgroup, and by received message duration.The persistence is
The mechanism that routine data is changed between permanent state and instantaneous state.Specifically, persistence by data (in internal memory
Object) be saved in the form of file or database can be in the storage device of persistence (such as disk).End 6 is recorded by passage
By the service message persistence in all multicast channels, it is easy to not receive the information consumption end 2 of multicast message in time (such as at this
This message is issued when information consumption end 2 adds multicast finishes) can be by being sent a request for by recording end 6
Required history message.
In step S270, the news release end 1, information consumption end 2 and passage record end 6 will apply the letter such as health parameters
Breath is sent to monitoring management end 7.It is described using health parameters include process status, the handling capacity of information receiving and transmitting, service registry and
The success rate of subscription and the Loss Rate of message etc..By applying health parameters in the monitoring system of monitoring management end 7, it is easy to quick
It was found that problem encountered improves the reliability of message switching system to solve in time during message exchange.It should be understood that walk above
Rapid numbering not represents the order between step, and above-mentioned the step of being related to different executive agents can change according to actual conditions.
For example, an information consumption end 2 may be added into subnet in the case where there are multiple information consumption ends 2, and carry out
The steps such as certification, service subscription and message sink.Meanwhile a news release end 1 be authenticated, can be with after registration service
Add in the multicast at existing multiple information consumption ends 2, then given out information.
, can be with when information consumption end 2 is missed or loses ordered history message in an optional embodiment
History message is asked to passage record end 6.
Specifically, the history service message for asking to specify to passage record end 6 in step S280, information consumption end 2.
In step S290, passage records end 6 and sends its history service message asked to information consumption end 2.
Second embodiment of the invention is compared to first embodiment, except using micro services and UDP multicasting technologys so that message
Exchange decentralization and then develop maintenance and more facilitate, and information real-time is exchanged, it is excellent to improve efficiency and performance etc.
Point is outer, and the distributed message switching system of second embodiment with the addition of configuration management end 4 and monitoring management end 7.The configuration pipe
Reason is managed collectively configuration information corresponding to each functional unit in end 4 so that completes system upgrade more conveniently.The monitoring
Management end 7 collects the running situation applied health parameters, can understand system in real time of each functional unit, when event occurs in system
During barrier, it can find and solve in time.
Fig. 5 is the schematic diagram of the distributed message switching system of third embodiment of the invention.As shown in figure 5, the described 4th
The distributed message switching system of embodiment includes the first multicast subgroup 1 and the second multicast subgroup 2.First multicast subgroup 1 includes
News release end 11, the first certificate server 12, the first directory agent 13, first message agency 14 and first passage record end
15.Second multicast subgroup 2 includes the second Message Agent 21, the second certificate server 22, the second information consumption end 23, the second catalogue
Agency 24 and second channel record end 25.Each functional unit of first multicast subgroup 1 and the inside of the second multicast subgroup 2 between each other may be used
To pass through UDP cast communications.Communicated between first multicast subgroup 1 and second multicast subgroup 2 by Transmission Control Protocol.It should be understood that
Cast communication can not across subnet progress.In the first multicast subgroup 1, news release end 11 is configured as being matched somebody with somebody according to what is be pre-configured with
Confidence, which is ceased to all directory agents (the first directory agent 13 and the second directory agent 24), sends multicast address and corresponding service
Mark passes through multicast channel issuing service message corresponding to the multicast address of registration with registration service.First message agency 14
The service identifiers in the configuration information being pre-configured with are configured as to the subscription service of the first directory agent 13 to obtain correspondingly
Multicast address, and according to the multicast address incoming multicast passage to receive service message, by received service message
Second Message Agent 21 is sent to corresponding multicast address.First certificate server 12 is configured as sending out the message
Cloth end 11 and first passage record end 15 carry out the authority that authentication sends service message with grant message consumption terminal 11, authorize
First message agency 14 and first passage record end 15 receive the authority of service message.First directory agent 13 is configured as managing
Registered or the multicast address subscribed to and corresponding service identifiers.First passage record end 15, which is configured as receiving all multicasts, to be led to
The service message in road and the service message persistence that will be received.First passage record end 15 is additionally configured to disappear to request history
The information consumption end of breath or Message Agent 14 send corresponding history message.It should be understood that do not have in the first multicast subgroup of diagram
There is display information consumption end, but do not represent and information consumption end is not present in the multicast subgroup.
In the second multicast subgroup, the second Message Agent 21 is configured as issuing from first message in the second multicast subgroup
The message that agency 14 is received.Second certificate server 22 is configured as to the information consumption end 23 and second channel record end
25 progress authentications to authorize the authority that the second Message Agent 21 sends service message, lead to by grant message consumption terminal 23 and second
Trace record end 25 receives the authority of service message.Information consumption end 23 is configured as the clothes in the configuration information being pre-configured with
Business is identified to the subscription service of the second directory agent 24 to obtain corresponding multicast address, and according to the multicast address incoming multicast
Channel reception service message.Second directory agent 24 is configured as managing registered or multicast address that is subscribing to and corresponding service
Mark.Second channel record end 25 is configured as receiving the service message of all multicast channels and holds the service message received
Longization.First passage record end 25 be additionally configured to request history message information consumption end 23 send corresponding to history disappear
Breath.
It should be understood that all multicast subgroups can also only set a certificate server, all information consumption ends and message
Publishing side is authenticated to this certificate server.
In different multicast subgroups, the service identifiers of identical message service type are identical with its corresponding multicast address,
So the publish/subscribe messenger service between different multicast networkings can be realized by Message Agent.
Fig. 6 is the flow chart of the distributed message exchange method of third embodiment of the invention.As shown in fig. 6, in step
S310, news release end 11 send identity information to the first certificate server 12 and carry out authentication.Information consumption end 23 is to
Two certificate servers 22 send identity information and carry out authentication.News release end 11 is obtained in the first and second multicast subgroups
Send the authority of service message.Information consumption end 23 is obtained in the inscribed authority for receiving service message of the second multicast subgroup.
It should be understood that above-mentioned authentication is operation independently, does not represent and do not represented simultaneously between each other yet
In the presence of restriction.
In step S320, news release end 11 is according to the configuration information being pre-configured with to all directory agents (the first catalogue
The directory agent 24 of agency 13 and second) multicast address and corresponding service identifiers are sent with registration service.
In the present embodiment, the configuration information at news release end 11 includes the multicast address for being available for its issuing service message
With corresponding service identifiers.
In step S330, first message acts on behalf of 14 service identifiers in the configuration information being pre-configured with to the first catalogue
13 subscription services are acted on behalf of to obtain corresponding multicast address, and according to the multicast address incoming multicast passage.Information consumption end
23 according to the service identifiers in the configuration information that is pre-configured with to the subscription service of the second directory agent 24 to obtain corresponding multicast
Address, and according to the multicast address incoming multicast passage.
Specifically, first message agency 13 and information consumption end 23 can obtain a corresponding multicast after subscription service
Address.First message agency 13 and information consumption end 23 can be by sending message addition group to the router for being used as hardware facility
Multicast group corresponding to address is broadcast, so as to incoming multicast passage.
It should be understood that above-mentioned authentication is operation independently, does not represent and do not represented simultaneously between each other yet
In the presence of restriction.
In step S340, news release end 11 is to the multicast channel issuing service message corresponding to the multicast address of registration.
In step S350, first message is acted on behalf of in 14 multicast channel ordered by it and receives service message.
In step S360, first message agency 14 is by the service message of reception and corresponding multicast address with TCP communication
Mode is sent to the second Message Agent 21.
In step S370, the second Message Agent 21 enters multicast according to the multicast address obtained at first message agency 14
Passage simultaneously will act on behalf of 14 news releases received into multicast channel from first message.
In step S380, message consumer 23 receives service message in its multicast channel subscribed to.
, can when information consumption end 23 is missed or loses ordered service message in an optional embodiment
To ask history message to Message Record end 25.Message Record end 25 sends its history service asked to information consumption end 23
Message.Above step numbering not represents the order between step, and above-mentioned the step of being related to different executive agents can be according to reality
Border situation change.For example, an information consumption end 23 may be added into the case where having there is multiple information consumption ends 23
In subnet, and it is authenticated, the step such as service subscription and message sink.Meanwhile a news release end 11 is being authenticated, noted
It can add in the multicast at multiple information consumption ends 23 after volume service, then be given out information.
Fourth embodiment of the invention describes news release end and information consumption end in different multicast subgroups, passes through
TCP communication and UDP cast communications cooperate, and realize efficiently easily message exchange.
Fig. 7 is the schematic diagram of the distributed message switching system of fourth embodiment of the invention.As shown in fig. 7, the described 4th
The distributed message switching system of embodiment includes news release end 1, information consumption end 2, passage record end 3 and directory agent 4.
The news release end 1, information consumption end 2, passage record end 3 and directory agent 4 are located in same UDP multicast subgroups, phase
It can pass through UDP cast communications between mutually.
In embodiments of the present invention, news release end 1 is configured as according to the configuration information that is pre-configured with to directory agent
Multicast address and corresponding service identifiers are sent with registration service, and are issued by multicast channel corresponding to the multicast address of registration
Service message.Information consumption end 2 is configured as according to the service identifiers in the configuration information that is pre-configured with to the directory agent 4
Subscription service is to obtain corresponding multicast address, and according to the multicast address incoming multicast channel reception service message.Passage
The service message persistence that record end 3 is configured as receiving the service message of all multicast channels and will received.First passage
Record end 5 is additionally configured to send corresponding history message to the information consumption end 2 of request history message.Preferably, passage is remembered
Record end 5 can subscribe to all services to directory agent 4 to realize the reception of the service message to all multicast channels.Meanwhile
Persistence is the mechanism for changing routine data between permanent state and instantaneous state.Specifically, persistence by data (such as
Object in internal memory) be saved in the form of file or database can be in the storage device of persistence (such as disk).Catalogue generation
Reason 4 is configured as disappearing to message publishing side 1, information consumption end 2 and passage the record progress of end 5 authentication to authorize the message
Take the authority that end 1 sends service message, authorize the information consumption end 2 and passage record end 5 receives the power of service message
Limit.Directory agent 4 is additionally configured to manage registered or multicast address that is subscribing to and corresponding service identifiers.Compared to invention the
The function of directory agent and certificate server is integrated in directory agent by one embodiment, the present invention, reduces One function group
Part so that system deployment is easier to be easily achieved.
Fig. 8 is the flow chart of the distributed message exchange method of fourth embodiment of the invention.As shown in figure 8, in step
S410, news release end 1 send identity information to directory agent 4 and carry out authentication to obtain the transmission clothes in this multicast subgroup
The authority for message of being engaged in.Information consumption end 2 and passage record end 3 carry out authentication to the transmission identity information of certificate server 3 respectively and recognized
Card, obtain in the inscribed authority for receiving service message of this multicast subgroup.
Specifically, news release end 1 can act on behalf of 4 with login directory and carry out authentication, in certification by rear, directory agent
The identity information at 4 storage news release ends 1 is simultaneously labeled as certification.Similarly, information consumption end 2 can act on behalf of 4 with login directory
Authentication is carried out, in certification by rear, directory agent 4 stores the identity information at information consumption end 2 and is labeled as certification.It is logical
Trace record end 3 can act on behalf of 4 with login directory and carry out authentication, in certification by rear, the memory channel of directory agent 4 record end 3
Identity information and be labeled as certification.It is readily appreciated that, directory agent 4 is for news release end 1, information consumption end 2 and passage
The certification mark difference at end 3 is recorded to distinguish different authorities.
It should be understood that the authentication at news release end 1, information consumption end 2 and passage record end 3 is not limit while also not
The independent operation mutually restricted.Passage record end 5 just carries out authentication in system initialization.News release end 1 and disappear
Breath consumption terminal 2 can carry out authentication when needing to issue or receiving service message.
In step 420, news release end 1 according to the configuration information being pre-configured with to directory agent 4 send multicast address and
Corresponding service identifiers are with registration service.
In the present embodiment, the configuration information at news release end 1 includes the multicast address for being available for its issuing service message
With corresponding service identifiers.
In step S430, service identifiers of the information consumption end 2 in the configuration information being pre-configured with are ordered to directory agent 4
Read and service to obtain corresponding multicast address, and the multicast channel according to corresponding to accessing multicast address.Passage records end 3 according to pre-
The configuration information first configured subscribes to all services to obtain corresponding all multicast address to directory agent 4, and according to multicast
Location is respectively connected to corresponding multicast channel.
Specifically, information consumption end 2 can obtain a corresponding multicast address after subscription service.Messenger service end 2
Multicast group corresponding to multicast address can be added by sending message to the router for being used as hardware facility, so as to which incoming multicast leads to
Road.
The configuration information at Message Record end 3 includes all service identifiers, therefore can subscribe in directory agent 4 and own
Service.Message Record end 3 is circulative to send subscription information to directory agent 4, to subscribe to all services in real time.
It should be understood that news release end 1 and the passage record subscription service of end 3 are operations independently, can't mutually make
About.News release end 1 is when service message corresponding to its needs, according to the service identifiers subscription service configured.And lead to
Trace record end 3 needs real-time scanning directory agency 4 to subscribe to whole services.
In step S440, news release end 1 is to the multicast channel issuing service message corresponding to the multicast address of registration.
In step S450, information consumption end 2 receives service message in the multicast channel ordered by it.Passage records end 3
Receive the service message in all multicast channels in multicast subgroup, and by received service message persistence.
, can be with when information consumption end 2 is missed or loses ordered service message in an optional embodiment
History message is asked to Message Record end 3.Message Record end 3 sends its history service message asked to information consumption end 2.
Directory agent in the present embodiment is used to realize two functions of authentication and service management.Reduce One function
Component make it that system deployment is easier.Also, directly authentication information can be preserved and marked after directory agent authentication, it is not necessary to given
Authentication end retransmits the mark such as digital certificates, it is easy to accomplish.
The preferred embodiments of the present invention are the foregoing is only, are not intended to limit the invention, for those skilled in the art
For, the present invention can have various changes and change.All any modifications made within spirit and principles of the present invention, it is equal
Replace, improve etc., it should be included in the scope of the protection.
Claims (12)
1. a kind of distributed message exchange method, including：
News release end according to the configuration information being pre-configured with to directory agent send multicast address and corresponding service identifiers with
Registration service；
Service identifiers of the information consumption end in the configuration information being pre-configured with are to the directory agent subscription service to obtain
Corresponding multicast address, and according to the multicast address incoming multicast passage；
The news release end passes through multicast channel issuing service message corresponding to the multicast address of registration；
The information consumption end receives service message in the multicast channel of subscription；
The service message persistence that passage record end receives the service message of all multicast channels and will received；
The information consumption end sends a request for the history service message of ordered service to passage record end.
2. distributed message exchange method according to claim 1, it is characterised in that methods described is in the news release
Also include before the registration service of end：
The news release end carries out authentication to obtain the authority of transmission service message to certificate server；And
The passage records end and carries out authentication to certificate server to obtain the authority of reception service message；
Methods described also includes before the subscription service of the information consumption end：
The information consumption end carries out authentication to obtain the authority of reception service message to certificate server.
3. distributed message exchange method according to claim 1, it is characterised in that methods described also includes：
Corresponding configuration information is respectively configured at configuration management end remembers to the news release end, the information consumption end and passage
Record end.
4. distributed message exchange method according to claim 1, it is characterised in that methods described also includes：
Health parameters are applied in the monitoring system of monitoring management end, the application health parameters include process status, information receiving and transmitting
Handling capacity, service registry and the Loss Rate of the success rate of subscription and message.
5. distributed message exchange method according to claim 1, it is characterised in that methods described also includes：
Service message is transferred into the message as the first multicast subgroup where the news release end using Message Agent to disappear
The second multicast subgroup where Fei Duan.
6. distributed message exchange method according to claim 1, it is characterised in that the multicast channel is UDP multicasts
Passage.
7. a kind of distributed message switching system, including：
Directory agent, it is configured as managing registered or multicast address that is subscribing to and corresponding service identifiers；
News release end, it is configured as sending multicast address and corresponding clothes to directory agent according to the configuration information being pre-configured with
Business mark passes through multicast channel issuing service message corresponding to the multicast address of registration with registration service；
Information consumption end, the service identifiers being configured as in the configuration information being pre-configured with subscribe to clothes to the directory agent
It is engaged in obtain corresponding multicast address, and according to the multicast address incoming multicast channel reception service message；And
Passage records end, the service message persistence that is configured as receiving the service message of all multicast channels and will receive.
8. distributed message switching system according to claim 7, it is characterised in that the information consumption end is also configured
The ordered history service message serviced is sent a request for record end to the passage.
9. distributed message switching system according to claim 7, it is characterised in that the system also includes：
Certificate server, it is configured as that the news release end, the information consumption end and passage record end are carried out authentication and recognized
Card authorizes the information consumption end and passage record termination is conquered to authorize the authority that the information consumption end sends service message
The authority for message of being engaged in.
10. distributed message switching system according to claim 7, it is characterised in that the system also includes：
Configuration management end, it is configured as corresponding configuration information being respectively configured to the news release end, the information consumption
End and passage record end.
11. distributed message switching system according to claim 7, it is characterised in that the system also includes：
Monitoring management end, be configured as in monitoring system apply health parameters, it is described application health parameters include process status,
Handling capacity, service registry and the Loss Rate of the success rate of subscription and message of information receiving and transmitting.
12. distributed message switching system according to claim 7, it is characterised in that the system also includes：
Message Agent, for service message to be sent to positioned at other subnets as the first subnet where the news release end
Message Agent.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201710867141.7A CN107592364B (en) | 2017-09-22 | 2017-09-22 | Distributed message exchange method and system |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201710867141.7A CN107592364B (en) | 2017-09-22 | 2017-09-22 | Distributed message exchange method and system |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN107592364A true CN107592364A (en) | 2018-01-16 |
| CN107592364B CN107592364B (en) | 2020-08-11 |
Family
ID=61048422
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201710867141.7A Active CN107592364B (en) | 2017-09-22 | 2017-09-22 | Distributed message exchange method and system |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN107592364B (en) |
Cited By (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN109992432A (en) * | 2019-03-15 | 2019-07-09 | 青岛海信移动通信技术股份有限公司 | A kind of data processing system and method based on message queue |
| CN110730116A (en) * | 2019-10-21 | 2020-01-24 | 杭州鸿雁智能科技有限公司 | Operation method of communication equipment in local area network, communication equipment and gateway equipment |
| CN111245925A (en) * | 2020-01-09 | 2020-06-05 | 北京理工大学 | Communication method and system for modern distributed micro-service architecture |
| CN111399787A (en) * | 2020-03-25 | 2020-07-10 | 中孚安全技术有限公司 | Distributed printing auditing system and auditing method |
| CN113301091A (en) * | 2020-07-31 | 2021-08-24 | 阿里巴巴集团控股有限公司 | Message processing method and device for distributed system, electronic equipment and medium |
Citations (13)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101136741A (en) * | 2006-08-30 | 2008-03-05 | 西安电子科技大学 | Multicast key management method and central node used for the same |
| CN101567905A (en) * | 2009-06-03 | 2009-10-28 | 杭州华三通信技术有限公司 | Method, sending terminal and receiving terminal for data synchronization |
| CN102457906A (en) * | 2010-10-26 | 2012-05-16 | 中国移动通信集团河南有限公司 | Load balancing control method and system of message queues |
| CN103856393A (en) * | 2013-07-09 | 2014-06-11 | 携程计算机技术（上海）有限公司 | Distributed message-oriented middleware system based on database and operating method thereof |
| CN104618221A (en) * | 2015-01-06 | 2015-05-13 | 厦门雅迅网络股份有限公司 | Decentralized message service system |
| US9100202B2 (en) * | 2010-11-18 | 2015-08-04 | Business Objects Software Limited | Message routing based on modeled semantic relationships |
| CN104980441A (en) * | 2015-06-26 | 2015-10-14 | 浪潮软件股份有限公司 | Method for implementing tenant authentication mechanism |
| CN105306559A (en) * | 2015-10-12 | 2016-02-03 | 国电南瑞科技股份有限公司 | Multi-partition message control system without central partition for regional power grid regulation and control system |
| CN105610926A (en) * | 2015-12-22 | 2016-05-25 | 广州唯品会信息科技有限公司 | Message transmitting method and system and message middleware system |
| CN105677494A (en) * | 2016-02-01 | 2016-06-15 | 北京京东尚科信息技术有限公司 | Message distribution method and device |
| US20160255041A1 (en) * | 2008-08-05 | 2016-09-01 | HeyWire, Inc. | Social messaging system having multiple number, dual mode phone support |
| CN105933384A (en) * | 2016-04-06 | 2016-09-07 | 腾讯科技（深圳）有限公司 | File sharing method, terminal and file sharing system |
| CN106302817A (en) * | 2016-09-29 | 2017-01-04 | 南京中新赛克科技有限责任公司 | A kind of data/address bus implementation method based on Distributed Message Queue and device |
-
2017
- 2017-09-22 CN CN201710867141.7A patent/CN107592364B/en active Active
Patent Citations (13)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101136741A (en) * | 2006-08-30 | 2008-03-05 | 西安电子科技大学 | Multicast key management method and central node used for the same |
| US20160255041A1 (en) * | 2008-08-05 | 2016-09-01 | HeyWire, Inc. | Social messaging system having multiple number, dual mode phone support |
| CN101567905A (en) * | 2009-06-03 | 2009-10-28 | 杭州华三通信技术有限公司 | Method, sending terminal and receiving terminal for data synchronization |
| CN102457906A (en) * | 2010-10-26 | 2012-05-16 | 中国移动通信集团河南有限公司 | Load balancing control method and system of message queues |
| US9100202B2 (en) * | 2010-11-18 | 2015-08-04 | Business Objects Software Limited | Message routing based on modeled semantic relationships |
| CN103856393A (en) * | 2013-07-09 | 2014-06-11 | 携程计算机技术（上海）有限公司 | Distributed message-oriented middleware system based on database and operating method thereof |
| CN104618221A (en) * | 2015-01-06 | 2015-05-13 | 厦门雅迅网络股份有限公司 | Decentralized message service system |
| CN104980441A (en) * | 2015-06-26 | 2015-10-14 | 浪潮软件股份有限公司 | Method for implementing tenant authentication mechanism |
| CN105306559A (en) * | 2015-10-12 | 2016-02-03 | 国电南瑞科技股份有限公司 | Multi-partition message control system without central partition for regional power grid regulation and control system |
| CN105610926A (en) * | 2015-12-22 | 2016-05-25 | 广州唯品会信息科技有限公司 | Message transmitting method and system and message middleware system |
| CN105677494A (en) * | 2016-02-01 | 2016-06-15 | 北京京东尚科信息技术有限公司 | Message distribution method and device |
| CN105933384A (en) * | 2016-04-06 | 2016-09-07 | 腾讯科技（深圳）有限公司 | File sharing method, terminal and file sharing system |
| CN106302817A (en) * | 2016-09-29 | 2017-01-04 | 南京中新赛克科技有限责任公司 | A kind of data/address bus implementation method based on Distributed Message Queue and device |
Non-Patent Citations (1)
| Title |
|---|
| 夏千林: "PaaS云基础架构中消息中间件的设计与实现", 《中国优秀硕士学位论文全文数据库》 * |
Cited By (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN109992432A (en) * | 2019-03-15 | 2019-07-09 | 青岛海信移动通信技术股份有限公司 | A kind of data processing system and method based on message queue |
| CN110730116A (en) * | 2019-10-21 | 2020-01-24 | 杭州鸿雁智能科技有限公司 | Operation method of communication equipment in local area network, communication equipment and gateway equipment |
| CN110730116B (en) * | 2019-10-21 | 2021-10-29 | 杭州鸿雁智能科技有限公司 | Operation method of communication equipment in local area network, communication equipment and gateway equipment |
| CN111245925A (en) * | 2020-01-09 | 2020-06-05 | 北京理工大学 | Communication method and system for modern distributed micro-service architecture |
| CN111399787A (en) * | 2020-03-25 | 2020-07-10 | 中孚安全技术有限公司 | Distributed printing auditing system and auditing method |
| CN111399787B (en) * | 2020-03-25 | 2023-04-21 | 中孚安全技术有限公司 | Distributed printing auditing system and auditing method |
| CN113301091A (en) * | 2020-07-31 | 2021-08-24 | 阿里巴巴集团控股有限公司 | Message processing method and device for distributed system, electronic equipment and medium |
Also Published As
| Publication number | Publication date |
|---|---|
| CN107592364B (en) | 2020-08-11 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN107592364A (en) | A kind of distributed message exchange method and system | |
| CN101785281B (en) | Automated service discovery and dynamic connection management | |
| US8369246B2 (en) | Method and apparatus for sending and receiving multicast packets on a multicast tree | |
| US8099764B2 (en) | Secure push and status communication between client and server | |
| US8458359B2 (en) | System for the internet connections, and server for routing connection to a client machine | |
| US20050002405A1 (en) | Method system and data structure for multimedia communications | |
| US20050240758A1 (en) | Controlling devices on an internal network from an external network | |
| US20070297430A1 (en) | Terminal reachability | |
| US20110138058A1 (en) | Server for routing connection to client device | |
| US20030108030A1 (en) | System, method, and data structure for multimedia communications | |
| JP2005516544A (en) | Controlled multicast system and method of execution | |
| Baker et al. | Internet protocols for the smart grid | |
| US20120317254A1 (en) | Network platform in a network device ecosystem | |
| US20090319611A1 (en) | Method and System for Facilitating Exchange of A Data Between Applications Using a Communication Platform | |
| US11088996B1 (en) | Secure network protocol and transit system to protect communications deliverability and attribution | |
| US20100257226A1 (en) | Communication module and application program provided with same | |
| CN104349208A (en) | Message processing method, message processing device, gateway, set-top box and network television system | |
| CN102055816A (en) | Communication method, business server, intermediate equipment, terminal and communication system | |
| JP2019515555A (en) | Anonymous Identification Information and Protocol of Identification Information Oriented Network | |
| Li et al. | IoT middleware architecture over information-centric network | |
| US20050002388A1 (en) | Data structure method, and system for multimedia communications | |
| JP4463277B2 (en) | Service relay inter-subnet multicast-A cross-subnet multicast solution independent of the network infrastructure | |
| US10904115B2 (en) | Anonymous integration of cloud based applications and on-premise network analytics | |
| WO2012075768A1 (en) | Method and system for monitoring locator/identifier separation network | |
| JP2005086700A (en) | Domain name resolution/authentication method and apparatus |
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 |