JP6277680B2 - Transfer program, apparatus, and method - Google Patents

Description

  The disclosed technology relates to a transfer program, a transfer device, and a transfer method.

  Conventionally, computer systems that asynchronously transfer messages with high reliability have been proposed. Hereinafter, asynchronous transmission of a message with high reliability is described as “high reliability messaging”. A “message” is a cluster of data having a certain meaning. In reliable messaging, data is transferred in units of messages. “Asynchronous transfer” is a transfer method in which a transmission source and a reception destination do not have to operate simultaneously. The transmission source transmits a message at the convenience (timing) of the transmission source, and the reception destination receives the message at the timing of the reception destination. “Reliable” in reliable messaging is a function that ensures that each message is transferred only once.

  Conventionally, asynchronous transfer has been used in a connection environment between a transmission source and a reception destination. However, in order to improve processing performance and minimize the use of resources, a many-to-many connection environment is used. Has come to be used. Resources are a plurality of transmission queues and a plurality of transmission side transfer devices for transferring messages from a plurality of transmission sources, and a plurality of reception queues and a plurality of reception sides for transferring messages to a plurality of reception destinations. It is a transfer device. It is assumed that each of a plurality of transmission sources and a plurality of reception destinations executes the same processing in a distributed manner. In this case, in reliable messaging in a many-to-many connection environment, messages transmitted from each of a plurality of transmission sources are distributed so that resources are effectively used and transferred to each of a plurality of reception destinations. .

  A plurality of messages may make sense as a group. For example, with the adoption of XML and the enlargement of the message size due to transmission / reception of data other than text such as image data, the message may be divided and transferred in order to avoid a load on the network. In this case, the divided message group is a unit that should be processed as one message. For such a group of messages, in order to perform reliable messaging in a many-to-many connection environment, it is necessary to guarantee the order and the same recipient. The guarantee of order is a function that guarantees that each message included in a group of messages is transferred to the receiving destination while maintaining the order. The guarantee of the same recipient is a function that guarantees that each message included in a group of messages is transferred to the same recipient.

  A technique related to a server queuing system has been proposed for guaranteeing the order and the same receiver when transferring messages. In this technique, a queue server is used for reliable message transfer when one subsystem attempts to perform one or more ordered operations asynchronously. Messages are sent to a queue as a group having one or more messages, and messages within a particular group are processed in a predetermined order. Message groups are also marked as correlated so that all groups within a particular correlation are processed in a predetermined order.

  A method for guaranteeing the order of transmission data in asynchronous communication has been proposed. In this technique, a transmission system and a reception system constitute a business group, and the transmission system transmits a request for issuing a sequence number for each business group to the sequence number management system. The sequence number management system returns the sequence number for the business group to the request source. The transmission system transmits transmission data to which a sequence number issued for each business group is added to the reception system, and the reception system processes the received data in the order of the sequence numbers.

JP 2006-190265 A JP 2003-046510 A

  However, the above-described conventional technology does not assume a complex connection environment of many to many including a plurality of transmission queues, a plurality of transmission devices on the transmission side, a plurality of reception queues, and a plurality of reception devices on the reception side. Therefore, there is a problem in that the ordering and the same receiver may not be guaranteed in the reliable messaging in the many-to-many complicated connection environment.

  An object of the disclosed technique is to guarantee the order and the same receiver when transferring a group of messages even in a complicated connection environment of many-to-many.

The disclosed technique extracts a message from a corresponding transmission queue among a plurality of transmission queues in which messages transferred from each of a plurality of transmission sources are stored. Further, the disclosed technique determines whether or not the extracted message is a guarantee message included in a message group that needs to be transferred to the same recipient while maintaining the order. In the case of guaranteed message is selected from a plurality of receiving transfer section for transferring a message to one of a plurality of recipients, the receiving transfer portion in a state that is not in charge of forwarding assurance message. Alternatively, the receiving side transfer unit that is in charge of transferring the guarantee message included in the same message group as the extracted message is selected. If the extracted message is other than the guarantee message, the receiving side transfer unit that is not in charge of transferring the guarantee message is selected. Further, the disclosed technique transfers a message to the selected receiving side transfer unit.

Further, the disclosed technology accepts a message transferred from each of a plurality of transmission side transfer units. Further, the disclosed technique determines whether or not the received message is a guarantee message included in a message group that needs to be transferred to the same reception destination while maintaining the order. In the case of guaranteed message, from a plurality of receive queues corresponding to each of the plurality of recipients, to select a receive queue state not responsible for storage of assurance message. Or selecting a receive queue state in charge of storing assurance message included in the received message and the same message group. Further, in the disclosed technology, when the received message is other than the guarantee message, the reception queue in a state not in charge of storing the guarantee message is selected. The disclosed technique stores the message in the selected reception queue.

  As one aspect, the disclosed technology has an effect that it is possible to guarantee the order and the same receiver property when transferring a group of messages even in a complicated connection environment of many to many.

