[go: up one dir, main page]

CN1292365C - 公共工作队列环境中的最适宜服务器 - Google Patents

公共工作队列环境中的最适宜服务器 Download PDF

Info

Publication number
CN1292365C
CN1292365C CNB038068060A CN03806806A CN1292365C CN 1292365 C CN1292365 C CN 1292365C CN B038068060 A CNB038068060 A CN B038068060A CN 03806806 A CN03806806 A CN 03806806A CN 1292365 C CN1292365 C CN 1292365C
Authority
CN
China
Prior art keywords
server
message
queue
shared queue
servers
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.)
Expired - Lifetime
Application number
CNB038068060A
Other languages
English (en)
Other versions
CN1643506A (zh
Inventor
格伦·兰达尔·维尔考克
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.)
International Business Machines Corp
Original Assignee
International Business Machines Corp
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 International Business Machines Corp filed Critical International Business Machines Corp
Publication of CN1643506A publication Critical patent/CN1643506A/zh
Application granted granted Critical
Publication of CN1292365C publication Critical patent/CN1292365C/zh
Anticipated expiration legal-status Critical
Expired - Lifetime legal-status Critical Current

Links

Images

Classifications

    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/01—Protocols
    • H04L67/10—Protocols in which an application is distributed across nodes in the network
    • H04L67/1001—Protocols in which an application is distributed across nodes in the network for accessing one among a plurality of replicated servers
    • H04L67/1004—Server selection for load balancing
    • H04L67/1008—Server selection for load balancing based on parameters of servers, e.g. available memory or workload
    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F15/00—Digital computers in general; Data processing equipment in general
    • G06F15/16—Combinations of two or more digital computers each having at least an arithmetic unit, a program unit and a register, e.g. for a simultaneous processing of several programs
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/01—Protocols
    • H04L67/10—Protocols in which an application is distributed across nodes in the network
    • H04L67/1001—Protocols in which an application is distributed across nodes in the network for accessing one among a plurality of replicated servers
    • H04L67/1029—Protocols in which an application is distributed across nodes in the network for accessing one among a plurality of replicated servers using data related to the state of servers by a load balancer
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/01—Protocols
    • H04L67/10—Protocols in which an application is distributed across nodes in the network
    • H04L67/1001—Protocols in which an application is distributed across nodes in the network for accessing one among a plurality of replicated servers
    • H04L67/1038—Load balancing arrangements to avoid a single path through a load balancer
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L9/00—Cryptographic mechanisms or cryptographic arrangements for secret or secure communications; Network security protocols
    • H04L9/40—Network security protocols
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/01—Protocols
    • H04L67/10—Protocols in which an application is distributed across nodes in the network
    • H04L67/1001—Protocols in which an application is distributed across nodes in the network for accessing one among a plurality of replicated servers
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/01—Protocols
    • H04L67/10—Protocols in which an application is distributed across nodes in the network
    • H04L67/1001—Protocols in which an application is distributed across nodes in the network for accessing one among a plurality of replicated servers
    • H04L67/10015—Access to distributed or replicated servers, e.g. using brokers

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Computer Hardware Design (AREA)
  • General Engineering & Computer Science (AREA)
  • Theoretical Computer Science (AREA)
  • Computer Security & Cryptography (AREA)
  • Physics & Mathematics (AREA)
  • Software Systems (AREA)
  • General Physics & Mathematics (AREA)
  • Computer And Data Communications (AREA)
  • Multi Processors (AREA)
  • Hardware Redundancy (AREA)

Abstract

本发明涉及公共工作队列环境中的最适宜服务器。具体地说，是一种用于管理服务器的系统和方法。该系统包括：用于处理消息的多个服务器；用于向服务器发送消息以及从服务器接收消息的至少一个客户机；以及用于维护一个列表的处理装置，该列表指明是否有至少一个服务器适宜处理消息。最好，所述服务器适合处理各种不同类型的消息，并且所述处理装置包括在所述列表上指明，对于每一个不同类型的消息，是否有至少一个服务器适宜处理所述每一个不同类型的消息的装置。另外，在优选实施例中，每一个客户机包括，在所述客户机向所述服务器之一发送给定类型的消息之前，读所述列表以判断是否有至少一个服务器适宜处理所述给定类型的消息的装置。

