JP3785152B2 - Reference conversion apparatus, distributed processing system and method thereof - Google Patents

Description

[0001]
BACKGROUND OF THE INVENTION
  The present invention relates to a distributed processing system in which a plurality of computer nodes are coupled to each other, and a computing space having a plurality of processing modules is distributed on the network, a distributed processing method in the environment, and the distributed processing system For converting reference information to properly link processing modules in distributed processing methodsIn placeRelated.
[0002]
[Prior art]
Along with the development of data processing technology and communication technology, the construction of a network in which various data processing devices are connected so as to use information and perform various data processing more efficiently is progressing.
For example, the construction of an internetwork that connects a plurality of computer networks into a large-scale network is progressing. In particular, the so-called “Internet” has become a global network using TCP / IP as a protocol. Is a typical example of such a network.
[0003]
In the Internet, an IP address and a DNS (Domain Name System) name are assigned to a node on the network. The IP address is an identification number of each data processing apparatus connected to the network, and is represented by a 32-bit integer. The DNS name is a name that allows a user to distinguish nodes on the network by a meaningful symbolic name. The DNS name is assigned to each range by dividing the network into management ranges. DNS (Domain Name System), which is a hierarchical naming mechanism based on a DNS name composed of a series of names divided by periods, is a machine name hierarchization in the Internet based on TCP / IP. Is realized.
Note that these IP addresses and DNS names must not be duplicated on the network, that is, around the world, and are centrally managed by a network information center (NIC).
[0004]
On the other hand, in recent years, development of ISM (Information Super-Market), which is an information provision service application that uses and distributes multimedia information, has been actively conducted. In ISM, in order to enhance the interactivity between functional modules (classes) and the flexibility of inter-module configuration, an application execution environment that efficiently performs network-wide multimedia parallel processing is required. That is, a more advanced parallel distributed processing environment is required.
[0005]
[Problems to be solved by the invention]
By the way, in the DNS widely used as a name resolution mechanism for conventional objects, the conversion of reference information is as simple as the conversion from a DNS name to an IP address. In other words, it can handle only one-step conversion and cannot be used for complicated name resolution that requires multi-step conversion. Further, it is not possible to appropriately cope with complicated reference information based on a plurality of pieces of information.
This means that DNS is not suitable as a reference mechanism used in a more advanced parallel distributed processing environment as described above. That is, in such a parallel and distributed processing environment, it is necessary to efficiently refer to various computational resources and various objects on the network using various names and IDs. It is because it cannot respond.
[0006]
Therefore, the object of the present invention is to cope with multi-stage name / reference resolution, reference by a large number of elements, etc., and more efficiently communicate between objects, thereby providing an advanced parallel distributed processing environment. It is an object of the present invention to provide a reference conversion device that can do this.
Another object of the present invention is to provide such an effective distributed processing method.
Still another object of the present invention is to provide a distributed processing system capable of providing such a highly parallel distributed processing environment.
Still another object of the present invention is to provide a distributed processing method capable of providing such a highly parallel distributed processing environment.
[0007]
[Means for Solving the Problems]
  In the distributed processing system according to the first aspect of the present invention, a calculation space composed of a plurality of processing modules is distributed and arranged on a computer network in which a plurality of computer devices are combined, and each processing module performs substantial communication. A distributed processing system that performs distributed processing in conjunction with the above, directly specifying logical reference information for specifying a processing module in the calculation space, similar logical reference information, and objects on the computer system A plurality of reference conversion means for converting the reference information of any one of the system reference information or a combination thereof, the input logical reference information, and the logical reference information converted and generated by the reference conversion means, Based on the logical reference information, recursively input to any of the plurality of reference conversion means, and the input logical reference Conversion control means for converting information into the system reference information, and logical reference information of the processing module of the communication destination is converted into system reference information by the reference conversion means via the conversion control means. And a plurality of reference conversion means, a first reference conversion means for converting the logical reference information into the system reference information, and the logical reference information as the system reference information. A pair of second reference conversion means for converting the logical reference information into another logical reference information, a third reference conversion means for converting the logical reference information into other logical reference information, and a set of other logical reference information. And a fourth reference conversion means for converting the logical reference information into a set of the system reference information and the logical reference information, wherein the conversion control means is the input The logical reference information and the logical reference information generated by the conversion are input to any one of the first reference conversion means to the fifth reference conversion means based on the contents of the logical reference information. .
[0008]
  According to the distributed processing method of the invention of the second aspect, a calculation space composed of a plurality of processing modules is distributed and arranged on a computer network in which a plurality of computer devices are combined, and each processing module performs substantial communication. A distributed processing method for performing distributed processing in conjunction with the communication reference method, wherein the reference conversion method is determined based on the contents of the logical reference information of the communication destination of each processing module, and the determined reference conversion method To convert the logical reference information of the communication destination into other logical reference information and system reference information that directly identifies an object on the computer network, or reference information of a combination thereof, For the logical reference information in the reference information of the conversion result, a reference conversion method is determined again based on the logical reference information, and the determined reference According to the conversion method, the conversion is performed again, the determination of the reference conversion method for the logical reference information and the conversion based on it are repeated until all the elements of the reference information of the conversion result become the system reference information, When all the elements become the system reference information, the communication between the processing modules is performed based on the reference information, and the processing modules perform the distributed processing substantially in cooperation.
[0009]
  In the reference conversion device according to the third aspect of the present invention, a calculation space composed of a plurality of processing modules is distributed and arranged on a computer network in which a plurality of computer devices are combined, and each processing module performs substantial communication. A reference conversion device used for the processing module of a computer system that performs distributed processing in conjunction with the logical reference information for logically identifying the processing module in the computer system, and similarly processing the logical processing module. A plurality of reference conversion means for converting logical reference information to be identified and system reference information for directly identifying an object on a computer system, or a combination thereof, and an input logical reference Information and the logical reference information converted and generated by the reference conversion means, the logical reference information Conversion control means for recursively input to any of the plurality of reference conversion means based on the input, and converting the inputted logical reference information into the system reference information, and logical reference information of the processing module of the communication destination Is converted into system reference information by the reference conversion means via the conversion control means, and communication means for performing communication between the processing modules, and the plurality of reference conversion means includes the logical reference information. First reference conversion means for converting the logical reference information into the system reference information, second reference conversion means for converting the logical reference information into the set of system reference information, and other logical references for the logical reference information Third reference conversion means for converting the information into information, fourth reference conversion means for converting the logical reference information into another set of logical reference information, and the logical reference information as the system reference information. Fifth conversion means for converting the set of logical reference information into a set of logical reference information, the conversion control means including the input logical reference information and the logical reference information generated by the conversion, Based on the contents of the logical reference information, it is input to any of the first to fifth reference conversion means.
