JP5432595B2 - Communication apparatus and processing method thereof - Google Patents

Description

  The present invention relates to a communication apparatus that transmits / receives a message to / from another apparatus via a network, and a processing method thereof.

In recent years, cooperation between PCs and devices using Web service technology in which a plurality of devices exchange data with each other via a network is generally performed. The service receives a request message for requesting execution of the service from the client, executes the service logic, and transmits a response message including the execution result to the client. After the service receives the request message, if the connection is disconnected due to a network failure, timeout, or client cancellation, the service side cannot stop the service logic execution process. Normally, the execution of the service logic is completed, the response message is written out, the disconnection is noticed, and the process is terminated. Therefore, the created response message is wasted.
Therefore, in the prior art, in response to receiving a web service request, there is a patent which is controlled by a web service controller and can use a cached one without executing service logic (reference) Reference 1).

JP2007-200311

  In the case of Patent Document 1, a cache is used in any case, but it is difficult to cache all information. Also, in the case of a Web service operation call, even if the call is the same, the same execution result is not always returned. For example, consider the case of a service that downloads files such as application documents. The application documents are processed by a number of people and processed for approval. Therefore, even if the file name is the same, the information on the application document differs depending on the call timing. In other words, there is no point in caching the execution results of a service that has been called once.

  In some cases, it may not be possible to cache at all. In that case, the execution process of the service logic which is very heavy processing is wasted. Therefore, there is a need for a mechanism that can interrupt the execution process of service logic that is very heavy even when the connection is disconnected even when the cache is not used.

  The present invention provides a communication apparatus and a processing method thereof that efficiently use a result of executing a service.

A communication apparatus according to an embodiment of the present invention is a communication apparatus that transmits / receives a message to / from another apparatus via a network,
Receiving means for receiving a message requesting execution of a service from the other device;
Monitoring means for monitoring whether or not the connection with the other device is disconnected;
Determining means for determining whether or not information for identifying the message is attached to the message;
When the connection with the other device is disconnected while executing the service of the received message, and the determination unit determines that the information is given, the result of executing the service is and storage means for storing together before Kijo report,
If the connection with the other device is disconnected while the service of the received message is being executed, and the determination unit determines that the information is not given, the service of the received message Control means for interrupting the execution of
When the information stored in the storage unit is added to the message received by the reception unit, a transmission unit that transmits the execution result stored together with the information to the other device;
It is characterized by having.

  According to the present invention, it is possible to efficiently use a result of executing a service.