Description

公共工作队列环境中的最适宜服务器
技术领域
本发明总体上涉及并行处理环境，尤其涉及应用共享队列的并行处理系统。
背景技术
在现代数据处理环境中提供多个系统来处理一个或者多个客户机的处理需求是很常见的。例如，两个或者多个系统，比如事务处理系统，可以通过通信网络被连接到一个或者多个客户机。在这样的环境中，当一个客户机有任务要由所述系统之一执行时，该客户机向所希望的系统发送一个输入消息，请求由在该系统上运行的应用程序进行处理。该主体系统将消息排队，并将消息提供给所述应用程序进行处理。当处理完成时，所述应用程序将一个输出消息放置到用于在网络上传输到该客户机的队列中。
为了利用这种环境的多处理特征，由该客户机最初分配任务的系统，系统A，可以从其队列中提取该输入消息，将该输入消息转发给第二系统，系统B，来进行处理。当系统B完成了处理时，将响应(输出消息)转发到系统A，并放置在系统A的用于传输到客户机的队列中。这样，以这样的方式，可以使用多系统来处理来自许多客户机的处理请求。
但是，使用这种方案有一些缺点。
例如，如果系统A失灵，则系统A的队列上的任何工作都不能被访问。因此，客户机被迫等待系统A恢复在线才能处理其事务。
为了对付这些缺点，可以提供共享的或者说公共队列来存储要由多个数据处理系统中的任何系统处理的输入消息。一个公共队列服务器接收消息，并将消息排队到公共队列中，使得具有可用的处理消息的能力的系统能够取出它们。在工作时，具有可用的处理能力的系统取出一个排队的消息，执行必要的处理，并将合适的响应消息放回到共享队列上。这样，共享队列存储在请求处理的客户机和执行处理的数据处理系统之间在任意方向发送的消息。
由于消息被排队到共享队列中，所述消息可以由在能够访问所述共享队列的多个系统中的任何系统上运行的应用程序来处理。这样，可以实现所述多个系统之间的自动工作负荷管理。另外，由于任何连接到所述共用队列的系统都能处理消息，提供了处理能力冗余度的好处。如果处理某个消息的特定应用程序失灵，则另一个应用程序可以从共用队列中取出该消息，执行该处理，而客户机不用等待该最初的应用程序恢复在线。这对数据处理环境的客户机提供了处理能力冗余度。
当利用公共工作队列时，所有向公共队列提交请求的客户机都期望它们的工作请求能够在合理的时间内完成。在不是所有的服务器都适宜处理所有请求的环境中，在任何给定时刻都有可能不存在适宜处理队列中的某些或者所有工作请求的服务器。当一个工作请求是同步的时候，重要的是提交该请求的客户机被告知没有服务器适宜处理该同步请求。
更具体地，在共享工作队列环境中，存在一个或者多个提交请求的客户机和一个或者多个处理这些请求的服务器。在处理请求的这些服务器中，不是所有的服务器都有能力处理公共工作队列中的每一个请求。这可能是因为：(a)服务器被设计为只处理特定类型的请求，或者(b)服务器不能访问处理特定类型的请求所需的资源。(a)情形的一个例子是，尽管其它服务器可能被设计为处理所有请求，但是某些服务器可能被配置为只处理来自特定客户机的请求。(b)情形的一个例子是，某些请求可能需要访问特定存储器库，但是不是所有的服务器都连接到了所述存储器库。只有连接到了所需的存储器库的服务器才能处理这些请求。
在CA2282931A(MICROLOG CORP)，“A contact center systemcapable of handling multiple media type of contacts and method forusing the same”中，介绍了一种应用多个代理工作站的联系中心系统和方法，它包括一个排队部件，其能够接收不同媒体类型的联系，并在一个公共队列中维护不同媒体类型的联系。该系统还包括一个路由部件，用于将排队的联系根据所述联系的标准、或者所述代理工作站的标准或者这两种标准发送到所述代理工作站。
在WO9420904(ROLM CO)，“Queue managing system andmethod”中，介绍了一种为代表各种客户类型的多个客户服务的队列管理系统。一个队列管理器将所述客户放到一个与客户类型匹配的处理队列中。在电话系统环境中，所述客户是消息，所述客户类型是针对各种目的地的消息的编码。
在EP1126371A(SONY CORP；Information broadcasting labI(JP))，“Service providing apparatus transmitting apparatus，receiving apparatus，and receiving method”中，介绍了一种向客户机广播服务目录的客户机-服务器系统。客户机搜索其收到的服务目录来选择提供服务的服务器。
在US5887168A(PATTERSON BETTY J ET AL)，“Computerprogram product for a shared queue structure for data integrity”中，提供了一种共享队列，以允许多个系统中的任何系统都能处理客户机所接收到的消息。所述多个系统中任何具有可用的处理能力的系统能够从所述共享队列中取出消息，然后处理该消息。对该消息的响应在适当的时候被加入到所述共享队列中，以送回所述客户机。提供了一种独特的列表结构来实现所述队列。该列表结构由多个子列表或者队列类型构成。
发明内容
本发明的一个目的是改进就如US5887168A所公开的那种数据处理系统，该系统由适合处理某些或者全部类型的请求的服务器使用公共队列来处理工作请求。改进的方式是，对于每一种不同的类型，维护适宜性状态，也就是，是否有至少一个所述服务器适宜处理所述每一个不同类型。
本发明的另一个目的是通知提交了同步请求的客户机是否有适宜处理该请求的服务器，在没有服务器适宜处理其请求的情况下，这允许该客户机从所述共享队列中移除其请求。
本发明的另一个目的是防止提交没有适宜处理的服务器的同步请求。
这些以及其它目的是用本发明所提供的一种管理服务器的系统、方法和程序达到的。该系统包括：用于处理消息的多个服务器，用于向服务器发送消息以及从服务器接收消息的至少一个客户机，以及用于维护一个列表的处理装置，该列表指明是否有至少一个所述服务器适宜处理消息。最好，所述服务器适合处理各种不同类型的消息；并且所述处理装置包括在所述列表上指明，对于每一个不同类型的消息，是否有至少一个所述服务器适宜处理每一个不同类型的消息的装置。
另外，在优选实施例中，每一个所述客户机包括，在所述客户机向所述服务器之一发送给定类型的消息之前，读所述列表以判断是否有至少一个所述服务器适宜处理所述给定类型的消息的装置。另外，当所述列表有变化时，所述处理装置可以通知所述客户机，每一个所述客户机可以包括，在不再有适宜处理消息的服务器的情况下，从所述公共队列移除所述消息的装置。一个队列服务器为所述公共队列提供必要的接口。可以使用任何合适的队列服务器，但是，公共队列服务器最好是可从国际商业机器公司获得的z系列(zSeries)处理环境中的连接设备(Coupling Facility)。
本发明还提供了一种服务器管理系统，包括：用于向一个共享队列发送消息以及从该共享队列接收响应消息的至少一个客户机；用于处理来自所述共享队列的客户机消息，并向所述共享队列发送响应消息的多个服务器，所述服务器适合处理各种不同类型的消息；该系统的特征在于：在该系统中存储有一个列表，该列表指明对于每一个不同类型的消息，是否有至少一个所述服务器适宜处理所述这样的不同类型的消息。
本发明还提供了一种管理服务器的方法，包括下述步骤：使用至少一个客户机向一个共享队列发送消息以及从共享队列接收响应消息；提供多个服务器，用于处理来自所述共享队列的客户机消息，以及向所述共享队列发送响应消息，所述服务器适合处理各种不同类型的消息；该方法的特征在于：提供一个列表，该列表指明对于每一个所述不同类型的消息，是否有至少一个所述服务器适宜处理该类型的消息。
结合附图阅读下面的详细说明可以更加清楚本发明的其它优点。附图图示了本发明的优选实施例。
附图说明
图1的框图图示了客户机/服务器环境中的共享队列；
图2图示了一个共享队列处理环境，其中使用了最适宜服务器状态记录；
图3图示了用于更新最适宜服务器状态记录的方法。
具体实施方式
本发明总体上涉及可以允许多个处理系统中的任何一个为一个或者多个客户机处理消息的系统和方法。在优选实施例中，提供了一种结构化外部存储设备，比如共享队列，以为所述多个系统对客户消息进行排队。当从客户机接收到进入的消息时，将它们放入队列中。当所述多个系统中的某个系统具有可用的处理能力时，它取出所述消息，处理该消息，并将响应放到该队列中。
图1的框图图解了客户机/服务器环境10中的共享队列。该客户机/服务器环境包括通过一个或者多个网络16连接到多个处理系统14的一个或者多个客户机12。当某个客户机12具有要处理的事务时，该客户机将消息加入共享队列20中。当从客户机收到另外的消息时，它们也入队到所述共享队列中。每一个消息都保留在共享队列20中，直到被所述系统14之一取出以进行处理。
当某个系统14确定它自己具有能力处理另一个事务时，该系统14从共享队列20中取出一个消息。该系统14然后处理该消息，对产生该进入的消息的客户机做出合适的响应，并将该响应放到所述共享队列20中。一个公共队列服务器22在共享队列20和系统14之间提供必要的接口。当输入的消息被该公共队列服务器接收到以便加入共享队列20时，该队列服务器22将该消息缓存在一个或者多个缓冲器中，然后将该数据传输到共用队列。
在实现本发明时，可以使用任何合适的公共队列和公共队列服务器。然而，该公共队列服务器最好是可从国际商业机器公司获得的z系列(zSeries)处理环境中的连接设备(Coupling Facility)。这种连接设备提供了用在本发明的优选实施方式中的各种特征。
如上所述，当使用公共工作队列时，可能发生的一种困难，是在任何给定时间，都有可能没有服务器适合处理队列中的工作请求中的某些或者全部。为了应付这种需要，本发明使用了一种称为“最适宜服务器(Most Eligible Server)”的特征。最适宜服务器是具有最强的请求处理能力的服务器。通过了解最适宜服务器的状态，客户机可以根据是否存在适宜处理其请求的服务器来向公共工作队列提交请求。
为了防止提交没有适宜进行处理的服务器的同步请求，维护一个“最适宜服务器状态(MESS，Most Eligible Server Status)”记录。该MESS记录表明是否存在适合处理请求的服务器，如果有，适合处理什么类型的请求。不一定需要维护适宜的服务器的数量，但是可以维护该数量。MESS记录表明存在至少一个服务器适宜处理请求，从而请求不会在队列上停留不确定的时间。在提交请求之前，客户机迅速地读取MESS记录以判断是否存在适宜处理其请求的服务器。如果有，则该客户机将其请求放到队列中。
最好，如果MESS记录中有变化的话，向客户机通知该变化。如果MESS低于其先前的状态，也就是，如果没有服务器可用或者特定类型的请求不再能被处理，则客户机可以选择从队列中移除不再有适宜处理的服务器的请求。
图2图解了一种可以使用最适宜服务器状态记录的环境。作为例子，两个服务器32、34处理来自一个公共工作队列36的请求。两个服务器都连接到一个磁盘库40，但是只有一个服务器可以连接到磁带库42。服务器34是唯一能够处理要求磁带资源的请求的服务器。只要服务器34可用，则MESS记录就表明存在可用于处理要求磁带的请求的服务器。当服务器34不可用时，就要更新MESS记录44，指出没有服务器可用于处理磁带请求，这样客户机46和50就可以舍弃已有的未处理的磁带请求，而相应提交新的请求。
图3图示了更新最适宜服务器状态记录的方法。如步骤60和62所示，当一个服务器连接到公共工作队列时，它判断其适宜处理请求的适宜性是否大于MESS记录当前所反映的适宜性。如果是，则在步骤64更新MESS记录；如果不是，则如步骤66所示，不改变MESS记录。该记录也可以在被连接的服务器的适宜性出现变化时被更新。可以维护每一个服务器的适宜性状态的记录，以便做出上述判断。当一个服务器与公共工作队列断开时，如果MESS的状态发生了改变，则可以更新MESS记录。
维护和更新MESS记录的处理可以由任何合适的处理装置完成。例如，队列服务器22可以用来维护和更新该列表，一个或者多个处理系统14可以用于该目的，或者可以提供一个单独的设备来执行这些功能。另外，取决于本发明所应用的具体环境，该处理装置还可以包括单个处理器或者多个处理器。例如，取决于本发明所使用的具体系统，可以用具有单个处理器的标准个人计算机，或者任何其它合适类型的计算机(包括，例如，具有多个处理器的计算机)，来维护和更新MESS记录。另外，可以注意到，如果需要的话，所需的处理可以主要由软件来完成，主要由硬件来完成，或者由硬件和软件的组合来完成。

