JP2008131577A - Telegraphic message transmission/reception system, telegraphic message transmission/reception method, telegraphic message transmitter, telegraphic message receiver and program - Google Patents

Abstract

<P>PROBLEM TO BE SOLVED: To provide a telegraphic message transmission/reception system capable of recovering a telegraphic message with excellent transmission efficiency. <P>SOLUTION: A telegraphic message transmitting section 101 of a telegraphic message transmitter 100 transmits a telegraphic message after giving a serial number thereto. A retransmission request receiving section 102 of the telegraphic message transmitter 100 receives a retransmission request and instructs the telegraphic message transmitting section 101 to stop transmitting a new telegraphic message, A retransmission section 103 of the telegraphic message transmitter 100 sequentially transmits telegraphic messages after a serial number included in the retransmission request. A telegraphic message receiving section 201 of a telegraphic message receiver 200 judges whether the serial number added to the received telegraphic message and a serial number of the last received telegraphic message are continued and if it is judged that they are not continued, even when a telegraphic message of a serial number other than the next serial number is received, it is discarded until a telegraphic message of a serial number next to the serial number of the last received telegraphic message is received. If the serial numbers are not continued as a result of the judgment made by the telegraphic message receiving section 201, a retransmission request section 202 of the telegraphic message receiver 200 transmits a retransmission request including the serial number next to the serial number of the last received telegraphic message. <P>COPYRIGHT: (C)2008,JPO&INPIT

Description

  The present invention relates to a message transmission / reception system, a message transmission / reception method, a message transmission device, a message reception device, and a program, and in particular, a message transmission / reception system, a message transmission / reception method, a message transmission device, a message reception device, and a message transmission / reception asynchronously. Regarding the program.

In a conventional message transmission / reception system that transmits / receives a message asynchronously, a message with a serial number is transmitted on the transmission side. Here, the message is information transmitted and received between devices connected via a communication path. Asynchronous transmission / reception of electronic messages refers to transmission / reception of electronic messages in which the receiving side does not return a response indicating that the electronic message has been received. Note that the reception response returned by the lower layer protocol for sending and receiving this message is not included in the response that the message is received, so a reception response such as TCP / IP is used as the lower layer protocol. Even if a return protocol is used, it is called a message transmission / reception system that transmits and receives messages asynchronously.
In this conventional message transmission / reception system, when a message cannot be received normally on the receiving side for some reason, such as a buffer overflow in the internal processing on the sending side or the receiving side, or a communication path error, this message Is performed by the GAP / FILL method that requests the transmission side to retransmit the message of the serial number that the receiving side has lost when the receiving side detects the missing serial number (for example, non-patent) Reference 1).

  For example, as shown in FIG. 9, it is assumed that the receiving side receives a message of serial number m transmitted by the transmitting side (S1000), and then cannot receive the messages of serial number m + 1 and serial number m + 2 for some reason (S1001). , S1002). At this time, when the receiving side receives the message with the next serial number m + 3 (S1003), it detects the jump of the serial number from the serial number m to the serial number m + 3, and retransmits the message with the serial numbers m + 1 and m + 2 between them. A request is made to the side (S1004). In response to this request, the transmission side retransmits the telegrams of serial numbers m + 1 and m + 2 (S1005, S1006). In addition, the transmission side adds the serial number m + 4 that is the serial number next to the serial number m + 3 added before the retransmission to the next message and transmits it (S1007). The receiving side receives the messages of the serial numbers m + 1, m + 2, and m + 4.