It is the schematic which shows an example of the simple connection environment of the transmission source 1 versus the receiving destination 1. FIG. 1 is a schematic diagram illustrating an example of a many-to-many complex connection environment. FIG. 1 is a schematic diagram illustrating an example of a many-to-many complex connection environment. FIG. It is the schematic which shows the concept of SOA. 1 is a schematic diagram illustrating an example of a many-to-many complex connection environment. FIG. 1 is a block diagram showing a schematic configuration of a transfer system 10 according to the present embodiment. It is a figure which shows an example of the data structure of a message. It is a block diagram which shows schematic structure of a transmission side transfer part. It is a figure which shows an example of a transmission management table. It is a block diagram which shows schematic structure of a receiving side transfer part. It is a figure which shows an example of a reception management table. It is a block diagram which shows schematic structure of the computer which functions as a transmission part. It is a block diagram which shows schematic structure of the computer which functions as a receiving part. It is a flowchart which shows an example of a transmission side transfer process. It is a flowchart which shows an example of a receiving side transfer process. It is a flowchart which shows an example of a deletion process. It is the schematic for demonstrating an example of message transfer. It is the schematic for demonstrating an example of message transfer. It is a figure which shows an example of the transmission management table in an example of message transfer. It is a figure which shows an example of the reception management table in an example of message transfer. It is the schematic for demonstrating an example of message transfer. It is a figure which shows an example of the transmission management table in an example of message transfer. It is a figure which shows an example of the reception management table in an example of message transfer. It is the schematic for demonstrating an example of message transfer. It is the schematic for demonstrating an example of message transfer.

  First, the many-to-many complex connection environment that is the premise of the present embodiment will be described. As a comparative example, an example of a simple connection environment between the transmission source 1 and the reception destination 1 will be described. As shown in FIG. 1, in a simple connection environment of a transmission source 1 to a reception destination 1, one transmission queue and one transfer device (transmission side) are provided on the transmission side corresponding to one transmission source. It has been. A reception side connected to the transmission side via a network is provided with one reception queue and one transfer device (reception side) corresponding to one reception destination. In the case of this configuration, messages included in a message group that need to guarantee the order and the same receiver (hereinafter referred to as “guaranteed messages”. In the example of FIG. 1, “1” and “2” circled ”And“ 3 ”) are transferred to the same receiver while maintaining the order.

  However, many-to-many complex connection environments have come to be used in order to improve the processing performance and to make the configuration in which resources are not wasted as much as possible. FIG. 2 shows an example of a many-to-many complex connection environment. In the example of FIG. 2, on the transmission side, two transmission queues (A1, A2) and two transfer devices (A, B) (transmission side) corresponding to three transmission sources (A, B, C). Is provided. The receiving side connected to the transmitting side via the network has four receiving queues (B1, B2, B3, B4) corresponding to the four receiving destinations (A, B, C, D) and Three transfer devices (A, B, C) (receiving side) are provided.

  In this case, when a message is stored in the transmission queue from the transmission source, the transmission queue is selected so that resources can be used efficiently. Similarly, when transferring a message from the transfer device (transmission side) to the transfer device (reception side) and when storing a message from the transfer device (reception side) to the reception queue, resources can be used efficiently. A transfer device (reception side) and a reception queue are selected. As a result, even in the guarantee message group, the order of the guarantee messages may not be maintained and may be transferred to the reception destination or may be transferred to different reception destinations. That is, the order and the same receiver may not be guaranteed.

  For example, in the example of FIG. 2, it is assumed that the messages “C1”, “C2”, and “C3” transmitted from the transmission source C are the guarantee message group. The messages “C1,” “C2,” and “C3” stored in the transmission queue A2 from the transmission source C are sequentially taken out by the transfer apparatus B (transmission side). Then, the transfer device (reception destination) is selected so that the transfer device B can efficiently use the resources, and each message is transferred. As a result, the messages “C1” and “C3” are transferred to the transfer device B (reception side), and the message “C2” is transferred to the transfer device C (reception side). Further, the message “C3” is stored in the reception queue B2 from the transfer device B (reception side), the message “C1” is stored in the reception queue B3 from the transfer device B (reception side), and the message “C2” is The data is stored in the reception queue B4 from the transfer device C (reception side). As a result, the message “C1” is transferred to the receiver C, the message “C2” is transferred to the receiver D, and the message “C3” is transferred to the receiver B. Therefore, the same receiver property cannot be guaranteed for the guarantee message group including the guarantee messages “C1”, “C2”, and “C3”. In addition, the receiving destinations B, C, and D take out messages from the receiving queues corresponding to the receiving destinations at the respective timings, and thus the order is not guaranteed.

  In the example of FIG. 2, it is assumed that the messages “A1” and “A2” transmitted from the transmission source A are guarantee message groups. When this guarantee message group is stored in the transmission queue A1, the message “B4” transmitted from the transmission source B is inserted and transferred to the reception destination A in that state. Since each guarantee message included in the guarantee message group is to be processed in order by the same recipient, even if another message is inserted between guarantee messages in this way, Can not be guaranteed.

  In order to solve the problems in the above-mentioned many-to-many complicated connection environment, as shown in FIG. 3, it is conceivable to create a queue and transfer device dedicated to guarantee messages. In the example of FIG. 3, a route dedicated to the guarantee message A (transmission source A → transmission queue A1 → transfer device A (transmission side) → transfer device A (reception side) → reception queue B1 → reception destination A) is created. .

  However, in this case, it is necessary to reserve extra resources for the dedicated route. In addition, when it is necessary to transfer a guarantee message for a new purpose, a resource for creating a route dedicated to a new guarantee message is required, which results in poor scalability and waste of resources. In the example of FIG. 3, a new route dedicated to the guarantee message D having a different purpose from the guarantee message A (transmission source D → transmission queue A4 → transfer device D (transmission side) → transfer device D (reception side) → reception queue B5 → An example in which the receiver F) is created is shown. The guarantee messages having different purposes include, for example, a message related to a sales slip in a slip management system and a message related to an order slip.

  It is also conceivable to solve the problems in the many-to-many complex connection environment described above by using SOA (Service Oriented Architecture). As shown in FIG. 4, the concept of SOA is that there is an EndPoint on the ESB (Enterprise Service Bus), and each of the transmission source and the reception destination stores and retrieves the message with respect to the EndPoint.

  However, SOA has no concept of transfer in the first place. Also, in order to guarantee the order in the SOA environment, as in the case of FIG. 3, a dedicated EndPoint is created, and the exclusive route is used only by themselves upon agreement between the transmission source and the reception destination. It is necessary to design to.

  Therefore, in this embodiment, as shown in FIG. 5, the guarantee message group (“C1,” “C2,” and “C3” shown by the shaded circles in FIG. 5) is a many-to-many complex connection. Even in the environment, the data is transferred to the receiver so as to guarantee the order and the same receiver.

  Hereinafter, an example of an embodiment according to the disclosed technology will be described in detail with reference to the drawings.

  As illustrated in FIG. 6, the transfer system 10 according to the present embodiment includes a transmission side information processing device 20 and a reception side information processing device 30. Each of the transmission-side information processing device 20 and the reception-side information processing device 30 is, for example, a physical server or a virtual server.

  In the transmission-side information processing device 20, processing by a plurality of transmission-side applications (applications) 221, 222, and 223 is executed. When each of the transmission side applications 221, 222, and 223 is described without distinction, it is expressed as “transmission side application 22n”. The number of transmission side applications 22n is not limited to three, but may be two or four or more. The transmission side application 22n is an example of a transmission source of the disclosed technology. The transmission side information processing apparatus 20 includes a transmission unit 21. The transmission unit 21 is an example of a transfer device according to the disclosed technology. The transmission unit 21 includes transmission queues 231 and 232, transmission side transfer units 241 and 242, a transmission management table 25, and a transmission side deletion unit 26. When each of the transmission queues 231 and 232 is described without distinction, it is expressed as “transmission queue 23n”. In addition, when each of the transmission side transfer units 241 and 242 is described without distinction, it is expressed as “transmission side transfer unit 24n”. The numbers of transmission queues 23n and transmission side transfer units 24n are not limited to two, but may be three or more.

  In the reception side information processing apparatus 30, processing by a plurality of reception side applications 321, 322, and 323 is executed. When each of the reception-side applications 321, 322, and 323 is described without distinction, it is expressed as “reception-side application 32n”. The number of receiving-side applications 32n is not limited to three and may be two or four or more. Note that the receiving-side application 32n is an example of a recipient of the disclosed technology. The reception side information processing apparatus 30 includes a reception unit 31. The receiving unit 31 is an example of a transfer device according to the disclosed technology. The reception unit 31 includes reception queues 331, 332, 333, reception side transfer units 341, 342, 343, a reception management table 35, and a reception side deletion unit 36. When each of the reception queues 331, 332, and 333 is described without distinction, it is expressed as “reception queue 33n”. In addition, when each of the reception side transfer units 341, 342, and 343 is described without distinction, it is expressed as “reception side transfer unit 34n”. The number of reception queues 33n and reception side transfer units 34n is not limited to three, but may be two or four or more.

  The transmission-side application 22n selects the transmission queue 231 or the transmission queue 232 and stores a message so that resources can be effectively used. For example, the transmission queue 23n with the smaller data amount is selected and the message is stored. Further, the transmission side application 22n assigns a guarantee message ID indicating that the guarantee message included in the guarantee message group is a guarantee message. As the guarantee message ID, a different value is assigned to each guarantee message group for identifying the guarantee message group. Further, the transmission side application 22n gives a final flag indicating whether or not each guarantee message is the final guarantee message in the guarantee message group.

  FIG. 7 shows an example of the message 12 transmitted from the transmission application. The message 12 includes an area 121 where a guarantee ID is stored, an area 122 where a final flag is stored, and an area 123 where data indicating the content of the message is stored. In the case of a message that is not a guarantee message, the area 121 in which the guarantee ID is stored is blank. In the case of the last guarantee message of the guarantee message group, a final flag indicating that it is the final message is set in the area 122 where the final flag is stored, and if it is not the final message, the final flag is not set. .

  The transmission-side application 22n stores the guarantee messages to which the same guarantee ID is assigned in the transmission queue 231 or the transmission queue 232 while maintaining the order.

  The transmission queue 23n is a queue that stores messages transmitted from the transmission-side application 22n in the order of transmission. The transmission queue 23n is provided corresponding to each of the transmission side transfer units 24n.

  As shown in FIG. 8, the transmission side transfer unit 24n includes an extraction unit 24nA, a transmission side selection unit 24nB, and a transfer unit 24nC.

  The extraction unit 24nA sequentially extracts messages stored in the transmission queue 23n corresponding to the transmission side transfer unit 24n.

  The transmission side selection unit 24nB refers to the transmission management table 25 and selects the reception side transfer unit 34n that transfers the extracted message. The transmission side selection unit 24nB holds information on the reception side transfer unit 34n existing in the reception unit 31. Here, the transmission side selection unit 24nB holds information that the reception side transfer units 341, 342, and 343 exist as the reception side transfer unit 34n.

  Further, as shown in FIG. 9, the transmission management table 25 stores information on the guarantee message that is in charge of transfer by the receiving side transfer unit 34n. In the example of FIG. 9, the transmission management table 25 stores information on the guarantee ID, the receiving transfer unit name, the update time, and the entry deletion time. The transmission management table 25 can be, for example, a hash table in which entries having respective values of the receiving transfer unit name, the update time, and the entry deletion time are stored using the guarantee ID as a key.

  The “update time” stores the time when the entry is added to the transmission management table 25 or the last time when the receiving side transfer unit 34n is selected. The “entry deletion time” stores a value for automatically deleting an entry after a predetermined time has elapsed in order to prevent the entry from remaining without being deleted. The predetermined time can be defined by the user. The predetermined time may be a fixed time, or a different time may be determined for each type and purpose of the guarantee message. For example, in the case of a guarantee message group in which a large message is divided, each message included in the group of messages is transferred without a gap, so a relatively short time (for example, 5 minutes) is required. The entry deletion time can be set in advance. Further, for example, when a message group related to processing for a predetermined period (for example, one hour) of the same type of slip processing in the slip management system is to be set as a guarantee message group, the predetermined period (for example, one hour) ) Can be defined as the entry deletion time.

  The transmission management table 25 is a table commonly referred to by the transmission side selection units 241B and 242B of the transmission side transfer units 241 and 242.

  The transmission side selection unit 24nB determines whether or not the message extracted by the extraction unit 24nA is a guarantee message to which a guarantee ID is assigned. In the case of a guarantee message, the transmission management table 25 is referred to, and the receiving side transfer unit 34n that is responsible for transferring the guarantee message included in the same guarantee message group as the message extracted by the extraction unit 24nA is selected. . If there is no receiving side transfer unit 34n that is in charge of transferring the same guarantee message group, the receiving side transfer unit 34n that is not in charge of transferring the guarantee message is selected. More specifically, when the message extracted by the extraction unit 24nA is a guarantee message, the transmission side selection unit 24nB searches the transmission management table 25 for an entry using the guarantee ID assigned to the guarantee message as a key. . If there is no corresponding entry, the receiving side transfer unit 34n having no entry in the transmission management table 25 is selected from the receiving side transfer units 34n existing in the receiving unit 31. If the corresponding entry exists, the receiving side transfer unit 34n indicated by the “receiving side transfer unit name” of the entry is selected.

  In addition, when the message extracted by the extraction unit 24nA is other than the guarantee message, the transmission side selection unit 24nB selects the reception side transfer unit 34n that is not responsible for the transfer of the guarantee message. More specifically, the transmission side selection unit 24nB selects a reception side transfer unit 34n that does not have an entry in the transmission management table 25 among the reception side transfer units 34n that exist in the reception unit 31.

  Further, the transmission side selection unit 24nB deletes the corresponding entry from the transmission management table 25 when the message extracted by the extraction unit 24nA is a guarantee message and the final guarantee message in the guarantee message group. The corresponding entry is deleted after selecting the receiving side transfer unit 34n that is the transfer destination of the corresponding message.

  The transfer unit 24nC transfers the message extracted by the extraction unit 24nA to the reception side transfer unit 34n selected by the transmission side selection unit 24nB.

  For each entry stored in the transmission management table 25, the transmission side deletion unit 26 deletes the corresponding entry when the difference between the current time and the update time exceeds the entry deletion time.

  As shown in FIG. 10, the reception side transfer unit 34n includes a reception unit 34nA, a reception side selection unit 34nB, and a storage unit 34nC.

  The accepting unit 34nA accepts a message transferred from each of the transmission side transfer units 24n.

  The reception side selection unit 34nB refers to the reception management table 35 and selects the reception queue 33n that stores the received message. The reception-side selection unit 34nB holds information on the reception queue 33n existing in the reception unit 31. Here, the reception-side selection unit 34nB holds information that the reception queues 331, 332, and 333 exist as the reception queue 33n.

  Further, as shown in FIG. 11, the reception management table 35 stores information on guarantee messages that are stored in the reception queue 33n. In the example of FIG. 11, the reception management table 35 stores guarantee ID, reception queue name, update time, and entry deletion time information. Since the reception management table 35 is the same as the transmission management table 25 shown in FIG. 9 except that the “reception side transfer unit name” is “reception queue name”, detailed description thereof is omitted. The reception management table 35 is a table that is commonly referred to by the reception side selection units 341B, 342B, and 343B of the reception side transfer units 341, 342, and 343.

  The specific processing for selecting the reception queue 33n by the reception side selection unit 34nB is the same as the processing for selecting the reception side transfer unit 34n by the transmission side selection unit 24nB of the transmission side transfer unit 24n. Omitted.

  The storage unit 34nC stores the message received by the reception unit 34nA in the reception queue 33n selected by the reception side selection unit 34nB.

  For each entry stored in the reception management table 35, the reception side deletion unit 36 deletes the corresponding entry when the difference between the current time and the update time exceeds the entry deletion time.

  The reception queue 33n is provided corresponding to each of the reception side applications 32n.

  The reception-side application 32n sequentially takes out the messages stored in the reception queue 33n corresponding to each at each timing.

  The transmission unit 21 can be realized by, for example, the computer 40 shown in FIG. The computer 40 includes a CPU 42, a memory 44, a nonvolatile storage unit 46, an input / output interface (I / F) 47, and a network I / F 48. The CPU 42, the memory 44, the storage unit 46, the input / output I / F 47, and the network I / F 48 are connected to each other via a bus 49.

  The storage unit 46 can be realized by an HDD (Hard Disk Drive), a flash memory, or the like. A storage unit 46 as a storage medium stores a transmission program 50 for causing the computer 40 to function as the transmission unit 21. The storage unit 46 includes a transmission queue area 53 and a transmission management table storage area 55. The CPU 42 reads out the transmission program 50 from the storage unit 46 and expands it in the memory 44, and sequentially executes processes included in the transmission program 50.

  The transmission program 50 includes an extraction process 54nA, a transmission side selection process 54nB, a transmission side transfer process 54n including a transfer process 54nC, and a transmission side deletion process 56. The same number of transmission side transfer processes 54n as the number of transmission side transfer units 24n to be created are included. The CPU 42 operates as the extraction unit 24nA illustrated in FIG. 8 by executing the extraction process 54nA. Further, the CPU 42 operates as the transmission side selection unit 24nB illustrated in FIG. 8 by executing the transmission side selection process 54nB. Further, the CPU 42 operates as the transfer unit 24nC illustrated in FIG. 8 by executing the transfer process 54nC. Further, the CPU 42 operates as the transmission side deletion unit 26 illustrated in FIG. 6 by executing the transmission side deletion process 56.

  When the transmission unit 21 is realized by the computer 40, the transmission queue area 53 is used as the transmission queue 23n illustrated in FIG. The transmission management table storage area 55 is used as a storage area for storing the transmission management table 25 shown in FIG. As a result, the computer 40 that has executed the transmission program 50 functions as the transmission unit 21.

  The receiving unit 31 can also be realized by the computer 40 shown in FIG. When the reception unit 31 is realized by the computer 40, the storage unit 46 stores a reception program 60 for causing the computer 40 to function as the reception unit 31. The storage unit 46 includes a reception queue area 63 and a reception management table storage area 65. The CPU 42 reads the reception program 60 from the storage unit 46 and expands it in the memory 44, and sequentially executes the processes included in the reception program 60.

  The reception program 60 includes a reception process 64nA, a reception side selection process 64nB, a reception side transfer process 64n including a storage process 64nC, and a reception side deletion process 66. The same number of reception side transfer processes 64n as the number of reception side transfer units 34n to be created are included. The CPU 42 operates as the reception unit 34nA illustrated in FIG. 10 by executing the reception process 64nA. Further, the CPU 42 operates as the reception side selection unit 34nB illustrated in FIG. 10 by executing the reception side selection process 64nB. Further, the CPU 42 operates as the storage unit 34nC illustrated in FIG. 10 by executing the storage process 64nC. Further, the CPU 42 operates as the reception side deletion unit 36 illustrated in FIG. 6 by executing the reception side deletion process 66.

  When the reception unit 31 is realized by the computer 40, the reception queue area 63 is used as the reception queue 33n illustrated in FIG. The reception management table storage area 65 is used as a storage area for storing the reception management table 35 shown in FIG. As a result, the computer 40 that has executed the reception program 60 functions as the reception unit 31.

  The transmission unit 21 and the reception unit 31 can be realized by, for example, a semiconductor integrated circuit, more specifically, an ASIC (Application Specific Integrated Circuit).

  Next, the operation of the transfer system 10 according to the present embodiment will be described. A message transmitted from each of the transmission side applications 22n is stored in each of the transmission queues 23n. And each of the transmission side transfer parts 24n of the transmission part 21 performs the transmission side transfer process shown in FIG. Here, the message transmitted from the transmission side application 22n includes a guarantee message and a message other than the guarantee message. Then, when a message is transferred from each of the transmission side transfer units 24n to the reception side information processing device 30, each of the reception side transfer units 34n of the reception unit 31 executes a reception side transfer process illustrated in FIG. Further, in parallel with the transmission side transfer process and the reception side transfer process, each of the transmission side deletion unit 26 and the reception side deletion unit 36 executes the deletion process shown in FIG. Hereinafter, each process is explained in full detail.

  First, transmission side transfer processing will be described. In step S11 of the transmission side transfer process shown in FIG. 14, the extraction unit 24nA extracts one message stored in the transmission queue 23n corresponding to the transmission side transfer unit 24n from the head of the transmission queue 23n.

  Next, in step S12, the transmission side selection unit 24nB determines whether or not the message extracted in step S11 is a guarantee message with a guarantee ID. This determination can be made based on, for example, information stored in the area 121 of the message 12 shown in FIG. If it is a guarantee message to which a guarantee ID is assigned, the process proceeds to step S13. If it is not a guarantee message, the process proceeds to step S20.

  In step S13, the transmission side selection unit 24nB searches the transmission management table 25 for an entry using the guarantee ID given to the guarantee message extracted in step S11 as a key. If there is an entry corresponding to the guarantee ID, the process proceeds to step S16. If there is no corresponding entry, the process proceeds to step S14.

  In step S14, the transmission side selection unit 24nB refers to the transmission management table 25 and selects the reception side transfer unit 34n that is not in charge of transfer of the guarantee message. Specifically, the transmission side selection unit 24nB selects a reception side transfer unit 34n that does not have an entry in the transmission management table 25 among the reception side transfer units 34n that exist in the reception unit 31.

  Next, in step S15, the transmission side selection unit 24nB adds a new entry with the guarantee ID assigned to the guarantee message extracted in step S11 as a key, and proceeds to step S21. The new entry stores information on the receiving side transfer unit name indicating the receiving side transfer unit 34n selected in step S14, the time when the new entry was added (update time), and the entry deletion time. As the entry deletion time, a predetermined fixed time may be stored, or the purpose and type of the message is determined from the data stored in the message area 123, and a predetermined time is determined according to the purpose and type of the message. It may be stored.

  On the other hand, in step S16, the transmission side selection unit 24nB selects the reception side transfer unit 34n that is responsible for transferring the guarantee message included in the same guarantee message group as the message extracted in step S11. Specifically, the transmission side selection unit 24nB selects the reception side transfer unit 34n indicated by the “reception side transfer unit name” of the entry searched in step S13.

  Next, in step S17, the transmission side selection unit 24nB updates the “update time” of the entry corresponding to the selected reception side transfer unit 34n to the time when the reception side transfer unit 34n is selected.

  Next, in step S18, the transmission side selection unit 24nB determines whether or not the message extracted in step S11 is the final guarantee message in the guarantee message group. This determination can be made based on the final flag stored in the area 122 of the message 12 shown in FIG. In the case of the final message, the process proceeds to step S19, and the transmission side selection unit 24nB deletes the corresponding entry from the transmission management table 25, and proceeds to step S21. If it is not the final message, step S19 is skipped and the process proceeds to step S21.

  On the other hand, when the process proceeds to step S20, that is, when the message extracted in step S11 is not a guarantee message, the transmission side selection unit 24nB refers to the transmission management table 25 and is responsible for forwarding the guarantee message. A non-reception side transfer unit 34n is selected. Specifically, the transmission-side selection unit 24nB selects a reception-side transfer unit 34n that does not have an entry in the transmission management table 25 among the reception-side transfer units 34n that exist in the reception unit 31, and proceeds to step S21. .

  In step S21, the transfer unit 24nC transfers the message extracted in step S11 to the reception side transfer unit 34n selected in step S14, S16, or S20, and ends the transmission side transfer process.

  Next, the reception side transfer process will be described. Note that detailed description of the same processing as the transmission-side transfer processing is omitted.

  In step S31 of the reception side transfer process shown in FIG. 15, the reception unit 34nA receives the message transferred from each of the transmission side transfer units 24n.

  Next, in step S33, the receiving side selection unit 34nB determines whether or not the message accepted in step S31 is a guarantee message with a guarantee ID. If it is a guarantee message assigned with a guarantee ID, the process proceeds to step S33, and if it is not a guarantee message, the process proceeds to step S40.

  In step S33, the receiving side selection unit 34nB searches the reception management table 35 for an entry using the guarantee ID given to the guarantee message accepted in step S31 as a key. When there is an entry corresponding to the guarantee ID, the process proceeds to step S36, and when there is no corresponding entry, the process proceeds to step S34.

  In step S34, the reception side selection unit 34nB refers to the reception management table 35 and selects the reception queue 33n that is not in charge of storing the guarantee message. Next, in step S35, the receiving side selector 34nB adds a new entry with the guarantee ID given to the guarantee message extracted in step S11 as a key, and proceeds to step S41.

  On the other hand, in step S36, the receiving side selection unit 34nB selects the reception queue 33n that is responsible for storing guarantee messages included in the same guarantee message group as the message accepted in step S31. Next, in step S37, the receiving side selector 34nB updates the “update time” of the entry corresponding to the selected reception queue 33n to the time when the reception queue 33n is selected.

  Next, in step S38, the receiving side selector 34nB determines whether or not the message accepted in step S31 is the final guarantee message in the guarantee message group. In the case of the final message, the process proceeds to step S39, where the receiving side selection unit 34nB deletes the corresponding entry from the reception management table 35, and proceeds to step S41. If it is not the final message, step S39 is skipped and the process proceeds to step S41.

  On the other hand, when the process proceeds to step S40, that is, when the message accepted in step S31 is not a guarantee message, the receiving side selection unit 34nB is in charge of storing the guarantee message with reference to the reception management table 35. A non-reception queue 33n is selected. Then, the process proceeds to step S41.

  In step S41, the storage unit 34nC stores the message received in step S31 in the reception queue 33n selected in step S34, S36, or S40, and ends the reception side transfer process.

  Next, the deletion process will be described. The deletion process executed by the transmission side deletion unit 26 and the deletion process executed by the reception side deletion unit 36 differ only in the transmission management table 25 and the reception management table 35. A deletion process executed by the transmission side deletion unit 26 will be described.

  In step S51 of the deletion process shown in FIG. 16, the transmission side deletion unit 26 sets 0 to the variable i. Next, in step S52, the transmission side deletion unit 26 increments the variable i by 1.

  Next, in step S53, the transmission side deletion unit 26 acquires the update time and the entry deletion time from the i-th entry of the transmission management table 25.

  Next, in step S54, the transmission side deletion unit 26 determines whether or not the difference between the current time and the update time exceeds the entry deletion time. If the entry deletion time is exceeded, the process proceeds to step S55, where the transmission side deletion unit 26 deletes the i-th entry from the transmission management table 25, and the process proceeds to step S56. On the other hand, if the difference between the current time and the update time does not exceed the entry deletion time, step S55 is skipped and the process proceeds to step S56.

  In step S56, the transmission side deletion unit 26 determines whether or not the processing in steps S53 to S55 has been completed for all entries registered in the transmission management table 25. If there is an unprocessed entry, the process returns to step S52. When the process is completed for all entries, the deletion process is terminated.

  A message transfer process in the transfer system 10 according to the present embodiment will be described with a more specific example.

  First, at the start of processing, it is assumed that no entry is stored in the transmission management table 25 and the reception management table 35 as shown in FIGS. As shown in FIG. 17, a guarantee message group (guarantee ID = “X”) including guarantee messages “X1”, “X2”, and “X3” is stored in the transmission queue 231 from the transmission-side application 221. The Further, a guarantee message group (guarantee ID = “Y”) including the guarantee message “Y 1” is stored in the transmission queue 232 from the transmission-side application 222. Further, the message “1” other than the guarantee message is stored in the transmission queue 232 from the transmission side application 223.

  As illustrated in FIG. 18, the extraction unit 241A of the transmission side transfer unit 241 extracts the message “X1” from the transmission queue 231. At this stage, no entry is stored in the transmission management table 25. That is, among the receiving side transfer units 34n existing in the receiving unit 31, there is no receiving side transfer unit 34n that is responsible for transferring the guarantee message. Therefore, the transmission side selection unit 241B selects a reception side transfer unit 34n that can efficiently use resources from the reception side transfer units 341, 342, and 343. Here, it is assumed that the transmission side selection unit 241B has selected the reception side transfer unit 342 (reception side transfer unit name = reception side transfer unit 2). Then, the transmission side selection unit 241B adds a new entry with the guarantee ID “X” to the transmission management table 25 as illustrated in FIG.

  When the guarantee message “X1” is transferred to the reception-side transfer unit 342, the reception unit 342A receives the guarantee message “X1”. At this stage, no entry is stored in the reception management table 35. That is, among the reception queues 33n existing in the reception unit 31, there is no reception queue 33n that is responsible for storing the guarantee message. Therefore, the reception-side selection unit 342B selects a reception queue 33n that can efficiently use resources from the reception queues 331, 332, and 333. Here, it is assumed that the reception-side selection unit 342B has selected the reception queue 331 (reception queue name = reception queue 1). Then, the reception-side selection unit 342B adds a new entry with the guarantee ID “X” to the reception management table 35 as illustrated in FIG. The message stored in the reception queue 331 is taken out by the reception side application 321.

  Next, as illustrated in FIG. 21, the extraction unit 241A of the transmission-side transfer unit 241 extracts the guarantee message “X2” from the transmission queue 231. The transmission side selection unit 241B searches the transmission management table 25 for the guarantee ID “X” of the guarantee message “X2”. Here, as shown in FIG. 19, since there is an entry corresponding to the guarantee ID “X”, the reception-side transfer unit indicated by the reception-side transfer unit name “reception-side transfer unit 2” corresponding to the guarantee ID “X”. 342 is selected. The transmission side selection unit 241B updates the “update date / time” of the entry corresponding to the guarantee ID “X” in the transmission management table 25.

  Further, the extraction unit 242A of the transmission side transfer unit 242 extracts the guarantee message “Y1” from the transmission queue 232. At this stage, the transmission management table 25 stores an entry of the receiving side transfer unit name “receiving side transfer unit 2” using the guarantee ID “X” as a key. Therefore, the transmission-side selection unit 242B selects the reception-side transfer unit 34n that can efficiently use resources from the reception-side transfer units 341 and 343 as the reception-side transfer unit 34n that is not in charge of the guarantee message transfer. . Here, it is assumed that the transmission side selection unit 242B has selected the reception side transfer unit 343 (reception side transfer unit name = reception side transfer unit 3). Then, the transmission side selection unit 242B adds a new entry with the guarantee ID “Y” to the transmission management table 25 as illustrated in FIG.

  When the guarantee message “X2” is transferred to the reception side transfer unit 342, the reception unit 342A receives the guarantee message “X2”, and the reception side selection unit 342B sets the reception queue 331 that is the same as the storage destination of the guarantee message “X1”. select. The reception side selection unit 342B updates the “update date / time” of the entry corresponding to the guarantee ID “X” in the reception management table 35.

  In addition, when the guarantee message “Y1” is transferred to the reception-side transfer unit 343, the reception unit 343A receives the guarantee message “Y1”. At this stage, the reception management table 35 stores an entry for the reception queue name “reception queue 1” with the guarantee ID “X” as a key. Accordingly, the reception-side selection unit 343B selects a reception queue 33n that can efficiently use resources from the reception queues 332 and 333 as the reception queue 33n that is not in charge of storing the guarantee message. Here, it is assumed that the reception-side selection unit 343B has selected the reception queue 333 (reception queue name = reception queue 3). Then, the reception-side selection unit 343B adds a new entry with the guarantee ID “Y” to the reception management table 35 as illustrated in FIG. The message stored in the reception queue 333 is extracted by the reception side application 323.

  Next, as illustrated in FIG. 24, the extraction unit 241A of the transmission-side transfer unit 241 extracts the guarantee message “X3” from the transmission queue 231, and the transmission-side selection unit 241B receives the reception in the same manner as the guarantee message “X2”. The side transfer unit 342 is selected. The transmission side selection unit 241B updates the “update date / time” of the entry corresponding to the guarantee ID “X” in the transmission management table 25.

  Further, the extraction unit 242 A of the transmission side transfer unit 242 extracts the message “1” from the transmission queue 232. At this stage, the transmission management table 25 includes an entry for the receiving side transfer unit name “receiving side transfer unit 2” with the guarantee ID “X” as a key, and a receiving side transfer unit name with the guarantee ID “Y” as a key. An entry of “receiving side transfer unit 3” is stored. Therefore, the transmission side selection unit 242B selects the reception side transfer unit 341 that is not in charge of transferring the guarantee message. Since the message “1” is not a guarantee message, the transmission management table 25 is not updated.

  When the guarantee message “X3” is transferred to the reception side transfer unit 342, the reception unit 342A receives the guarantee message “X2”, and the reception side selection unit 342B selects the reception queue 331 in the same manner as the guarantee message “X2”. To do. The reception side selection unit 342B updates the “update date / time” of the entry corresponding to the guarantee ID “X” in the reception management table 35.

  When the message “1” is transferred to the receiving side transfer unit 341, the reception unit 341A receives the message “1”. At this stage, the reception management table 35 has an entry for the reception queue name “reception queue 1” with the guarantee ID “X” as a key, and an entry for the reception queue name “reception queue 3” with the guarantee ID “Y” as a key. Is stored. Therefore, the reception side selection unit 341B selects a reception queue 332 that is not in charge of storing messages. Since the message “1” is not a guarantee message, the reception management table 35 is not updated. The message stored in the reception queue 332 is taken out by the reception side application 322.

  As a result, as shown in FIG. 25, the guarantee message group including the guarantee messages “X1”, “X2”, and “X3” is transferred to the receiving-side application 321 while maintaining the order. In addition, the guarantee message “Y1” included in another guarantee message group and the message “1” other than the guarantee message do not intervene.

