[go: up one dir, main page]

JP2007299308A - Job processing system, job processing method, program, and recording medium - Google Patents

Job processing system, job processing method, program, and recording medium Download PDF

Info

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
Application number
JP2006128261A
Other languages
Japanese (ja)
Inventor
Kazuyuki Ikenotani
和幸 池ノ谷
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Ricoh Co Ltd
Original Assignee
Ricoh Co Ltd
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by Ricoh Co Ltd filed Critical Ricoh Co Ltd
Priority to JP2006128261A priority Critical patent/JP2007299308A/en
Publication of JP2007299308A publication Critical patent/JP2007299308A/en
Pending legal-status Critical Current

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.

このシステムおよび方法では、サーバ負荷の少ない時間帯を指定すればサーバの負荷軽減を図ることができるものの、複数のユーザが「すぐに登録」を同じ時期に指定すると、この指定が重なり、サーバ負荷が大きくなる場合がある。また、このシステムでは、登録状況画面において、登録状況を確認し、登録を実行する処理が少ない時間帯を指定することができるものの、バックグラウンドで実行される登録処理以外の処理については確認することができないため、必ずしもサーバ負荷を軽減することはできない。
特開2002−259413号公報
In this system and method, the server load can be reduced by specifying a time zone with a low server load. However, if multiple users specify "Register Immediately" at the same time, this specification overlaps and the server load is reduced. May become larger. In this system, the registration status screen can be used to check the registration status and specify a time period when there is little processing to perform registration, but to confirm processing other than registration processing executed in the background. Therefore, the server load cannot always be reduced.
JP 2002-259413 A

すなわち、時間を要する文書ファイルの登録や検索等のジョブを実行した後に返される結果を待つことなく、他のジョブを処理することができるシステムや方法の提供が望まれていた。   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 network system 10 shown in FIG. 1 is connected to a network 11 such as the Internet or an intranet, a document management server 12 that is connected to the network 11 and implements a job processing system, and is also connected to the network 11 and manages documents via the network 11. It comprises a plurality of clients 13 that communicate with the server 12. Here, a network system 10 configured as a document management server 12 that manages document files and a plurality of clients 13 is disclosed.

文書管理サーバ12は、クライアント13からの処理要求を受信し、処理結果をクライアント13に返す。例えば、作成した文書を文書ファイルとして登録する処理、登録された文書ファイルを検索する処理、検索し、ダウンロードした文書の画像を変換する処理等の要求を受信し、その要求に対する処理を行い、その処理結果を返す。クライアント13は、ユーザによって入力される情報から上記のような要求を生成し、その要求を文書管理サーバ12に送信し、文書管理サーバ12からその処理結果を受信する。   The document management server 12 receives a processing request from the client 13 and returns a processing result to the client 13. For example, processing for registering a created document as a document file, processing for searching a registered document file, processing for searching and converting an image of a downloaded document, etc. are received, processing for that request is performed, Returns the processing result. The client 13 generates a request as described above from information input by the user, transmits the request to the document management server 12, and receives the processing result from the document management server 12.

クライアント13は、処理要求を生成および送信し、処理結果を受信することができるものであればいかなるものであってもよく、パーソナルコンピュータのほか、通信機能を備えるプリンタ、ファクシミリ装置、コピー装置、スキャナ装置、これらを含むデジタル複合機等とすることができる。文書管理サーバ12も同様のものを用いることができる。   The client 13 may be any client as long as it can generate and transmit a processing request and receive a processing result. In addition to a personal computer, the printer 13 includes a printer, a facsimile apparatus, a copying apparatus, and a scanner having a communication function. It can be a device, a digital multi-function peripheral including these, or the like. The same document management server 12 can be used.

詳細には、ネットワーク11を介して通信を行うために必要なネットワークアダプタ、モデム、プロキシサーバ等を含む通信装置、文書ファイルを記憶するために必要なメモリ、ハードディスクドライブ等の記憶装置、登録処理や検索処理を実行するプロセッサを含むものとされる。登録処理や検索処理は、プロセッサがプログラムを実行することによって行うことができ、このプログラムは、上記記憶装置に記憶され、必要に応じて読み出して実行される。   Specifically, a communication device including a network adapter, a modem, and a proxy server necessary for performing communication via the network 11, a memory necessary for storing a document file, a storage device such as a hard disk drive, registration processing, A processor that executes a search process is included. Registration processing and search processing can be performed by the processor executing a program, and the program is stored in the storage device and read and executed as necessary.

図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 job processing system 20 shown in FIG. 2 is implemented in the document management server shown in FIG. 1, and includes a system load monitoring unit 21, a threshold storage unit 22, a determination unit 23, a job management unit 24, a processing request storage unit 25, A priority storage unit 26, a job processing unit 27, a document file storage unit 28, and a message transmission / reception unit 29 are included. The job processing system may be the document management server itself.

システム負荷監視部21は、サーバの負荷を監視する。サーバ負荷は、プロセッサ使用率、メモリ使用率、サーバに接続しているユーザ数、サーバに対する基本操作のレスポンスタイム等から得ることができる。例えば、プロセッサ使用率やメモリ使用率は、オペレーティングシステム上で実行されるシステムモニタによって監視することができる。基本操作のレスポンスタイムは、例えば、文書管理クライアントからのログイン操作(ユーザIDおよびパスワードの送信)に対し、ユーザIDおよびパスワードを受信し、それらが一致するか照合し、ログインした旨の通知あるいはログインできない旨の通知を返すまでの応答時間とすることができる。   The system load monitoring unit 21 monitors the load on the server. The server load can be obtained from the processor usage rate, the memory usage rate, the number of users connected to the server, the response time of basic operations on the server, and the like. For example, the processor usage rate and the memory usage rate can be monitored by a system monitor executed on the operating system. The response time of the basic operation is, for example, for a login operation (transmission of user ID and password) from the document management client, receiving the user ID and password, checking whether they match, and notifying that the user has logged in or logging in It can be a response time until a notification that it is not possible is returned.