Claims (12)

1.一种服务器管理系统(10)，包括：
用于向一个共享队列(20)发送消息以及从该共享队列接收响应消息的至少一个客户机(12)；
用于处理来自所述共享队列(20)的客户机消息，并向所述共享队列(20)发送响应消息的多个服务器(14)，所述服务器(14)适合处理各种不同类型的消息；
该系统(10)的特征在于：
在该系统中存储有一个列表(44)，该列表指明对于每一个不同类型的消息，是否有至少一个所述服务器(14)适宜处理所述这样的不同类型的消息。
2.如权利要求1所述的服务器管理系统(10)，还包括一个在其中维护所述共享队列(20)的公共队列服务器(22)。
3.如权利要求2所述的服务器管理系统(10)，其中，在所述公共队列服务器(22)上维护所述列表(44)。
4.如权利要求1所述的服务器管理系统(10)，其中，在一个或者多个所述服务器(14)上维护所述列表(44)。
5.如权利要求1所述的服务器管理系统(10)，其中，在一个单独的设备上维护所述列表(44)。
6.如权利要求1所述的服务器管理系统(10)，其中，每一个所述客户机(12)包括，在所述客户机(12)向所述共享队列(20)发送给定类型的消息之前，读所述列表(44)以判断是否有至少一个所述服务器(14)适宜处理所述给定类型的消息的装置。
7.如权利要求1所述的服务器管理系统(10)，其中，当所述列表(44)有变化时，所述服务器通知所述客户机(12)。
8.如权利要求1所述的服务器管理系统(10)，其中，每一个所述客户机(12)包括，在不再有适宜处理给定类型的消息的服务器(14)的情况下，从共享队列(20)移除消息的装置。
9.一种管理服务器(14)的方法，包括下述步骤：
使用至少一个客户机(12)向一个共享队列(20)发送消息以及从共享队列(20)接收响应消息；
提供多个服务器(14)，用于处理来自所述共享队列的客户机消息，以及向所述共享队列发送响应消息，所述服务器(14)适合处理各种不同类型的消息；
该方法的特征在于：
提供一个列表(44)，该列表(44)指明对于每一个所述不同类型的消息，是否有至少一个所述服务器(14)适宜处理该类型的消息。
10.如权利要求9所述的方法，还包括下述步骤：在每一个所述客户机(12)向所述共享队列(20)发送给定类型的消息之前，所述客户机读所述列表(44)以判断是否有至少一个所述服务器(14)适宜处理所述给定类型的消息。
11.如权利要求9所述的方法，还包括下述步骤：当所述列表(44)有变化时，使用所述服务器通知所述客户机(12)。
12.如权利要求9所述的方法，还包括下述步骤：在不再有适宜处理给定类型的消息的服务器(14)的情况下，每一个所述客户机(12)从所述共享队列(20)移除消息。
CNB038068060A 2002-03-29 2003-03-14 公共工作队列环境中的最适宜服务器 Expired - Lifetime CN1292365C (zh)

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
US10/112,134 US7454501B2 (en) 2002-03-29 2002-03-29 Most eligible server in a common work queue environment
US10/112,134 2002-03-29