As described above, according to the transfer system according to the present embodiment, when the transmission side transfer unit transfers the guarantee message, it is responsible for transferring the guarantee message from the reception unit side transfer unit existing in the reception unit. Select a non-recipient forwarding unit to forward the guarantee message. Further, when storing the guarantee message in the reception queue, the reception side transfer unit selects a reception queue that is not in charge of storing the guarantee message from the reception queues existing in the reception unit, and stores the guarantee message. As a result, even in a many-to-many complex connection environment, it is possible to guarantee the order and the same receiver when transferring a group of messages.

  In addition, even when a guarantee message and a message other than a guarantee message are mixed, it is possible to efficiently use resources and transfer a message that guarantees the order and the same recipient if necessary. .

  In addition, it is necessary to design a transfer route that prescribes one-to-one transmission-side application and reception-side application, such as a mechanism that guarantees the order and the same receiver in the communication of the application layer and the OS layer. Absent. Further, there is no need for processing such as controlling transmission to a specific destination or reassembling messages from the same source on the receiving side. For this reason, the cost for creating a special process is unnecessary, and the order and the same receiver can be ensured without the application being aware of it.

  Functions expected of middleware that is an application execution platform include expansion and degeneration of application execution multiplicity. In the present embodiment, even if the application execution multiplicity is freely changed, it is not necessary to allocate dedicated resources or communication lines to the added applications in order to guarantee the order and the same reception destination. Can be used effectively.

  Regarding the above embodiment, the following additional notes are disclosed.