The figure which shows an example of the hardware constitutions of the communication apparatus in this embodiment. The figure which shows an example of the software configuration of the communication apparatus in this embodiment. The figure which shows the process in the case of the request message to which identification ID is not provided. The figure which shows the process in the case of the request message to which identification ID was provided. The figure which shows the process in the case of the request message only of identification ID. The figure which shows an example of the information hold | maintained at a database. The flowchart which shows the process of the communication apparatus in this embodiment. The flowchart which shows the process which deletes the data which passed the preservation | save period.

  Hereinafter, embodiments for carrying out the invention will be described in detail with reference to the drawings. First, an example of the hardware configuration of the communication apparatus according to the present embodiment will be described with reference to FIG. In the present embodiment, a communication apparatus that executes a service in response to a service request from another apparatus and returns an execution result (response) to the other apparatus will be described as an example.

  In FIG. 1, another device 101 is a device (computer) on the service side that exchanges messages with a service device (communication device) 102 via a network 113. The service device 102 includes a CPU 103, a memory 104, an HD (hard disk) device 105, a display board 106, a peripheral controller 107, and a network I / F 108. The CPU 103 executes processing of each processing unit of the service device 102 according to the program. The program is stored in the HD device 105 or the memory 104, and is read into the RAM when the CPU 103 executes the program. The memory 104 includes a ROM for storing programs and control data, and a RAM as a work area for the CPU 103, and further stores XML elements and objects. The program is for causing a computer to function as a communication device.

  The HD device 105 includes an interface for controlling access to the hard disk, and stores various data. The display board 106 includes an interface for connecting the display device 109, and causes the display device 109 to display the status of the service device 102 and the processing result. The peripheral controller 107 includes an interface for connecting a mouse 110 and a keyboard 111, and controls instructions and various inputs to the service device 102. The network I / F 108 includes an interface for communicating with the network 113 and controls communication with other apparatuses 101.

  The system bus 112 connects the above-described units. The network 113 may have any form as long as the other apparatus 101 and the service apparatus 102 can communicate messages, such as the Internet, WAN, or LAN. Also, the communication protocol is not limited to a specific protocol.

  Next, an example of the software configuration of the service device 102 will be described with reference to FIG. When a request message 201 is transmitted as a message requesting execution of a service from another apparatus 101, the message receiving unit 202 receives the request message 201. Here, the connection disconnection detection unit 203 detects whether or not the connection between the other apparatus 101 and the service apparatus 102 is disconnected. If the connection is not disconnected, the message analysis unit 204 analyzes the request message 201 and determines what service is called. The message analysis unit 204 also determines whether or not the request message 201 includes an identification ID as information for identifying the message.

  Next, when the service to be called is specified by the message analysis unit 204, the service logic control unit 205 calls the service logic 206. Further, when the connection disconnection detection unit 203 detects disconnection, the service logic 206 is interrupted when the identification ID is not given to the request message 201. In the service logic 206, the service logic control unit 205 executes the service and interrupts the execution.

  When the service logic control unit 205 finishes executing the service, the message creation unit 207 creates a response message 209 that is returned to the other apparatus 101 based on the execution result of the service logic 206. Then, the message transmission unit 208 transmits a response message 209 as a message indicating the service execution result to the other apparatus 101. The response message 209 is a message indicating failed information when the service execution fails.

  If the message cannot be transmitted due to the disconnection with the other device 101, the unsent message management unit 210 holds the unsent response message in the database 211. This is performed when an identification ID is assigned to the request message 201 from another device 101, and the identification ID and the response message 209 are linked and held. Further, when the request message 201 having the same identification ID is transmitted from another device 101 again, the unsent message management unit 210 passes the already associated response message to the message transmission unit 208. The database 211 is a storage location where the unsent message management unit 210 stores information, and is included in the HD device 105.

  Next, characteristic processing of the service device according to the present embodiment will be described with reference to FIGS. First, a specific example of exchanging request messages without an identification ID is shown in FIG. The request message 301 is a specific example that is transmitted when another device 101 calls the getData operation. The request message 301 is not given an identification ID. The service device 102 receives this request message 301 and executes specific service logic 302. As a result of executing the service logic 302, a specific response message 303 is created. However, if the connection is disconnected while the processing of the service logic 302 is being executed, the identification of the request message 301 is not given, so the execution of the service logic 302 is interrupted. Therefore, in this case, the response message 303 is not created.

  Next, a specific example of exchanging request messages with identification IDs is shown in FIG. The request message 401 is a specific example that is transmitted when another device 101 calls the getData operation. The request message 401 has an identification ID “100020”. Since this identification ID is the first access, there is no response message 303 associated with the database 211. Therefore, the service device 102 executes the service logic 302 and creates a response message 303. As a result of executing the service logic 302, a specific response message 303 is created. Here, when the connection is disconnected during the processing of the service logic 302, since the identification ID is given to the request message 401, the service logic 302 is executed to the end. Then, a response message 303 is created and associated with the identification ID “100020” and held. When the request message 401 is transmitted again from the other apparatus 101, the response message 303 associated with the identification ID “100020” exists, so that the message is transmitted without executing the service logic 302. Then, the information of the response message 303 associated with the identification ID “100020” is deleted from the database 211.

  If the connection is not disconnected during the processing of the service logic 302, the response message 303 created by executing the service logic 302 is transmitted to the other apparatus 101 as it is.

  Here, FIG. 5 shows a message transmitted and received between devices when only the identification ID is transmitted from another device 101. A request message 501 having only identification ID information is transmitted. The service apparatus 102 determines whether or not a response message associated with the transmitted identification ID “100020” is stored. If the determined message 303 exists as a result of the determination, the message is transmitted in the same manner as in FIG. 4 and the stored message information is deleted from the database 211. However, if the associated message 303 does not exist, the service to be executed with only the identification ID is unknown, so a fault message is created as a specific response message 502. A response message 502 indicating that the service execution has failed is transmitted to the other apparatus 101.

  An example of information held in the database 211 in the service device 102 described above is shown in FIG. When the connection is disconnected during the execution process of the service of the request message 401 shown in FIG. 4, the identification ID “100020” is stored together with the response message (601). In this example, the identification ID “100120” is also stored together with the response message (602). In this example, a storage period is also described. 601 has 60 minutes remaining, and 602 has 120 minutes remaining. This is an example in which a period for storing data is provided in the database 211 of the service apparatus 102.

  There are two possibilities of disconnecting the connection when another apparatus 101 makes a service execution request. One is disconnection unintended by the other device 101 due to a network failure or timeout. In this case, there is a high possibility that another device 101 will retry. However, the other apparatus 101 may intentionally disconnect for some reason. In this case, there is a possibility that it will be executed later, but there is a case where it is not executed. Therefore, there will be a message that will never retry. It is not good to keep messages that are never accessed again in the database, so it is desirable to have a certain retention period.

  This storage period may be freely set by the creator of the service device 102 or may be given as information to a request message from another device 101. The data that has passed this storage period is deleted. However, if a request message is transmitted with the identification ID after being deleted, the service logic is executed if a service message is included as shown in FIG. Will not be a problem. However, as shown in FIG. 5, in the case of a request message with only an identification ID, a fault response message is returned.

  Next, the processing of the service device 102 in this embodiment will be described using the flowchart shown in FIG. The message receiving unit 202 receives the request message 201 sent from the other apparatus 101 (S701). Next, the connection disconnection detection unit 203 always monitors whether the connection is disconnected (S702). When the disconnection is detected, the message receiving unit 202 is immediately notified. The notified information is transmitted to all other processing units.

  Next, the message analysis unit 204 determines whether or not an identification ID is given to the request message 201 (S703). As a result of the determination, if an identification ID is not given to the request message 201 (NO in S703), the service to be called is specified (S704), and the process proceeds to the service logic control unit 205. The service logic control unit 205 executes the service logic 206 based on the service specified by the message analysis unit 204 (S705). When the request message 201 is the request message 301 for calling the above-described getData operation, the service logic 302 is executed.

  If the connection disconnection detection unit 203 does not detect disconnection during execution of the service logic 206 (NO in S706), the message creation unit 207 creates a response message 209 including the service logic result (S707). ). Next, the message transmission unit 208 transmits the created response message 209 to the other apparatus 101 (S708), and the process ends.

  On the other hand, when the connection disconnection detection unit 203 detects the disconnection of the connection (YES in S706), the service logic control unit 205 interrupts the execution of the service logic 206 (S709) and ends this process. There are several possible methods for interrupting this service logic. For example, the service logic is executed separately for each thread, and when an interruption is detected, the thread is stopped. Alternatively, a cancel method is prepared in the service logic and the method is called. The interruption method may be implemented in any way.

  If the message analysis unit 204 determines that the request message is given an identification ID as in the request message 401 described above (YES in S703), the process proceeds to the unsent message management unit 210. The unsent message management unit 210 determines whether a response message corresponding to the identification ID “100020” exists in the database 211 (S710). If it is determined that the request message with the identification ID “100020” is received for the first time, it does not exist in the database 211 (NO in S710). Therefore, the message analysis unit 204 analyzes the message and specifies what service is called (S711). Note that in the case of the request message 401, since service call information is included, it is possible to specify what call is being made (YES in S711). A request message 401 is a request message for calling a getData operation.

  Next, the service logic control unit 205 executes the service logic 206 based on the service specified by the message analysis unit 204 (S712). In this case, the service logic 302 described above is executed. Next, the message creation unit 207 creates a response message 209 including the result of the service logic 206 (S713). Next, if the connection disconnection detection unit 203 has not detected disconnection of the connection (NO in S714), the message transmission unit 208 transmits the created response message 209 to the other device 101 (S715), and this process Exit.

  On the other hand, if the connection disconnection detection unit 203 detects disconnection of the connection during execution of the service logic (YES in S714), the process proceeds to the unsent message management unit 210. The unsent message management unit 210 associates the created response message 303 with the identification ID “100020” in the database 211 and stores it as 601 (S716), and ends this processing.

  If the unsent message management unit 210 determines in S710 described above that a response message corresponding to the identification ID “100020” exists in the database 211, the process proceeds to the message transmission unit 208. Here, the message transmission unit 208 transmits the associated response message to the other device 101 (S717). Then, the information (601) corresponding to the response message whose transmission has been completed is deleted from the database 211 (S718), and this process is terminated.

  In S711 described above, if the message analysis unit 204 analyzes the request message 201 and cannot identify what call, the process proceeds to the message creation unit 207. Specifically, the case where the storage period of the database 211 has expired and the data has been deleted, the case where the identification ID is random, or the case where the response message corresponding to the identification ID does not exist cannot be specified. In these cases, the message creation unit 207 creates a response message including fault information (S719). Specifically, a response message 502 shown in FIG. 5 is created.

  Next, if the connection disconnection detection unit 203 has not detected disconnection of the connection (NO in S720), the message transmission unit 208 transmits the created response message 502 to the other device 101 (S715). Exit. However, if the connection disconnection detection unit 203 detects the disconnection of the connection (YES in S720), the process is terminated as it is. The created fault message is not stored in the database 211.

  Here, a process in which the unsent message management unit 210 of the service apparatus 102 deletes data whose storage period of the database 211 has passed will be described with reference to the flowchart shown in FIG. For example, when the storage period of the database 211 is 0 minutes, the data is deleted from the database 211. In this example, it is assumed that the request message 201 is received from another device 101 as the timing of deletion. In addition, when the request message 201 is received from the other apparatus 101, this process is performed between the processes of S701 and S702 because it is confirmed whether there is data to be deleted.

  First, the message reception unit 202 receives the request message 201 (S701), and the unsent message management unit 210 checks whether there is data in the database 211 whose storage period has passed (S801). If there is no data that has passed the storage period (NO in S801), the process proceeds to the connection disconnection detection unit 203 as it is. On the other hand, if there is data that has passed the storage period, such as when the storage period is 0 minutes remaining (YES in S801), the data is deleted (S802). Then, the processing moves to the connection disconnection detection unit 203.

  Note that the timing of deleting data is not limited to this, and may be other cases. For example, the message transmission unit 208 may delete the response message 209 after transmitting it. Further, instead of the processing timing, the database 211 may always be monitored, and data whose storage period has passed may be immediately detected and deleted.

  As described above, by using this processing in the service device 102, it becomes possible for another device 101 that uses the service to efficiently acquire data. For example, the other device 101 transmits a request message 401 to which the identification ID is assigned to the service device 102. If the service logic 302 executed by the service device 102 is known to be a very heavy process, the other device 101 intentionally disconnects the connection. Then, after a while, the request message 401 is transmitted to the service device 102 again. As a result, in the service device 102, the execution of the service logic 302 has already been completed, and the response message 303 is stored in the database 211. Accordingly, a response message is immediately transmitted to the other device 101.

  In this way, the other apparatus 101 does not need to maintain the connection all the time in order to obtain the response message from the service apparatus 102. While the service apparatus 102 is performing processing, it is possible to perform other processing, and the problem of keeping a connection long and causing a timeout is also solved.

  According to the present embodiment, in the service, the execution of the service logic can be suppressed to the minimum necessary, and the load on the embedded device with a small amount of memory can be reduced.

