JP5823919B2 - Distributed execution system, method, apparatus, and program - Google Patents

Description

  The present invention relates to a technique for distributing and executing program modules executed by a service gateway apparatus that connects various devices to a network.

  Currently, ICT services that connect various devices are being introduced in large and medium-sized companies. However, in small offices and homes, the introduction of ICT services is delayed compared to large corporations because of cost. In order to promote the introduction of ICT services in small offices and homes, it is considered to provide a platform that allows service providers to easily disseminate services, and as an example, the construction and provision of a home ICT infrastructure is progressing. .

  In the home ICT platform, a service gateway device (SGW) is installed in a user's home in order to connect a network in the user's home such as a small office or home to an external network. The SGW enables service provision using various devices in the house connected by a network. For this reason, not only device connection management corresponding to various communication protocols but also functions for protocol conversion and for converting and accumulating data itself acquired from the device are required.

  As another background technology related to the present invention, there are load distribution and distributed computing in which a plurality of computers are combined to perform a large amount of calculation processing.

  The load distribution is a technique for preparing a plurality of Web servers so that processing can be performed even when a large number of accesses are concentrated on the Web server, and distributing the access so that the load on each server is equalized. After the load distribution apparatus receives a request as a virtual server, the request is distributed and transmitted to a plurality of real Web servers. Basically, similar processing is performed in a plurality of real servers, and predetermined processing is executed by a program prepared and installed in advance (see Non-Patent Document 1).

  Distributed computing divides a program into parallel processing units (tasks), processes tasks in parallel on multiple networked computers, and completes the processing by sending and receiving processed data between computers To do. In distributed computing, it is necessary to divide a program into tasks that can be processed in parallel and distribute each task to a plurality of computers (see Non-Patent Document 2).

“Introduction to Load Balancing”, [online], November 14, 2006, Fujitsu Limited, [Search June 1, 2012], Internet <URL: http://fenics.fujitsu.com/products/ipcom/ catalog / data / 1 / 1.html> Norihito Goda, “Chapter 3 Distributed Computing System”, [online], May 11, 2010, The Institute of Electronics, Information and Communication Engineers, [Search June 1, 2012], Internet <URL: http: // www .ieice-hbkb.org / portal / doc_479.html>

  Since the SGW is installed in a home, a high-spec device cannot be installed, or it is not easy to replace a once-installed device with a high-spec device. In providing services, it is necessary to operate software that handles a wide variety of protocols and data within limited computational resources, so it is difficult to maintain the required service performance, or multiple services There was a problem that it could not be provided at the same time.

  In order to apply the load distribution technique to the SGW, it is necessary to prepare a load distribution apparatus and a plurality of SGWs, which causes a problem that the cost becomes very high. Further, as in the SGW, in order to download a program module for each service and execute a plurality of services simultaneously, it is necessary to prepare a plurality of program modules in a plurality of SGWs. It is inefficient to manage a plurality of modules, including their versions, with a large number of SGWs because the management cost increases.

  In addition, in order to apply distributed computing to SGW, it is necessary to divide the tasks into tasks that can be processed in parallel and distribute the tasks to computers. As a result, there is a problem that the cost of providing services increases. Actually, if task division becomes inefficient, the ratio of overhead due to decentralization such as data transfer and synchronization processing increases, so efficient task division is often difficult.

  The present invention has been made in view of the above, and an object of the present invention is to provide a technology capable of providing various services even when a service gateway device with limited specifications is used.

A distributed execution system according to a first aspect of the present invention is a distributed execution system comprising a service gateway and a computer connected to the service gateway via a network, wherein the service gateway includes receiving means for receiving a program module; analysis means for receiving the program module registered in the management table as a characteristic of the program modules to analyze whether using instructions to use the hardware features of the service gateway, executing those the service gateway program modules when requested, said based on the characteristics of the management said program modules registered in the table, or to execute the program module in the service gateway, and selecting means for selecting whether to run on said computer, said election If the unit is selected to execute the program module in the service gateway, executing means for executing the program module, if the selection means has selected the executing said program module in the computer, said computer the program modules The computer has execution means for executing the program module, and control means for receiving the program module and causing the execution means to execute the same as the service gateway. It is characterized by.

  In the distributed execution system, the service gateway includes a resource management unit that manages a resource status of the service gateway and a resource status of the computer, and the selection unit allocates the program module based on the resource status. It is characterized in that it is selected whether it is executed by a service gateway or by the computer.

