COMMUNICATION SYSTEM, NODE DEVICE, NODE PROGRAM, AND COMMUNICATION PROGRAM
First Claim
1. A communication system which is constituted by a plurality of nodes connected to each other via a network, comprising:
- a first node which is one of a plurality of the nodes used for the communication system, that receives a publish message for requesting for transmission of an object, from a publisher terminal;
a second node which is different from the first node of a plurality of the nodes,wherein each of the nodes from the first node to the second nodehas a storage unit of its own in which first routing information showing a nexthop node as a transfer destination of the publish message is recorded,performs a first routing in which the publish message is transferred to the nexthop which is obtained from the first routing information, andrecords, in the storage unit of its own, an object ID of the publish message transferred using the first routing, and second routing information in which an adjacent node having transferred the publish message to the node itself is determined as a nexthop; and
a third node which is different from the first node and the second node of a plurality of the nodes, that receives a subscribe message for requesting for receipt of the object, from a subscriber terminal,wherein each of the nodes from the third node to the first nodeperforms a second routing in which the subscribe message is transferred to the nexthop which is obtained by searching the second routing information for a object ID of the subscribe message or to a pre-set default nexthop, andrecords, in the storage unit of its own, the object ID of the subscribe message transferred using the second routing, and third routing information in which an adjacent node having transferred the subscribe message to the node itself is determined as a nexthop.
1 Assignment
0 Petitions
Accused Products
Abstract
A communication system constituted by a plurality of nodes connected to each other via a network includes: a first node that receives a publish message for requesting for transmission of an object, from a publisher terminal; and a second node. Each of the nodes from the first node to the second node: has a storage unit in which first routing information is recorded; performs a first routing; and records, in the storage unit, an object ID of the publish message and second routing information. The communication system also includes a third node that receives a subscribe message for requesting for receipt of the object, from a subscriber terminal. Each of the nodes from the third node to the first node: performs a second routing; and records, in the storage unit, an object ID of the subscribe message, and third routing information.
13 Citations
10 Claims
-
1. A communication system which is constituted by a plurality of nodes connected to each other via a network, comprising:
-
a first node which is one of a plurality of the nodes used for the communication system, that receives a publish message for requesting for transmission of an object, from a publisher terminal; a second node which is different from the first node of a plurality of the nodes, wherein each of the nodes from the first node to the second node has a storage unit of its own in which first routing information showing a nexthop node as a transfer destination of the publish message is recorded, performs a first routing in which the publish message is transferred to the nexthop which is obtained from the first routing information, and records, in the storage unit of its own, an object ID of the publish message transferred using the first routing, and second routing information in which an adjacent node having transferred the publish message to the node itself is determined as a nexthop; and a third node which is different from the first node and the second node of a plurality of the nodes, that receives a subscribe message for requesting for receipt of the object, from a subscriber terminal, wherein each of the nodes from the third node to the first node performs a second routing in which the subscribe message is transferred to the nexthop which is obtained by searching the second routing information for a object ID of the subscribe message or to a pre-set default nexthop, and records, in the storage unit of its own, the object ID of the subscribe message transferred using the second routing, and third routing information in which an adjacent node having transferred the subscribe message to the node itself is determined as a nexthop. - View Dependent Claims (2, 3, 4)
-
-
5. A node device used for a communication system which is constituted by a plurality of nodes connected to each other via a network, comprising:
-
a publish transfer table that associates an object ID of a publish message for requesting for transmission of an object, with a nexthop as a transfer destination toward a subscriber terminal of the publish message; a storage unit that stores therein a subscribe transfer table which associates an object ID of a subscribe message for requesting for reception of the object, with a nexthop as a transfer destination toward a publisher terminal of the subscribe message; a subscribe transfer table creation unit that stores, in the subscribe transfer table, an object ID of the received publish message, and an adjacent node which has transferred the publish message to itself, as a nexthop, in association with each other; a publish transfer table search unit that searches the publish transfer table for an object ID of the publish message and identifies a nexthop to which the publish message is transferred; a publish transfer table creation unit that stores, in the publish transfer table, an object ID of the received subscribe message, and an adjacent node which has transferred the subscribe message to itself, as a nexthop, in association with each other; and a subscribe transfer table search unit that searches the subscribe transfer table for an object ID of the subscribe message and identifies a nexthop to which the subscribe message is transferred. - View Dependent Claims (6)
-
-
7. A non-transitory computer-readable medium storing a communication program used for a communication system which is constituted by a plurality of nodes connected to each other via a network, the communication program for causing a computer to make, by being loaded and executed by a plurality of the nodes:
-
a first node of a plurality of the nodes receive a publish message for requesting for transmission of an object, from a publisher terminal; each of nodes from the first node to a second node which is different from the first node of a plurality of the nodes record first routing information indicating a node as a nexthop which is a transfer destination of the publish message, in a storage unit of its own, perform a first routing in which the publish message is transferred to the nexthop which is obtained from the first routing information, and record an object ID of the publish message transferred using the first routing, and second routing information in which an adjacent node having transferred the publish message to the node itself is determined as a nexthop, in a storage unit of its own; a third node which is different from the first and second nodes of a plurality of the nodes receive a subscribe message for requesting for reception of the object, from a subscriber terminal; and each of the nodes from the third node to the first node to perform a second routing in which the subscribe message is transferred to the nexthop obtained by the object ID of the subscribe message from the second routing information or a pre-set default nexthop, and record, in a storage unit of its own, an object ID of the subscribe message transferred using the second routing, and third routing information in which an adjacent node having transferred the subscribe message to the node itself is determined as a nexthop. - View Dependent Claims (8, 9, 10)
-
Specification