[0011]
DETAILED DESCRIPTION OF THE INVENTION
First embodiment
A first embodiment of the present invention will be described with reference to FIGS.
In the first embodiment, for example, a calculation space composed of a plurality of processing modules is developed on a computer network in which a plurality of computer devices are combined, and each processing module communicates with other modules substantially. In an environment where distributed processing or parallel distributed processing is performed, for example, in order to communicate between the processing modules, the reference information of each processing module specified at the application level is directly identified as an object on the actual system. 1 shows a reference conversion device for converting into system reference information that can be performed.
[0012]
FIG. 1 is a block diagram showing the configuration of the reference conversion apparatus.
The reference conversion device 130 includes an input switching unit 131, a first conversion unit 132, a second conversion unit 133, a third conversion unit 134, a fourth conversion unit 135, a fifth conversion unit 136, and an output switching unit 137. And a control unit 138.
In FIG. 1, reference symbol A indicates application reference information, and reference symbol S indicates system reference information.
[0013]
First, the configuration and function of each unit will be described.
Based on the switching signal from the control unit 138, the input switching unit 131 receives the application reference information input or the application reference information input again from the output switching unit 137 described later, from the first conversion unit 132 to the first conversion unit 132. 5 is selectively input to one of the five converters 136.
The first conversion unit 132 converts the input application reference information into one system reference information.
The second conversion unit 133 converts the input application reference information into a set of two or more system reference information.
The third conversion unit 134 converts the input application reference information into other application reference information.
[0014]
The fourth conversion unit 135 converts the input application reference information into a set of two or more application reference information.
The fifth conversion unit 136 converts the input application reference information into a set of other application reference information and system reference information.
Based on the control signal input from the control unit 138, the output switching unit 137 switches the processing of the reference information that is converted by the first conversion unit 132 to the fifth conversion unit 136 and sequentially output. That is, the system reference information among the output reference information is switched to be output to the outside, and the application reference information is switched to be input to the input switching unit 131 again. The output switching unit 137 includes a storage unit (not shown), and system reference information that can be converted and output to the outside is temporarily stored in the storage unit. Then, when all the reference information for the application reference information input to the reference conversion device 130 is converted into the system reference information, the system reference information including the information stored in the storage unit is collectively output. .
[0015]
The control unit 138 controls the input switching unit 131 and the output switching unit 137 so as to appropriately convert the input application reference information into system reference information. First, the control unit 138 reads application reference information input to the input switching unit 131 from the outside, which is application reference information to be converted, or application reference information input from the output switching unit 137, and examines the contents. It is determined which of the first converter 132 to the fifth converter 136 is appropriate to perform reference resolution. Then, based on the determination result, the input switching unit 131 is switched so that the input application reference information is appropriately input to a desired conversion unit.
[0016]
Further, the control unit 138 determines whether the reference information of the conversion result input from the first conversion unit 132 to the fifth conversion unit 136 to the output switching unit 137 is application reference information or system reference information. If there is, the output switching unit 137 is controlled so as to be input to the input switching unit 131 again. Further, if it is system reference information, the output switching unit 137 is controlled so as to be stored in the storage unit in the output switching unit 137 as reference information for output.
When all the reference information for the input application reference information is converted into system reference information, the control unit 138 outputs the system reference information or a set of the system reference information to the outside as a conversion result.
[0017]
An operation in which the control unit 138 substantially controls the reference conversion device 130 will be described with reference to the flowchart of FIG.
As shown in FIG. 2, the control unit 138 starts processing when application reference information is input to the reference conversion device 130 (step S110), and the input application reference information is converted from the first conversion unit 132 to the fifth conversion. It is checked in which of the units 136 conversion is possible, and conversion is started by inputting the application reference information to the conversion unit (step S111). When the conversion is completed, it is checked whether or not application reference information exists in the reference information of the conversion result (step S112). If the application reference information exists, the process of step S111 is repeated for the application reference information.
If it is determined in step S112 that all reference information has been converted to system reference information, the conversion result is output (step S113), and the series of conversion processing ends (step S114).
[0018]
Next, the operation of the reference converter 130 will be described with reference to FIG.
First, an example of normal operation of the reference converter 130 is shown in FIG.
In the example shown in FIG. 3A, the input application reference information A is first checked by the control unit 138 and determined to be converted by the fourth conversion unit 135. The part 135 converts the application reference information into a set (A1, A2, A3). Since all the conversion results are application reference information, conversion is performed again, and the contents of each application reference information are checked again by the control unit 138 to determine the next conversion unit. In the example of FIG. 3A, the application reference information A1 to A3 are separately input to the first to third conversion units 132 to 134, and conversion is performed.
[0019]
As a result of the conversion, the application reference information A1 is applied to one system reference information S1 in the first conversion unit 132, and the application reference information A2 is applied to the system reference information set (S2, S3) in the second conversion unit 133. The reference information 3 is converted into one application reference information A4 by the third converter 134.
Of these conversion results, only the reference information A4 is still application reference information, and therefore conversion is performed again. That is, the conversion unit is selected again based on the contents, and as a result, the fifth conversion unit 136 converts the application reference information and system reference information into a set (A5, S4, S5). Furthermore, since the application reference information A5 remains in the conversion result, this is converted into one system reference information S6 by the first conversion unit 132 this time.
As a result of such sequential conversion, the input application reference information A is converted into a system reference information sequence (S1, (S2, S3), (S6, S4, S5)) and output.
[0020]
The application reference information and the system reference information are specifically logical names or IDs of the modules and objects.
In addition, the first conversion unit 132 to the fourth conversion unit 135 can collectively process a set of reference information. An example is shown in FIG.
In FIG. 3B, a set of application reference information (A1, A2, A3) is generated from the input application reference information A by the fourth conversion unit 135, and this set of application reference information is then generated. The data is directly input to the first conversion unit 132, and a corresponding set of system reference information (S1, S2, S3) is obtained.
In the first conversion unit 132 to the fifth conversion unit 136 of the reference conversion device 130, a set of application reference information can be input as described above.
[0021]
In addition, as shown in FIG. 3B, a set of application reference information may not be input all at once, but only a part thereof may be input.
Such an example is shown in FIG.
Also in FIG. 3C, a set of application reference information (A1, A2, A3) is generated from the input application reference information A by the fourth conversion unit 135. In the next stage, a set (A1, A2) of application reference information is extracted, and the remaining application reference information A3 is output to the second conversion unit 133 to the first conversion unit 132 and converted again. Yes.
In the reference conversion device 130, it is also possible to appropriately recombine the set of application reference information generated in this way and to input the application reference information in the next stage.
[0022]
As described above, in the reference conversion device 130, the first conversion unit 132 to the fifth conversion unit 136 are repeatedly selected as appropriate for the input application reference information, based on the content of the reference information, and the reference information. The conversion is done. Therefore, even application reference information having a complicated configuration is finally expanded as a sequence of system reference information that directly indicates an object on the system.
[0023]
Second embodiment
A second embodiment of the present invention will be described with reference to FIGS.
As the second embodiment, a distributed processing system in which the reference conversion apparatus described as the first embodiment is applied and processing modules are substantially linked to perform processing will be specifically described.
[0024]
FIG. 4 is a conceptual diagram of such a distributed processing system.
As shown in FIG. 4, in the distributed processing system 1, network nodes 3, 4, and 5 communicate with each other via the network 2 and perform certain processing. As the network nodes 3, 4, and 5, for example, a personal computer or a workstation is used. As the network 2, for example, Ethernet or CATV is used.
[0025]
In the network nodes 3, 4, and 5, there are calculation objects such as calculation modules, instances, classes, methods, global functions, and files for executing programs. For example, calculation objects 6 to 9 exist in the network node 3.
In addition, the network nodes 3, 4, 5 have a partial space composed of a plurality of calculation objects in the same network node. For example, in the network node 3, the subspace 10 is constituted by the calculation objects 6 and 7, and the subspace 11 is constituted by the calculation objects 8 and 9. Here, the subspace is a process executed by a daemon that is a calculation module provided in the network node.
[0026]
In addition, a calculation space is configured by subspaces and calculation objects existing in different network nodes. In the present embodiment, the calculation space 15 is configured by the partial spaces 10, 12, and 14, and the calculation space 16 is configured by the partial spaces 11 and 13. Note that the calculation space may include a partial space and a calculation object existing in the same network node. Here, the calculation space is an area in which information regarding the arrangement of calculation objects and subspaces existing in the space is clarified.
[0027]
Further, in the distributed processing system 1, the arrangement of the calculation object and the subspace is determined by information given in advance, an inquiry between subspaces, or the like. The arrangement of the calculation object and the partial space is managed by the space management units 17 and 18.
In the distributed processing system 1, as shown in FIG. 4, the network node 4 includes a space management unit 17 corresponding to the calculation space 15, and the network node 4 includes a space management unit 18 corresponding to the calculation space 16. It is.
The space management unit may be provided for each partial space or for each calculation object.
[0028]
In the distributed processing system 1, there is a daemon for each partial space, and reference information is managed by this daemon. Here, the space represented by the reference information is referred to as “reference space”. An API (Application Program Interface) identifies and manages processes and calculation objects on this reference space. With respect to this reference space, the actual existence space referred to is referred to as “real space”. Here, “reference” means pointing to these processes and calculation objects.
[0029]
A domain formed by an arbitrary reference set is configured on such a reference space.
Each process (subspace) and computational object is allowed to belong to multiple domains. Domains are allowed to be nested. In this case, the included domain is called a subdomain, and the included domain is called a super domain. By introducing a domain, a network-wide free space (service space, application space, personal space, community, etc.) can be formed.
[0030]
In the present embodiment, each reference is given a name, and a process identification space, a calculation object, and a domain identification domain are provided. This identification space is called a “name space”. From the API, processes, computational objects, and domains can be identified and managed even in this name space. Also, name uniqueness is guaranteed only within each namespace.
Therefore, name collisions are allowed between calculation objects belonging to different domains, and the degree of freedom of names that can be used in each domain is increased.
[0031]
In such a distributed processing system of the present embodiment shown in FIG. 4, each parallel object communicates based on message transmission to realize parallel distributed processing.
In this message transmission, a transmission destination node, a process, and an object are specified from a remote reference to the transmission destination object, and transmission processing is performed. At this time, if the transmission destination is a domain or an object cluster, multicasting is performed.
[0032]
If the reference indicates a proxy object, the message is transmitted via the proxy. Further, depending on the location of the transmission destination, RPC on the network, intra-node IPC, or intra-process communication is selected to perform message transmission.
At this time, the concurrent objects manage mutual remote references in the application space, thereby realizing high-speed message transmission.
A reference conversion apparatus according to the present invention that converts object reference information in the application space in such a distributed processing system and system reference information for actual transmission will be described below.
[0033]
FIG. 5 is a block diagram showing the configuration of the reference converter 150.
The reference converter 150 includes a conversion control unit 151, a domain conversion unit 152, an entity conversion unit 153, a process conversion unit 154, a node name conversion unit 155, and a DNS name proxy conversion unit 156.
[0034]
First, reference information for space management of the distributed processing system of the present invention, which is referred to by each unit of the domain conversion unit 152 to the node name conversion unit 155, will be described.
Main reference information used in this distributed processing system is managed by four reference tables and three search hash tables as shown in FIG. The four reference tables include a local function reference table 50 shown in FIG. 7, a remote function reference table 51 shown in FIG. 8, a process reference table 52 shown in FIG. 9, and a domain reference table 53 shown in FIG. The hash table for search is a hash table between names and identifiers. The domain name hash table 54 shown in FIG. 11, the function / process name hash table 55 shown in FIG. 12, and the remote function ID hash shown in FIG. This is a table 56.
[0035]
(Local function reference table)
FIG. 7 is a diagram for explaining the local function reference table 50.
The local function reference table 50 is an internal reference table for functions existing in the partial space (process).
As shown in FIG. 7, the local function reference table 50 has five fields: a print name 61, a local function ID 62, a domain reference list 63, a remote function ID 64, and an in-domain name 65.
The print name 61 is a function name on the program source code. For example, if the class is implemented in C ++, the class name is entered.
The local function ID 62 is a function identifier in the network node used on the system, and an actual access is performed using this function identifier.
[0036]
The domain reference list 63 is a pointer list to the domain reference table to which the function belongs. As shown in FIG. 7, the domain reference list 63 is represented by data having a list structure. This is for enabling expression when the function belongs to a plurality of domains.
The remote function ID 64 is an external identifier of the function, and is called from the outside of the network node by specifying the function using the external identifier.
The in-domain name 65 is a name in a domain on the name space, and a function is specified and called using this name.
[0037]
(Remote function reference table)
FIG. 8 is a diagram for explaining the remote function reference table 51.
The remote function reference table 51 is an external reference table for functions existing in the partial space (process).
As shown in FIG. 8, the remote function reference table 51 has five fields: a print name 71, a process reference 72, a remote function ID 73, a domain reference list 74, and an in-domain name 75.
The meanings of the print name 71, the remote function ID 73, the domain reference list 74, and the intra-domain name 75 are the same as those in the local function reference table 50 described above.
The process reference 72 is information regarding the location of the process in which the remote function exists, and indicates a pointer to the process reference table 52, for example.
[0038]
(Process reference table)
FIG. 9 is a diagram for explaining the process reference table 52.
The process reference table 52 is a table that stores information indicating the location of a partial space (process). As shown in FIG. 9, the process reference table 52 has four fields: a network node reference 81, a network port ID 82, a domain reference list 83, and an intra-domain name 84.
Here, the meanings of the domain reference list 83 and the intra-domain name 84 are the same as those described above.
[0039]
The network node reference 81 indicates reference information regarding the network node in which the process exists, and has three fields: a network node name 85, a reference list 88, a communication medium 86, and a network address 87.
The network node name 85 indicates the name of the network node on the name space.
A communication medium 86 indicates a communication means, for example, Ethernet or ATM.
The network address 87 indicates the network address of the node corresponding to the communication means, and indicates, for example, an IP address or a DNS name.
[0040]
The network port ID 82 indicates a daemon port number in each network node used on the distributed processing system 1, and access is performed by specifying a process with the network address and the daemon port number.
This is because some network nodes have a plurality of communication media (access functions). For example, some network nodes can be accessed by both Ethernet and ATM. Usually, in such a case, a network address is assigned to each access function.
[0041]
Therefore, in the process reference table 52, the correspondence between the network name and the network address is expressed using a reference list 88 having a list structure as shown in FIG. The correspondence relationship with a plurality of network addresses 87 corresponding to the above is expressed.
In the example illustrated in FIG. 9, in the process in which the intradomain name 84 is “N1”, the network port ID 82 is “# 10000” and the network node name 85 is “nodeA”. Also, “nodeA” includes Ethernet and ATM as the communication media 86, and the network addresses 87 are “111.11.11.11.111” and “111.11.11.11.112”, respectively.
[0042]
(Domain reference table)
FIG. 10 is a diagram for explaining the domain reference table 53.
The domain reference table 53 is a table for managing domain reference information. As described above, domains can have a hierarchical structure, and one domain can include other domains.
As shown in FIG. 10, the domain reference table 53 has a domain element reference list 91, a super domain reference list 92, and a domain name 93.
The domain element reference list 91 shows pointers to function references and subdomain references that are constituent elements of the domain.
The super domain reference list 92 shows a pointer list to the super domain (higher domain) of the domain. Here, the reason why the list structure is used for the super domain reference is that one domain may have a plurality of super domains.
A domain name 93 indicates a domain name on the name space.
[0043]
(Domain name hash table)
FIG. 11 is a diagram showing the domain name hash table 54.
The domain name hash table 54 is constructed based on a domain name assigned in a unique name space, and enables a domain reference table to be searched by name.
As shown in FIG. 11, the domain name hash table 54 has two fields of a domain name 100 and a reference list 101.
The domain name 100 indicates a domain name on the name space. The reference list 101 indicates a pointer list to the domain reference table.
In the example shown in FIG. 11, when the domain name hash table 54 is used with the domain name “D1” as a key, the address of the domain name “D1” in the domain reference table 53 is obtained.
[0044]
(Function / process name hash table)
FIG. 12 is a diagram for explaining the function / process name hash table 55.
The function / process name hash table 55 is constructed based on the intra-domain name given in its own name space, and enables a search by the names of the function reference table and the process reference table.
As shown in FIG. 12, the function / process name hash table 55 has two fields, an intra-domain name 110 and a reference list 111.
The intra-domain name 110 indicates any of a local function name, a remote function name, and a process name in the domain on the name space.
The reference list 111 is a pointer list for any one of the local function reference table 50, the remote function reference table 51, and the process reference table 52.
For example, in FIG. 12, when the local function name hash table as the function / process name hash table 55 is used with the function name “A” that is the intra-domain name 110 as a key, the reference list 111 indicates that the local function reference table 50 The address of the domain name “A” is obtained. The function / process name hash table 55 includes a remote function name hash table and a process name hash table in addition to the local function name hash table.
[0045]
(Remote function ID hash table)
FIG. 13 is a diagram for explaining the remote function ID hash table 56.
The remote function ID hash table 56 is constructed based on the remote function ID, and enables the search of the local function reference table by the remote function ID. As shown in FIG. 13, the remote function ID hash table 56 has two fields: a remote function ID 120 and a local function reference 121.
The local function reference 121 indicates a pointer to the local function reference in the local function reference table corresponding to the remote function ID.
For example, in FIG. 13, when the remote function ID hash table 56 is used with “# 000001” which is the remote function ID 120 as a key, the address where the remote function ID 64a is “# 000001” in the local function reference table 50a is obtained. .
[0046]
Next, the configuration of each part of the reference converter 150 shown in FIG. 5 will be described.
The conversion control unit 151 manages the entire reference converter 150. Specifically, the content of the input application reference information is confirmed, and the input name is output to one of the domain conversion unit 152 to the node name conversion unit 155 according to the type. Then, the conversion result obtained by the conversion unit is read, and it is checked whether or not the obtained reference information is system reference information. Then, the application reference information is input again to the domain conversion unit 152 to the node name conversion unit 155 according to the content. By repeating such processing, the conversion control unit 151 causes the finally inputted application reference information to be indicated by the system reference information, and outputs the obtained system reference information.
The conversion control unit 151 includes a storage unit, and sequentially stores system reference information for output that is sequentially detected with respect to input reference information. When all the reference information is finally converted into system reference information, the contents of the storage means are read out, and the converted system reference information is output collectively.
In addition, in the conversion control unit 151, when additional information such as information specifying a communication medium is input together with the application reference information, the additional information is also output to the conversion unit together with each reference information.
[0047]
The domain conversion unit 152 converts the input domain reference information with reference to the domain reference table 53, and converts the input domain reference information into a set of elements constituting the domain. Specifically, for example, it is converted into a set of an entity reference and a domain reference included in the domain.
The entity conversion unit 153 converts the input entity reference information into the reference information of the process in which the entity exists and the remote identifier therewith by referring to the entity reference table. This entity reference table is substantially the same table as the local function reference table 50 and the remote function reference table 51 described above. In addition, an entity here shows an instance, a class, a method, a global function etc., for example.
[0048]
The process conversion unit 154 converts the input process reference information with reference to the process reference table 52 to information on a node in which the process exists and a process identifier in the node. The node information is either a DNS name, an IP address, or a node name uniquely assigned.
The node name conversion unit 155 converts the input node name into a DNS name or an IP address with reference to a node reference table included in the process reference table 52.
[0049]
The DNS name proxy conversion unit 156 converts the input DNS name into an IP address. The DNS name proxy conversion unit 156 includes a communication unit and a storage unit. When the DNS name is input, communication is performed via the communication means to the DNS name conversion unit 160 which is an external reference conversion device, and conversion of the DNS name into an IP address is obtained. Then, the result is output as a conversion result.
Also, in the DNS name proxy conversion unit 156, the correspondence between the DNS name obtained at this time and the IP address is stored in the internal storage means described above. When the DNS name to be converted is input, first the DNS name stored in this storage means is searched. If there is the same DNS name (already converted once), the DNS name is searched. The IP address stored in the storage means is output as a conversion result. Therefore, the DNS name conversion unit 160 is inquired only about the DNS name that is not stored in the internal storage means.
[0050]
In each converter of the domain conversion unit 152 to the node name conversion unit 155, when the input application reference information is a name or ID, the domain name hash table 54 to the remote function ID hash table 56 described above and By referring to other hash tables (not shown) as appropriate, the corresponding items in each table are searched.
Also, the conversion of information related to the nodes on the network performed by the process conversion unit 154 to the node name conversion unit 155 is performed with reference to additional information indicating communication media input from the conversion control unit 151 together with reference information. This is because the addresses are usually different for different communication media even for the same system. Therefore, as the additional information, specifically, information designating Ethernet or ATM is input. In the present embodiment, when there is no designation of this communication medium, conversion is performed using Ethernet as the communication medium as a default.
[0051]
Next, a specific operation of the reference resolution unit 150 will be described with reference to FIG.
FIG. 14 is a diagram illustrating a reference information conversion process in a case where a message is transmitted to all entities belonging to a domain as an example of the operation of the reference converter 150.
In FIG. 14, when the same operation is performed in the reference conversion device 130 of the first embodiment described above in each conversion process, the conversion unit that performs the conversion process and the type of the conversion operation are simultaneously shown. Keep in mind.
[0052]
First, when the domain name D1 is input to the conversion control unit 151 of the reference converter 150, the conversion control unit 151 outputs the reference information to the domain conversion unit 152 because the content is the domain name.
The domain conversion unit 152 refers to the domain reference table 53 via the domain name hash table 54 and extracts all entities and domains included in the domain. As a result, the domain name D1 is converted into a set of entities E1, E2 and domain names D2, D3.
The domain names D2 and D3 in the obtained elements are further recursively converted in the domain conversion unit 152, and thereby converted into sets of entities E3 and E4 and entities E5 and E6, respectively.
Eventually, the input domain name D is converted into a set of entities (E1, E2, E3, E4, E5, E6) by the domain conversion unit 152.
[0053]
Next, the obtained entities E1 to E6 are sequentially input to the entity conversion unit 153. The entity conversion unit 153 converts each entity reference information E1 to E6 into a set of reference information and a remote identifier of a process in which the entity exists. As a result, as shown in the figure, reference information indicated by a set of reference information P1 to P4 and remote identifiers ID1 to ID3 is obtained.
Next, the conversion control unit 151 inputs the obtained process reference information P <b> 1 to P <b> 4 to the process conversion unit 154. In the process conversion unit 154, the process reference information is converted into node information and a process identifier. That is, the node information indicated by the DNS name and the process identifier in the node for the processes P1 and P2 and the node information indicated by the IP address and the process identifier in the node for the process P3 are the process P4. Is obtained by the node information indicated by the node name and the process ID in the node.
[0054]
Among the obtained node name information, the node information indicated by the node name obtained for the process P4 is then input to the node name conversion unit 155 and converted into a DNS name.
The node information obtained with the DNS names obtained for the processes P1 and P2 is transferred to the DNS name conversion unit 160 via the node name conversion unit 155, and converted into an IP address by the DNS name conversion unit 160. The
As a result of such processing, the input domain name D1 is converted into system reference information all indicated by a system address.
[0055]
As described above, the reference converter 150 performs the conversion of the reference information by recursive and multi-stage processing, so that the application level reference information can be converted into the system reference information even on a complicated computer network. . In other words, various computing resources, that is, domains, nodes, processes, instances, classes, methods, global functions, and the like can be referred to from the logical application reference information without depending on the system configuration. As a result, an advanced distributed processing system that does not depend on the physical network configuration can be realized.
[0056]
Note that the present invention is not limited to the present embodiment, and any suitable modification may be made.
For example, the configuration of the reference converter according to the present invention is shown in FIG. 5, but this configuration shows a basic function, and various modifications may be added.
As an example, FIG. 15 shows a more specific configuration example of the reference converter.
The reference resolver 200 shown in FIG. 15 is configured by separating the conversion unit into a name resolution unit 202 and a reference resolution unit 208.
Hereinafter, the configuration and function of the reference solution 200 will be briefly described.
The reference resolver 200 includes a resolver management unit 201, a name resolution unit 202, a reference resolution unit 208, and a table management unit 214.
The resolver management unit 201 manages the entire reference resolver 200. Specifically, it is determined whether the input reference information is a name or reference information, and if it is a name, it is output to the name resolution unit 202, and if it is reference information, it is output to the reference information resolution unit 208.
[0057]
The name resolution unit 202 converts the name in the name space to be converted input from the resolver management unit 201 into a corresponding reference.
The name resolution management unit 203 manages the entire name resolution unit 202. The name resolution management unit 203 outputs the input name to one of the domain name resolution unit 204 to the proxy resolution unit 207 according to the given name type. Then, the reference obtained by the resolution unit is read and output to the resolver management unit 201.
[0058]
The domain name resolution unit 204 uses the domain name hash table 54 to convert the domain name into a domain reference.
The process name resolution unit 205 uses the function / process name hash table 55 to convert the process name into a process reference.
The entity name resolution unit 206 performs conversion from an entity name to an entity reference using another name hash table (not shown).
The external name proxy resolution unit 207 performs conversion from an external name to an external reference using a proxy. Specifically, for example, it is a proxy to a DNS name server.
[0059]
The reference resolution unit 208 converts the conversion target reference input from the resolver management unit 201 into a primitive reference.
The reference solution management unit 209 manages the entire reference solution unit 208. The reference resolution management unit 209 outputs the input reference to any of the domain reference resolution unit 210 to the external reference resolution unit 213 according to the given reference type. Then, the conversion result obtained by the resolution unit is read and output to the resolver management unit 201.
The domain reference resolution unit 210 performs conversion from a domain reference to an entity reference. Specifically, the domain reference is converted into a set of (entity reference, domain reference). The domain reference obtained as a result of the conversion is recursively converted in the domain reference resolution unit 210.
[0060]
The process reference resolution unit 211 performs conversion from a process reference to a primitive process reference. At this time, the network node name is converted into a desired network address by designating the communication medium.
The entity reference resolution unit 212 performs resolution from the input entity reference to the primitive entity reference. In this example, in the case of conversion of a local entity reference, the given local entity reference is directly returned as a conversion result. In the case of remote entity reference resolution, the process reference appearing in the internal representation is converted into a primitive reference and the result is output.
The external reference resolution unit 213 performs resolution from an external reference to a primitive external reference.
[0061]
In FIG. 15, an external name resolution unit 215 is a DNS name conversion unit that converts an input DNS name into an IP address.
Further, the message transmission unit 300 performs message transmission for performing communication between objects in the distributed processing system 1.
Therefore, in the reference resolver 200, for example, reference information indicating, for example, a destination node, process, and object is input from the message transmitting unit 300, and the reference resolver 200 converts the reference information into system reference information. The message transmitter 300 actually communicates based on the system reference information.
The reference resolver may have such a configuration.
[0062]
【The invention's effect】
As described above, according to the present invention, system reference information is obtained by developing application level reference information by recursive and multi-stage processing on a computer network composed of a plurality of computer devices. Therefore, even complex reference information can be appropriately handled. Furthermore, it is possible to convert the reference information in a grouped state, request a solution to another reference resolver, or control the resolution operation by giving additional information related to the solution. The system reference information can be appropriately obtained with respect to the form reference information. As a result, the present invention can solve the reference information regardless of the topology of the computer network, and can contribute to providing a more advanced distributed processing system and distributed processing environment. .
[Brief description of the drawings]
FIG. 1 is a block diagram illustrating a configuration of a reference conversion apparatus according to a first embodiment of this invention.
FIG. 2 is a flowchart showing a flow of processing of a control unit shown in FIG.
FIGS. 3A to 3C are diagrams each illustrating an operation example of the reference conversion apparatus illustrated in FIG. 1;
FIG. 4 is a conceptual diagram of a distributed processing system according to a second embodiment of this invention.
FIG. 5 is a block diagram showing a configuration of a reference resolver in the distributed processing system shown in FIG. 4;
6 is a diagram for explaining the contents of a table management unit of the reference resolver shown in FIG. 5. FIG.
7 is a diagram for explaining a local function reference table shown in FIG. 6; FIG.
FIG. 8 is a diagram for explaining a remote function reference table shown in FIG. 6;
FIG. 9 is a diagram for explaining the process reference table shown in FIG. 6;
10 is a diagram for explaining the domain reference table shown in FIG. 6. FIG.
11 is a diagram for explaining the domain name hash table shown in FIG. 6. FIG.
12 is a diagram for explaining the function / process name hash table shown in FIG. 6; FIG.
13 is a diagram for explaining the remote function ID hash table shown in FIG. 6; FIG.
FIG. 14 is a diagram illustrating an operation example of the reference resolver illustrated in FIG. 5;
FIG. 15 is a diagram illustrating a specific example of the reference resolver illustrated in FIG. 5;
[Explanation of symbols]
DESCRIPTION OF SYMBOLS 1 ... Distributed processing system, 2 ... Network, 3-5 ... Network node, 6-9 ... Calculation object, 10-14 ... Subspace, 15, 16 ... Calculation space, 17, 18 ... Space management part, 50 ... Local function Reference table, 51 ... Remote function reference table, 52 ... Process reference table, 53 ... Domain reference table, 54 ... Domain name hash table, 55 ... Function / process name hash table, 56 ... Remote function ID hash table, 130 ... Reference conversion Device, 131 ... input switching unit, 132 ... first conversion unit, 133 ... second conversion unit, 134 ... third conversion unit, 135 ... fourth conversion unit, 136 ... fifth conversion unit, 137 ... Output switching unit, 138 ... control unit, 150 ... reference converter, 151 ... conversion control unit, 152 ... domain conversion unit, 153 ... d Titi conversion unit, 154... Process conversion unit, 155... Node name conversion unit, 156... DNS name proxy conversion unit, 160... DNS name conversion unit, 200. , 203 ... name resolution management unit, 204 ... domain name resolution unit, 205 ... process name resolution unit, 206 ... entity name resolution unit, 207 ... external name proxy resolution unit, 208 ... reference resolution unit, 209 ... reference resolution management unit, 210 ... Domain reference resolution unit, 211 ... Process reference resolution unit, 212 ... Entity reference resolution unit, 213 ... External reference resolution unit, 214 ... Table management unit, 215 ... External name resolution unit, 300 ... Message transmission unit