A service gateway according to a second aspect of the present invention is a service gateway for transmitting a program module to a computer connected via a network and executing the program module, receiving means for receiving the program module, and received program analysis means for module registered in the management table as a characteristic of the program modules to analyze whether using instructions to use the hardware features of the service gateway, those the service gateway is requested to execute the program modules and when, on the basis of the characteristics of managed the program modules registered in the table, or to execute the program module in the service gateway, and selecting means for selecting whether to run on said computer, said selection means If you choose to execute the program module in the service gateway, executing means for executing the program module, if the selection means has selected the executing said program module in the computer, transmit the program module to the computer Transmitting means.

A distributed execution method according to a third aspect of the present invention is a distributed execution method by a service gateway and a computer connected to the service gateway via a network, the step of receiving a program module by the service gateway, comprising the steps of program module registered in the management table as a characteristic of the program modules to analyze whether using instructions to use the hardware features of the service gateway, those the service gateway is requested to execute the program modules when the, on the basis of the characteristics of the program modules registered in the management table, whether to execute the program module in the service gateway, and selecting whether to run on said computer, said selecting If you choose to execute the program module in the service gateway step, step a, if you choose to execute the program module in the computer in the step of selecting, the computer the program modules for executing the program module Transmitting the program module, and receiving the program module by the computer and executing the received program module.

  A distributed execution program according to a fourth aspect of the present invention operates a computer as the service gateway.

  According to the present invention, it is possible to provide a technology that can provide various services even when a service gateway device with limited specifications is used.

It is a whole block diagram which shows the structure of the distributed execution system in this Embodiment. It is a whole block diagram which shows the structure of another distributed execution system in this Embodiment. It is a whole lineblock diagram showing the composition of the example of a distributed execution system.

  Hereinafter, embodiments of the present invention will be described with reference to the drawings.

  FIG. 1 is an overall configuration diagram showing the configuration of the distributed execution system in the present embodiment. The distributed execution system shown in the figure includes an SGW 1 that receives and executes a functional module, and a personal computer (PC) 2 that receives and executes the functional module from the SGW 1. The functional module is a program module that operates on a program execution environment included in the SGW 1 or the PC 2.

  The SGW 1 is connected to an external network 100 and a home network. A PC 2, a sensor 5, a telephone terminal 7, and the like are connected to the home network. The SGW 1 operates the functional module, for example, enables the telephone service by connecting the telephone terminal 7 to the network 100 as an IP telephone, or acquires the measurement value of the sensor 5 in response to an inquiry from an external telephone terminal. Perform functions such as sending. When the load on the SGW 1 is high and the function module cannot be operated, the function module is transmitted to the PC 2 to operate the function module on the PC 2.

  The SGW 1 includes a GW function unit 11, a VM 12, a function module control unit 13, and a resource management unit 14, and receives the function modules 15A, 15B, and 15C and executes them on the VM 12. Each unit included in the SGW 1 may be configured by a computer including an arithmetic processing device, a storage device, and the like, and the processing of each unit may be executed by a program. This program is stored in a storage device included in the SGW 1, and can be recorded on a recording medium such as a magnetic disk, an optical disk, or a semiconductor memory, or provided through a network. Hereinafter, each part of SGW1 is demonstrated.

  The GW function unit 11 has a gateway function such as receiving an incoming call from the outside, transmitting to the outside, and relaying communication between the home network and the network 100. For the function modules 15A, 15B, and 15C requested to be executed, an executable device (SGW1 itself or PC2) is determined based on the resource status of the SGW1 and the PC2 and the characteristics of the function modules 15A, 15B, and 15C. When it is determined to be executed by the PC 2, the function modules 15A, 15B, and 15C requested to be executed are transmitted to the PC 2 and are operated on the PC 2.

  The VM 12 is a program execution environment such as a Java (registered trademark) VM, for example, and executes the function modules 15A, 15B, 15C, and the like.

  The function module control unit 13 installs, executes, and deletes the function modules 15A, 15B, and 15C, and has a function module management table that describes the characteristics of the function modules 15A, 15B, and 15C. In the present embodiment, the functional module management table describes whether each functional module 15A, 15B, 15C is a functional module that uses the SGW1 hardware. The function module characteristics described in the function module management table include, for example, a communication bandwidth required between the SGW 1 and the PC 2 when the function module is executed on the PC 2, and an SGW 1 directly connected to the external network 100. Whether or not performance is ensured by processing.

  The resource management unit 14 manages the resource status of the SGW 1 itself and the resource status of the PC 2. The resource status of PC2 is transmitted from the resource management unit 23 of PC2. In the present embodiment, the CPU usage rate is used as the resource status. Note that resource status such as memory usage, network bandwidth used, and number of processes may be used.

  The PC 2 includes a program execution environment similar to the SGW 1 such as the VM 21 and the functional module control unit 22 and a resource management unit 23 that manages the resource status of the PC 2 itself.

  The functional module control unit 22 installs, executes, and deletes the functional module received from the SGW 1.

  The resource management unit 23 manages the resource status and transmits the resource status to the SGW 1.

  FIG. 2 is an overall configuration diagram showing the configuration of another distributed execution system in the present embodiment. In the distributed execution system shown in the figure, the function server 3 receives the function module from the SGW 1 and executes it instead of the PC 2. Of course, both the PC 2 and the function server 3 may be used.

  The function server 3 is connected to the SGW 1 via the network 100. The function server 3 includes a program execution environment similar to the SGW 1 such as the VM 33 and the function module control unit 34, an SGW management unit 31, a function server control unit 32, and a resource management unit 35.

  The SGW management unit 31 recognizes and manages the SGW 1 that has requested execution of the functional module.

  The function server control unit 32 has functions such as reception of function modules and communication with the SGW 1.

  The resource management unit 35 manages the resource status and transmits the resource status to the SGW 1.

  Note that the PC 2 and the function server 3 may secure not only the function module execution environment but also a storage area as a function of the SGW 1.

  1 and 2, the PC 2 and the function server 3 are connected one by one. Of course, a plurality of PCs and the function server 3 may be connected.