閾値記憶部22は、サーバ負荷に関する閾値を記憶する。プロセッサ使用率、メモリ使用率に対しては、例えば70%、ユーザ数に対しては、例えば30ユーザ、レスポンスタイムに対しては、例えば5分といったデータを閾値として記憶する。これらの値は、サーバの管理者において適切な値を設定することができる。また、これらのほか、サーバの負荷が経験的に高くなる時間帯を含めることもできる。本発明では、これらすべての閾値を超えない、閾値の範囲を満足する場合に、リアルタイム処理することもできるし、特定の閾値のみを判断して、同期処理するか、非同期処理するかを決定することもできる。この閾値記憶部22は、上記メモリやハードディスクドライブの一部として構成することができる。   The threshold storage unit 22 stores a threshold related to the server load. Data such as 70% for the processor usage rate and memory usage rate, for example 30 users for the number of users, and 5 minutes for the response time are stored as threshold values. These values can be set appropriately by the server administrator. In addition to these, it is possible to include a time period during which the load on the server is empirically high. In the present invention, when all the threshold values are not exceeded and the range of the threshold values is satisfied, real-time processing can be performed, or only a specific threshold value is determined to determine whether to perform synchronous processing or asynchronous processing. You can also. The threshold storage unit 22 can be configured as a part of the memory or hard disk drive.

図2に示す実施形態では、処理要求や処理結果を送受信するメッセージ送受信部29を備えている。メッセージ送受信部29は、上記通信装置に相当するものである。メッセージ送受信部29は、上記のユーザIDおよびパスワードの受信、ログイン通知のほか、文書登録や文書検索等の処理要求を受信し、その処理要求に対する処理結果を送信する。   In the embodiment shown in FIG. 2, a message transmission / reception unit 29 that transmits and receives a processing request and a processing result is provided. The message transmitting / receiving unit 29 corresponds to the communication device. The message transmission / reception unit 29 receives processing requests for document registration, document search, and the like in addition to receiving the above user ID and password and log-in notification, and transmits a processing result for the processing request.

ここで、図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 threshold storage unit 22, which will be described in detail. The processing request includes a processing request ID field 300 for identifying the processing request, a location information field 301 of the client that transmitted the processing request, a priority field 302 indicating the execution priority of the processing request, and a job content field 303. It is comprised including. The processing request ID field 300 includes information for the client to identify the processing request. The client location information field 301 includes location information such as an IP address and a Mac (Media access control) address. This location information can be used to return the processing result to the appropriate client.

優先度フィールド302には、ユーザが設定した優先度情報で、例えば、「高」、「中」、「低」といった3段階で示されるいずれかの情報が含まれる。ジョブ内容フィールド303には、文書登録や文書検索といった処理内容を示す情報が含まれる。文書登録であれば、文書登録であることを示す情報、文書名、文書ファイルを含み、文書検索であれば、文書検索であることを示す情報、文書名等の検索キーワードを含む。   The priority field 302 includes priority information set by the user, and includes, for example, any of three levels of information such as “high”, “medium”, and “low”. The job content field 303 includes information indicating processing content such as document registration and document search. For document registration, information indicating document registration, a document name, and a document file are included. For document search, information indicating document search, a search keyword such as a document name is included.

閾値記憶部22のデータ構造は、各条件を識別する条件IDフィールド400と、判定条件フィールド401と、閾値フィールド402と、処理方式フィールド403とを含む構成とされる。条件IDフィールド400には、条件を識別することができる識別情報が含まれ、図4に示すように「1」、「2」、…といった番号とすることができる。判定条件フィールド401には、サーバ負荷の条件を示すもので、「CPU使用率が閾値を超えたか」、「サーバ接続ユーザ数が閾値を超えたか」といった条件が含まれる。その他、時間帯を閾値として用いる場合には、「閾値の時間帯か」といった条件、優先度を用いる場合には、「優先度が閾値か」といった条件を含めることもできる。   The data structure of the threshold value storage unit 22 includes a condition ID field 400 for identifying each condition, a determination condition field 401, a threshold value field 402, and a processing method field 403. The condition ID field 400 includes identification information that can identify a condition, and can be numbers such as “1”, “2”,... As shown in FIG. The determination condition field 401 indicates a server load condition, and includes conditions such as “CPU usage rate exceeds a threshold value” and “Server connection user count exceeds a threshold value”. In addition, when a time zone is used as a threshold, a condition such as “whether it is a threshold time zone” or a priority such as “whether the priority is a threshold” can be included.

閾値フィールド402には、同期処理するか、非同期処理するかを決定するために使用される設定値が含まれる。この設定値は、サーバの管理者が適宜設定することができ、図4に示すようにCPU使用率であれば70%、ユーザ数であれば30ユーザと設定することができる。時間帯は、例えば、サーバへのアクセスが多い10時〜15時とすることができる。また、優先度を用いる場合には、例えば、「高」と設定することができる。処理方式フィールド403には、同期処理(リアルタイム処理)か、非同期処理かが設定され、その情報が格納される。   The threshold value field 402 includes a setting value used for determining whether to perform synchronous processing or asynchronous processing. This setting value can be set as appropriate by the server administrator. As shown in FIG. 4, the CPU usage rate can be set to 70%, and the number of users can be set to 30 users. The time zone can be set, for example, from 10:00 to 15:00 when there are many accesses to the server. Further, when the priority is used, for example, “high” can be set. In the processing method field 403, either synchronous processing (real-time processing) or asynchronous processing is set, and the information is stored.