(Appendix 1)
On the computer,
Among a plurality of transmission queues storing messages transferred from each of a plurality of transmission sources, a message is extracted from a corresponding transmission queue,
If the retrieved message is a guarantee message included in a message group that needs to be transferred to the same recipient while maintaining the order, multiple recipients that forward the message to one of multiple recipients From the forwarding part, select the receiving side forwarding part that is not responsible for forwarding the guarantee message or the receiving side forwarding part that is responsible for forwarding the guarantee message included in the same message group as the retrieved message. However, if the message is not a guarantee message, a transfer program for executing a process including selecting a receiving-side transfer unit that is not responsible for transferring the guarantee message and transferring the message to the selected receiving-side transfer unit.

(Appendix 2)
In the computer,
A plurality of processes including retrieving the message, selecting the receiving-side transfer unit, and transferring the message;
When selecting the receiving-side transfer unit, the information on the receiving-side transfer unit selected as the transfer destination of the guarantee message is registered in a transmission management table that is commonly referred to in a plurality of processes for selecting the receiving-side transfer unit. The transfer program according to appendix 1, for executing a process including:

(Appendix 3)
When the transfer of all the guarantee messages included in the message group is completed, the information on the receiving side transfer unit that was responsible for transferring the guarantee message included in the message group is deleted from the transmission management table. The transfer program according to supplementary note 2 for executing a process including:

(Appendix 4)
In the computer,
When selecting the receiving side transfer unit, in the transmission management table, register information on the update time to be updated every time the receiving side transfer unit is selected,
Deleting from the transmission management table information on the receiving side transfer unit that has not been selected for a predetermined time or more in the process of selecting the receiving side transfer unit based on the update time information registered in the transmission management table. The transfer program according to supplementary note 2 or supplementary note 3 for executing processing including:

(Appendix 5)
The transfer program according to any one of Supplementary Note 1 to Supplementary Note 4, wherein a message group including a plurality of guarantee messages is stored in the same transmission queue while maintaining the order by the transmission source.

(Appendix 6)
On the computer,
Accepts a message transferred from each of a plurality of transmission side transfer units,
If the received message is a guaranteed message included in a message group that needs to be transferred to the same recipient while maintaining the order, the guarantee is received from a plurality of reception queues corresponding to each of the plurality of recipients. If a receive queue that is not responsible for storing messages or a receive queue that is responsible for storing guaranteed messages in the same message group as the accepted messages is selected, and the received message is not a guaranteed message , Select a receive queue that is not responsible for storing warranty messages,
A transfer program for executing processing including storing messages in a selected receive queue.

(Appendix 7)
In the computer,
Receiving a plurality of processes including receiving the message, selecting the reception queue, and storing the message;
When selecting the reception queue, execute processing including registering information of the reception queue selected as the storage destination of the guarantee message in a reception management table that is commonly referred to by a plurality of processes for selecting the reception queue The transfer program according to appendix 6 for causing