[Example]
Next, an example of the distributed execution system in this embodiment will be described.

  FIG. 3 is an overall configuration diagram of an embodiment of the distributed execution system. The SGW 1 shown in the figure has a function of connecting the temperature sensor 5 and converting the temperature sensor information (current temperature information) of the temperature sensor 5 into a voice and returning it in response to an inquiry from the outside. When the load on the SGW 1 itself is high, the SGW 1 transmits the function module to the function server 3 on the cloud for execution.

  In the embodiment of FIG. 3, the SGW 1 executes the speech recognition module 15A, the speech synthesis module 15B, and the encryption module 15C as functional modules. Among these, the speech recognition module 15A and the speech synthesis module 15B are downloaded from the cloud-side download server 4 and installed. The encryption module 15C is a functional module that encrypts data using the hardware of the SGW1. In the function module management table in the function module control unit 13, the speech recognition module 15A and the speech synthesis module 15B are registered as function modules that do not use the hardware of the SGW1, and the encryption module 15C has a function that uses the hardware of the SGW1. Registered as a module.

  As a method of registering the characteristics of the function module in the function module management table, when the function module is downloaded, it is analyzed whether or not the function module uses an instruction to use the hardware function of SGW1, and the result is registered. And a method of analyzing whether or not an instruction using the hardware of the SGW 1 is used when the downloaded functional module is operated for the first time on the SGW 1 and registering the result.