As described above, when the receiving side detects the skip of the serial number, it designates the missing serial number range and requests retransmission, and the transmitting side retransmits the telegram in response to this request. As a result, a message that has not been transmitted to the receiving side for some reason can be transmitted to the receiving side.
“FIX 4.4 Specification”, [online], 2003.04.30, FIX (Financial Information eXchange) Protocol Limited, [2006.1037 search], Internet <URL: http://www.fixprotocol.org/specifications/fix4.4spec>

  However, in the conventional message transmission / reception system, for example, as shown in sequence S1008 and subsequent steps in FIG. 9, the reception side cannot receive the message with the serial number m + 5 (S1008), and the transmission side receives the message with the serial number m + 6 and the serial number m + 7. When the message is continuously transmitted (S1009, S1010), the receiving side requests the retransmission of the message with the serial number m + 5 to each of the message with the serial number m + 6 and the message with the serial number m + 7 (S1011, S1011). S1012). The transmitting side performs retransmission of the serial number m + 5 in response to each of these requests, that is, double (S1013, S1014). Since the receiving side has received the message of sequence number m + 5 in sequence S1013, the message of sequence number m + 5 received in sequence S1014 is unnecessary and is discarded. As described above, in the conventional message transmission / reception system, when recovering a message that could not be communicated, unnecessary retransmission request or re-transmission message transmission / reception may occur, and transmission efficiency deteriorates. There's a problem.

  The present invention has been made in view of such circumstances, and an object thereof is to provide a message transmission / reception system capable of recovering a message that could not be communicated with excellent transmission efficiency.

  This invention was made in order to solve the above-mentioned subject, and the message transmission / reception system of the present invention is a message transmission / reception system comprising a message transmission device for transmitting a message and a message reception device for receiving the message. The message transmission device transmits a message with a serial number, and transmits a message to the message transmission unit for storing the message in a transmission message storage unit, and receives a retransmission request, and transmits a new message to the message transmission unit. Re-transmission request receiving means for instructing to cancel the re-transmission means, and re-transmission means for sequentially reading out and transmitting a message after the serial number requested by the retransmission request received by the retransmission request receiving means from the transmission message storage means, The message receiving device receives the transmitted message, determines whether the serial number assigned to the message and the sequence number of the previously received message are consecutive, and determines that they are not consecutive. A message receiving means for discarding a message with a sequence number other than the next sequence number until receiving a message with a sequence number next to the sequence number of the previously received message, and the message reception unit If it is determined that the message is not continuous in the determination, a retransmission request means for transmitting a retransmission request for requesting a message having a sequence number next to the sequence number of the previously received message is provided.

  Thereby, since the message transmission / reception system recovers a message that could not be communicated without transmitting / receiving an unnecessary message, the message transmission / reception system can be recovered with excellent transmission efficiency.

  The message transmission / reception system according to the present invention is the message transmission / reception system described above, wherein the retransmission request means transmits the sequence number requested by the retransmission request even after a predetermined time has elapsed since the retransmission request was transmitted. When the message receiving unit does not receive the attached message, the retransmission request is transmitted again.

  As a result, the message transmission / reception system allows the message reception device to receive without transmitting / receiving unnecessary messages even if the message transmission device cannot receive a retransmission request related to the message that the message reception device could not receive. Can be recovered.

  Moreover, the message transmission / reception system of the present invention is the message transmission / reception system described above, wherein the message reception device includes received sequence number transmission means for transmitting information indicating the sequence number of the received message by the message reception unit, The electronic message transmitting device includes a received serial number receiving unit that receives information indicating the received serial number and deletes the electronic message before the serial number from the transmitted message storage unit.

  Thereby, the message | telegram transmission / reception system can suppress the memory capacity which the message | telegram memory | storage means in a message | telegram transmission apparatus requires.

  Moreover, the message transmission / reception system of the present invention is any one of the message transmission / reception systems described above, and at the start of a session, the message transmission device and the message reception device each have a serial number managed by each as an initial value. Features.

  As a result, the message transmission / reception system starts the session regardless of the serial number management state before the session start of the message transmission device and the message reception device, so that the serial number managed by each becomes the initial value. It can be performed.

  The message transmission / reception method of the present invention is a message transmission / reception method in a message transmission / reception system comprising a message transmission side for transmitting a message and a message reception side for receiving the message, wherein the message transmission side assigns a serial number to the message. And transmitting the message in the transmission message storage means, and the message receiving side receives the transmitted message, the serial number assigned to the message, and the last received message It is determined whether or not the serial number is continuous. When it is determined that the serial number is not continuous, until the message of the serial number next to the serial number of the previously received message is received, the serial number other than the next serial number is received. The second process of discarding even if a message with a serial number is received, and when the message receiver determines that it is not continuous in the determination in the second process, it is next to the serial number of the previously received message Re-requesting the serial number message A third process of transmitting a request, and the message transmitting device receives the transmitted retransmission request, sequentially reads and transmits a message after the serial number requested by the retransmission request from the transmission message storage unit, and And a fourth process of canceling a new message transmission during this transmission.

  Further, the message transmission device of the present invention transmits a message with a serial number, and transmits a message transmission means for storing the message in a transmission message storage means, a retransmission request, and the message transmission means A retransmission request receiving means for instructing to cancel a new message transmission; and a retransmission means for sequentially reading out and transmitting a message after a serial number requested by the retransmission request received by the retransmission request receiving means from the transmission message storage means; It is characterized by providing.

  In addition, the program of the present invention transmits a computer with a serial number attached to a message, receives a message transmission means for storing the message in a transmission message storage means, a retransmission request, and sends the message to the message transmission means. Retransmission request receiving means for instructing to cancel a new message transmission, functioning as a retransmission means for sequentially reading out and transmitting messages after the serial number requested by the retransmission request received by the retransmission request receiving means from the transmission message storage means Let

  In addition, the message receiving device of the present invention receives a message, determines whether the serial number assigned to the message and the sequence number of the previously received message are consecutive, and determines that they are not consecutive A message receiving means for discarding a message having a sequence number other than the next sequence number until reception of a message having a sequence number next to the sequence number of the previously received message, and determination by the message reception unit When it is determined that the message is not continuous, a retransmission request means for transmitting a retransmission request for requesting a message having a sequence number next to the sequence number of the previously received message is provided.

  Further, the program of the present invention receives a message, determines whether the serial number assigned to the message and the serial number of the previously received message are consecutive, and determines that they are not consecutive. When receiving a message with a sequence number next to the sequence number of the previously received message, even if a message with a sequence number other than the next sequence number is received, the message reception unit, the determination of the message reception unit When it is determined that the message is not continuous, the request is made to function as a retransmission request means for transmitting a retransmission request for requesting a message having a sequence number next to the sequence number of the previously received message.

  According to the present invention, since a message that could not be communicated is recovered without transmitting / receiving unnecessary messages, the message can be recovered with excellent transmission efficiency.

  Embodiments of the present invention will be described below with reference to the drawings. FIG. 1 is a diagram for explaining the outline of serial number management of a message transmission / reception system according to an embodiment of the present invention. In the message transmission / reception system of the present embodiment, the message transmission device 100 that transmits a message stores the transmitted message sequence number, and the message reception device 200 that receives the message stores the message sequence number of the message to be received next. is doing. For example, it is assumed that a message sequence number “N-1” is stored in the message transmission device 100 and an expected sequence number “N” is stored in the message reception device 200. When the message transmission device 100 updates the stored message sequence number and transmits the message with the sequence number “N” (Sa1), the message reception device 200 stores the stored expected sequence number “N” of the received message. After confirming that the message sequence number “N” matches, the expected sequence number is updated to “N + 1”. Next, when the message transmission device 100 updates the stored message sequence number and transmits the message with the sequence number “N + 1” (Sa2), the message reception device 200 receives the stored expected sequence number “N + 1”. It is confirmed that the message sequence number “N + 1” of the received message matches, and the expected sequence number is updated to “N + 2”. Hereinafter, the same thing is repeated.

  As described above, in the message transmission / reception system of this embodiment, the message transmission device 100 and the message reception device 200 each store a serial number, and transmit / receive a message while updating the serial number. According to the present invention, in such a message transmission / reception system, a message does not reach the message reception device 200 for some reason, such as a processing error such as a buffer overflow in the internal processing of the message transmission device 100 or the message reception device 200 or a communication path error. The present invention relates to recovery processing when a message dropout is detected in the message reception device 200.

  FIG. 2 is a schematic block diagram showing the configuration of the telegram transmission / reception system in the present embodiment. The message transmission device 100 and the message reception device 200 are connected so as to be capable of bidirectional communication via a communication path 300 such as a LAN (Local Area Network) or a WAN (Wide Area Network). The message transmission device 100 includes a message transmission unit (message transmission unit) 101, a retransmission request reception unit (retransmission request reception unit) 102, a retransmission unit (retransmission unit) 103, a message sequence number storage unit (message sequence number storage unit) 104, A transmission message storage unit (transmission message storage unit) 105 and a received serial number reception unit (received serial number reception unit) 106 are provided.

  The message transmission unit 101 adds “1” to the sequence number stored in the message sequence number storage unit 104, adds the sequence number to the message, and transmits the message in the transmission message storage unit 105. The retransmission request receiving unit 102 receives the received message (retransmission request) from the message receiving device 200 and instructs the retransmission unit 103 to retransmit the message after the serial number specified in the received message. In addition, the retransmission request receiving unit 102 instructs the message transmission unit 101 to cancel the new message transmission while the retransmission unit 103 is retransmitting. The retransmitting unit 103 sequentially reads and transmits the messages after the serial number designated by the retransmission request receiving unit 102 from the transmission message storage unit 105. The received serial number receiving unit 106 receives the serial number received by the electronic message receiving device 200 from the electronic message receiving device 200, and deletes the electronic message before the serial number from the transmitted message storage unit 105. The transmitted message storage unit 105 stores the message transmitted by the message transmission unit 101. The message sequence number storage unit 104 stores the sequence number of the latest message transmitted by the message transmission unit 101.

  The message receiving device 200 includes a message receiving unit 201, a retransmission request unit 202, an expected sequence number storage unit 203, and a received sequence number transmission unit 204. The message receiving unit 201 receives a message from the message transmission device 100, compares the received message sequence number with the sequence number stored in the expected sequence number storage unit 203, and receives the sequence number of the currently received message and the previous reception. It is determined whether or not the serial number of the received message is continuous. If the two serial numbers match as a result of the comparison, the electronic message receiving unit 201 determines that the serial number is normal and adds “1” to the serial number stored in the expected serial number storage unit 203. As a result of the comparison by the message receiving unit 201, the retransmission request unit 202 recognizes that a missing message has been detected when these two numbers do not match (that is, when it is determined that they are not consecutive). A retransmission request for requesting a telegram message stored in the serial number storage unit 203 is transmitted. The retransmission request unit 202 transmits a retransmission request again when the message reception unit 201 does not receive the message with the serial number requested by the retransmission request even after a predetermined time has elapsed since the retransmission request was transmitted. . The received serial number transmission unit 204 transmits received serial number information representing a serial number that is one smaller than the serial number stored in the expected serial number storage unit 203, which corresponds to the serial number of the message that has already been received by the message receiving device 200. The expected serial number storage unit 203 stores a serial number that is one greater than the received electronic message. That is, the sequence number stored in the expected sequence number storage unit 203 coincides with the sequence number of the message when the next message is normally received.

  FIG. 3 is a table for explaining the items in the header part of the message according to the present embodiment. The electronic message is composed of the header part and a data part that is a part following the header part and stores information to be transmitted by electronic message. As shown in FIG. 3, the message header part of this embodiment sets the message length that sets the message length that does not include its own item length, the message type that sets the message type, and the length of the data part. Edit data length to be set, the number of edit data to set the number of data stored in the data portion, the serial number set by the message transmission unit 101, the transmission source transmission date to set the occurrence date of the message, and the occurrence time of the message And a send flag set when the message is a re-transmission message for recovery.

  Next, the operation of this message transmission / reception system will be described. FIG. 4 is a sequence diagram illustrating an operation example when a sequence number is lost in a message received by the message reception device 200 due to a temporary abnormality in the communication path 300 in the message transmission / reception system according to the present embodiment. In the state before the sequence shown in FIG. 4 starts, the sequence number stored in the message sequence number storage unit 104 is “n−1”, and the sequence number stored in the expected sequence number storage unit 203 is “n”. First, the message transmission unit 101 of the message transmission device 100 reads out a sequence number “n−1” from the message sequence number storage unit 104 and transmits a message with a sequence number “n” obtained by adding 1 to this (Sb1). ), The message is stored in the transmitted message storage unit 105, and the sequence number stored in the message sequence number storage unit 104 is updated to this sequence number “n.” The message reception unit 201 of the message reception device 200 receives this message. The message sequence number “n” is compared with the sequence number “n” read from the expected sequence number storage unit 203. Here, since the two sequence numbers match, the message reception unit 201 is stored in the expected sequence number storage unit 203. Add 1 to the serial number , To update the serial number "n + 1".

  Next, in the same manner, the message transmission unit 101 reads out the sequence number “n” from the message sequence number storage unit 104 and transmits a message with the sequence number “n + 1” obtained by adding 1 to this (Sb2). Is stored in the transmission message storage unit 105, and the sequence number “n” stored in the message sequence number storage unit 104 is updated to this sequence number “n + 1.” The message reception unit 201 of the message reception device 200 receives this message, The message sequence number “n + 1” is compared with the sequence number “n + 1” read from the expected sequence number storage unit 203. Here, since the two sequence numbers match, the message reception unit 201 is stored in the expected sequence number storage unit 203. 1 is added to the serial number, and the serial number is updated to “n + 2”. Further, the message transmission unit 101 reads the sequence number “n + 1” from the message sequence number storage unit 104, transmits a message with the sequence number “n + 2” obtained by adding 1 to this (Sb3), and transmits the message to the transmission message storage unit. 105, and the sequence number “n + 1” stored in the message sequence number storage unit 104 is updated to this sequence number “n + 2” However, this message did not reach the message reception device 200 due to an abnormality in the communication path 300 or the like. Similarly, for the next message, the message transmission unit 101 reads out the sequence number “n + 2” from the message sequence number storage unit 104 and transmits a message with the sequence number “n + 3” obtained by adding 1 to this. (Sb4), the message is stored in the transmission message storage unit 105, and the sequence number “n + 2” stored in the message sequence number storage unit 104 is updated to this sequence number “n + 3”. You can have, due to the communication path abnormality, it is assumed that not reach message receiving apparatus 200.

  Next, the message transmission unit 101 reads the sequence number “n + 3” from the message sequence number storage unit 104, transmits a message with the sequence number “n + 4” obtained by adding 1 to this (Sb5), and stores the message as a transmission message storage. The sequence number “n + 3” stored in the unit 105 and stored in the message sequence number storage unit 104 is updated to this sequence number “n + 4.” The message reception unit 201 of the message receiver 200 receives this message, and receives the message sequence number “ n + 4] and the serial number stored in the sequence Sb2, and the serial number “n + 2” read from the expected serial number storage unit 203 is compared. Here, since these two serial numbers do not match, the message receiving unit 201 retransmits The request unit 202 is notified of the serial number mismatch (Sb6), and the serial number read from the expected serial number storage unit 203, that is, until the message of the serial number “n + 2” is received thereafter. Serial number telegram of other than the "n + 2" sets itself to discard. When receiving the serial number mismatch, the retransmission request unit 202 transmits a send request storing information requesting retransmission of the message after the serial number “n + 2” read from the expected serial number storage unit 203 (Sb7). When receiving the send request, the retransmission request receiving unit 102 of the message transmitting apparatus 100 instructs the message transmitting unit 101 to stop the new message transmission (Sb8).

  Next, the retransmission request receiving unit 102 instructs the retransmission unit 103 to perform retransmission after the serial number “n + 2” requested by the send request (Sb9). The re-transmission unit 103 transmits all the messages stored in the transmission message storage unit 105 after the sequence number “n + 2” instructed by the retransmission from the transmission message storage unit 105, that is, messages from the sequence number “n + 2” to the sequence number “n + 4”. Are sequentially read, and a send flag in the header portion is set and transmitted (Sb10 to Sb12). The message receiving unit 201 of the message receiving apparatus 200 receives these messages, and each time the message receiving unit 201 receives these messages, the message numbers “n + 2”, “n + 3”, “n + 4” and the sequence numbers read from the expected sequence number storage unit 203 are displayed. Compare. Since these comparison results all match, the message receiving unit 201 updates the sequence number stored in the expected sequence number storage unit 203 to a value obtained by adding 1 each time they match. Here, since the sequence Sb10 to Sb12 is received three times, when receiving the message of the sequence number “n + 4” of the sequence Sb12, the message receiver 201 receives the sequence number “0” stored in the expected sequence number storage unit 203. n + 5 ". In sequence Sb12, retransmission unit 103 reads and transmits the message with serial number “n + 4”, that is, the latest message stored in transmission message storage unit 105, and the transmission instructed in sequence Sb8. The message transmission unit 101 is instructed to cancel the cancellation (Sb13).

  The message transmission unit 101 that has received the cancellation of the transmission reads out the sequence number “n + 4” stored at the time of the message transmission of the sequence Sb5 from the message sequence number storage unit 104, and adds the sequence number “n + 5” to which 1 is added. The telegram receiving unit 201 receives the telegram of the serial number “n + 5”, reads out the serial number “n + 5” stored at the time of reception of the sequence Sb12 from the expected serial number storage unit 203, and transmits these telegrams (Sb14). Compare Since these sequence numbers match, the message receiving unit 201 updates the expected sequence number storage unit 203 to the sequence number “n + 6” obtained by adding 1 to the sequence number stored in the expected sequence number storage unit 203.

  As described above, when the message receiving unit 201 that has received the message having the sequence number “n + 4” in the sequence Sb5 detects the discontinuity of the sequence number, that is, it is stored in the sequence number and the expected sequence number storage unit 203 of the received message. When the serial numbers do not match, the message receiving unit 201 discards the messages of other serial numbers until receiving the messages of the serial numbers stored in the expected serial number storage unit 203, In addition, the retransmission request unit 202 transmits a send message for requesting a sequence number message to be received next. Further, in the message transmitting apparatus 100 that has received the received request message, the retransmission unit 103 sequentially reads and transmits the messages after the serial number requested by the received message from the transmitted message storage unit 105, and the retransmission request receiving unit 102. However, it is a simple process of instructing the message transmission unit 101 to cancel the new message transmission during the transmission, and the message received by the message reception device 200 for some reason is changed to an unnecessary message. Recovery can be performed without transmission / reception.

  FIG. 5 shows an operation example when the telegram transmitting apparatus 100 cannot receive the sent message transmitted by the telegram receiving apparatus 200 when the missing serial number occurs as shown in FIG. 4 in the telegram transmitting / receiving system according to the present embodiment. It is a sequence diagram. In the state before the sequence shown in FIG. 5 starts, the sequence number stored in the message sequence number storage unit 104 is “n−1” and the sequence number stored in the expected sequence number storage unit 203 is the same as in FIG. It is assumed that “n”. Since the sequence Sc1 to Sc7 is the same as the sequence Sb1 to Sb7 in FIG.4, the description is omitted.However, in this operation example, the retransmission request unit 202 transmits in the sequence Sc7. It is assumed that the resend message cannot be received by the retransmission request receiving unit 102 of the message transmitting apparatus 100 due to an abnormality in the communication path 300. Although not described in the description of FIG. In addition to transmitting a telegram, a timer provided in the telegram receiving apparatus 200 is configured to start after a predetermined time has elapsed and send a resend telegram again. A constant.

  Thereafter, the message transmission unit 101 of the message transmission device 100 reads the sequence number from the message sequence number storage unit 104 and transmits a message with a sequence number obtained by adding 1 to the sequence number. In this operation example, the message transmission unit 101 repeats the transmission of this message four times and transmits messages of serial numbers “n + 5” to “n + 8” (Sc8 to Sc9). As a result, the message sequence number storage unit 104 The serial number “n + 8” is stored. The message receiving unit 201 that has received the messages (sequence Sc8 to Sc9) from the sequence numbers “n + 5” to “n + 8” until the message of the sequence number “n + 2” is received in the sequence Sc6. Since it has set itself to be discarded, the messages of the serial numbers “n + 5” to “n + 8” are discarded. When the above-mentioned predetermined time elapses after retransmission request section 202 transmits the send message in sequence Sc7, retransmission request section 202 detects that the time has elapsed with reference to the timer, and proceeds to sequence Sc7. The transmitted send message (the send message requesting the message with the serial number “n + 2”) is sent again (Sc10).

  When receiving the send request, the retransmission request receiving unit 102 of the message transmitting apparatus 100 instructs the message transmitting unit 101 to stop the new message transmission (Sc11). Next, the retransmission request receiving unit 102 instructs the retransmitting unit 103 to retransmit the message after the serial number “n + 2” requested by the send request (Sc12). The retransmitting unit 103 receives messages stored in the transmitted message storage unit 105 after the sequence number “n + 2” instructed to be retransmitted from the transmitted message storage unit 105, that is, messages from the sequence number “n + 2” to the sequence number “n + 8”. Read sequentially, set a send flag in the header, and transmit (Sc13 to Sc15). The message receiving unit 201 of the message receiving device 200 receives these messages, and reads out the sequence numbers “n + 2”, “n + 3”,... “N + 8” of each message from the expected sequence number storage unit 203 each time they are received. Compare the serial number. Since these comparison results all match, the message receiving unit 201 updates the sequence number stored in the expected sequence number storage unit 203 to the sequence number obtained by adding 1 to this sequence number every time they match. Here, since the sequence Sc13 to Sc15 has been received seven times, when receiving a message with the sequence number “n + 8” in the sequence Sc15, the message reception unit 201 displays the sequence number stored in the expected sequence number storage unit 203. Update to serial number “n + 9”. In sequence Sc15, retransmission unit 103 reads and transmits the message with serial number “n + 8”, that is, the latest message stored in transmission message storage unit 105, and the transmission instructed in sequence Sc12. The message transmission unit 101 is instructed to cancel the cancellation (Sc16).

  The message transmission unit 101 that has received the cancellation of the transmission reads out the sequence number “n + 8” stored at the time of message transmission of the sequence Sc9 from the message sequence number storage unit 104, and adds the sequence number “n + 9” obtained by adding 1 to this sequence number. The telegram receiving unit 201 receives the telegram of the serial number “n + 9”, reads out the serial number “n + 9” stored at the time of receiving the sequence Sc15 from the expected serial number storage unit 203, and transmits these telegrams (Sc17). Compare Since these serial numbers match, the message receiving unit 201 updates the expected serial number storage unit 203 to the serial number “n + 10” obtained by adding 1 to the serial number stored in the expected serial number storage unit 203.

  Note that the retransmission request unit 202 also sets a timer when transmitting a send message in the sequence Sc10, but the message reception unit 201 sets a message with a send flag (in this case, the serial number “transmitted in the sequence Sc13“ When the message “n + 2” is received), the retransmission request unit 202 does not further transmit a send message requesting a message with the serial number “n + 2”.

  Thus, in sequence Sc7, when retransmission request unit 202 transmits a send message, the timer is set to start again after a predetermined time and send a send message again. If the message receiving unit 201 does not receive the message with the send flag within the time, that is, if the message requested by the send message is not received within the predetermined time, the retransmission request unit 202 refers to the timer to determine the predetermined message. Is detected and the resend message is transmitted again. Therefore, even if the resend message cannot be received by the retransmission request receiver 102 for any reason, the message receiver 200 cannot receive the message before that time. Can be recovered.

  FIG. 6 is a sequence diagram illustrating an operation example in which the received sequence number transmission unit 204 notifies the message transmission apparatus 100 of the received sequence number in the message transmission / reception system according to the present embodiment. In the state before the sequence shown in FIG. 6 starts, the sequence number stored in the message sequence number storage unit 104 is “n−1” and the sequence number stored in the expected sequence number storage unit 203 is the same as in FIG. It is assumed that “n”. First, the message transmission unit 101 of the message transmission device 100 reads the sequence number “n−1” from the message sequence number storage unit 104 and adds the sequence number “n” to which 1 is added. While transmitting a message (Sd1), the message is stored in the transmitted message storage unit 105, and the sequence number stored in the message sequence number storage unit 104 is updated to this sequence number “n.” The message reception unit 201 of the message reception device 200. Receives the message and compares the message sequence number “n” with the sequence number “n” read from the expected sequence number storage unit 203. Here, since the two sequence numbers match, the message reception unit 201 Stored in the serial number storage unit 203 The serial number that is updated by adding 1 to the number vent the serial number "n + 1".

  Next, in the same manner, the message transmission unit 101 reads the sequence number “n” from the message sequence number storage unit 104 and transmits a message with the sequence number “n + 1” obtained by adding 1 to this (Sd2). Is stored in the transmitted message storage unit 105, and the sequence number stored in the message sequence number storage unit 104 is updated to the sequence number “n + 1.” The message reception unit 201 of the message reception apparatus 200 receives this message and receives the sequence number of the message. “N + 1] is compared with the serial number“ n + 1 ”read from the expected serial number storage unit 203. Here, since the two serial numbers match, the message receiving unit 201 uses the serial number stored in the expected serial number storage unit 203. , 1 is added to the serial number to update to the serial number “n + 2”.

  Here, notification of the received serial number from the message receiving device 200 to the message transmitting device 100 is performed asynchronously with the transmission of the message from the message transmitting device 100 to the message receiving device 200. For example, the electronic message receiving apparatus 200 notifies the received serial number at a constant cycle. That is, the received serial number transmission unit 204 of the electronic message receiving apparatus 200 reads the serial number “n + 2” stored in the expected serial number storage unit 203 and subtracts 1 from the serial number “n + 2” (that is, the message reception “n + 1”). The received serial number information representing the serial number of the telegram received by the apparatus 200 is transmitted to the telegram transmitting apparatus 100 (Sd3). The received serial number receiving unit 106 of the message transmitting apparatus 100 receives the received serial number information. The received serial number receiving unit 106 deletes the previous message including the serial number “n + 1” represented by the received received serial number information from the transmitted message storage unit 105.

  Thereafter, in this operation example, the messages with the serial numbers “n + 2” and “n + 3” transmitted by the message transmitting unit 101 are not received by the message receiving device 200 due to a temporary abnormality in the communication path 300 (Sd4, Sd5). Next, the message with the sequence number “n + 4” transmitted by the message transmission unit 101 is received by the message reception unit 201 (Sd6), the sequence number “n + 4” of the message and the sequence number updated in the sequence Sd2, and the expected sequence number storage. The serial number “n + 2” read from the unit 203 is compared.Here, since the two serial numbers do not match, the message receiving unit 201 notifies the retransmission request unit 202 of the serial number mismatch (Sd7). Upon receiving the serial number mismatch, transmits a send request requesting retransmission of a message after the serial number “n + 2” read from the expected serial number storage unit 203 (Sd8).

  As in the case of the send message in the sequence Sd8 transmitted after the time point of the sequence Sd3 described above, the serial number requested by the send message transmitted after a certain time point is the serial number stored in the expected serial number storage unit 203 at a certain time point. Thereafter (including the serial number). Therefore, as in the sequence Sd3, the received serial number transmission unit 204 notifies the message transmission device 100 of the serial number immediately before the serial number stored in the expected serial number storage unit 203 at an arbitrary time, and the notification is sent. The received serial number receiving unit 106 deletes the message before the notified serial number (including the serial number) from the transmission message storage unit 105, so that a message that is not likely to be retransmitted is transmitted to the transmission message storage unit. 105 can be deleted. Thereby, the storage capacity required for the transmission message storage unit 105 can be suppressed.

  In the present embodiment, recovery with a message serial number is performed only for messages from the message transmission device 100 to the message reception device 200, that is, only in one direction, but as shown in FIG. You may use the message | telegram transmission / reception system in this embodiment bidirectionally. In FIG. 7, the server 400 includes the message transmission device 100 and the message reception device 200, and the server 500 also includes the message transmission device 100 and the message reception device 200. Then, the message transmission apparatus 100 of the server 400 and the message reception apparatus 200 of the server 500 perform transmission / reception of an uplink message from the server 400 to the server 500. Further, the telegram receiving apparatus 200 of the server 400 and the telegram transmitting apparatus 100 of the server 500 perform transmission / reception of downlink telegrams from the server 500 to the server 400. In this manner, the uplink and downlink pairs may be managed as a session described with reference to FIG.

  At this time, the received telegram (for example, sequence Sb7 in FIG. 4) and the received serial number information (for example, sequence Sd3 in FIG. 6) described as transmitting from the telegram receiving device 200 to the telegram transmitting device 100 in the present embodiment are reversed. It is good also as a message | telegram from the message | telegram transmission apparatus 100 of a reverse direction to the message | telegram reception apparatus 200 by giving a serial number in the message | telegram transmission apparatus 100 of a direction. That is, the received telegram and the received serial number information from the message receiver 200 of the server 400 to the message transmitter 100 of the server 500 (downward) are transferred from the message transmitter 100 of the server 400 to the message receiver 200 of the server 500 (upstream). ), And when a message omission occurs in an upstream message, the received message and the received serial number information may be recovered together. The same applies to the case where up and down are reversed.

  Also, the received serial number information may be transmitted by using the received serial number information in the message for transmitting other information, instead of using a dedicated electronic message for transmitting the information. When the received serial number information is transmitted by such a method, the received serial number information will not be transmitted in a time zone in which there is no message for transmitting other information. If there is a survival monitoring message transmitted when the state continues, it may be included in the message.

  FIG. 8 is a diagram for explaining a session, which is a unit for managing a message serial number. In each of the upstream and downstream between the login process for establishing a session and the logout process for releasing the session, the serial number is defined as a continuous unique number that is incremented by 1 for each message whose initial value is “1”. The In the login process for establishing a session, the upstream and downstream serial numbers of the server 400 and the server 500 are initialized between the server 400 and the server 500. That is, the initial value “0” is stored in the message sequence number storage unit 104 of the message transmission device 100 of each of the server 400 and the server 500, and the initial value “1” is stored in the expected sequence number storage unit 203 of the message reception device 200. Remember. In the present embodiment, the serial number has an initial value of “1” and has been described as a continuous value that increases by 1. However, for example, the uplink is an odd number of the initial value “1”, and the downlink is the initial value “2”. It may be a value that increases by 2 evenly. Thereby, the message transmission / reception system of this embodiment manages each by performing a Login process and starting a session irrespective of the management state of the serial number before the session start of the message transmission apparatus 100 and the message reception apparatus 200. Since the serial number is the initial value, it is possible to send and receive messages.

  In addition, the program for realizing the functions of the message transmission unit 101, the retransmission unit 103, the received sequence number reception unit 106, the message reception unit 201, the retransmission request unit 202, and the received sequence number transmission unit 204 in FIG. The processing of each of these units may be performed by recording in a recording medium, reading the program recorded in the recording medium into a computer system, and executing the program. Here, the “computer system” includes an OS and hardware such as peripheral devices.