Publications (2)

Publication Number Publication Date
CN1643506A CN1643506A (zh) 2005-07-20
CN1292365C true CN1292365C (zh) 2006-12-27

Family

ID=28453247

Family Applications (1)

Application Number Title Priority Date Filing Date
CNB038068060A Expired - Lifetime CN1292365C (zh) 2002-03-29 2003-03-14 公共工作队列环境中的最适宜服务器

Country Status (10)

Country Link
US (2) US7454501B2 (zh)
EP (1) EP1490781B1 (zh)
JP (2) JP4028847B2 (zh)
KR (1) KR100763319B1 (zh)
CN (1) CN1292365C (zh)
AT (1) ATE357022T1 (zh)
AU (1) AU2003221501A1 (zh)
CA (1) CA2479949C (zh)
DE (1) DE60312498T2 (zh)
WO (1) WO2003083683A2 (zh)

Families Citing this family (19)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP4039195B2 (ja) * 2001-12-27 2008-01-30 富士ゼロックス株式会社 ネットワークシステム
US8423662B1 (en) * 2003-04-28 2013-04-16 Akamai Technologies, Inc. Forward request queuing in a distributed edge processing environment
US8122201B1 (en) * 2004-09-21 2012-02-21 Emc Corporation Backup work request processing by accessing a work request of a data record stored in global memory
US8370839B2 (en) * 2007-07-20 2013-02-05 International Business Machines Corporation Monitoring message queues in message queuing information systems and initiating batch jobs to perform functions on the message queues
US8572627B2 (en) * 2008-10-22 2013-10-29 Microsoft Corporation Providing supplemental semantics to a transactional queue manager
GB2466314A (en) * 2008-12-22 2010-06-23 Symbian Software Ltd Managing a Message Queue for Asynchronous Communication
US20100157806A1 (en) * 2008-12-23 2010-06-24 Inventec Corporation Method for processing data packet load balancing and network equipment thereof
US8874724B2 (en) * 2009-08-26 2014-10-28 At&T Intellectual Property I, L.P. Using a content delivery network for security monitoring
US9690638B2 (en) 2011-09-29 2017-06-27 Oracle International Corporation System and method for supporting a complex message header in a transactional middleware machine environment
US9104486B2 (en) * 2011-11-08 2015-08-11 Mckesson Financial Holdings Apparatuses, systems, and methods for distributed workload serialization
US9009702B2 (en) 2011-11-30 2015-04-14 Red Hat Israel, Ltd. Application-driven shared device queue polling in a virtualized computing environment
US8924501B2 (en) 2011-11-30 2014-12-30 Red Hat Israel, Ltd. Application-driven shared device queue polling
US9612866B2 (en) * 2012-08-29 2017-04-04 Oracle International Corporation System and method for determining a recommendation on submitting a work request based on work request type
US20150006620A1 (en) * 2013-06-27 2015-01-01 Applied Materials, Inc. Scalable manufacturing facility management system
US9654408B2 (en) * 2013-11-06 2017-05-16 Amazon Technologies, Inc. Strict queue ordering in a distributed system
JP2015095163A (ja) * 2013-11-13 2015-05-18 オリンパス株式会社 演算装置および演算方法
CN105721337B (zh) * 2014-12-04 2019-06-25 中国移动通信集团公司 软件定义网络中的分布式事务处理方法及装置
CN107612950B (zh) * 2016-07-11 2021-02-05 阿里巴巴集团控股有限公司 一种提供服务的方法、装置、系统、电子设备
CN112003949B (zh) * 2020-09-01 2022-09-13 中国银行股份有限公司 一种was集群下的jms消息进程分发控制系统及方法