Claims (50)

A distributed processing system in which a computing space composed of a plurality of processing modules is distributed and arranged on a computer network in which a plurality of computer devices are combined, and each processing module communicates with each other and substantially performs distributed processing. There,
The logical reference information for specifying the processing module in the calculation space is the same logical reference information, system reference information for directly specifying an object on the computer system, or reference information for a combination thereof. A plurality of reference conversion means for converting;
The input logical reference information and the logical reference information converted and generated by the reference conversion means are recursively input to any of the plurality of reference conversion means based on the logical reference information, Conversion control means for converting the inputted logical reference information into the system reference information;
Communication means for converting logical reference information of a processing module of a communication destination into system reference information by the reference conversion means via the conversion control means, and performing communication between the processing modules;
The plurality of reference conversion means includes a first reference conversion means for converting the logical reference information into the system reference information, and a second reference conversion means for converting the logical reference information into a set of the system reference information. A third reference conversion means for converting the logical reference information into other logical reference information; a fourth reference conversion means for converting the logical reference information into a set of other logical reference information; Fifth conversion means for converting the logical reference information into a set of the system reference information and the logical reference information;
The conversion control means converts the input logical reference information and the logical reference information generated by the conversion into the first reference conversion means to the fifth reference based on the contents of the logical reference information. A distributed processing system that inputs to one of the reference conversion means. The distributed processing system according to claim 1, wherein the logical reference information is reference information for specifying a processing module in an application. The reference conversion means has a first table in which correspondence between at least the logical reference information and other logical reference information and / or the system reference information is indicated. The distributed processing system according to claim 1, wherein the conversion is performed with reference to a table. The logical reference information and the system reference information each specify the processing module and the object by their identifiers,
The distributed processing system according to claim 3, wherein the reference conversion unit refers to the first table based on the identifier. The logical reference information and the system reference information respectively identify the processing module and the object by their logical names,
The reference conversion means further includes a second table that associates at least the logical name with the identifier, obtains the identifier by referring to the second table based on the logical name, and the identifier The distributed processing system according to claim 4, wherein the first table is referred to based on the first table. The distribution according to any one of claims 1 to 5, wherein the conversion control means recursively inputs the logical reference information converted and generated by the reference conversion means sequentially into any of the plurality of reference conversion means. Processing system. The conversion control unit recursively returns a set of logical reference information converted and generated by the reference conversion unit to any of the plurality of reference conversion units based on the contents of the set of logical reference information. The distributed processing system according to any one of claims 1 to 5. The conversion control means extracts arbitrary logical reference information from the set of logical reference information converted and generated by the reference conversion means to generate a new set of logical reference information, and The distributed processing system according to claim 1, wherein a set of target reference information is collectively input to any of the plurality of reference conversion units based on the contents of the set. It further has conversion condition input means for inputting conversion conditions in the reference conversion means,
The distributed processing system according to claim 1, wherein the reference conversion unit performs the conversion based on the input conversion condition. The distributed processing system according to claim 1, wherein the reference conversion unit includes a communication unit, and performs the conversion based on information from another reference conversion device obtained via the communication unit. The distributed processing system according to claim 1, wherein the reference conversion unit includes a storage unit that temporarily stores information related to the conversion, and performs the conversion based on the information stored in the storage unit. . The plurality of reference conversion means includes domain information conversion means for converting domain reference information into corresponding other reference information, entity information conversion means for converting entity reference information into corresponding other reference information, Process information conversion means for converting process reference information into corresponding other reference information, node name information conversion means for converting a node name into other corresponding reference information, and a predetermined corresponding name in the domain name system The distributed processing system according to claim 1, comprising any one, a plurality, or all of domain name information conversion means for converting into reference information. The distributed processing system according to claim 12, wherein the domain information conversion unit converts the domain reference information into information composed of reference information of elements constituting the domain. The entity information conversion unit converts reference information about each element of an instance, a class, a method, and a global function into information including reference information of a process in which the element exists and an identifier in the process. Or the distributed processing system of 13. The process information conversion unit converts the information into node reference information indicated by any one of a domain name, an IP address, and a node name, and a process identifier in the node, where the process exists. Any one of the distributed processing systems. The distributed processing system according to any one of claims 12 to 15, wherein the node name information conversion means converts the node name into information of a domain name or an IP address that is another expression of the node. The distributed processing system according to claim 12, wherein the domain name information conversion unit converts the domain name into a corresponding IP address. The distributed processing system according to claim 17, wherein the domain name information conversion means instructs the conversion to another reference conversion means different from the reference conversion means. The said process information conversion means and the said node name information conversion means determine the said IP address with reference to the media information input separately, when performing the conversion which acquires the said IP address. Distributed processing system. A distributed processing method in which a computing space composed of a plurality of processing modules is distributed and arranged on a computer network in which a plurality of computer devices are combined, and each processing module communicates with each other and substantially performs distributed processing. There,
For the logical reference information of the communication destination of each processing module, determine a reference conversion method based on the content,
According to the determined reference conversion method, the logical reference information of the communication destination is one of other logical reference information and system reference information that directly specifies the object on the computer network, or Convert it into a combination of reference information,
For the logical reference information in the reference information of the conversion result, again determine a reference conversion method based on the logical reference information,
Performing the conversion again according to the determined method of reference conversion;
Until all the elements of the reference information of the conversion result become the system reference information, the determination of the reference conversion method for the logical reference information and the conversion based on the determination are repeated, and when all the elements become the system reference information , Communication between the processing modules based on the reference information,
A distributed processing method in which the respective processing modules perform distributed processing substantially in cooperation. The distributed processing method according to claim 20, wherein the logical reference information is reference information for specifying a processing module in an application. The reference conversion method includes a first method for converting the logical reference information into the system reference information, a second method for converting the logical reference information into the set of system reference information, and the logical reference information. A third method for converting reference information into other logical reference information, a fourth method for converting the logical reference information into another set of logical reference information, and the logical reference information as the system reference Of the fifth method of converting into a set of information and the logical reference information, it is determined based on the inputted logical reference information and the content of the logical reference information generated by the conversion. The distributed processing method according to claim 20 or 21. In the reference conversion method, the conversion is performed with reference to a first table in which correspondence between at least the logical reference information and other logical reference information and / or system reference information is indicated. The distributed processing method according to any one of claims 20 to 22. The logical reference information and the system reference information respectively specify the processing module and the object by their identifiers,
The distributed processing method according to claim 23, wherein, in the first to fifth methods, the conversion is performed with reference to the first table based on the identifier. The logical reference information and the system reference information respectively identify the processing module and the object by their logical names,
In the first to fifth methods, the identifier is obtained by referring to at least a second table associating the logical name with the identifier based on the logical name, and based on the identifier, The distributed processing method according to claim 24, wherein the conversion is performed with reference to a table of one. The distributed processing method according to any one of claims 20 to 25, wherein for each set of logical reference information generated by the conversion, the conversion method is individually determined, and the conversion is sequentially performed. For the set of logical reference information generated by conversion, the conversion method is determined based on the content of the set of logical reference information, and the set of logical reference information is collectively processed. The distributed processing method according to claim 20, wherein the conversion is performed. Arbitrary logical reference information is extracted from the converted and generated set of logical reference information to generate a new set of logical reference information, and the set of logical reference information is the contents of the set. The distributed processing method according to any one of claims 20 to 25, wherein a plurality of conversions by the reference conversion method are collectively performed based on the method. The distributed processing method according to any one of claims 20 to 28, wherein the conversion is performed based on information on conversion conditions that are input separately. The distributed processing method according to any one of claims 20 to 29, wherein the conversion is performed based on information related to the conversion obtained by communicating with another reference conversion device. Information related to the conversion obtained at the time of the conversion is temporarily stored in the storage means,
The distributed processing method according to any one of claims 20 to 30, wherein the conversion is performed based on the stored information. The reference conversion method includes a domain information conversion method for converting domain reference information into corresponding other reference information, an entity information conversion method for converting entity reference information into corresponding other reference information, and a process. Process information conversion method for converting reference information into corresponding other reference information, node name information conversion method for converting node name into other corresponding reference information, and predetermined reference corresponding to a name in the domain name system 21. The distributed processing method according to claim 20, wherein a domain name information conversion method that converts information into information is determined based on the input logical reference information and the content of the logical reference information generated by the conversion. The distributed processing method according to claim 32, wherein the domain information conversion method converts the domain reference information into information including reference information of elements constituting the domain. The entity information conversion method converts reference information about each element of an instance, a class, a method, and a global function into information including reference information of a process in which the element exists and an identifier in the process. Or the distributed processing method of 33. The process information conversion means converts the information into information including a node reference information indicated by any one of a domain name, an IP address, and a node name and a process identifier in the node. Any one of the distributed processing methods. 36. The distributed processing method according to any one of claims 32 to 35, wherein the node name information conversion means converts the node name into information of a domain name or an IP address that is another expression of the node. 37. The distributed processing method according to claim 32, wherein the domain name information conversion unit converts the domain name into a corresponding IP address. 38. The distributed processing method according to claim 37, wherein the domain name information conversion unit instructs the conversion to another reference conversion unit different from the reference conversion unit. The said process information conversion means and the said node name information conversion means determine the said IP address with reference to the media information input separately, when performing the conversion which acquires the said IP address. Distributed processing method. A computer system in which a computing space composed of a plurality of processing modules is distributed and arranged on a computer network in which a plurality of computer devices are combined, and each processing module performs a distributed processing in a substantially linked manner while performing communication. A reference conversion device used for a processing module,
Logical reference information for logically specifying a processing module in the computer system, logical reference information for logically specifying a processing module, and system reference information for directly specifying an object on the computer system A plurality of reference conversion means for converting into reference information of any one or a combination thereof;
The input logical reference information and the logical reference information converted and generated by the reference conversion means are recursively input to any of the plurality of reference conversion means based on the logical reference information, Conversion control means for converting the inputted logical reference information into the system reference information;
Communication means for converting logical reference information of the processing module of the communication destination into system reference information by the reference conversion means via the conversion control means, and performing communication between the processing modules;
The plurality of reference conversion means includes a first reference conversion means for converting the logical reference information into the system reference information, and a second reference conversion means for converting the logical reference information into a set of the system reference information. A third reference conversion means for converting the logical reference information into other logical reference information; a fourth reference conversion means for converting the logical reference information into a set of other logical reference information; A fifth conversion means for converting the logical reference information into a set of the system reference information and the logical reference information;
The conversion control means converts the input logical reference information and the logical reference information generated by the conversion into the first reference conversion means to the fifth reference based on the contents of the logical reference information. A reference conversion device for inputting to any of the reference conversion means. 41. The reference conversion device according to claim 40, wherein the logical reference information is reference information for specifying a processing module in an application. The reference conversion means has a first table in which correspondence between at least the logical reference information and other logical reference information and / or the system reference information is indicated. The reference conversion device according to claim 40 or 41, wherein the conversion is performed with reference to a table. The logical reference information and the system reference information each specify the processing module and the object by their identifiers,
The reference conversion apparatus according to claim 42, wherein the reference conversion means refers to the first table based on the identifier. The logical reference information and the system reference information respectively identify the processing module and the object by their logical names,
The reference conversion means further includes a second table that associates at least the logical name with the identifier, obtains the identifier by referring to the second table based on the logical name, and the identifier 44. The reference conversion apparatus according to claim 43, wherein the first table is referred to based on the reference table. 45. The reference according to claim 40, wherein the conversion control means recursively inputs the logical reference information converted and generated by the reference conversion means to any one of the plurality of reference conversion means sequentially. Conversion device. The conversion control unit recursively returns a set of logical reference information converted and generated by the reference conversion unit to any of the plurality of reference conversion units based on the contents of the set of logical reference information. 45. The reference conversion device according to any one of claims 40 to 44, wherein: The conversion control means extracts arbitrary logical reference information from the set of logical reference information converted and generated by the reference conversion means to generate a new set of logical reference information, and The reference conversion device according to any one of claims 40 to 44, wherein a set of target reference information is collectively input to any of the plurality of reference conversion means based on the contents of the set. It further has conversion condition input means for inputting conversion conditions in the reference conversion means,
The reference conversion device according to any one of claims 40 to 47, wherein the reference conversion unit performs the conversion based on the input conversion condition. The reference conversion device according to any one of claims 40 to 48, wherein the reference conversion unit includes a communication unit and performs the conversion based on information from another reference conversion device obtained through the communication unit. The reference conversion device according to any one of claims 40 to 49, wherein the reference conversion means includes storage means for temporarily storing information relating to conversion, and performs the conversion based on information stored in the storage means. .

Images