(Appendix 8)
When the storage of all guarantee messages included in the message group is completed in the computer, information on the reception queue that was responsible for storing the guarantee message included in the message group is deleted from the reception management table. The transfer program according to appendix 7, for executing processing including:

(Appendix 9)
In the computer,
When selecting the reception queue, in the reception management table, register information on the update time to be updated every time the reception queue is selected,
A process that includes deleting information from the reception management table that has not been selected for a predetermined time or more in the process of selecting the reception queue based on the update time information registered in the reception management table. The transfer program according to appendix 7 or appendix 8 for execution.

(Appendix 10)
An extraction unit that extracts a message from a corresponding transmission queue among a plurality of transmission queues in which messages transferred from each of a plurality of transmission sources are stored;
When the message extracted by the extraction unit is a guarantee message included in a message group that needs to be transferred to the same recipient while maintaining the order, the message is transferred to one of a plurality of recipients. Receiving side transfer unit that is not in charge of guarantee message transfer from a plurality of receiving side transfer units, or reception that is in charge of transfer of guarantee messages included in the same message group as the message extracted by the extraction unit Selecting a side transfer unit, and if the message taken out by the extraction unit is other than a guarantee message, a transmission side selection unit that selects a reception side transfer unit that is not responsible for transfer of the guarantee message;
A transfer unit for transferring a message to the reception side transfer unit selected by the transmission side selection unit;
Transfer device including.

(Appendix 11)
A plurality of transmission side transfer units including the extraction unit, the transmission side selection unit, and the transfer unit;
Each of the transmission side selection units of the plurality of transmission side transfer units shares information of the reception side transfer unit selected as the transfer destination of the guarantee message with each of the transmission side selection units of the plurality of transmission side transfer units. The transfer device according to appendix 10, wherein the transfer device is registered in a transmission management table to be referred to.

(Appendix 12)
Each of the transmission side selection units of the plurality of transmission side transfer units, when the transfer of all the guarantee messages included in the message group is completed, the reception side that was in charge of transferring the guarantee message included in the message group The transfer device according to appendix 11, wherein information of the transfer unit is deleted from the transmission management table.

(Appendix 13)
Each of the transmission side selection units of the plurality of transmission side transfer units registers, in the transmission management table, information on an update time to be updated every time the reception side transfer unit is selected,
Based on the update time information registered in the transmission management table, information on the reception side transfer unit that has not been selected for a predetermined time or more by each transmission side selection unit of the plurality of transmission side transfer units is transmitted to the transmission management unit. 14. The transfer device according to supplementary note 12 or supplementary note 13, including a transmission side deletion unit for deletion from the table.