Family Cites Families (20)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2867381B2 (ja) 1987-06-23 1999-03-08 株式会社日立製作所 トランザクション処理の負荷分散方法
US5844980A (en) * 1993-03-03 1998-12-01 Siemens Business Communication Systems, Inc. Queue managing system and method
US5459837A (en) * 1993-04-21 1995-10-17 Digital Equipment Corporation System to facilitate efficient utilization of network resources in a computer network
US5797005A (en) * 1994-12-30 1998-08-18 International Business Machines Corporation Shared queue structure for data integrity
US6185611B1 (en) * 1998-03-20 2001-02-06 Sun Microsystem, Inc. Dynamic lookup service in a distributed system
US5758077A (en) * 1996-08-02 1998-05-26 Hewlett-Packard Company Service-centric monitoring system and method for monitoring of distributed services in a computing network
JPH1091595A (ja) 1996-09-12 1998-04-10 Kyushu Nippon Denki Software Kk トランザクション管理装置
US5991808A (en) * 1997-06-02 1999-11-23 Digital Equipment Corporation Task processing optimization in a multiprocessor system
US6601084B1 (en) * 1997-12-19 2003-07-29 Avaya Technology Corp. Dynamic load balancer for multiple network servers
US6304867B1 (en) * 1999-02-25 2001-10-16 Electronic Data Systems Corporation System and method for enhanced performance of a relational database management system through the use of application-specific memory-resident data
JP2000259591A (ja) 1999-03-11 2000-09-22 Matsushita Electric Ind Co Ltd 分散処理ジョブ実行方法およびネットワークシステム
US7089530B1 (en) * 1999-05-17 2006-08-08 Invensys Systems, Inc. Process control configuration system with connection validation and configuration
US6845393B1 (en) * 1999-06-14 2005-01-18 Sun Microsystems, Inc. Lookup discovery service in a distributed system having a plurality of lookup services each with associated characteristics and services
CA2282931C (en) * 1999-09-21 2011-11-22 Microlog Corporation A contact center system capable of handling multiple media types of contacts and method for using the same
JP2001160038A (ja) 1999-12-02 2001-06-12 Ntt Comware Corp 負荷分散式情報処理システム及びその記録媒体
JP2001229142A (ja) * 2000-02-16 2001-08-24 Jisedai Joho Hoso System Kenkyusho:Kk サービス提供装置、送信装置、受信装置および受信方法
US7065574B1 (en) * 2000-05-09 2006-06-20 Sun Microsystems, Inc. Messaging system using pairs of message gates in a distributed computing environment
EP1187016A1 (en) * 2000-09-07 2002-03-13 Matsushita Electric Industrial Co., Ltd. Distributed processing job executing method and network system
US7296268B2 (en) * 2000-12-18 2007-11-13 Microsoft Corporation Dynamic monitor and controller of availability of a load-balancing cluster
US6907461B2 (en) * 2001-03-29 2005-06-14 International Business Machines Corporation Interactive data processor controlled display interface for tracking allocated messages in a dynamic workload balancing communication system