再び図2を参照すると、判定部23は、メッセージ送受信部29が受信した処理要求を受け取り、システム負荷監視部21と閾値記憶部22とにアクセスする。システム負荷監視部21からは、処理要求の受け取り時におけるプロセッサ使用率、メモリ使用率、ユーザ数等のサーバ負荷に関する負荷情報を取得する。また、閾値記憶部22からは、プロセッサ使用率、メモリ使用率、ユーザ数等の閾値を読み出して取得する。判定部23は、システム負荷監視部21から取得したサーバ負荷情報と、閾値とを比較し、閾値を超えるか否かを判定する。   Referring to FIG. 2 again, the determination unit 23 receives the processing request received by the message transmission / reception unit 29 and accesses the system load monitoring unit 21 and the threshold storage unit 22. From the system load monitoring unit 21, load information related to the server load such as a processor usage rate, a memory usage rate, and the number of users when a processing request is received is acquired. Further, the threshold storage unit 22 reads and acquires thresholds such as the processor usage rate, the memory usage rate, and the number of users. The determination unit 23 compares the server load information acquired from the system load monitoring unit 21 with a threshold value, and determines whether or not the threshold value is exceeded.

この判定で閾値を超える場合には、現在のサーバ負荷は大きいため、その処理要求は非同期、例えば、後にサーバ負荷が小さくなったときに処理され、閾値を超えない場合には、現在のサーバ負荷は小さいため、その処理要求は同期、すなわちリアルタイムに処理される。   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 determination unit 23 determines that the threshold value is exceeded, the job management unit 24 receives a processing request and stores it in the processing request storage unit 25. Here, the processing request storage unit 25 is configured separately from the job management unit 24, but may be included in the job management unit 24. In this case, the job management unit 24 may hold the processing request. it can. The job management unit 24 sends a reception message indicating that the processing request has been received to the message transmission / reception unit 29 together with the storage of the processing request. The processing request storage unit 25 is queued, and generally sends a processing request to the job processing unit 27 so as to process a job that has been input first. In the embodiment shown in FIG. 2, priorities are preset in relation to jobs, and priority information related to the priorities is stored in the priority storage unit 26. The priority storage unit 26 may also be included in the job management unit 24, and can retain priority. The priority storage unit 26 and the processing request storage unit 25 can also be configured as a part of the memory and the hard disk drive, similarly to the threshold storage unit 22.

ここで、図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 request storage unit 25 will be described with reference to FIG. The processing request storage unit 25 is configured as a table including a job ID field 500, a job priority field 501, a status field 502, a client name field 503, a processing request field 504, and a processing result field 505. . When the determination unit 23 determines that the threshold value is exceeded, the job management unit 24 sequentially receives processing requests, and job IDs are associated in that order and stored in the job ID field 500. The job ID can be a job number that can identify the job. In the embodiment shown in FIG. 5, job numbers 97 to 100 are set, and these jobs are waiting for transmission of processing results and waiting for processing.

優先度フィールド501には、ジョブの優先度に応じて「高」、「中」、「低」という3段階で示される情報が格納される。ステータスフィールド502には、ジョブが完了したか、処理中であるか、未完了であるかを示す情報が格納される。ジョブ処理部27に発行されていない処理要求はすべて未完了ジョブである。ステータスフィールド502中のステータスは、処理中を示すジョブの処理が終了すると、完了を示す情報に変更され、未完了を示すジョブの処理が開始されると、処理中を示す情報に変更される。クライアント名フィールド503には、サーバと通信しているクライアントを識別するための識別情報が格納される。図5に示す実施形態ではクライアント名とされているが、IPアドレスや、Macアドレス等であってもよい。なお、クライアント名には、IPアドレスや、Macアドレス等の位置情報が関連付けられる。   The priority field 501 stores information indicated by three levels of “high”, “medium”, and “low” according to the priority of the job. The status field 502 stores information indicating whether the job is completed, being processed, or not completed. All processing requests that have not been issued to the job processing unit 27 are incomplete jobs. The status in the status field 502 is changed to information indicating completion when processing of a job indicating processing is completed, and is changed to information indicating processing when processing of a job indicating incomplete is started. The client name field 503 stores identification information for identifying the client communicating with the server. In the embodiment shown in FIG. 5, the client name is used, but it may be an IP address, a Mac address, or the like. The client name is associated with location information such as an IP address and a Mac address.

処理要求フィールド504には、検索、登録といったジョブ内容を示す情報が格納される。図5に示す実施形態では、ジョブ番号97に設定された処理要求が、検索処理を要求し、検索キーワードとして「議事録」を用いて検索するよう要求している。また、ジョブ番号98に設定された処理要求は、登録処理を要求し、文書名を「XXXX」としてファイル「YYYY」を記憶するよう要求している。処理結果フィールド505には、ジョブ処理部27に処理要求が発行され、処理された結果が格納される。ジョブ番号97のジョブは、ステータスフィールド502に格納される情報が完了を示しているため、処理結果フィールド505に処理結果が格納されている。その他のジョブは、ステータスフィールド502中のステータスが処理中または未完了であるため、処理結果は格納されておらず、空欄とされている。ジョブ番号97の処理結果には、関連する文書ファイルが3件ヒットしたことを示す「結果3件ヒット…」という情報が格納されている。   The processing request field 504 stores information indicating job contents such as search and registration. In the embodiment shown in FIG. 5, the processing request set in the job number 97 requests a search process and requests to search using “minutes” as a search keyword. The processing request set in the job number 98 requests registration processing, and requests to store the file “YYYY” with the document name “XXXX”. In the processing result field 505, a processing request is issued to the job processing unit 27 and the processing result is stored. Since the information stored in the status field 502 indicates completion for the job with the job number 97, the processing result is stored in the processing result field 505. For other jobs, the status in the status field 502 is being processed or has not been completed, so the processing result is not stored and is blank. The processing result of job number 97 stores information “result 3 hits ...” indicating that 3 related document files have been hit.