Further, the “computer system” includes a homepage providing environment (or display environment) if a WWW system is used.
The “computer-readable recording medium” refers to a storage device such as a flexible medium, a magneto-optical disk, a portable medium such as a ROM and a CD-ROM, and a hard disk incorporated in a computer system. Furthermore, the “computer-readable recording medium” dynamically holds a program for a short time like a communication line when transmitting a program via a network such as the Internet or a communication line such as a telephone line. In this case, a volatile memory in a computer system serving as a server or a client in that case, and a program that holds a program for a certain period of time are also included. The program may be a program for realizing a part of the functions described above, and may be a program capable of realizing the functions described above in combination with a program already recorded in a computer system.

  The embodiment of the present invention has been described in detail with reference to the drawings. However, the specific configuration is not limited to this embodiment, and includes design and the like within a scope not departing from the gist of the present invention.

  The present invention is suitable for use in a securities trading system, but is not limited to this.

It is a figure explaining the outline | summary of the serial number management of the message | telegram transmission / reception system by one Embodiment of this invention. It is a schematic block diagram which shows the structure of the message | telegram transmission / reception system in the embodiment. It is a table | surface explaining the item of the header part of the message | telegram by the embodiment. It is a sequence diagram which shows the operation example when the serial number omission occurs in the message transmission / reception system according to the embodiment. It is a sequence diagram which shows the operation example when the message | telegram transmission apparatus 100 cannot receive the received message | telegram in the message | telegram transmission / reception system by the embodiment. It is a sequence diagram which shows the operation example which notifies the message | telegram transmission apparatus 100 of the received serial number in the message | telegram transmission / reception system by the embodiment. It is a figure explaining the system which used the message | telegram transmission / reception system by the same embodiment bidirectionally. It is a figure explaining the session which is a unit which manages the serial number of a message in the system which used the message transmission / reception system by the same embodiment bidirectionally. It is a sequence diagram which shows the operation example of the conventional message transmission / reception system.