Also Published As

Publication number Publication date
US20080307111A1 (en) 2008-12-11
ATE357022T1 (de) 2007-04-15
JP2008033952A (ja) 2008-02-14
DE60312498T2 (de) 2007-11-29
WO2003083683A3 (en) 2004-04-15
DE60312498D1 (de) 2007-04-26
EP1490781A2 (en) 2004-12-29
KR20040104467A (ko) 2004-12-10
US7454501B2 (en) 2008-11-18
AU2003221501A1 (en) 2003-10-13
CN1643506A (zh) 2005-07-20
CA2479949A1 (en) 2003-10-09
US8190743B2 (en) 2012-05-29
KR100763319B1 (ko) 2007-10-05
JP4028847B2 (ja) 2007-12-26
JP4144897B2 (ja) 2008-09-03
JP2005521945A (ja) 2005-07-21
CA2479949C (en) 2009-04-14
WO2003083683A2 (en) 2003-10-09
US20030187969A1 (en) 2003-10-02
EP1490781B1 (en) 2007-03-14

Similar Documents

Publication Publication Date Title
CN1292365C (zh) 公共工作队列环境中的最适宜服务器
CN1143228C (zh) 对服务器进行负荷管理的数据处理设备和方法
KR100243637B1 (ko) 고-가용성 컴퓨터 서버 시스템
CN103562890B (zh) 在发布/订阅消息系统中管理消息订阅的方法和系统
US7464138B2 (en) Mirror queue in a shared queue environment
US9015303B2 (en) Message queue behavior optimizations
US8938507B2 (en) Integrated two-way communications between database client users and administrators
CN1825312A (zh) 用于定位从联系人源收集的联系人信息的方法和系统
EP2215773A1 (en) Method and system for handling failover in a distributed environment that uses session affinity
US8196150B2 (en) Event locality using queue services
US8230086B2 (en) Hidden group membership in clustered computer system
EP4544412A1 (en) Communication system node having multiple modules and a shared memory
US7979497B2 (en) Message delivery using a plurality of queue managers
US7366960B2 (en) Use of incarnation number for resource state cycling
CN118426980A (zh) 提高大量订单请求速度的方法、装置、设备及存储介质
GB2504124A (en) Managing concurrent conversations over a communications link between a client computer and a server computer
US20040105445A1 (en) Internet protocol for resource-constrained devices
Romano et al. A lightweight and scalable e-Transaction protocol for three-tier systems with centralized back-end database
CN119597502A (zh) 消息处理方法和装置
CN114189489A (zh) 一种消息推送方法、装置、服务器和介质

Legal Events

Date Code Title Description
C06 Publication
PB01 Publication
C10 Entry into substantive examination
SE01 Entry into force of request for substantive examination
C14 Grant of patent or utility model
GR01 Patent grant
CX01 Expiry of patent term
CX01 Expiry of patent term

Granted publication date: 20061227