再び図2を参照すると、ジョブ管理部24は、優先度記憶部26を参照しつつ、処理要求記憶部25から処理要求を順に取り出し、ジョブ処理部27に発行する。処理要求記憶部25は、上記のように、先に入れられたジョブを先に処理する待ち行列とされているが、ジョブ管理部24は、優先度記憶部26を参照して優先度が高いジョブを優先的に取り出し、ジョブ処理部27に発行する。優先度記憶部26は、処理要求に優先度に関する情報が含まれている場合には、ジョブ管理部24による処理要求の記憶の際に、ジョブ管理部24がその優先度情報を取り出し、処理要求に関連付けて記憶する。また、ユーザが、文書登録や文書検索といったジョブの種類によって優先度を予め設定し、それをジョブに関連付けて優先度記憶部26に記憶しておくこともできる。ユーザが決定し、予め設定するのではなく、優先度決定部を備えていてもよい。この優先度決定部は、ジョブの種類によって優先度を決定するように設定しており、ジョブ管理部24が処理要求を処理要求記憶部25に記憶する際、あるいは、ジョブ処理部27に発行する際、各処理要求の優先度を決定し、その優先度に応じてジョブ処理部27に発行することができる。   Referring to FIG. 2 again, the job management unit 24 sequentially retrieves processing requests from the processing request storage unit 25 while referring to the priority storage unit 26 and issues them to the job processing unit 27. As described above, the processing request storage unit 25 is a queue that processes a job that has been input first, but the job management unit 24 refers to the priority storage unit 26 and has a high priority. The job is preferentially taken out and issued to the job processing unit 27. When information regarding priority is included in the processing request, the priority storage unit 26 extracts the priority information when the processing request is stored by the job management unit 24, and the processing request Store it in association with. Also, the user can set a priority in advance according to the type of job such as document registration or document search, and can store the priority in the priority storage unit 26 in association with the job. Instead of being determined and preset by the user, a priority determination unit may be provided. The priority determination unit is set to determine the priority according to the type of job, and is issued to the job processing unit 27 when the job management unit 24 stores the processing request in the processing request storage unit 25. At this time, the priority of each processing request can be determined and issued to the job processing unit 27 according to the priority.

また、優先度記憶部26は、ユーザ毎の優先度を記憶することもでき、これにより、一般職の社員の処理要求に比較して管理職の社員の処理要求を、管理職の社員の処理要求に比較して役員の処理要求を優先的に処理することができる。さらに、ユーザが自由に優先度を決定してもよく、処理要求とは別に、優先度設定情報を送信し、優先度決定部が、その優先度設定情報を受け取り、その情報に基づいて優先度を決定し、優先度記憶部26に記憶することができる。また、ユーザではなく、ジョブ処理システムを実装する文書管理サーバの管理者が優先度を変更することもでき、この場合、優先度変更部を備えており、管理者による優先度変更情報の入力に応答して、優先度変更部が優先度を変更し、その優先度を優先度記憶部26に記憶する。   Further, the priority storage unit 26 can also store the priority for each user, so that the processing request of the managerial employee can be compared with the processing of the managerial employee compared to the processing request of the general employee. The processing request of the officer can be processed with priority compared to the request. In addition, the user may freely determine the priority, separately from the processing request, the priority setting information is transmitted, and the priority determination unit receives the priority setting information, and the priority is based on the information. Can be determined and stored in the priority storage unit 26. In addition, the administrator of the document management server that implements the job processing system can change the priority instead of the user. In this case, a priority changing unit is provided, and the administrator can input priority changing information. In response, the priority changing unit changes the priority, and the priority is stored in the priority storage unit 26.

優先度は、優先度が高いものから、「高」、「中」、「低」と設定することができる。すなわち、優先度が「高」のジョブは、「中」や「低」のジョブに比較して優先的に処理され、「中」のジョブは、「低」のジョブに比較して優先的に処理される。例えば、同じ「中」であるものは、処理要求記憶部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 request storage unit 25. In the present invention, the priority setting values are not limited to these three levels, and may be five levels such as “high / high”, “high”, “medium”, “low”, and “low / low”. Alternatively, there may be 10 levels of “10” to “1”.