The SGW 1 includes a sensor information acquisition unit 16. The sensor information acquisition unit 16 acquires temperature sensor information from the temperature sensor 5. On the other hand, the function server 3 includes a VM 33 that is the same program execution environment as the SGW 1. It is possible to execute the speech recognition module 15A and the speech synthesis module 15B that do not use hardware. In FIG. 3, the voice recognition module 15A and the voice synthesis module 15B are described in the function server 3, but they are not installed until the voice recognition module 15A and the voice synthesis module 15B are transmitted from the SGW 1. The function server 3 also includes an encryption module 36 that decrypts the data encrypted by the encryption module 15C of the SGW 1.

  Hereinafter, the operations of the SGW 1 and the function server 3 when the telephone terminal 7C queries the SGW 1 for temperature sensor information when the load on the SGW 1 is high while the telephone terminals 7A and 7B are engaged in a call will be described.

  First, the user calls SGW1 from the telephone terminal 7C.

  When the SGW 1 receives a call from the telephone terminal 7C, the GW function unit 11 requests voice command input.

  When the user requests acquisition of temperature sensor information by voice input using the telephone terminal 7C, the GW function unit 11 tries to start the voice recognition module 15A in order to analyze the input voice.

  First, the GW function unit 11 inquires of the function module control unit 13 whether or not the voice recognition module 15A is a function module using hardware. The functional module control unit 13 refers to the functional module management table and notifies the GW functional unit 11 that the voice recognition module 15A is a functional module that does not use hardware.

  Subsequently, the GW function unit 11 inquires of the resource management unit 14 whether or not the voice recognition module 15A can be activated on the VM 12 of the SGW 1 itself. The resource management unit 14 determines that the activation cannot be performed because the CPU usage rate of the SGW 1 exceeds the predetermined threshold, and notifies the GW function unit 11 of the activation.

  Since the voice recognition module 15 </ b> A cannot be activated on the VM 12, the GW function unit 11 inquires of the resource management unit 14 whether the function server 3 can be used. The resource management unit 14 refers to the CPU usage rate of the function server 3, determines that it can be used, and notifies the GW function unit 11.

  Upon receiving notification that the function server 3 is available, the GW function unit 11 requests the function server 3 to execute the voice recognition module 15A and transmits the voice recognition module 15A.

  When the function server control unit 32 receives the request to execute the speech recognition module 15A and the speech recognition module 15A, the SGW management unit 31 recognizes and manages the request source SGW1, and the speech recognition module 15A received by the function module control unit 34. Is deployed on the VM 33 and activated.

  When the voice recognition module 15 </ b> A is executed by the function server 3, the GW function unit 11 transfers the user voice data received from the telephone terminal 7 </ b> C to the function server 3.

  In the function server 3, the voice data received by the voice recognition module 15A is converted into text data, and the function server control unit 32 returns the text data after the voice recognition process to the SGW 1. Also, the functional module control unit 34 terminates the voice recognition module 15A and deletes it from the VM 33 upon completion of the processing of the voice recognition module 15A.

  The GW function unit 11 recognizes that the user's request is acquisition of temperature sensor information from the received text data, and the sensor information acquisition unit 16 requests the temperature sensor information from the temperature sensor 5 to obtain temperature sensor information. .

  Subsequently, the GW function unit 11 tries to activate the speech synthesis module 15B in order to convert the acquired temperature sensor information into speech. Similar to the processing for the speech recognition module 15A, the GW function unit 11 inquires of the function module control unit 13 whether or not the speech synthesis module 15B is a function module that uses hardware. The resource management unit 4 is inquired as to whether the server 3 is available, requests the function server 3 to execute the speech synthesis module 15B, and transmits the speech synthesis module 15B.

  When the function server control unit 32 receives the request for execution of the speech synthesis module 15B and the speech synthesis module 15B, the SGW management unit 31 recognizes and manages the request source SGW1, and the speech synthesis module 15B received by the function module control unit 34. Is deployed on the VM 33 and activated.

  When the speech synthesis module 15B is executed by the function server 3, the GW function unit 11 transfers the temperature sensor information to the function server 3. At this time, the GW function unit 11 encrypts the temperature sensor information for security. Send after conversion.

  Therefore, the GW function unit 11 tries to activate the encryption module 15C in order to encrypt the temperature sensor information.

  The GW function unit 11 inquires of the function module control unit 13 whether the cryptographic module 15C is a function module using hardware. The functional module control unit 13 refers to the functional module management table and notifies the GW functional unit 11 that the cryptographic module 15C is a functional module using hardware.

  Since the cryptographic module 15C is a functional module that uses hardware, the GW function unit 11 starts the cryptographic module 15C on the SGW 1, sends temperature sensor information to the cryptographic module 15C, encrypts the temperature sensor information, and encrypts it. The temperature sensor information is transmitted to the function server 3.

  In the function server 3, the encrypted temperature sensor information received is decrypted by the encryption module 36, and after the voice synthesis module 15B converts the temperature sensor information into voice data, the function server control unit 32 returns the voice data to the SGW 1 To do. Also, the functional module control unit 34 terminates the speech synthesis module 15B and deletes it from the VM 33 upon completion of the processing of the speech synthesis module 15B.

  The GW function unit 11 receives the voice data from the function server 3 and transmits it to the telephone terminal 7C, so that the user can check the current temperature information with the voice output from the telephone terminal 7C.

  It should be noted that frequently used function modules are arranged in advance in each device, so that transmission / reception of the function modules is not always necessary.

  As described above, according to the present embodiment, the program execution environment for executing the function modules 15A, 15B, and 15C is prepared in the PC 2 and the function server 3, and the function modules 15A, 15B, and 15C requested to execute are prepared. , SGW1, PC2, function server 3 resource status, function module 15A, 15B, 15C based on the characteristics of the function module 15A, 15B, 15C, the executable module is determined to be executed if it is determined to execute on a device other than SGW1 By transmitting and executing 15A, 15B, and 15C, when the load on the SGW 1 is high, the PC 2 and the function server 3 can perform processing, so the resources of the SGW 1 itself (CPU, memory, storage device, etc.) PC2 and function server 3 are prepared without expanding or replacing SGW1 SGW1 functionality can be extended, and a variety of services can be provided.

  According to the present embodiment, the function requested to be executed is described as a characteristic of the function modules 15A, 15B, and 15C in the function module management table indicating whether or not the function module uses the SGW1 hardware. It can be determined whether or not the modules 15A, 15B, and 15C can be executed by a device other than the SGW1.

  According to the present embodiment, the SGW 1 manages the resource status of itself and the resource status of the PC 2 and the function server 3, and determines a device to be executed in units of function modules, whereby tasks that can process individual function modules in parallel are determined. There is no need to split it.