Explanation of symbols

DESCRIPTION OF SYMBOLS 100 ... Message transmission apparatus 101 ... Message transmission part 102 ... Retransmission request reception part 103 ... Retransmission part 104 ... Message sequence number storage part 105 ... Transmission message storage part 106 ... Received sequence number reception part 200 ... Message reception apparatus 201 ... Message reception part 202 ... Retransmission request unit 203 ... Expected sequence number storage unit 204 ... Received sequence number transmission unit 300 ... Communication path 400, 500 ... Server

Claims (9)

In a message transmission / reception system comprising a message transmission device for transmitting a message and a message reception device for receiving the message,
The message transmission device
A message transmission means for sending a message with a serial number and storing the message in a transmission message storage means;
A retransmission request receiving means for receiving a retransmission request and instructing the message transmission means to cancel a new message transmission;
Retransmission means for sequentially reading out and transmitting a message after a serial number requested by the retransmission request received by the retransmission request receiving means from the transmission message storage means,
The message receiving device is:
When the transmitted message is received, it is determined whether or not the serial number assigned to the message and the serial number of the previously received message are continuous. Until receiving a message of a sequence number next to the sequence number of the message, a message receiving means for discarding even if a message of a sequence number other than the next sequence number is received,
A retransmission requesting unit for transmitting a retransmission request for requesting a message having a sequence number next to a sequence number of a previously received message when the message reception unit determines that the message is not continuous. A telegram transmission / reception system.   The retransmission request means sends a retransmission request again when the message receiving means does not receive a message with a serial number requested by the retransmission request even after a predetermined time has elapsed since the retransmission request was transmitted. The electronic message transmission / reception system according to claim 1, wherein transmission is performed. The message receiving device is:
The message receiving means comprises received sequence number transmitting means for transmitting information indicating the sequence number of a received message,
The message transmission device
The message transmission / reception system according to claim 2, further comprising: a received serial number receiving unit that receives information indicating the received serial number and deletes a message before the serial number from the transmission message storage unit.   The message transmission / reception system according to any one of claims 1 to 3, wherein at the start of a session, the message transmission device and the message reception device use a serial number managed by each as an initial value. In a message transmission / reception method in a message transmission / reception system comprising a message transmission side for transmitting a message and a message reception side for receiving the message,
A first step in which the message transmission side transmits a message with a serial number, and stores the message in a transmission message storage unit;
When the message receiving side receives the transmitted message, determines whether the serial number assigned to the message and the sequence number of the previously received message are consecutive, and determines that they are not consecutive A second process of discarding a message with a sequence number other than the next sequence number until receiving a message with a sequence number next to the sequence number of the previously received message;
A third process of transmitting a retransmission request for requesting a message having a sequence number next to a sequence number of a previously received message when the message receiving apparatus determines that the message is not continuous in the determination in the second process; When,
The message transmission device receives the transmitted retransmission request, sequentially reads out the message after the serial number requested by the retransmission request from the transmission message storage means, and transmits a new message transmission during this transmission. A message transmission / reception method comprising: a fourth process of canceling. A message transmission means for sending a message with a serial number and storing the message in a transmission message storage means;
A retransmission request receiving means for receiving a retransmission request and instructing the message transmission means to cancel a new message transmission;
A message transmission apparatus comprising: a retransmission unit that sequentially reads and transmits a message after a serial number requested by the retransmission request received by the retransmission request reception unit from the transmission message storage unit. Computer
A message transmission means for transmitting a message with a serial number and storing the message in a transmission message storage means;
Retransmission request receiving means for receiving a retransmission request and instructing the message transmission means to cancel a new message transmission;
A program for functioning as a retransmission unit that sequentially reads out and transmits a message after a serial number requested by the retransmission request received by the retransmission request receiving unit from the transmission message storage unit. A message is received, and it is determined whether or not the serial number assigned to the message and the serial number of the previously received message are continuous. If it is determined that the serial number is not continuous, the serial number of the previously received message is determined. Until receiving a message of the next serial number, a message receiving means for discarding even if a message of a serial number other than the next serial number is received,
A retransmission requesting unit for transmitting a retransmission request for requesting a message having a sequence number next to a sequence number of a previously received message when the message reception unit determines that the message is not continuous. A telegram receiver. Computer
A message is received, and it is determined whether or not the serial number assigned to the message and the serial number of the previously received message are continuous. If it is determined that the serial number is not continuous, the serial number of the previously received message is determined. Until receiving a message with the next serial number, a message receiving means for discarding even if a message with a serial number other than the next serial number is received,
A program for functioning as a retransmission requesting means for transmitting a retransmission request for requesting a message having a sequence number next to a sequence number of a previously received message when it is determined that the message reception unit is not continuous.

Images