(Appendix 14)
The transfer device according to any one of Supplementary Note 10 to Supplementary Note 13, wherein a message group including a plurality of guarantee messages is stored in the same transmission queue while maintaining the order by the transmission source.

(Appendix 15)
A reception unit that receives a message transferred from each of a plurality of transmission side transfer units;
If the message received by the receiving unit is a guarantee message included in a message group that needs to be transferred to the same receiver while maintaining the order, a plurality of messages corresponding to each of the plurality of receivers From the reception queue, select a reception queue that is not in charge of storing a guarantee message or a reception queue that is in charge of storing a guarantee message included in the same message group as the message received by the reception unit. If the message received by the part is other than the guarantee message, a receiving side selection part that selects a reception queue that is not responsible for storing the guarantee message;
A storage unit for storing a message in the reception queue selected by the reception side selection unit;
Including transfer device.

(Appendix 16)
A plurality of reception side transfer units including the reception unit, the reception side selection unit, and the storage unit;
Each of the reception side selection units of the plurality of reception side transfer units refers to information of the reception queue selected as the storage destination of the guarantee message in common by each reception side selection unit of the plurality of reception side transfer units. The transfer device according to attachment 15, wherein the transfer device is registered in the reception management table.

(Appendix 17)
Each of the reception side selection units of the plurality of reception side transfer units receives a reception queue that is in charge of storing a guarantee message included in the message group when storage of all the guarantee messages included in the message group is completed. The transfer device according to appendix 16, wherein the information is deleted from the reception management table.

(Appendix 18)
Each reception side selection unit of the plurality of reception side transfer units registers, in the reception management table, information on an update time to be updated every time the reception queue is selected,
Based on the update time information registered in the reception management table, information on reception queues that have not been selected for a predetermined time or more by each reception side selection unit of the plurality of reception side transfer units from the reception management table. 18. The transfer device according to supplementary note 16 or supplementary note 17, including a reception side deletion unit to be deleted.

(Appendix 19)
On the computer,
Among a plurality of transmission queues storing messages transferred from each of a plurality of transmission sources, a message is extracted from a corresponding transmission queue,
If the retrieved message is a guarantee message included in a message group that needs to be transferred to the same recipient while maintaining the order, multiple recipients that forward the message to one of multiple recipients From the forwarding part, select the receiving side forwarding part that is not responsible for forwarding the guarantee message or the receiving side forwarding part that is responsible for forwarding the guarantee message included in the same message group as the retrieved message. However, if the message is not a guarantee message, a transfer method that executes a process including selecting a receiving-side transfer unit that is not responsible for transferring the guarantee message and transferring the message to the selected receiving-side transfer unit.

(Appendix 20)
In the computer,
A plurality of processes including retrieving the message, selecting the receiving-side transfer unit, and transferring the message;
When selecting the receiving-side transfer unit, the information on the receiving-side transfer unit selected as the transfer destination of the guarantee message is registered in a transmission management table that is commonly referred to in a plurality of processes for selecting the receiving-side transfer unit. The transfer method according to appendix 19, wherein a process including:
(Appendix 21)
When the transfer of all the guarantee messages included in the message group is completed, the information on the receiving side transfer unit that was responsible for transferring the guarantee message included in the message group is deleted from the transmission management table. The transfer method according to appendix 20, wherein a process including performing the process is executed.

(Appendix 22)
In the computer,
When selecting the receiving side transfer unit, in the transmission management table, register information on the update time to be updated every time the receiving side transfer unit is selected,
Deleting from the transmission management table information on the receiving side transfer unit that has not been selected for a predetermined time or more in the process of selecting the receiving side transfer unit based on the update time information registered in the transmission management table. The transfer method according to appendix 2 or appendix 21, wherein a process including

(Appendix 23)
The transfer method according to any one of Supplementary Note 19 to Supplementary Note 22, wherein a message group including a plurality of guarantee messages is stored in the same transmission queue while maintaining the order by the transmission source.

(Appendix 24)
On the computer,
Accepts a message transferred from each of a plurality of transmission side transfer units,
If the received message is a guaranteed message included in a message group that needs to be transferred to the same recipient while maintaining the order, the guarantee is received from a plurality of reception queues corresponding to each of the plurality of recipients. If a receive queue that is not responsible for storing messages or a receive queue that is responsible for storing guaranteed messages in the same message group as the accepted messages is selected, and the received message is not a guaranteed message , Select a receive queue that is not responsible for storing warranty messages,
A transfer method that performs processing including storing a message in a selected receive queue.

(Appendix 25)
In the computer,
Receiving a plurality of processes including receiving the message, selecting the reception queue, and storing the message;
When selecting the reception queue, execute processing including registering information of the reception queue selected as the storage destination of the guarantee message in a reception management table that is commonly referred to by a plurality of processes for selecting the reception queue The transfer method according to appendix 24.

(Appendix 26)
When the storage of all guarantee messages included in the message group is completed in the computer, information on the reception queue that was responsible for storing the guarantee message included in the message group is deleted from the reception management table. The transfer method according to appendix 25, wherein a process including:

(Appendix 27)
In the computer,
When selecting the reception queue, in the reception management table, register information on the update time to be updated every time the reception queue is selected,
A process that includes deleting information from the reception management table that has not been selected for a predetermined time or more in the process of selecting the reception queue based on the update time information registered in the reception management table. The transfer method according to supplementary note 25 or supplementary note 26 to be executed.

(Appendix 28)
An extraction unit that extracts a message from a corresponding transmission queue among a plurality of transmission queues in which messages transferred from each of a plurality of transmission sources are stored;
When the message extracted by the extraction unit is a guarantee message included in a message group that needs to be transferred to the same recipient while maintaining the order, the message is transferred to one of a plurality of recipients. Receiving side transfer unit that is not in charge of guarantee message transfer from a plurality of receiving side transfer units, or reception that is in charge of transfer of guarantee messages included in the same message group as the message extracted by the extraction unit Selecting a side transfer unit, and if the message taken out by the extraction unit is other than a guarantee message, a transmission side selection unit that selects a reception side transfer unit that is not responsible for transfer of the guarantee message;
A transmission unit that includes a transfer unit that transfers a message to the reception-side transfer unit selected by the transmission-side selection unit; and
A reception unit for receiving a message transferred from the transmission device on the transmission side;
When the message accepted by the accepting unit is a guarantee message, it is accepted from a plurality of reception queues corresponding to each of a plurality of recipients by a reception queue that is not responsible for storing guarantee messages or by the accepting unit. Select the reception queue that is in charge of storing guarantee messages included in the same message group as the received message, and if the message received by the reception unit is other than the guarantee message, take charge of storing the guarantee message A receiving side selector that selects a receiving queue that is not
A storage unit that stores a message in the reception queue selected by the reception side selection unit;
Including transfer system.

(Appendix 29)
The transmission side transfer device includes a plurality of transmission side transfer units including the extraction unit, the transmission side selection unit, and the transfer unit,
Each of the transmission side selection units of the plurality of transmission side transfer units shares information of the reception side transfer unit selected as the transfer destination of the guarantee message with each of the transmission side selection units of the plurality of transmission side transfer units. Registered in the transmission management table to be referenced,
The reception side transfer device includes a plurality of reception side transfer units including the reception unit, the reception side selection unit, and the storage unit,
Each of the reception side selection units of the plurality of reception side transfer units refers to information of the reception queue selected as the storage destination of the guarantee message in common by each reception side selection unit of the plurality of reception side transfer units. The transfer system according to attachment 28, which is registered in the reception management table.

