JP2007299308A - Job processing system, job processing method, program, and recording medium - Google Patents
Job processing system, job processing method, program, and recording medium Download PDFInfo
- Publication number
- JP2007299308A JP2007299308A JP2006128261A JP2006128261A JP2007299308A JP 2007299308 A JP2007299308 A JP 2007299308A JP 2006128261 A JP2006128261 A JP 2006128261A JP 2006128261 A JP2006128261 A JP 2006128261A JP 2007299308 A JP2007299308 A JP 2007299308A
- Authority
- JP
- Japan
- Prior art keywords
- processing
- job
- priority
- unit
- processing request
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
Images
Landscapes
- Accessory Devices And Overall Control Thereof (AREA)
- Facsimiles In General (AREA)
Abstract
【課題】 時間を要する文書ファイルの登録や検索等のジョブを実行した後に返される結果を待つことなく、他のジョブを処理できるシステム、方法、プログラムおよび記録媒体を提供する。
【解決手段】 本発明のジョブ処理システム20は、システム負荷を監視するシステム負荷監視部21と、システム負荷に関する閾値を記憶する閾値記憶部22と、ユーザからのジョブ内容を含む処理要求に応答して、負荷情報を取得し、閾値を読み出し、負荷情報が閾値を超えるか否かを判定する判定部23と、閾値を超えるとの判定に応答して、処理要求を処理要求記憶部25に記憶し、受付メッセージをユーザに送信するジョブ管理部24と、閾値を超えないとの判定に応答して、処理要求をジョブ内容に基づいて処理し、処理結果をユーザに送信するジョブ処理部27とを含む。ジョブ管理部24は、処理要求をジョブ処理部27に発行して非同期処理させ、ユーザに処理結果を送信する。
【選択図】 図2
PROBLEM TO BE SOLVED: To provide a system, method, program and recording medium capable of processing another job without waiting for a result returned after executing a job such as registration and search of a document file which requires time.
A job processing system 20 according to the present invention responds to a processing request including a job content from a user, a system load monitoring unit 21 that monitors a system load, a threshold storage unit 22 that stores a threshold relating to the system load. In response to the determination that the load information is acquired, the threshold value is read, the load information exceeds the threshold value, and the threshold value is exceeded, the processing request is stored in the processing request storage unit 25 A job management unit 24 that transmits a reception message to the user, and a job processing unit 27 that processes a processing request based on the job contents and transmits a processing result to the user in response to a determination that the threshold value is not exceeded. including. The job management unit 24 issues a processing request to the job processing unit 27 to perform asynchronous processing, and transmits the processing result to the user.
[Selection] Figure 2
Description
本発明は、システムの負荷に応じてジョブを処理するシステム、方法、その方法を実行するためのコンピュータ可読なプログラム、そのプログラムを格納した記録媒体に関する。 The present invention relates to a system and method for processing a job according to a load on the system, a computer-readable program for executing the method, and a recording medium storing the program.
作成した文書を文書ファイルとして登録し、ユーザからの文書ファイルの要求に応答して、その文書ファイルを検索し、ユーザに提供するために、文書管理サーバが利用されている。文書管理サーバは、インターネット等のネットワークに接続され、そのネットワークに接続されたクライアントコンピュータからの要求に応答して、文書ファイルを登録し、検索し、送信することができる。 A document management server is used to register a created document as a document file, search for the document file in response to a request for the document file from the user, and provide the document file to the user. The document management server is connected to a network such as the Internet, and can register, search, and transmit a document file in response to a request from a client computer connected to the network.
クライアントコンピュータを使用してユーザが必要な文書ファイルを取得する場合、文書ファイルを検索する機能を使用する。例えば、文書ファイルのファイル名や文書内の用語をキーワードとして入力し、それに関連する文書ファイルを検索する。これは、文書管理サーバに登録されている、すなわち記憶されている文書ファイルが大量である場合、検索結果を得るまで相当の時間を要する。また、1回のキーワード入力だけでは関連する文書ファイルが大量であるため、何度もキーワード入力を行わなければならない場合があり、こういった検索条件が複雑なものの場合、さらに検索時間を要する。 When a user acquires a necessary document file using a client computer, a function for searching for the document file is used. For example, a file name of a document file or a term in the document is input as a keyword, and a document file related to it is searched. This requires a considerable amount of time to obtain a search result when there are a large number of document files registered in the document management server, that is, stored. In addition, since there are a large number of related document files with only one keyword input, it may be necessary to input keywords many times. If these search conditions are complicated, more search time is required.
検索自体は時間を要しない処理でも、バックグラウンドで、大量の文書ファイルの登録やプロセッサに負荷がかかるその他の処理が行われている場合、システムのレスポンスは悪化する。こういった場合、検索結果が得られるまで、その他の処理を実行することができない状態、あるいは、その他の処理が終了し、結果が返されるまで、検索処理を行うことができない状態が生じる。 Even if the search itself does not take time, the system response deteriorates if a large number of document files are registered in the background or if other processes that impose a load on the processor are performed. In such a case, a state in which other processing cannot be executed until a search result is obtained, or a state in which search processing cannot be performed until the other processing ends and a result is returned occurs.
インターネット越しに文書管理を行う際、文書を登録する時間の短縮化、サーバの負荷軽減が可能な文書管理システムおよび方法が提案されている(特許文献1参照)。このシステムおよび方法では、クライアントマシンからサーバマシンへのデータ転送と、サーバマシン上でのデータ登録の処理タイミングとをずらし、サーバの負荷の少ない時間帯に登録を開始することで、サーバの負荷軽減、処理時間を短縮する。具体的には、「すぐ登録」、「あとで登録」、「夜間に登録」といった登録のタイミングを指定し、同時にデータファイルをサーバに転送し、指定したタイミングに従って登録を実行する。 There has been proposed a document management system and method capable of reducing the time for registering a document and reducing the load on a server when managing documents over the Internet (see Patent Document 1). In this system and method, the load on the server is reduced by shifting the data transfer from the client machine to the server machine and the data registration processing timing on the server machine, and starting the registration at a time when the server load is low. , Reduce processing time. Specifically, registration timings such as “immediate registration”, “later registration”, and “night registration” are designated, and at the same time, the data file is transferred to the server, and registration is executed according to the designated timing.
このシステムおよび方法では、サーバ負荷の少ない時間帯を指定すればサーバの負荷軽減を図ることができるものの、複数のユーザが「すぐに登録」を同じ時期に指定すると、この指定が重なり、サーバ負荷が大きくなる場合がある。また、このシステムでは、登録状況画面において、登録状況を確認し、登録を実行する処理が少ない時間帯を指定することができるものの、バックグラウンドで実行される登録処理以外の処理については確認することができないため、必ずしもサーバ負荷を軽減することはできない。
すなわち、時間を要する文書ファイルの登録や検索等のジョブを実行した後に返される結果を待つことなく、他のジョブを処理することができるシステムや方法の提供が望まれていた。 In other words, it has been desired to provide a system and method that can process other jobs without waiting for a result returned after executing a job such as registration and search of a document file that requires time.
本発明は、上記課題に鑑みてなされたものであり、サーバの負荷を監視し、サーバの負荷が閾値を超えていない場合には、処理要求をリアルタイム処理(同期処理)し、超えている場合には、処理要求を受け付けたことを示すメッセージを返し、その処理要求に対しては非同期に処理し、処理結果を待つことなく他のジョブを処理することを可能にするシステム、方法、その方法を実行するためのコンピュータ可読なプログラム、そのプログラムを格納した記録媒体を提供することを目的とする。 The present invention has been made in view of the above problems. When the server load is monitored and the server load does not exceed the threshold, the processing request is processed in real time (synchronized processing) and exceeds Returns a message indicating that a processing request has been accepted, the processing request is processed asynchronously, and other jobs can be processed without waiting for the processing result. An object of the present invention is to provide a computer-readable program for executing the above and a recording medium storing the program.
本発明は、上記課題を解決するために、システムの負荷に合わせて、適切な処理方式(同期処理または非同期処理)を判断し、非同期処理の場合、処理要求を送信したユーザに対し、処理要求を受け付けたことを示すメッセージを返し、処理が終了した際に、処理結果を送信するようにしたものである。 In order to solve the above problems, the present invention determines an appropriate processing method (synchronous processing or asynchronous processing) according to the system load, and in the case of asynchronous processing, the processing request is sent to the user who sent the processing request. Is returned, and the processing result is transmitted when the processing is completed.
すなわち、本発明によれば、システム負荷に応じてジョブを処理するジョブ処理システムであって、
前記システム負荷を監視するシステム負荷監視部と、
前記システム負荷に関する閾値を記憶する閾値記憶部と、
ユーザからのジョブ内容を含む処理要求の受信に応答して、前記システム負荷監視部から負荷情報を取得し、前記閾値記憶部から前記閾値を読み出し、前記負荷情報が前記閾値を超えるか否かを判定する判定部と、
前記閾値を超えるとの判定に応答して、前記処理要求を保持し、前記処理要求を受け付けたことを示す受付メッセージを前記ユーザに対して送信するジョブ管理部と、
前記閾値を超えないとの判定に応答して、前記処理要求を前記ジョブ内容に基づいて処理し、処理結果を前記ユーザに対して送信するジョブ処理部とを含み、
前記ジョブ管理部は、保持した前記処理要求を前記ジョブ処理部に発行して前記ジョブ処理部に非同期処理させ、前記ジョブ処理部から前記処理結果を受け取り、前記ユーザに対して前記処理結果を送信する、ジョブ処理システムが提供できる。
That is, according to the present invention, a job processing system that processes a job according to a system load,
A system load monitoring unit for monitoring the system load;
A threshold storage unit for storing a threshold related to the system load;
In response to receiving a processing request including a job content from a user, load information is acquired from the system load monitoring unit, the threshold value is read from the threshold value storage unit, and whether or not the load information exceeds the threshold value A determination unit for determining;
In response to the determination that the threshold is exceeded, the job management unit holds the processing request and transmits an acceptance message indicating that the processing request has been accepted to the user;
In response to the determination that the threshold value is not exceeded, a job processing unit that processes the processing request based on the job content and transmits a processing result to the user,
The job management unit issues the held processing request to the job processing unit, causes the job processing unit to perform asynchronous processing, receives the processing result from the job processing unit, and transmits the processing result to the user A job processing system can be provided.
前記処理要求はジョブ処理の優先度情報を含むことができ、前記ジョブ管理部は、記憶した複数の前記処理要求を前記優先度情報に基づいて前記ジョブ処理部に発行することができる。 The processing request may include job processing priority information, and the job management unit may issue a plurality of stored processing requests to the job processing unit based on the priority information.
前記ジョブ管理部は、前記ジョブ内容に基づき予め設定された優先度を記憶する優先度記憶部を備え、記憶した複数の前記処理要求を前記優先度に基づいて前記ジョブ処理部に発行することができる。 The job management unit includes a priority storage unit that stores a priority set in advance based on the job content, and issues the plurality of stored processing requests to the job processing unit based on the priority. it can.
前記ジョブ管理部は、前記処理要求に含まれる前記ジョブ内容に基づき優先度を決定する優先度決定部を備え、前記優先度決定部は、記憶した複数の前記処理要求の各々に対して前記優先度を決定し、前記複数の処理要求を前記優先度に基づいて前記ジョブ処理部に発行することもできる。 The job management unit includes a priority determination unit that determines priority based on the job content included in the processing request, and the priority determination unit is configured to apply the priority to each of the plurality of stored processing requests. It is also possible to determine the degree and issue the plurality of processing requests to the job processing unit based on the priority.
前記ジョブ管理部は、ユーザ毎に、前記ジョブ内容に基づき予め設定された優先度を記憶する優先度記憶部と、前記処理要求に含まれるユーザ識別情報からユーザを特定し、前記優先度記憶部に記憶される前記ユーザに関連付けられた前記優先度に基づき、前記ジョブの優先度を決定する優先度決定部とを含むことができる。 The job management unit specifies, for each user, a priority storage unit that stores a priority set in advance based on the job content, and identifies a user from user identification information included in the processing request, and the priority storage unit And a priority determining unit that determines the priority of the job based on the priority associated with the user stored in the user ID.
前記ジョブ管理部は、各ユーザが入力した優先度を、ユーザ毎に記憶する優先度記憶部と、前記処理要求に含まれるユーザ識別情報からユーザを特定し、前記優先度記憶部に記憶される前記ユーザに関連付けられた前記優先度に基づき、ジョブの優先度を決定する優先度決定部とを含むこともできる。 The job management unit specifies a user from a priority storage unit that stores the priority input by each user for each user and user identification information included in the processing request, and stores the user in the priority storage unit. A priority determination unit that determines a priority of a job based on the priority associated with the user.
前記システムの管理者による優先度の変更の入力に応答して、前記優先度記憶部に記憶された優先度を変更する優先度変更部をさらに含むことができる。 The system may further include a priority changing unit that changes the priority stored in the priority storage unit in response to an input of a priority change by an administrator of the system.
前記処理要求は、文書検索要求、文書登録要求、文書の画像変換要求とすることができ、前記ジョブ内容は、文書検索、文書登録、文書の画像変換とすることができる。 The processing request may be a document search request, a document registration request, or a document image conversion request, and the job content may be a document search, document registration, or document image conversion.
前記ジョブ処理システムは、プリンタ、ファックス装置、コピー装置、スキャナ装置、これらを機能として備えるデジタル複合機に実装することができる。 The job processing system can be implemented in a printer, a fax machine, a copy machine, a scanner machine, or a digital multifunction machine having these functions.
本発明によれば、システム負荷に応じてジョブを処理するジョブ処理方法も提供する。この方法では、システムは、システム負荷監視部が前記システムの負荷情報を監視し、閾値記憶部が前記システムの負荷情報の閾値を記憶しており、
ユーザからのジョブ内容を含む処理要求の受信に応答して、前記システムが備える判定部が、前記システム負荷監視部から前記負荷情報を取得し、前記閾値記憶部から前記閾値を読み出し、前記負荷情報が前記閾値を超えるか否かを判定するステップと、
前記閾値を超えないとの判定に応答して、前記システムが備えるジョブ処理部が、前記処理要求を前記ジョブ内容に基づいて処理し、処理結果を前記ユーザに対して送信するステップと、
前記閾値を超えるとの判定に応答して、前記システムが備えるジョブ管理部が、前記処理要求を処理要求記憶部に記憶し、前記処理要求を受け付けたことを示す受付メッセージを前記ユーザに対して送信するステップと、
前記ジョブ管理部が、前記処理要求記憶部に記憶した前記処理要求を前記ジョブ処理部に非同期処理させ、処理結果を受け取り、前記ユーザに対して前記処理結果を送信するステップとを含む。
According to the present invention, a job processing method for processing a job according to a system load is also provided. In this method, in the system, the system load monitoring unit monitors the load information of the system, and the threshold storage unit stores the threshold of the load information of the system.
In response to receiving a processing request including a job content from a user, a determination unit included in the system acquires the load information from the system load monitoring unit, reads the threshold value from the threshold storage unit, and loads the load information. Determining whether or not exceeds the threshold;
In response to the determination that the threshold is not exceeded, a job processing unit included in the system processes the processing request based on the job content, and transmits a processing result to the user;
In response to the determination that the threshold is exceeded, the job management unit included in the system stores the processing request in the processing request storage unit, and receives an acceptance message indicating that the processing request has been accepted to the user. Sending, and
And a step of causing the job management unit to asynchronously process the processing request stored in the processing request storage unit, receiving a processing result, and transmitting the processing result to the user.
また、本発明の方法によれば、前記受付メッセージを送信するステップは、前記処理要求に、処理が完了したか、処理中であるか、未完了であるかを示すステータスを関連付けて前記処理要求記憶部に記憶するステップを含み、
前記ジョブ処理部に非同期処理させ、前記処理結果を送信するステップは、
前記ステータスが未完了を示すものがあるか否かを判定するステップと、
前記未完了を示すものがあると判定した場合、
前記処理要求記憶部から未完了であることを示す前記ステータスに関連付けられた前記処理要求を読み出し、該処理要求を非同期処理するステップと、
前記処理要求に関連付けられた前記ステータスを未完了から処理中に変更するステップと、
前記非同期処理が終了したことに応答して、前記処理結果を受け取り、前記処理要求記憶部に該処理結果を記憶し、前記ステータスを処理中から完了に変更するステップと、
前記未完了を示すものがないと判定した場合、
前記ステータスが完了を示すものがあるか否かを判定するステップと、
前記完了を示すものがあると判定した場合、前記ユーザに対して前記処理結果を送信するステップと、前記処理要求記憶部に記憶された前記処理要求および前記処理結果を削除するステップとを含む。
Further, according to the method of the present invention, the step of transmitting the acceptance message includes associating the processing request with a status indicating whether the processing is completed, being processed, or not completed. Storing in the storage unit,
The step of asynchronously processing the job processing unit and transmitting the processing result includes:
Determining whether there is an incomplete status.
If it is determined that there is something indicating the incomplete,
Reading the processing request associated with the status indicating incomplete from the processing request storage unit, and asynchronously processing the processing request;
Changing the status associated with the processing request from incomplete to processing;
In response to the completion of the asynchronous processing, receiving the processing result, storing the processing result in the processing request storage unit, and changing the status from being processed to complete;
If it is determined that there is nothing indicating the incomplete,
Determining whether the status is indicative of completion;
When it is determined that there is something indicating completion, the method includes a step of transmitting the processing result to the user, and a step of deleting the processing request and the processing result stored in the processing request storage unit.
前記処理要求にはジョブ処理の優先度情報が含まれていて、前記ジョブ処理部に非同期処理させ、前記処理結果を送信するステップは、前記優先度情報に基づき前記処理要求を前記ジョブ処理部に発行するステップをさらに含むことができる。 The processing request includes job processing priority information. The step of causing the job processing unit to perform asynchronous processing and transmitting the processing result includes sending the processing request to the job processing unit based on the priority information. The method may further include issuing.
本発明によれば、前記方法を、コンピュータに実行させるためのプログラムとして、さらにはそのプログラムを格納したコンピュータ可読な記録媒体として提供することもできる。 According to the present invention, the method can be provided as a program for causing a computer to execute the program, and further as a computer-readable recording medium storing the program.
本発明のシステム、方法、プログラムおよび記録媒体を提供することにより、時間を有するジョブの処理結果を待つことなく、他のジョブを実行することができる。 By providing the system, method, program, and recording medium of the present invention, it is possible to execute another job without waiting for the processing result of the job having time.
複数のユーザから処理要求が送信された場合でも、優先度が高いジョブから処理することができるため、割り込み処理を実現することができる。 Even when processing requests are transmitted from a plurality of users, it is possible to perform processing from a job having a high priority, so that interrupt processing can be realized.
例えば、文書登録や文書検索といった処理ごとに優先度を設けることで、システム負荷が小さい処理の優先度を上げ、負荷が大きい処理の優先度を下げ、システムを有効に利用することができる。 For example, by providing a priority for each process such as document registration or document search, the priority of a process with a small system load can be increased, the priority of a process with a large load can be decreased, and the system can be used effectively.
ユーザ毎の優先度を設定することで、例えば、役職者の処理を優先することができる。また、ユーザが自由に優先度を設定することもできる。さらには、ユーザに限らず、システムの管理者がユーザ毎の優先度を変更し、システムの負荷を調整することもできる。 By setting the priority for each user, for example, it is possible to give priority to the processing of the officer. In addition, the user can freely set the priority. Furthermore, not only the user but also the system administrator can change the priority for each user and adjust the system load.
本発明を、図面を参照して詳細に説明するが、本発明は図面に示される実施形態に限定されるものではない。まず、図1を参照して、本発明のジョブ処理システムを含むネットワークシステムの構成を説明する。図1に示すネットワークシステム10は、インターネットやイントラネット等のネットワーク11と、ネットワーク11に接続され、ジョブ処理システムを実装する文書管理サーバ12と、同じくネットワーク11に接続され、ネットワーク11を介して文書管理サーバ12と通信する複数のクライアント13とから構成されている。ここでは、文書ファイルを管理する文書管理サーバ12と複数のクライアント13として構成したネットワークシステム10を開示する。
The present invention will be described in detail with reference to the drawings, but the present invention is not limited to the embodiments shown in the drawings. First, a configuration of a network system including a job processing system of the present invention will be described with reference to FIG. A
文書管理サーバ12は、クライアント13からの処理要求を受信し、処理結果をクライアント13に返す。例えば、作成した文書を文書ファイルとして登録する処理、登録された文書ファイルを検索する処理、検索し、ダウンロードした文書の画像を変換する処理等の要求を受信し、その要求に対する処理を行い、その処理結果を返す。クライアント13は、ユーザによって入力される情報から上記のような要求を生成し、その要求を文書管理サーバ12に送信し、文書管理サーバ12からその処理結果を受信する。
The
クライアント13は、処理要求を生成および送信し、処理結果を受信することができるものであればいかなるものであってもよく、パーソナルコンピュータのほか、通信機能を備えるプリンタ、ファクシミリ装置、コピー装置、スキャナ装置、これらを含むデジタル複合機等とすることができる。文書管理サーバ12も同様のものを用いることができる。
The
詳細には、ネットワーク11を介して通信を行うために必要なネットワークアダプタ、モデム、プロキシサーバ等を含む通信装置、文書ファイルを記憶するために必要なメモリ、ハードディスクドライブ等の記憶装置、登録処理や検索処理を実行するプロセッサを含むものとされる。登録処理や検索処理は、プロセッサがプログラムを実行することによって行うことができ、このプログラムは、上記記憶装置に記憶され、必要に応じて読み出して実行される。
Specifically, a communication device including a network adapter, a modem, and a proxy server necessary for performing communication via the
図2を参照して、本発明のジョブ処理システムを詳細に説明する。図2に示すジョブ処理システム20は、図1に示す文書管理サーバに実装されるもので、システム負荷監視部21、閾値記憶部22、判定部23、ジョブ管理部24、処理要求記憶部25、優先度記憶部26、ジョブ処理部27、文書ファイル記憶部28、さらにはメッセージ送受信部29を含んで構成される。なお、ジョブ処理システムは、文書管理サーバ自体であってもよい。
The job processing system of the present invention will be described in detail with reference to FIG. A
システム負荷監視部21は、サーバの負荷を監視する。サーバ負荷は、プロセッサ使用率、メモリ使用率、サーバに接続しているユーザ数、サーバに対する基本操作のレスポンスタイム等から得ることができる。例えば、プロセッサ使用率やメモリ使用率は、オペレーティングシステム上で実行されるシステムモニタによって監視することができる。基本操作のレスポンスタイムは、例えば、文書管理クライアントからのログイン操作(ユーザIDおよびパスワードの送信)に対し、ユーザIDおよびパスワードを受信し、それらが一致するか照合し、ログインした旨の通知あるいはログインできない旨の通知を返すまでの応答時間とすることができる。
The system
閾値記憶部22は、サーバ負荷に関する閾値を記憶する。プロセッサ使用率、メモリ使用率に対しては、例えば70%、ユーザ数に対しては、例えば30ユーザ、レスポンスタイムに対しては、例えば5分といったデータを閾値として記憶する。これらの値は、サーバの管理者において適切な値を設定することができる。また、これらのほか、サーバの負荷が経験的に高くなる時間帯を含めることもできる。本発明では、これらすべての閾値を超えない、閾値の範囲を満足する場合に、リアルタイム処理することもできるし、特定の閾値のみを判断して、同期処理するか、非同期処理するかを決定することもできる。この閾値記憶部22は、上記メモリやハードディスクドライブの一部として構成することができる。
The
図2に示す実施形態では、処理要求や処理結果を送受信するメッセージ送受信部29を備えている。メッセージ送受信部29は、上記通信装置に相当するものである。メッセージ送受信部29は、上記のユーザIDおよびパスワードの受信、ログイン通知のほか、文書登録や文書検索等の処理要求を受信し、その処理要求に対する処理結果を送信する。
In the embodiment shown in FIG. 2, a message transmission /
ここで、図3に処理要求を、図4に閾値記憶部22のデータ構造を例示し、これらについて詳細に説明する。処理要求は、処理要求を識別するための処理要求IDフィールド300と、処理要求を送信したクライアントの位置情報フィールド301と、処理要求の実行優先順位を示す優先度フィールド302と、ジョブ内容フィールド303とを含んで構成される。処理要求IDフィールド300には、クライアントが処理要求を識別するための情報が含まれる。クライアントの位置情報フィールド301には、IPアドレスやMac(Media access control )アドレス等の位置情報が含まれる。この位置情報を使用して、処理結果を適切なクライアントに返すことができる。
Here, FIG. 3 illustrates a processing request, and FIG. 4 illustrates a data structure of the
優先度フィールド302には、ユーザが設定した優先度情報で、例えば、「高」、「中」、「低」といった3段階で示されるいずれかの情報が含まれる。ジョブ内容フィールド303には、文書登録や文書検索といった処理内容を示す情報が含まれる。文書登録であれば、文書登録であることを示す情報、文書名、文書ファイルを含み、文書検索であれば、文書検索であることを示す情報、文書名等の検索キーワードを含む。
The
閾値記憶部22のデータ構造は、各条件を識別する条件IDフィールド400と、判定条件フィールド401と、閾値フィールド402と、処理方式フィールド403とを含む構成とされる。条件IDフィールド400には、条件を識別することができる識別情報が含まれ、図4に示すように「1」、「2」、…といった番号とすることができる。判定条件フィールド401には、サーバ負荷の条件を示すもので、「CPU使用率が閾値を超えたか」、「サーバ接続ユーザ数が閾値を超えたか」といった条件が含まれる。その他、時間帯を閾値として用いる場合には、「閾値の時間帯か」といった条件、優先度を用いる場合には、「優先度が閾値か」といった条件を含めることもできる。
The data structure of the threshold
閾値フィールド402には、同期処理するか、非同期処理するかを決定するために使用される設定値が含まれる。この設定値は、サーバの管理者が適宜設定することができ、図4に示すようにCPU使用率であれば70%、ユーザ数であれば30ユーザと設定することができる。時間帯は、例えば、サーバへのアクセスが多い10時〜15時とすることができる。また、優先度を用いる場合には、例えば、「高」と設定することができる。処理方式フィールド403には、同期処理(リアルタイム処理)か、非同期処理かが設定され、その情報が格納される。
The
再び図2を参照すると、判定部23は、メッセージ送受信部29が受信した処理要求を受け取り、システム負荷監視部21と閾値記憶部22とにアクセスする。システム負荷監視部21からは、処理要求の受け取り時におけるプロセッサ使用率、メモリ使用率、ユーザ数等のサーバ負荷に関する負荷情報を取得する。また、閾値記憶部22からは、プロセッサ使用率、メモリ使用率、ユーザ数等の閾値を読み出して取得する。判定部23は、システム負荷監視部21から取得したサーバ負荷情報と、閾値とを比較し、閾値を超えるか否かを判定する。
Referring to FIG. 2 again, the
この判定で閾値を超える場合には、現在のサーバ負荷は大きいため、その処理要求は非同期、例えば、後にサーバ負荷が小さくなったときに処理され、閾値を超えない場合には、現在のサーバ負荷は小さいため、その処理要求は同期、すなわちリアルタイムに処理される。 If the threshold is exceeded in this determination, the current server load is large. Therefore, the processing request is processed asynchronously, for example, when the server load is later reduced, and if the threshold is not exceeded, the current server load is processed. Is small, the processing request is processed synchronously, that is, in real time.
ジョブ管理部24は、判定部23が閾値を超えると判定した場合に、処理要求を受け取り、処理要求記憶部25に記憶する。ここでは、処理要求記憶部25が、ジョブ管理部24とは別に構成されているが、ジョブ管理部24に含まれていてもよく、この場合、ジョブ管理部24が処理要求を保持することができる。このジョブ管理部24は、処理要求の記憶とともに、メッセージ送受信部29に処理要求を受け付けたことを示す受付メッセージを送る。処理要求記憶部25は、待ち行列とされ、一般に先に入れられたジョブを先に処理するように、処理要求をジョブ処理部27に送る。図2に示す実施形態では、ジョブに関連して優先度が予め設定され、その優先度に関する優先度情報が優先度記憶部26に記憶されている。この優先度記憶部26も、ジョブ管理部24に含まれていてもよく、優先度を保持することができる。なお、この優先度記憶部26および処理要求記憶部25も、閾値記憶部22と同様、上記のメモリおよびハードディスクドライブの一部として構成することができる。
When the
ここで、図5を参照して、処理要求記憶部25のデータ構造を説明する。処理要求記憶部25は、ジョブIDフィールド500と、ジョブの優先度フィールド501と、ステータスフィールド502と、クライアント名フィールド503と、処理要求フィールド504と、処理結果フィールド505とを含むテーブルとして構成される。判定部23が閾値を超えると判定したことを受けて、ジョブ管理部24が処理要求を順に受け取り、その順にジョブIDが関連付けられ、ジョブIDフィールド500に格納される。ジョブIDはジョブを識別することができるジョブ番号とすることができる。図5に示す実施形態では、ジョブ番号97〜100に設定され、これらジョブが処理結果の送信待ち、および、処理待ちしている。
Here, the data structure of the processing
優先度フィールド501には、ジョブの優先度に応じて「高」、「中」、「低」という3段階で示される情報が格納される。ステータスフィールド502には、ジョブが完了したか、処理中であるか、未完了であるかを示す情報が格納される。ジョブ処理部27に発行されていない処理要求はすべて未完了ジョブである。ステータスフィールド502中のステータスは、処理中を示すジョブの処理が終了すると、完了を示す情報に変更され、未完了を示すジョブの処理が開始されると、処理中を示す情報に変更される。クライアント名フィールド503には、サーバと通信しているクライアントを識別するための識別情報が格納される。図5に示す実施形態ではクライアント名とされているが、IPアドレスや、Macアドレス等であってもよい。なお、クライアント名には、IPアドレスや、Macアドレス等の位置情報が関連付けられる。
The
処理要求フィールド504には、検索、登録といったジョブ内容を示す情報が格納される。図5に示す実施形態では、ジョブ番号97に設定された処理要求が、検索処理を要求し、検索キーワードとして「議事録」を用いて検索するよう要求している。また、ジョブ番号98に設定された処理要求は、登録処理を要求し、文書名を「XXXX」としてファイル「YYYY」を記憶するよう要求している。処理結果フィールド505には、ジョブ処理部27に処理要求が発行され、処理された結果が格納される。ジョブ番号97のジョブは、ステータスフィールド502に格納される情報が完了を示しているため、処理結果フィールド505に処理結果が格納されている。その他のジョブは、ステータスフィールド502中のステータスが処理中または未完了であるため、処理結果は格納されておらず、空欄とされている。ジョブ番号97の処理結果には、関連する文書ファイルが3件ヒットしたことを示す「結果3件ヒット…」という情報が格納されている。
The
再び図2を参照すると、ジョブ管理部24は、優先度記憶部26を参照しつつ、処理要求記憶部25から処理要求を順に取り出し、ジョブ処理部27に発行する。処理要求記憶部25は、上記のように、先に入れられたジョブを先に処理する待ち行列とされているが、ジョブ管理部24は、優先度記憶部26を参照して優先度が高いジョブを優先的に取り出し、ジョブ処理部27に発行する。優先度記憶部26は、処理要求に優先度に関する情報が含まれている場合には、ジョブ管理部24による処理要求の記憶の際に、ジョブ管理部24がその優先度情報を取り出し、処理要求に関連付けて記憶する。また、ユーザが、文書登録や文書検索といったジョブの種類によって優先度を予め設定し、それをジョブに関連付けて優先度記憶部26に記憶しておくこともできる。ユーザが決定し、予め設定するのではなく、優先度決定部を備えていてもよい。この優先度決定部は、ジョブの種類によって優先度を決定するように設定しており、ジョブ管理部24が処理要求を処理要求記憶部25に記憶する際、あるいは、ジョブ処理部27に発行する際、各処理要求の優先度を決定し、その優先度に応じてジョブ処理部27に発行することができる。
Referring to FIG. 2 again, the
また、優先度記憶部26は、ユーザ毎の優先度を記憶することもでき、これにより、一般職の社員の処理要求に比較して管理職の社員の処理要求を、管理職の社員の処理要求に比較して役員の処理要求を優先的に処理することができる。さらに、ユーザが自由に優先度を決定してもよく、処理要求とは別に、優先度設定情報を送信し、優先度決定部が、その優先度設定情報を受け取り、その情報に基づいて優先度を決定し、優先度記憶部26に記憶することができる。また、ユーザではなく、ジョブ処理システムを実装する文書管理サーバの管理者が優先度を変更することもでき、この場合、優先度変更部を備えており、管理者による優先度変更情報の入力に応答して、優先度変更部が優先度を変更し、その優先度を優先度記憶部26に記憶する。
Further, the
優先度は、優先度が高いものから、「高」、「中」、「低」と設定することができる。すなわち、優先度が「高」のジョブは、「中」や「低」のジョブに比較して優先的に処理され、「中」のジョブは、「低」のジョブに比較して優先的に処理される。例えば、同じ「中」であるものは、処理要求記憶部25に先に入れられた順に処理される。本発明では、優先度の設定値はこの3段階のものに限られるものではなく、「高高」、「高」、「中」、「低」、「低低」といった5段階であってもよいし、「10」…「1」の10段階であってもよい。
The priority can be set to “high”, “medium”, and “low” from the highest priority. In other words, a job with a high priority is processed preferentially compared to a medium or low job, and a medium job is preferentially compared to a low job. It is processed. For example, the same “medium” items are processed in the order in which they are first placed in the processing
図6を参照して、優先度記憶部26のデータ構造について説明する。優先度記憶部26は、対象フィールド600と、優先度フィールド601とを含む。対象フィールド600には、クライアント名やジョブ内容等が含まれ、それらに応じて「高」、「中」、「低」といった情報が、優先度フィールド601に格納される。具体的には、図6に示すように、対象フィールド600には、クライアント名であるユーザA、ユーザB、ジョブ内容である文書登録、文書検索が格納される。図6に示す実施形態では、ユーザAが処理要求を送信した場合には、優先度が「高」であるため、優先的に処理が行われ、ユーザBが処理要求を送信した場合には、優先度が「低」であるため、優先度「高」、「中」の処理要求が処理された後に処理される。また、文書登録は「低」で、文書検索が「中」に設定されているため、処理要求に文書検索を含むものは、処理要求に文書登録を含むものより先に処理される。なお、対象フィールド600に、ユーザA、ユーザBといったクライアント名が先に設定されているため、優先度が同じ、例えば「高」のものは、ジョブ内容の優先度に応じて優先順位が決定される。
The data structure of the
再び図2を参照すると、判定部23が閾値を超えないと判定した場合、判定部23がメッセージ送受信部29に指示し、ジョブ処理部27は、メッセージ送受信部29から処理要求を受け取る。処理要求を受け取ったジョブ処理部27は、その処理要求をリアルタイムに処理する。ジョブ処理部27は、文書ファイル記憶部28と接続され、ジョブが文書検索であれば、処理要求に含まれるキーワード等に関連する文書ファイルを文書ファイル記憶部28から検索する。ジョブ処理部27は、処理した結果、ここでは検索結果をメッセージ送受信部29に送信する。メッセージ送受信部29は、検索結果を受け取ると、処理要求に含まれるクライアントの位置情報に基づき、その検索結果を送信する。検索結果としては、関連する文書ファイルの数、それらのファイル名や文書名、文書ファイルとすることができる。検索結果として文書名を送信し、次に、ダウンロード要求を受けて、文書ファイルを送信することもできる。
Referring to FIG. 2 again, when the
ジョブ処理部27は、上記のリアルタイム処理のほか、ジョブ管理部24からの処理要求の発行に応答して、発行された処理要求を処理する。ジョブ管理部24の処理要求の発行は、サーバ負荷に応じて実施され、その負荷が閾値を超えないときに実行される。したがって、サーバ負荷が、閾値記憶部22に記憶されている閾値を超えない場合に実行される。
In addition to the real-time processing described above, the
なお、記憶装置に記憶されたプログラムをプロセッサに実行させることで、システム負荷監視部21、判定部23、ジョブ管理部24、ジョブ処理部27として機能させることができる。
In addition, by causing the processor to execute a program stored in the storage device, the system
次に、図7を参照して、ジョブ処理システムが実行する処理の1つの実施形態を説明する。まず、ユーザが文書管理クライアントに検索キーワードを入力するなどして、検索処理等の処理要求を生成させる。ユーザが送信ボタンを押下するなどして文書管理サーバに処理要求を送信することにより、文書管理サーバは処理要求の処理を開始する(S700)。文書管理サーバに実装される、または、文書管理サーバ自体とされるジョブ処理システムは、メッセージ送受信部29でクライアントが送信した処理要求を受信する(S701)。メッセージ送受信部29は、判定部23に処理要求を受信した旨を通知し、判定部23は、システム負荷監視部21から現在のサーバ負荷に関する負荷情報を取得し、閾値記憶部22から閾値を読み出す(S702)。サーバ負荷に関する負荷情報は、現在のCPU使用率、メモリ使用率、サーバに接続しているユーザ数等である。
Next, an embodiment of processing executed by the job processing system will be described with reference to FIG. First, a user inputs a search keyword to the document management client, and generates a processing request such as search processing. When the user transmits a processing request to the document management server by pressing a transmission button or the like, the document management server starts processing the processing request (S700). The job processing system implemented in the document management server or the document management server itself receives the processing request transmitted from the client by the message transmission / reception unit 29 (S701). The message transmission /
判定部23は、取得した現在のサーバの負荷情報と、閾値とを比較し、サーバ負荷が閾値を超えているか否かを判定する(S703)。超えている場合は、非同期処理が選択され、超えていない場合は、同期処理が選択される。このようにして非同期処理が実行されるか否かが判定される。非同期処理が実行される場合、ジョブ管理部24に処理要求を送り、処理要求記憶部25に処理要求を記憶する(S704)。処理要求には、ジョブIDが関連付けられ、クライアント名フィールドにクライアントに関する情報が格納され、ステータスフィールドに未完了を示す情報が格納される。ジョブ管理部24は、処理要求を受け付けたことを示す受付メッセージを生成し、ジョブIDとともにメッセージ送受信部29に送る。ジョブIDは、ジョブを識別するための識別情報で、1つのクライアントが複数の処理要求を送信した場合に、それら処理要求に対する処理結果を識別するために用いられる。メッセージ送受信部29は、その受付メッセージをジョブIDとともにクライアントに送信する(S705)。
The
非同期処理が実行されない場合、処理要求がジョブ処理部27に送られ、ジョブ処理部27がリアルタイム処理し、処理した結果をメッセージ送受信部29に送る(S706)。メッセージ送受信部29は、受け取った処理結果を、クライアントを送信する(S707)。受付メッセージまたは処理結果をクライアントが受信することにより、クライアントが送信した処理要求に対する処理が終了する(S708)。この場合、リアルタイムに処理されるため、ジョブを識別するためのジョブIDは特に関連付ける必要はないが、処理要求IDとともに送信することもできる。
When the asynchronous processing is not executed, a processing request is sent to the
図8を参照して、図7に示すS704およびS705で実行される非同期処理を詳細に説明する。非同期処理で実行することが決定されると、非同期処理が開始される(S800)と、ジョブ管理部24は、処理要求記憶部25を定期的にポーリングし、ステータスを確認する(S801)。ポーリングは、処理要求が処理要求記憶部25に記憶されているかどうかを問い合わせるものである。ポーリングで、処理要求が記憶されている場合、処理要求に関連付けて記憶されるステータスを確認する。
With reference to FIG. 8, the asynchronous processing executed in S704 and S705 shown in FIG. 7 will be described in detail. When it is decided to execute the asynchronous process, the asynchronous process is started (S800), and the
ステータスが「未完了」のものがあるか否かを判定する(S802)。「未完了」がない場合には、ステータスが「完了」のものがあるか否かを判定する(S803)。ステータスは、処理が実行されていない「未完了」、現在、処理が実行されている「処理中」、処理が実行され、終了した「完了」のいずれかである。「未完了」のものがある場合、「未完了」の処理要求を取り出し、ジョブ処理部27にその処理要求を発行する(S804)。ジョブ処理部27は、非同期、すなわちリアルタイムではなく、例えば、後のサーバ負荷が閾値を超えないときにその処理要求の処理を開始する(S805)。処理を開始すると、ジョブ管理部24は、処理要求記憶部25のその処理要求に対応するステータスを、「未完了」から「処理中」に変更する(S806)。破線で示されるように、ジョブ処理部27は非同期にジョブを実行し(S807)、結果をジョブ管理部24に送る。ジョブ管理部24は、その結果を処理要求記憶部25の処理結果として記憶し、ステータスを「処理中」から「完了」に変更する(S808)。
It is determined whether or not there is a status of “incomplete” (S802). If there is no “incomplete”, it is determined whether there is a status of “completed” (S803). The status is one of “incomplete” in which the process is not executed, “in process” in which the process is currently executed, and “completed” in which the process is executed and completed. If there is an “incomplete” item, an “incomplete” processing request is taken out and issued to the job processing unit 27 (S804). The
S803で、ステータスが「完了」のものがない場合、非同期処理は終了する(S809)。非同期処理が終了しても、ジョブ管理部24は、S801のポーリングを定期的に行う。ステータスが「未完了」のものがある場合、S804へ進み、ない場合、S803へ進み、それぞれの処理が繰り返される。この間、処理中のジョブが終了すると、S808のように処理結果が記憶され、ステータスが「完了」に変更される。
If no status is “completed” in S803, the asynchronous process ends (S809). Even after the asynchronous processing is completed, the
S803で、ステータスが「完了」のものがある場合、ジョブ管理部24は、処理要求記憶部25から処理結果を取り出し、その処理結果をクライアントに返すために、ジョブIDとともにメッセージ送受信部29に送る(S810)。メッセージ送受信部29は、その処理結果を受け取ると、クライアントの位置情報に基づき処理結果を、その処理要求を送信したクライアントに送信する(S811)。メッセージ送受信部29がクライアントに処理結果を送信したことに応答して、ジョブ管理部24は、処理要求記憶部25に記憶されたその処理要求に関するジョブID、ステータス、クライアント名、処理要求、処理結果を削除する(S812)。
If the status is “complete” in S803, the
図9を参照して、ジョブ処理システムが実行する処理の別の実施形態について説明する。クライアントが処理要求を開始し(S900)、メッセージ送受信部29が処理要求を受信する(S901)。メッセージ送受信部29は、判定部23に処理要求を受信した旨を通知し、判定部23は、システム負荷監視部21から現在のサーバ負荷に関する負荷情報を取得し、閾値記憶部22から閾値を読み出す(S902)。判定部23は、取得した現在のサーバの負荷情報と、閾値とを比較し、サーバ負荷が閾値を超えているか否かを判定する(S903)。超えている場合は、非同期処理が選択され、超えていない場合は、同期処理が選択される。このようにして非同期処理が実行されるか否かが判定される。非同期処理が実行される場合、ジョブ管理部24に処理要求を送り、処理要求記憶部25に処理要求を記憶する(S904)。処理要求には、ジョブIDが関連付けられ、クライアント名フィールドにクライアントに関する情報が格納され、ステータスフィールドに未完了を示す情報が格納される。この実施形態では、優先度情報も優先度フィールドに格納される。優先度情報は、処理要求に含まれるか、優先度決定部により決定されるか、ユーザまたは管理者が入力することにより、ジョブ管理部24が取得することができる。ジョブ管理部24は、処理要求を受け付けたことを示す受付メッセージを生成し、受付メッセージをジョブIDとともにメッセージ送受信部29に送る。メッセージ送受信部29は、その受付メッセージをジョブIDとともにクライアントに送信する(S905)。
With reference to FIG. 9, another embodiment of processing executed by the job processing system will be described. The client starts a processing request (S900), and the message transmission /
非同期処理が実行されない場合、処理要求がジョブ処理部27に送られ、ジョブ処理部27が処理し、その結果をメッセージ送受信部29に送る(S906)。メッセージ送受信部29は、受け取った処理結果を、クライアントを送信する(S907)。受付メッセージまたは処理結果をクライアントが受信することにより、クライアントが送信した処理要求に対する処理が終了する(S908)。
When the asynchronous processing is not executed, a processing request is sent to the
図10を参照して、図9に示すS904およびS905で実行される非同期処理を詳細に説明する。非同期処理で実行することが決定され、非同期処理が開始される(S1000)と、ジョブ管理部24は、処理要求記憶部25を定期的にポーリングし、ステータスを確認する(S1001)。ここでは優先度を含むため、優先度が「高」、「中」、「低」の順に、ステータスを確認する。
With reference to FIG. 10, the asynchronous process executed in S904 and S905 shown in FIG. 9 will be described in detail. When it is decided to execute asynchronous processing and asynchronous processing is started (S1000), the
後の処理は、図8に示すフローチャートと同様である。すなわち、ステータスが「未完了」のものがあるか否かを判定する(S1002)。「未完了」がない場合には、ステータスが「完了」のものがあるか否かを判定する(S1003)。ステータスは、処理が実行されていない「未完了」、現在、処理が実行されている「処理中」、処理が実行され、終了した「完了」のいずれかである。「未完了」のものがある場合、「未完了」の処理要求を取り出し、ジョブ処理部27にその処理要求を発行する(S1004)。ここで、取り出される処理要求は、優先度の順に取り出される。このため、優先度が高いジョブは、処理要求記憶部25に、後に記憶されるものの、先に処理され、割り込み処理が実現される。
The subsequent processing is the same as the flowchart shown in FIG. That is, it is determined whether there is a status of “incomplete” (S1002). If there is no “incomplete”, it is determined whether there is a status of “completed” (S1003). The status is one of “incomplete” in which the process is not executed, “in process” in which the process is currently executed, and “completed” in which the process is executed and completed. If there is an “incomplete” item, an “incomplete” processing request is taken out and issued to the job processing unit 27 (S1004). Here, the extracted processing requests are extracted in order of priority. For this reason, although a job having a high priority is stored in the processing
ジョブ処理部27は、非同期、すなわちリアルタイムではなく、例えば、後のサーバ負荷が閾値を超えないときにその処理要求の処理を開始する(S1005)。処理を開始すると、ジョブ管理部24は、処理要求記憶部25のその処理要求に対応するステータスを、「未完了」から「処理中」に変更する(S1006)。破線で示されるように、ジョブ処理部27は非同期にジョブを実行し(S1007)、結果をジョブ管理部24に送る。ジョブ管理部24は、その結果を処理要求記憶部25の処理結果として記憶し、ステータスを「処理中」から「完了」に変更する(S1008)。
The
S1003で、ステータスが「完了」のものがない場合、非同期処理は終了する(S1009)。非同期処理が終了しても、ジョブ管理部24は、S1001のポーリングを定期的に行う。ステータスが「未完了」のものがある場合、S1004へ進み、ない場合、S1003へ進み、それぞれの処理が繰り返される。この間、処理中のジョブが終了すると、S1008のように処理結果が記憶され、ステータスが「完了」に変更される。
If no status is “complete” in S1003, the asynchronous process ends (S1009). Even after the asynchronous processing is completed, the
S1003で、ステータスが「完了」のものがある場合、ジョブ管理部24は、処理要求記憶部25から処理結果を取り出し、その処理結果をクライアントに返すために、ジョブIDとともにメッセージ送受信部29に送る(S1010)。メッセージ送受信部29は、その処理結果を受け取ると、クライアントの位置情報に基づき処理結果を、その処理要求を送信したクライアントに送信する(S1011)。メッセージ送受信部29がクライアントに処理結果を送信したことに応答して、ジョブ管理部24は、処理要求記憶部25に記憶されたその処理要求に関するジョブID、ステータス、クライアント名、処理要求、処理結果を削除する(S1012)。
If the status is “complete” in S1003, the
これまで本発明を図面に示した実施の形態をもって説明してきたが、本発明は図面に示した実施の形態に限定されるものではなく、他の実施の形態、追加、変更、削除など、当業者が想到することができる範囲内で変更することができ、いずれの態様においても本発明の作用・効果を奏する限り、本発明の範囲に含まれるものである。 Although the present invention has been described with the embodiments shown in the drawings, the present invention is not limited to the embodiments shown in the drawings, and other embodiments, additions, modifications, deletions, etc. It can be changed within the range that can be conceived by a trader, and any embodiment is included in the scope of the present invention as long as the effects and effects of the present invention are exhibited.
また、ジョブの同期処理および非同期処理は、コンピュータ可読なプログラムを実行することにより実施することができる。この場合、そのプログラムを格納した記録媒体として提供することができる。 Further, the synchronous processing and asynchronous processing of jobs can be performed by executing a computer-readable program. In this case, it can be provided as a recording medium storing the program.
10…ネットワークシステム、11…ネットワーク、12…文書管理サーバ、13…クライアント、20…ジョブ処理システム、21…システム負荷監視部、22…閾値記憶部、23…判定部、24…ジョブ管理部、25…処理要求記憶部、26…優先度記憶部、27…ジョブ処理部、28…文書ファイル記憶部、29…メッセージ送受信部、300…処理要求IDフィールド、301…位置情報フィールド、302…優先度フィールド、303…ジョブ内容フィールド、400…条件IDフィールド、401…判定条件フィールド、402…閾値フィールド、403…処理方式フィールド、500…ジョブIDフィールド、501…優先度フィールド、502…ステータスフィールド、503…クライアント名フィールド、504…処理要求フィールド、505…処理結果フィールド、600…対象フィールド、601…優先度フィールド
DESCRIPTION OF
Claims (14)
前記システム負荷を監視するシステム負荷監視部と、
前記システム負荷に関する閾値を記憶する閾値記憶部と、
ユーザからのジョブ内容を含む処理要求の受信に応答して、前記システム負荷監視部から負荷情報を取得し、前記閾値記憶部から前記閾値を読み出し、前記負荷情報が前記閾値を超えるか否かを判定する判定部と、
前記閾値を超えるとの判定に応答して、前記処理要求を保持し、前記処理要求を受け付けたことを示す受付メッセージを前記ユーザに対して送信するジョブ管理部と、
前記閾値を超えないとの判定に応答して、前記処理要求を前記ジョブ内容に基づいて処理し、処理結果を前記ユーザに対して送信するジョブ処理部とを含み、
前記ジョブ管理部は、保持した前記処理要求を前記ジョブ処理部に発行して前記ジョブ処理部に非同期処理させ、前記ジョブ処理部から前記処理結果を受け取り、前記ユーザに対して前記処理結果を送信する、ジョブ処理システム。 A job processing system that processes jobs according to system load,
A system load monitoring unit for monitoring the system load;
A threshold storage unit for storing a threshold related to the system load;
In response to receiving a processing request including a job content from a user, load information is acquired from the system load monitoring unit, the threshold value is read from the threshold value storage unit, and whether or not the load information exceeds the threshold value A determination unit for determining;
In response to the determination that the threshold is exceeded, the job management unit holds the processing request and transmits an acceptance message indicating that the processing request has been accepted to the user;
In response to the determination that the threshold value is not exceeded, a job processing unit that processes the processing request based on the job content and transmits a processing result to the user,
The job management unit issues the held processing request to the job processing unit, causes the job processing unit to perform asynchronous processing, receives the processing result from the job processing unit, and transmits the processing result to the user A job processing system.
ユーザからのジョブ内容を含む処理要求の受信に応答して、前記システムが備える判定部が、前記システム負荷監視部から前記負荷情報を取得し、前記閾値記憶部から前記閾値を読み出し、前記負荷情報が前記閾値を超えるか否かを判定するステップと、
前記閾値を超えないとの判定に応答して、前記システムが備えるジョブ処理部が、前記処理要求を前記ジョブ内容に基づいて処理し、処理結果を前記ユーザに対して送信するステップと、
前記閾値を超えるとの判定に応答して、前記システムが備えるジョブ管理部が、前記処理要求を処理要求記憶部に記憶し、前記処理要求を受け付けたことを示す受付メッセージを前記ユーザに対して送信するステップと、
前記ジョブ管理部が、前記処理要求記憶部に記憶した前記処理要求を前記ジョブ処理部に非同期処理させ、処理結果を受け取り、前記ユーザに対して前記処理結果を送信するステップと
を含む、ジョブ処理方法。 A job processing method for processing a job according to a system load, wherein the system monitors a load information of the system by a system load monitoring unit, and a threshold storage unit stores a threshold of the load information of the system ,
In response to receiving a processing request including a job content from a user, a determination unit included in the system acquires the load information from the system load monitoring unit, reads the threshold value from the threshold storage unit, and loads the load information. Determining whether or not exceeds the threshold;
In response to the determination that the threshold is not exceeded, a job processing unit included in the system processes the processing request based on the job content, and transmits a processing result to the user;
In response to the determination that the threshold is exceeded, the job management unit included in the system stores the processing request in the processing request storage unit, and receives an acceptance message indicating that the processing request has been accepted to the user. Sending, and
The job management unit including causing the job processing unit to asynchronously process the processing request stored in the processing request storage unit, receiving a processing result, and transmitting the processing result to the user. Method.
前記ジョブ処理部に非同期処理させ、前記処理結果を送信するステップは、
前記ステータスが未完了を示すものがあるか否かを判定するステップと、
前記未完了を示すものがあると判定した場合、
前記処理要求記憶部から未完了であることを示す前記ステータスに関連付けられた前記処理要求を読み出し、該処理要求を非同期処理するステップと、
前記処理要求に関連付けられた前記ステータスを未完了から処理中に変更するステップと、
前記非同期処理が終了したことに応答して、前記処理結果を受け取り、前記処理要求記憶部に該処理結果を記憶し、前記ステータスを処理中から完了に変更するステップと、
前記未完了を示すものがないと判定した場合、
前記ステータスが完了を示すものがあるか否かを判定するステップと、
前記完了を示すものがあると判定した場合、前記ユーザに対して前記処理結果を送信するステップと、前記処理要求記憶部に記憶された前記処理要求および前記処理結果を削除するステップとを含む、請求項10に記載のジョブ処理方法。 The step of transmitting the acceptance message includes the step of associating the processing request with a status indicating whether the processing is completed, being processed, or incomplete, and storing the status in the processing request storage unit.
The step of asynchronously processing the job processing unit and transmitting the processing result includes:
Determining whether there is an incomplete status.
If it is determined that there is something indicating the incomplete,
Reading the processing request associated with the status indicating incomplete from the processing request storage unit, and asynchronously processing the processing request;
Changing the status associated with the processing request from incomplete to processing;
In response to the completion of the asynchronous processing, receiving the processing result, storing the processing result in the processing request storage unit, and changing the status from being processed to complete;
If it is determined that there is nothing indicating the incomplete,
Determining whether the status is indicative of completion;
If it is determined that there is an indication of completion, the step of transmitting the processing result to the user, and the step of deleting the processing request and the processing result stored in the processing request storage unit, The job processing method according to claim 10.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2006128261A JP2007299308A (en) | 2006-05-02 | 2006-05-02 | Job processing system, job processing method, program, and recording medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2006128261A JP2007299308A (en) | 2006-05-02 | 2006-05-02 | Job processing system, job processing method, program, and recording medium |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| JP2007299308A true JP2007299308A (en) | 2007-11-15 |
Family
ID=38768733
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2006128261A Pending JP2007299308A (en) | 2006-05-02 | 2006-05-02 | Job processing system, job processing method, program, and recording medium |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP2007299308A (en) |
Cited By (21)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2009009477A (en) * | 2007-06-29 | 2009-01-15 | Toshiba Corp | Apparatus, method, and program for processing information by controlling calculation method |
| JP2009269292A (en) * | 2008-05-08 | 2009-11-19 | Ricoh Co Ltd | Image forming apparatus, image forming method, image forming control program, and recording medium |
| JP2009282577A (en) * | 2008-05-19 | 2009-12-03 | Nomura Research Institute Ltd | Job management apparatus |
| JP2013099951A (en) * | 2012-12-27 | 2013-05-23 | Ricoh Co Ltd | Image forming apparatus, image formation control method, image formation control program, and recording medium |
| CN104520822A (en) * | 2012-08-08 | 2015-04-15 | 亚马逊技术股份有限公司 | Data storage application programming interface |
| JP2015534142A (en) * | 2012-08-08 | 2015-11-26 | アマゾン テクノロジーズ インコーポレイテッド | Archive data storage system |
| US9465821B1 (en) | 2012-08-08 | 2016-10-11 | Amazon Technologies, Inc. | Data storage integrity validation |
| JP2016224488A (en) * | 2015-05-27 | 2016-12-28 | 富士通フロンテック株式会社 | Order processing program, order processing device, and order processing method |
| US9563681B1 (en) | 2012-08-08 | 2017-02-07 | Amazon Technologies, Inc. | Archival data flow management |
| US9652487B1 (en) | 2012-08-08 | 2017-05-16 | Amazon Technologies, Inc. | Programmable checksum calculations on data storage devices |
| US9767129B2 (en) | 2012-08-08 | 2017-09-19 | Amazon Technologies, Inc. | Data storage inventory indexing |
| US9767098B2 (en) | 2012-08-08 | 2017-09-19 | Amazon Technologies, Inc. | Archival data storage system |
| US9779035B1 (en) | 2012-08-08 | 2017-10-03 | Amazon Technologies, Inc. | Log-based data storage on sequentially written media |
| US9830111B1 (en) | 2012-08-08 | 2017-11-28 | Amazon Technologies, Inc. | Data storage space management |
| US9904788B2 (en) | 2012-08-08 | 2018-02-27 | Amazon Technologies, Inc. | Redundant key management |
| US10120579B1 (en) | 2012-08-08 | 2018-11-06 | Amazon Technologies, Inc. | Data storage management for sequentially written media |
| US10558581B1 (en) | 2013-02-19 | 2020-02-11 | Amazon Technologies, Inc. | Systems and techniques for data recovery in a keymapless data storage system |
| JP2020024481A (en) * | 2018-08-06 | 2020-02-13 | 京セラドキュメントソリューションズ株式会社 | Processing execution system and processing execution program |
| JP2020170331A (en) * | 2019-04-03 | 2020-10-15 | 富士ゼロックス株式会社 | Information processing device and program |
| US11386060B1 (en) | 2015-09-23 | 2022-07-12 | Amazon Technologies, Inc. | Techniques for verifiably processing data in distributed computing systems |
| US12086450B1 (en) | 2018-09-26 | 2024-09-10 | Amazon Technologies, Inc. | Synchronous get copy for asynchronous storage |
-
2006
- 2006-05-02 JP JP2006128261A patent/JP2007299308A/en active Pending
Cited By (29)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2009009477A (en) * | 2007-06-29 | 2009-01-15 | Toshiba Corp | Apparatus, method, and program for processing information by controlling calculation method |
| JP2009269292A (en) * | 2008-05-08 | 2009-11-19 | Ricoh Co Ltd | Image forming apparatus, image forming method, image forming control program, and recording medium |
| JP2009282577A (en) * | 2008-05-19 | 2009-12-03 | Nomura Research Institute Ltd | Job management apparatus |
| US9779035B1 (en) | 2012-08-08 | 2017-10-03 | Amazon Technologies, Inc. | Log-based data storage on sequentially written media |
| US9904788B2 (en) | 2012-08-08 | 2018-02-27 | Amazon Technologies, Inc. | Redundant key management |
| JP2015531125A (en) * | 2012-08-08 | 2015-10-29 | アマゾン テクノロジーズ インコーポレイテッド | Data storage application programming interface |
| JP2015534142A (en) * | 2012-08-08 | 2015-11-26 | アマゾン テクノロジーズ インコーポレイテッド | Archive data storage system |
| US9465821B1 (en) | 2012-08-08 | 2016-10-11 | Amazon Technologies, Inc. | Data storage integrity validation |
| US12487984B2 (en) | 2012-08-08 | 2025-12-02 | Amazon Technologies, Inc. | Data storage application programming interface |
| US9563681B1 (en) | 2012-08-08 | 2017-02-07 | Amazon Technologies, Inc. | Archival data flow management |
| US9652487B1 (en) | 2012-08-08 | 2017-05-16 | Amazon Technologies, Inc. | Programmable checksum calculations on data storage devices |
| JP2017162485A (en) * | 2012-08-08 | 2017-09-14 | アマゾン テクノロジーズ インコーポレイテッド | Data storage application programming interface |
| US9767129B2 (en) | 2012-08-08 | 2017-09-19 | Amazon Technologies, Inc. | Data storage inventory indexing |
| US9767098B2 (en) | 2012-08-08 | 2017-09-19 | Amazon Technologies, Inc. | Archival data storage system |
| US10936729B2 (en) | 2012-08-08 | 2021-03-02 | Amazon Technologies, Inc. | Redundant key management |
| US9830111B1 (en) | 2012-08-08 | 2017-11-28 | Amazon Technologies, Inc. | Data storage space management |
| CN104520822A (en) * | 2012-08-08 | 2015-04-15 | 亚马逊技术股份有限公司 | Data storage application programming interface |
| US10120579B1 (en) | 2012-08-08 | 2018-11-06 | Amazon Technologies, Inc. | Data storage management for sequentially written media |
| US10157199B2 (en) | 2012-08-08 | 2018-12-18 | Amazon Technologies, Inc. | Data storage integrity validation |
| CN104520822B (en) * | 2012-08-08 | 2019-01-08 | 亚马逊技术股份有限公司 | Data Storage Application Programming Interface |
| US10698880B2 (en) | 2012-08-08 | 2020-06-30 | Amazon Technologies, Inc. | Data storage application programming interface |
| JP2013099951A (en) * | 2012-12-27 | 2013-05-23 | Ricoh Co Ltd | Image forming apparatus, image formation control method, image formation control program, and recording medium |
| US10558581B1 (en) | 2013-02-19 | 2020-02-11 | Amazon Technologies, Inc. | Systems and techniques for data recovery in a keymapless data storage system |
| JP2016224488A (en) * | 2015-05-27 | 2016-12-28 | 富士通フロンテック株式会社 | Order processing program, order processing device, and order processing method |
| US11386060B1 (en) | 2015-09-23 | 2022-07-12 | Amazon Technologies, Inc. | Techniques for verifiably processing data in distributed computing systems |
| JP2020024481A (en) * | 2018-08-06 | 2020-02-13 | 京セラドキュメントソリューションズ株式会社 | Processing execution system and processing execution program |
| JP7128443B2 (en) | 2018-08-06 | 2022-08-31 | 京セラドキュメントソリューションズ株式会社 | Process execution system and process execution program |
| US12086450B1 (en) | 2018-09-26 | 2024-09-10 | Amazon Technologies, Inc. | Synchronous get copy for asynchronous storage |
| JP2020170331A (en) * | 2019-04-03 | 2020-10-15 | 富士ゼロックス株式会社 | Information processing device and program |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| JP2007299308A (en) | Job processing system, job processing method, program, and recording medium | |
| CN1525305B (en) | Network system and client representation method of printing document | |
| US8330980B2 (en) | System, method, and apparatus for networked print management | |
| US20060007480A1 (en) | Output end notifying method, output control apparatus, control program, and storing medium | |
| US8582162B2 (en) | Information processing apparatus, output method, and storage medium | |
| JP5786835B2 (en) | Printing system, printing apparatus, control method therefor, and computer program | |
| US8610934B2 (en) | Information processing apparatus, control method for information processing apparatus, and storage medium for same | |
| JPH1124870A (en) | Control method for network printer | |
| JP2006235989A (en) | Network systems, devices, and programs | |
| JP6040878B2 (en) | Printing apparatus, printing control apparatus, printing system, and program | |
| JP2009223728A (en) | Data distribution apparatus and system, its error notification method and program, and storage medium recording the same | |
| JP5709377B2 (en) | Image forming apparatus, image forming apparatus control method and program | |
| JP4987770B2 (en) | Event notification device, event notification method, and event notification program | |
| JP5571911B2 (en) | Image processing apparatus, control method thereof, and program | |
| JP2009266088A (en) | Information processing apparatus, information processing method, program and recording medium | |
| JP5657062B2 (en) | Image forming apparatus, image forming apparatus control method, and program | |
| JP6021651B2 (en) | Management system, management method, and computer program | |
| JP4375869B2 (en) | server | |
| JP4616980B2 (en) | Printing management apparatus, printing management method, and recording medium storing printing management program | |
| JP2002209035A (en) | Image processing apparatus, information processing system, and data processing method | |
| JP2008072318A (en) | Setting information management system, device, setting information management apparatus, setting information acquisition program, setting information providing program, and recording medium | |
| JP4455523B2 (en) | Information processing system, information processing method, program, and storage medium | |
| JP6127586B2 (en) | Information processing system and information processing method | |
| JP2006285840A (en) | Document management system | |
| JP2007087186A (en) | Log collection system and method |