1 ... SGW
11 ... GW functional unit 12 ... VM
DESCRIPTION OF SYMBOLS 13 ... Functional module control part 14 ... Resource management part 15A, 15B, 15C ... Functional module 16 ... Sensor information acquisition part 2 ... PC
21 ... VM
DESCRIPTION OF SYMBOLS 22 ... Function module control part 23 ... Resource management part 3 ... Function server 31 ... SGW management part 32 ... Function server control part 33 ... VM
34 ... Functional module control unit 35 ... Resource management unit 36 ... Cryptographic module 4 ... Download server 5 ... Sensor 7, 7A, 7B, 7C ... Telephone terminal 100 ... Network

Claims (6)

A distributed execution system comprising a service gateway and a computer connected to the service gateway via a network,
The service gateway is
Receiving means for receiving the program module;
Analyzing means for analyzing whether the received program module uses an instruction to use the hardware function of the service gateway and registering it in the management table as a characteristic of the program module;
When those the service gateway is requested to execute program modules or, on the basis of the characteristics of managed the program modules registered in the table, or to execute the program module in the service gateway, run on the said computer A selection means for selecting
An execution means for executing the program module when the selection means selects to execute the program module in the service gateway;
A transmission means for transmitting the program module to the computer when the selection means selects the computer to execute the program module;
The calculator is
Execution means for executing the same program module as the service gateway;
And a control unit that receives the program module and causes the execution unit to execute the program module. The service gateway has resource management means for managing the resource status of the service gateway and the resource status of the computer,
It said selecting means, wherein based on the resource status, distributed execution system according to claim 1, wherein the program modules or be executed in the service gateway, and selects whether to run on said computer. A service gateway that transmits a program module to a computer connected via a network and executes the program module,
Receiving means for receiving the program module;
Analyzing means for analyzing whether the received program module uses an instruction to use the hardware function of the service gateway and registering it in the management table as a characteristic of the program module;
When those the service gateway is requested to execute program modules or, on the basis of the characteristics of managed the program modules registered in the table, or to execute the program module in the service gateway, run on the said computer A selection means for selecting
An execution means for executing the program module when the selection means selects to execute the program module in the service gateway;
When the selection unit selects to execute the program module on the computer, a transmission unit that transmits the program module to the computer;
A service gateway characterized by comprising: Resource management means for managing the resource status of the service gateway and the resource status of the computer;
4. The service gateway according to claim 3 , wherein the selection unit selects whether to execute the program module on the service gateway or on the computer based on the resource status. A distributed execution method by a computer connected to a service gateway and the service gateway via a network,
By the service gateway,
Receiving a program module;
Analyzing whether the received program module uses an instruction to use the hardware function of the service gateway and registering it as a characteristic of the program module in the management table;
When those the service gateway is requested to execute program modules or, on the basis of the characteristics of managed the program modules registered in the table, or to execute the program module in the service gateway, run on the said computer A step of selecting
When selecting to execute the program module in the service gateway in the selecting step, executing the program module;
And when the computer module is selected to be executed by the computer in the selecting step, the program module is transmitted to the computer.
According to the calculator,
Receiving the program module;
And a step of executing the received program module. A distributed execution program for operating a computer as the service gateway according to claim 3 .

Images