図6を参照して、優先度記憶部26のデータ構造について説明する。優先度記憶部26は、対象フィールド600と、優先度フィールド601とを含む。対象フィールド600には、クライアント名やジョブ内容等が含まれ、それらに応じて「高」、「中」、「低」といった情報が、優先度フィールド601に格納される。具体的には、図6に示すように、対象フィールド600には、クライアント名であるユーザA、ユーザB、ジョブ内容である文書登録、文書検索が格納される。図6に示す実施形態では、ユーザAが処理要求を送信した場合には、優先度が「高」であるため、優先的に処理が行われ、ユーザBが処理要求を送信した場合には、優先度が「低」であるため、優先度「高」、「中」の処理要求が処理された後に処理される。また、文書登録は「低」で、文書検索が「中」に設定されているため、処理要求に文書検索を含むものは、処理要求に文書登録を含むものより先に処理される。なお、対象フィールド600に、ユーザA、ユーザBといったクライアント名が先に設定されているため、優先度が同じ、例えば「高」のものは、ジョブ内容の優先度に応じて優先順位が決定される。   The data structure of the priority storage unit 26 will be described with reference to FIG. The priority storage unit 26 includes a target field 600 and a priority field 601. The target field 600 includes a client name, job content, and the like, and information such as “high”, “medium”, and “low” is stored in the priority field 601 according to them. Specifically, as shown in FIG. 6, the target field 600 stores user names A and B as client names, document registration and job search as job contents. In the embodiment shown in FIG. 6, when the user A transmits a processing request, since the priority is “high”, the processing is performed with priority, and when the user B transmits a processing request, Since the priority is “low”, the request is processed after the processing requests with the priority “high” and “medium” are processed. Further, since the document registration is set to “low” and the document search is set to “medium”, the processing request including the document search is processed before the processing request including the document registration. Note that since the client names such as user A and user B are set in the target field 600 first, the priority of the same priority, for example, “high” is determined according to the priority of the job content. The

再び図2を参照すると、判定部23が閾値を超えないと判定した場合、判定部23がメッセージ送受信部29に指示し、ジョブ処理部27は、メッセージ送受信部29から処理要求を受け取る。処理要求を受け取ったジョブ処理部27は、その処理要求をリアルタイムに処理する。ジョブ処理部27は、文書ファイル記憶部28と接続され、ジョブが文書検索であれば、処理要求に含まれるキーワード等に関連する文書ファイルを文書ファイル記憶部28から検索する。ジョブ処理部27は、処理した結果、ここでは検索結果をメッセージ送受信部29に送信する。メッセージ送受信部29は、検索結果を受け取ると、処理要求に含まれるクライアントの位置情報に基づき、その検索結果を送信する。検索結果としては、関連する文書ファイルの数、それらのファイル名や文書名、文書ファイルとすることができる。検索結果として文書名を送信し、次に、ダウンロード要求を受けて、文書ファイルを送信することもできる。   Referring to FIG. 2 again, when the determination unit 23 determines that the threshold value is not exceeded, the determination unit 23 instructs the message transmission / reception unit 29, and the job processing unit 27 receives a processing request from the message transmission / reception unit 29. Upon receiving the processing request, the job processing unit 27 processes the processing request in real time. The job processing unit 27 is connected to the document file storage unit 28. If the job is a document search, the job processing unit 27 searches the document file storage unit 28 for a document file related to a keyword or the like included in the processing request. As a result of processing, the job processing unit 27 transmits the search result to the message transmitting / receiving unit 29 here. When the message transmission / reception unit 29 receives the search result, the message transmission / reception unit 29 transmits the search result based on the location information of the client included in the processing request. The search results can be the number of related document files, their file names and document names, and document files. A document name can be transmitted as a search result, and a document file can be transmitted in response to a download request.

ジョブ処理部27は、上記のリアルタイム処理のほか、ジョブ管理部24からの処理要求の発行に応答して、発行された処理要求を処理する。ジョブ管理部24の処理要求の発行は、サーバ負荷に応じて実施され、その負荷が閾値を超えないときに実行される。したがって、サーバ負荷が、閾値記憶部22に記憶されている閾値を超えない場合に実行される。   In addition to the real-time processing described above, the job processing unit 27 processes the issued processing request in response to the issuance of the processing request from the job management unit 24. The job management unit 24 issues processing requests according to the server load, and is executed when the load does not exceed the threshold. Therefore, it is executed when the server load does not exceed the threshold value stored in the threshold value storage unit 22.

なお、記憶装置に記憶されたプログラムをプロセッサに実行させることで、システム負荷監視部21、判定部23、ジョブ管理部24、ジョブ処理部27として機能させることができる。   In addition, by causing the processor to execute a program stored in the storage device, the system load monitoring unit 21, the determination unit 23, the job management unit 24, and the job processing unit 27 can be caused to function.

次に、図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 / reception unit 29 notifies the determination unit 23 that the processing request has been received. The determination unit 23 acquires load information related to the current server load from the system load monitoring unit 21 and reads the threshold value from the threshold value storage unit 22. (S702). The load information related to the server load includes the current CPU usage rate, memory usage rate, the number of users connected to the server, and the like.

判定部23は、取得した現在のサーバの負荷情報と、閾値とを比較し、サーバ負荷が閾値を超えているか否かを判定する(S703)。超えている場合は、非同期処理が選択され、超えていない場合は、同期処理が選択される。このようにして非同期処理が実行されるか否かが判定される。非同期処理が実行される場合、ジョブ管理部24に処理要求を送り、処理要求記憶部25に処理要求を記憶する(S704)。処理要求には、ジョブIDが関連付けられ、クライアント名フィールドにクライアントに関する情報が格納され、ステータスフィールドに未完了を示す情報が格納される。ジョブ管理部24は、処理要求を受け付けたことを示す受付メッセージを生成し、ジョブIDとともにメッセージ送受信部29に送る。ジョブIDは、ジョブを識別するための識別情報で、1つのクライアントが複数の処理要求を送信した場合に、それら処理要求に対する処理結果を識別するために用いられる。メッセージ送受信部29は、その受付メッセージをジョブIDとともにクライアントに送信する(S705)。   The determination unit 23 compares the acquired current server load information with a threshold value, and determines whether the server load exceeds the threshold value (S703). When it exceeds, asynchronous processing is selected, and when it does not exceed, synchronous processing is selected. In this way, it is determined whether or not asynchronous processing is executed. When asynchronous processing is executed, a processing request is sent to the job management unit 24, and the processing request is stored in the processing request storage unit 25 (S704). The processing request is associated with a job ID, information about the client is stored in the client name field, and information indicating incomplete is stored in the status field. The job management unit 24 generates a reception message indicating that the processing request has been received, and sends it to the message transmission / reception unit 29 together with the job ID. The job ID is identification information for identifying a job, and is used for identifying a processing result for each processing request when one client transmits a plurality of processing requests. The message transmitting / receiving unit 29 transmits the received message together with the job ID to the client (S705).