Claims (5)

A communication device that transmits and receives messages to and from other devices via a network,
Receiving means for receiving a message requesting execution of a service from the other device;
Monitoring means for monitoring whether or not the connection with the other device is disconnected;
Determining means for determining whether or not information for identifying the message is attached to the message;
When the connection with the other device is disconnected while executing the service of the received message, and the determination unit determines that the information is given, the result of executing the service is and storage means for storing together before Kijo report,
If the connection with the other device is disconnected while the service of the received message is being executed, and the determination unit determines that the information is not given, the service of the received message Control means for interrupting the execution of
When the information stored in the storage unit is added to the message received by the reception unit, a transmission unit that transmits the execution result stored together with the information to the other device;
A communication apparatus comprising:   The communication device according to claim 1, wherein the transmission unit deletes the information and the execution result when transmitting the execution result stored together with the information to the other device.   3. The storage unit manages a storage period of an execution result stored together with the information, and deletes the information and the execution result when a specific storage period has passed. Communication equipment. A processing method of a communication device for transmitting / receiving a message to / from another device via a network,
A receiving step for receiving a message requesting execution of a service from the other device;
A monitoring step for monitoring whether or not the connection with the other device is disconnected;
A determining step for determining whether or not information for identifying the message is given to the message;
Even if the connection with the other devices during the service before Symbol received message is disconnected, the determination step by the information if it is determined to have been granted, storage means, those wherein a storing step of storing with prior Kijo report the results of running the service,
When it is determined that the information is not given in the determination step when the connection with the other device is disconnected while executing the service of the received message, the control means receives the received A control process for interrupting the execution of the service of the message,
When the transmission means is provided with the information stored in the storage step to the message received in the reception step, a transmission step of transmitting the execution result stored together with the information to the other device;
A processing method for a communication apparatus, comprising: The program for functioning a computer as each means of the communication apparatus as described in any one of Claims 1 thru | or 3 .

Images