(Appendix 30)
Each of the transmission side selection units of the plurality of transmission side transfer units, when the transfer of all the guarantee messages included in the message group is completed, the reception side that was in charge of transferring the guarantee message included in the message group Delete the transfer unit information from the transmission management table,
Each of the reception side selection units of the plurality of reception side transfer units receives a reception queue that is in charge of storing a guarantee message included in the message group when storage of all the guarantee messages included in the message group is completed. The transfer system according to appendix 29, wherein the information is deleted from the reception management table.

(Appendix 31)
Each of the transmission side selection units of the plurality of transmission side transfer units registers, in the transmission management table, information on an update time to be updated every time the reception side transfer unit is selected,
The transmission device on the transmission side has not been selected by the transmission side selection unit of each of the plurality of transmission side transfer units for a predetermined time or more based on the update time information registered in the transmission management table. Including a transmission side deletion unit that deletes the information from the transmission management table,
Each reception side selection unit of the plurality of reception side transfer units registers, in the reception management table, information on an update time to be updated every time the reception queue is selected,
The reception-side transfer device is configured to receive information on a reception queue that has not been selected for a predetermined time or more by each reception-side selection unit of the plurality of reception-side transfer units based on the update time information registered in the reception management table. 32. The transfer system according to Supplementary Note 29 or Supplementary Note 30, further comprising: a reception side deletion unit that deletes from the reception management table.

(Appendix 32)
32. The transfer system according to any one of supplementary notes 28 to 31, wherein a message group including a plurality of guarantee messages is stored in the same transmission queue while maintaining the order by the transmission source.

DESCRIPTION OF SYMBOLS 10 Transfer system 20 Transmission side information processing apparatus 21 Transmission part 22n Transmission side application 23n Transmission queue 24n Transmission side transfer part 24nA Extraction part 24nB Transmission side selection part 24nC Transfer part 25 Transmission management table 26 Transmission side deletion part 30 Reception side information processing apparatus 31 reception unit 32n reception side application 33n reception queue 34n reception side transfer unit 34nA reception unit 34nB reception side selection unit 34nC storage unit 35 reception management table 36 reception side deletion unit

Claims (12)

On the computer,
Among a plurality of transmission queues storing messages transferred from each of a plurality of transmission sources, a message is extracted from a corresponding transmission queue,
If the retrieved message is a guarantee message included in a message group that needs to be transferred to the same recipient while maintaining the order, multiple recipients that forward the message to one of multiple recipients from the transfer unit, and selects the reception side transfer portion in a state in charge of forwarding assurance message included in the receiving transfer unit or retrieved message and the same message groups, the state in which no charge transport guarantees message , retrieved messages, in other cases assurance message to execute processing includes forwarding the message to the selected selected receiving side transfer unit to receiving transfer portion in a state that is not in charge of forwarding assurance message Transfer program for. In the computer,
A plurality of processes including retrieving the message, selecting the receiving-side transfer unit, and transferring the message;
When selecting the receiving-side transfer unit, the information on the receiving-side transfer unit selected as the transfer destination of the guarantee message is registered in a transmission management table that is commonly referred to in a plurality of processes for selecting the receiving-side transfer unit. The transfer program according to claim 1, for executing a process including:   When the transfer of all the guarantee messages included in the message group is completed, the information on the receiving side transfer unit that was responsible for transferring the guarantee message included in the message group is deleted from the transmission management table. The transfer program according to claim 2, for executing a process including: In the computer,
When selecting the receiving side transfer unit, in the transmission management table, register information on the update time to be updated every time the receiving side transfer unit is selected,
Deleting from the transmission management table information on the receiving side transfer unit that has not been selected for a predetermined time or more in the process of selecting the receiving side transfer unit based on the update time information registered in the transmission management table. The transfer program according to claim 2 or 3 for executing a process including: On the computer,
Accepts a message transferred from each of a plurality of transmission side transfer units,
If the received message is a guaranteed message included in a message group that needs to be transferred to the same recipient while maintaining the order, the guarantee is received from a plurality of reception queues corresponding to each of the plurality of recipients. Select a receive queue that is not responsible for storing messages, or a receive queue that is responsible for storing guaranteed messages in the same message group as the accepted messages, and the accepted messages are not guaranteed messages. , Select a receive queue that is not in charge of storing warranty messages,
A transfer program for executing processing including storing messages in a selected receive queue. In the computer,
Receiving a plurality of processes including receiving the message, selecting the reception queue, and storing the message;
When selecting the reception queue, execute processing including registering information of the reception queue selected as the storage destination of the guarantee message in a reception management table that is commonly referred to by a plurality of processes for selecting the reception queue The transfer program according to claim 5, for making it happen.   When the storage of all guarantee messages included in the message group is completed in the computer, information on the reception queue that was responsible for storing the guarantee message included in the message group is deleted from the reception management table. The transfer program according to claim 6, for executing processing including: In the computer,
When selecting the reception queue, in the reception management table, register information on the update time to be updated every time the reception queue is selected,
A process that includes deleting information from the reception management table that has not been selected for a predetermined time or more in the process of selecting the reception queue based on the update time information registered in the reception management table. 8. The transfer program according to claim 6 or 7 for execution. An extraction unit that extracts a message from a corresponding transmission queue among a plurality of transmission queues in which messages transferred from each of a plurality of transmission sources are stored;
When the message extracted by the extraction unit is a guarantee message included in a message group that needs to be transferred to the same recipient while maintaining the order, the message is transferred to one of a plurality of recipients. In charge of transfer of guarantee messages included in the same message group as the reception side transfer part that is not in charge of transfer of guarantee messages from the plurality of reception side transfer parts to be performed select receiving transfer portion where there, the message extracted by the extraction unit, in other cases guaranteed message sender selection for selecting a receiving transfer portion in a state that is not in charge of forwarding assurance message And
A transfer unit for transferring a message to the reception side transfer unit selected by the transmission side selection unit;
Including transfer device. A reception unit that receives a message transferred from each of a plurality of transmission side transfer units;
If the message received by the receiving unit is a guarantee message included in a message group that needs to be transferred to the same receiver while maintaining the order, a plurality of messages corresponding to each of the plurality of receivers selected from the receive queue, receive queue state in which no charge storage guarantees message, or the receive queue state in which the are responsible for storing assurance message included in the same group of messages and message received by the receiving unit and, a message received by the receiving unit, in the case of non-guaranteed message, a reception-side selection unit for selecting a receive queue state in which no charge storage assurance message,
A storage unit for storing a message in the reception queue selected by the reception side selection unit;
Including transfer device. On the computer,
Among a plurality of transmission queues storing messages transferred from each of a plurality of transmission sources, a message is extracted from a corresponding transmission queue,
If the retrieved message is a guarantee message included in a message group that needs to be transferred to the same recipient while maintaining the order, multiple recipients that forward the message to one of multiple recipients from the transfer unit, and selects the reception side transfer portion in a state in charge of forwarding assurance message included in the receiving transfer unit or retrieved message and the same message groups, the state in which no charge transport guarantees message , retrieved messages, in other cases assurance message to execute processing includes forwarding the message to the selected selected receiving side transfer unit to receiving transfer portion in a state that is not in charge of forwarding assurance message Transfer method. On the computer,
Accepts a message transferred from each of a plurality of transmission side transfer units,
If the received message is a guaranteed message included in a message group that needs to be transferred to the same recipient while maintaining the order, the guarantee is received from a plurality of reception queues corresponding to each of the plurality of recipients. Select a receive queue that is not responsible for storing messages, or a receive queue that is responsible for storing guaranteed messages in the same message group as the accepted messages, and the accepted messages are not guaranteed messages. , Select a receive queue that is not in charge of storing warranty messages,
A transfer method that performs processing including storing a message in a selected receive queue.