非同期処理が実行されない場合、処理要求がジョブ処理部27に送られ、ジョブ処理部27がリアルタイム処理し、処理した結果をメッセージ送受信部29に送る(S706)。メッセージ送受信部29は、受け取った処理結果を、クライアントを送信する(S707)。受付メッセージまたは処理結果をクライアントが受信することにより、クライアントが送信した処理要求に対する処理が終了する(S708)。この場合、リアルタイムに処理されるため、ジョブを識別するためのジョブIDは特に関連付ける必要はないが、処理要求IDとともに送信することもできる。   When the asynchronous processing is not executed, a processing request is sent to the job processing unit 27, the job processing unit 27 performs real-time processing, and the processing result is sent to the message transmitting / receiving unit 29 (S706). The message transmission / reception unit 29 transmits the received processing result to the client (S707). When the client receives the reception message or the processing result, the processing for the processing request transmitted by the client ends (S708). In this case, since the processing is performed in real time, it is not necessary to associate the job ID for identifying the job, but the job ID can be transmitted together with the processing request ID.

図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 job management unit 24 periodically polls the processing request storage unit 25 to check the status (S801). Polling inquires whether a processing request is stored in the processing request storage unit 25. When a processing request is stored by polling, the status stored in association with the processing request is confirmed.

ステータスが「未完了」のものがあるか否かを判定する(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 job processing unit 27 starts processing the processing request asynchronously, that is, not in real time, for example, when the subsequent server load does not exceed the threshold (S805). When the processing is started, the job management unit 24 changes the status corresponding to the processing request in the processing request storage unit 25 from “incomplete” to “processing” (S806). As indicated by the broken line, the job processing unit 27 executes the job asynchronously (S807) and sends the result to the job management unit 24. The job management unit 24 stores the result as the processing result of the processing request storage unit 25, and changes the status from “processing” to “completed” (S808).

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 job management unit 24 periodically performs the polling of S801. If the status is “incomplete”, the process proceeds to S804, and if not, the process proceeds to S803, and the respective processes are repeated. During this time, when the job being processed ends, the processing result is stored as in S808, and the status is changed to “completed”.

S803で、ステータスが「完了」のものがある場合、ジョブ管理部24は、処理要求記憶部25から処理結果を取り出し、その処理結果をクライアントに返すために、ジョブIDとともにメッセージ送受信部29に送る(S810)。メッセージ送受信部29は、その処理結果を受け取ると、クライアントの位置情報に基づき処理結果を、その処理要求を送信したクライアントに送信する(S811)。メッセージ送受信部29がクライアントに処理結果を送信したことに応答して、ジョブ管理部24は、処理要求記憶部25に記憶されたその処理要求に関するジョブID、ステータス、クライアント名、処理要求、処理結果を削除する(S812)。   If the status is “complete” in S803, the job management unit 24 extracts the processing result from the processing request storage unit 25, and sends the processing result to the message transmission / reception unit 29 together with the job ID in order to return the processing result to the client. (S810). When the message transmission / reception unit 29 receives the processing result, the message transmission / reception unit 29 transmits the processing result based on the position information of the client to the client that transmitted the processing request (S811). In response to the message transmission / reception unit 29 transmitting the processing result to the client, the job management unit 24 stores the job ID, status, client name, processing request, processing result regarding the processing request stored in the processing request storage unit 25. Is deleted (S812).

図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 / reception unit 29 receives the processing request (S901). The message transmission / reception unit 29 notifies the determination unit 23 that the processing request has been received, and the determination unit 23 acquires load information regarding the current server load from the system load monitoring unit 21 and reads the threshold value from the threshold storage unit 22. (S902). The determination unit 23 compares the acquired current server load information with a threshold value, and determines whether or not the server load exceeds the threshold value (S903). When it exceeds, asynchronous processing is selected, and when it does not exceed, synchronous processing is selected. In this way, it is determined whether or not asynchronous processing is executed. When asynchronous processing is executed, a processing request is sent to the job management unit 24, and the processing request is stored in the processing request storage unit 25 (S904). The processing request is associated with a job ID, information about the client is stored in the client name field, and information indicating incomplete is stored in the status field. In this embodiment, priority information is also stored in the priority field. The priority information can be acquired by the job management unit 24 by being included in the processing request, determined by the priority determination unit, or input by a user or an administrator. The job management unit 24 generates a reception message indicating that the processing request has been received, and sends the reception message to the message transmission / reception unit 29 together with the job ID. The message transmission / reception unit 29 transmits the received message together with the job ID to the client (S905).

非同期処理が実行されない場合、処理要求がジョブ処理部27に送られ、ジョブ処理部27が処理し、その結果をメッセージ送受信部29に送る(S906)。メッセージ送受信部29は、受け取った処理結果を、クライアントを送信する(S907)。受付メッセージまたは処理結果をクライアントが受信することにより、クライアントが送信した処理要求に対する処理が終了する(S908)。   When the asynchronous processing is not executed, a processing request is sent to the job processing unit 27, the job processing unit 27 processes the result, and the result is sent to the message transmission / reception unit 29 (S906). The message transmission / reception unit 29 transmits the received processing result to the client (S907). When the client receives the reception message or the processing result, the processing for the processing request transmitted by the client ends (S908).

図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 job management unit 24 periodically polls the processing request storage unit 25 to check the status (S1001). Here, since the priority is included, the statuses are checked in the order of priority “high”, “medium”, and “low”.

後の処理は、図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 request storage unit 25 later, it is processed first to implement interrupt processing.

ジョブ処理部27は、非同期、すなわちリアルタイムではなく、例えば、後のサーバ負荷が閾値を超えないときにその処理要求の処理を開始する(S1005)。処理を開始すると、ジョブ管理部24は、処理要求記憶部25のその処理要求に対応するステータスを、「未完了」から「処理中」に変更する(S1006)。破線で示されるように、ジョブ処理部27は非同期にジョブを実行し(S1007)、結果をジョブ管理部24に送る。ジョブ管理部24は、その結果を処理要求記憶部25の処理結果として記憶し、ステータスを「処理中」から「完了」に変更する(S1008)。   The job processing unit 27 starts processing the processing request asynchronously, that is, not in real time, for example, when the subsequent server load does not exceed the threshold (S1005). When the processing is started, the job management unit 24 changes the status corresponding to the processing request in the processing request storage unit 25 from “incomplete” to “processing” (S1006). As indicated by the broken line, the job processing unit 27 executes the job asynchronously (S1007), and sends the result to the job management unit 24. The job management unit 24 stores the result as a processing result of the processing request storage unit 25, and changes the status from “processing” to “completed” (S1008).

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 job management unit 24 periodically performs the polling of S1001. If there is a status of “incomplete”, the process proceeds to S1004. If not, the process proceeds to S1003, and each process is repeated. During this time, when the job being processed ends, the processing result is stored as in S1008, and the status is changed to “completed”.

S1003で、ステータスが「完了」のものがある場合、ジョブ管理部24は、処理要求記憶部25から処理結果を取り出し、その処理結果をクライアントに返すために、ジョブIDとともにメッセージ送受信部29に送る(S1010)。メッセージ送受信部29は、その処理結果を受け取ると、クライアントの位置情報に基づき処理結果を、その処理要求を送信したクライアントに送信する(S1011)。メッセージ送受信部29がクライアントに処理結果を送信したことに応答して、ジョブ管理部24は、処理要求記憶部25に記憶されたその処理要求に関するジョブID、ステータス、クライアント名、処理要求、処理結果を削除する(S1012)。   If the status is “complete” in S1003, the job management unit 24 extracts the processing result from the processing request storage unit 25, and sends the processing result to the message transmission / reception unit 29 together with the job ID in order to return the processing result to the client. (S1010). When the message transmission / reception unit 29 receives the processing result, the message transmission / reception unit 29 transmits the processing result based on the position information of the client to the client that transmitted the processing request (S1011). In response to the message transmission / reception unit 29 transmitting the processing result to the client, the job management unit 24 stores the job ID, status, client name, processing request, processing result regarding the processing request stored in the processing request storage unit 25. Is deleted (S1012).

これまで本発明を図面に示した実施の形態をもって説明してきたが、本発明は図面に示した実施の形態に限定されるものではなく、他の実施の形態、追加、変更、削除など、当業者が想到することができる範囲内で変更することができ、いずれの態様においても本発明の作用・効果を奏する限り、本発明の範囲に含まれるものである。   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.

ネットワークシステムの構成図。1 is a configuration diagram of a network system. 本発明のジョブ処理システムの構成を例示した図。The figure which illustrated the structure of the job processing system of this invention. 処理要求のデータ構成を例示した図。The figure which illustrated the data structure of the processing request. 閾値記憶部のデータ構造を例示した図。The figure which illustrated the data structure of the threshold storage part. 処理要求記憶部のデータ構造を例示した図。The figure which illustrated the data structure of the processing request storage part. 優先度記憶部のデータ構造を例示した図。The figure which illustrated the data structure of the priority memory | storage part. ジョブ処理システムによって実行される処理の1つの実施形態を示した図。The figure which showed one Embodiment of the process performed by the job processing system. 図7に示すフローにおける非同期処理を詳細に示した図。The figure which showed the asynchronous process in the flow shown in FIG. 7 in detail. ジョブ処理システムによって実行される処理の別の実施形態を示した図。The figure which showed another embodiment of the process performed by the job processing system. 図9に示すフローにおける非同期処理を詳細に示した図。The figure which showed the asynchronous process in the flow shown in FIG. 9 in detail.

符号の説明Explanation of symbols

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 SYMBOLS 10 ... Network system, 11 ... Network, 12 ... Document management server, 13 ... Client, 20 ... Job processing system, 21 ... System load monitoring part, 22 ... Threshold memory | storage part, 23 ... Judgment part, 24 ... Job management part, 25 ... processing request storage unit, 26 ... priority storage unit, 27 ... job processing unit, 28 ... document file storage unit, 29 ... message transmission / reception unit, 300 ... processing request ID field, 301 ... location information field, 302 ... priority field , 303 ... Job content field, 400 ... Condition ID field, 401 ... Judgment condition field, 402 ... Threshold field, 403 ... Processing method field, 500 ... Job ID field, 501 ... Priority field, 502 ... Status field, 503 ... Client Name field, 504 ... processing required Field 505 ... processing result field 600 ... target field, 601 ... priority field

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.
前記処理要求にはジョブ処理の優先度情報が含まれており、前記ジョブ管理部は、記憶した複数の前記処理要求を前記優先度情報に基づいて前記ジョブ処理部に発行する、請求項1に記載のジョブ処理システム。   The processing request includes job processing priority information, and the job management unit issues a plurality of stored processing requests to the job processing unit based on the priority information. The job processing system described. 前記ジョブ管理部は、前記ジョブ内容に基づき予め設定された優先度を記憶する優先度記憶部を備え、記憶した複数の前記処理要求を前記優先度に基づいて前記ジョブ処理部に発行する、請求項1または2に記載のジョブ処理システム。   The job management unit includes a priority storage unit that stores a priority set in advance based on the job content, and issues a plurality of stored processing requests to the job processing unit based on the priority. Item 3. The job processing system according to Item 1 or 2. 前記ジョブ管理部は、前記処理要求に含まれる前記ジョブ内容に基づき優先度を決定する優先度決定部を備え、前記優先度決定部は、記憶した複数の前記処理要求の各々に対して前記優先度を決定し、前記複数の処理要求を前記優先度に基づいて前記ジョブ処理部に発行する、請求項1または2に記載のジョブ処理システム。   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. The job processing system according to claim 1, wherein the job processing system determines a degree and issues the plurality of processing requests to the job processing unit based on the priority. 前記ジョブ管理部は、ユーザ毎に、前記ジョブ内容に基づき予め設定された優先度を記憶する優先度記憶部と、前記処理要求に含まれるユーザ識別情報からユーザを特定し、前記優先度記憶部に記憶される前記ユーザに関連付けられた前記優先度に基づき、前記ジョブの優先度を決定する優先度決定部とを含む、請求項1または2に記載のジョブ処理システム。   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 The job processing system according to claim 1, further comprising: a priority determination unit that determines the priority of the job based on the priority associated with the user stored in the job. 前記ジョブ管理部は、各ユーザが入力した優先度を、ユーザ毎に記憶する優先度記憶部と、前記処理要求に含まれるユーザ識別情報からユーザを特定し、前記優先度記憶部に記憶される前記ユーザに関連付けられた前記優先度に基づき、ジョブの優先度を決定する優先度決定部とを含む、請求項1または2に記載のジョブ処理システム。   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. The job processing system according to claim 1, further comprising: a priority determination unit that determines a job priority based on the priority associated with the user. 前記システムの管理者による優先度の変更の入力に応答して、前記優先度記憶部に記憶された優先度を変更する優先度変更部をさらに含む、請求項6に記載のジョブ処理システム。   The job processing system according to claim 6, further comprising a priority changing unit that changes a priority stored in the priority storage unit in response to an input of a priority change by an administrator of the system. 前記処理要求は、文書検索要求、文書登録要求、文書の画像変換要求であり、前記ジョブ内容は、文書検索、文書登録、文書の画像変換である、請求項1〜7のいずれか1項に記載のジョブ処理システム。   8. The process according to claim 1, wherein the processing request is a document search request, a document registration request, or a document image conversion request, and the job content is a document search, document registration, or document image conversion. The job processing system described. 前記ジョブ処理システムは、プリンタ、ファックス装置、コピー装置、スキャナ装置、これらを機能として備えるデジタル複合機に実装される、請求項1〜8のいずれか1項に記載のジョブ処理システム。   The job processing system according to claim 1, wherein the job processing system is mounted on a printer, a fax machine, a copier, a scanner, or a digital multi-function peripheral having these functions. システム負荷に応じてジョブを処理するジョブ処理方法であって、前記システムは、システム負荷監視部が前記システムの負荷情報を監視し、閾値記憶部が前記システムの負荷情報の閾値を記憶しており、
ユーザからのジョブ内容を含む処理要求の受信に応答して、前記システムが備える判定部が、前記システム負荷監視部から前記負荷情報を取得し、前記閾値記憶部から前記閾値を読み出し、前記負荷情報が前記閾値を超えるか否かを判定するステップと、
前記閾値を超えないとの判定に応答して、前記システムが備えるジョブ処理部が、前記処理要求を前記ジョブ内容に基づいて処理し、処理結果を前記ユーザに対して送信するステップと、
前記閾値を超えるとの判定に応答して、前記システムが備えるジョブ管理部が、前記処理要求を処理要求記憶部に記憶し、前記処理要求を受け付けたことを示す受付メッセージを前記ユーザに対して送信するステップと、
前記ジョブ管理部が、前記処理要求記憶部に記憶した前記処理要求を前記ジョブ処理部に非同期処理させ、処理結果を受け取り、前記ユーザに対して前記処理結果を送信するステップと
を含む、ジョブ処理方法。
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.
前記処理要求にはジョブ処理の優先度情報が含まれていて、前記ジョブ処理部に非同期処理させ、前記処理結果を送信するステップは、前記優先度情報に基づき前記処理要求を前記ジョブ処理部に発行するステップをさらに含む、請求項10または11に記載のジョブ処理方法。   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 job processing method according to claim 10, further comprising a issuing step. 請求項10〜12のいずれか1項に記載の方法を、コンピュータに対して実行させるためのプログラム。   The program for making a computer perform the method of any one of Claims 10-12. 請求項10〜12のいずれか1項に記載の方法を、コンピュータに対して実行させるためのプログラムを格納したコンピュータ可読な記録媒体。   The computer-readable recording medium which stored the program for making a computer perform the method of any one of Claims 10-12.
JP2006128261A 2006-05-02 2006-05-02 Job processing system, job processing method, program, and recording medium Pending JP2007299308A (en)

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)

* Cited by examiner, † Cited by third party
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

Cited By (29)

* Cited by examiner, † Cited by third party
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