Method of accessing message queue and system thereof

• US 5,999,964 A
• Filed: 12/13/1996
• Issued: 12/07/1999
• Est. Priority Date: 12/14/1995
• Status: Expired due to Fees

• Current Assignee: Hitachi, Ltd.
• Original Assignee: Hitachi, Ltd.
• Inventors: Shinya, Naofumi, Miyadate, Mamoru, Murakata, Yahei, Tsuzuki, Hiroya
• Primary Examiner(s): Dinh, Dung C.
• Application Number:
  US08/766,851
• Time in Patent Office: 1,089 Days
• Field of Search: 395/200.31, 395/200.33, 395/680, 395/200.47, 395/200.68, 395/200.36, 395/200.37, 710/52, 709/232, 709/201
• US Class Current: 709/201
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues
• CPC Class Codes: H04L 47/50 Queue scheduling
• CPC Class Codes: H04L 47/62 characterised by scheduling criteria
• CPC Class Codes: H04L 49/90 Buffering arrangements
• CPC Class Codes: H04L 49/901 using storage descriptor, e.g. read or write pointers

Abstract

A plurality of physically different queue files provided in a distributed processor node of a distributed processing system are regarded as a queue file group, and a message storage pointer and a message pick up pointer are provided in a message queue manager, and storing or picking up of a message is executed by a queue file indicated by the content of the message storage or pick up pointer, and the content of the pointer is updated every storing or picking up at the same time, so that access to a message queue in asynchronous storage type communication which can transfer a voluminous message without changing the application program is made possible.

Claims

1. A message queue writing method for a computer coupled with another computer via a network, said method comprising the steps of:

setting at least one queue group which includes a plurality of queues for storing messages to be stored on a plurality of recording media respectively;

putting said plurality of queues included in said queue group in order;

setting a message storage pointer for pointing to a certain queue in said queue group, for storing a message;

storing said message to be stored in said certain queue;

setting the next message storage pointer for pointing to a queue next to said certain queue, for storing the next message; and

storing the next message to be stored in said queue next to said certain queue.

2. A message queue access method for a computer coupled with another computer via a network, said method comprising the steps of:

setting at least one queue group which includes a plurality of queues for storing messages stored on a plurality of recording media respectively;

putting said plurality of queues included in said queue group in order;

setting a message pick up pointer for pointing to a certain queue in said queue group, for picking up a message;

picking up said message from said certain queue;

setting the next message pick up pointer for pointing to a queue next to said certain queue, for picking up the next message; and

a step of picking up the next message from said queue next to said certain queue.

3. A message queue access method for a computer coupled with another computer via a network, said method comprising the steps of:

setting at least one queue group which includes a plurality of queues for storing messages stored/to be stored on a plurality of recording media respectively;

putting said plurality of queues included in said queue group in order;

setting at least one of a message storage pointer and a message pick up pointer, for pointing to a certain queue in said queue group, for picking up/storing a message;

picking up/storing said message from/to said certain queue;

setting at least one of a next message storage pointer and a next message pick up pointer, for pointing to a certain queue in said queue group, for picking up/storing the next message; and

picking up/storing the next message from/to said queue next to said certain queue.

4. A message queue writing system, comprising:

a computer;

another computer coupled to said computer via a network;

means for setting at least one queue group which includes a plurality of queues for storing messages to be stored respectively on a plurality of recording media;

means for putting said plurality of queues included in said queue group in order;

means for setting a message storage pointer for pointing to a certain queue in said queue group, for storing a message;

means for storing said message to be stored in said certain queue;

means for setting the next message storage pointer for pointing to a queue next to said certain queue, for storing the next message; and

means for storing the next message to be stored in said queue next to said certain queue.

5. A message queue access system, comprising:

a computer;

another computer coupled to said computer via a network;

means for setting at least one queue group which includes a plurality of queues for storing messages stored on a plurality of recording media respectively;

means for putting said plurality of queues included in said queue group in order;

means for setting a message pick up pointer for pointing to a certain queue in said queue group, for picking up a message;

means for picking up said message from said certain queue;

means for setting the next message pick up pointer for pointing to a queue next to said certain queue, for picking up the next message; and

means for picking up the next message from said queue next to said certain queue.

6. A message queue access system, comprising:

a computer;

another computer coupled to said computer via a network;

means for setting at least one queue group which includes a plurality of queues for storing messages stored/to be stored on a plurality of recording media respectively;

means for putting said plurality of queues included in said queue group in order;

means for setting at least one of a message storage pointer and a message pick up pointer, for pointing to a certain queue in said queue group, for picking up/storing a message;

means for picking up/storing said message from/to said certain queue;

means for setting at least one of a next message storage pointer and a next message pick up pointer, for pointing to a certain queue in said queue group, for picking up/storing the next message; and

means for picking up/storing the next message from/to said queue next to said certain queue.

7. A program product for use with a computer, comprising:

a computer readable medium with a computer program recorded thereon, said program including;

a first process for causing the computer to set at least one queue group which includes a plurality of queues for storing messages to be stored on a plurality of recording media respectively;

a second process for causing the computer to put said plurality of queues included in said queue group in order;

a third process for causing the computer to set a message storage point for pointing to a certain queue in said queue group, for storing a message;

a fourth process for causing the computer to store said message to be stored in said certain queue;

a fifth process for causing the computer to set the next message storage pointer for pointing to a queue next to said certain queue, for storing the next message; and

a sixth process for causing the computer to store the next message to be stored in said queue next to said certain queue.

8. A program product for use with a computer, comprising:

a computer readable medium with a computer program recorded thereon, said program including;

a first process for causing the computer to set at least one queue group which includes a plurality of queues for storing messages stored on a plurality of recording media respectively;

a second process for causing the computer to put said plurality of queues included in said queue group in order;

a third process for causing the computer to set a message pick up pointer for pointing to a certain queue in said queue group, for picking up a message;

a fourth process for causing the computer to pick up said message from said certain queue;

a fifth process for causing the computer to set the next message pick up pointer for pointing to a queue next to said certain queue, for picking up the next message; and

a sixth process for causing the computer to pick up the next message from said queue next to said certain queue.

9. A program product for use with a computer, comprising:

a computer readable medium with a computer program recorded thereon, the program including;

a first process for causing the computer to set at least one queue group which includes a plurality of queues for storing messages stored/to be stored on a plurality of recording media respectively;

a second process for causing the computer to put said plurality of queues included in said queue group in order;

a third process for causing the computer to set at least one of a message storage pointer and a message pick up pointer, for pointing to a certain queue in said queue group, for picking up/storing a message;

a fourth process for causing the computer to pick up/store said message from/to said certain queue;

a fifth process for causing the computer to set at least one of a next message storage pointer and a next message pick up pointer, for pointing to a certain queue in said queue group, for picking up/storing the next message; and

a sixth process for causing the computer to pick up/storing the next message from/to said queue next to said certain queue.