数据结构域算法设计-tuxedo_mq1教案

《数据结构域算法设计-tuxedo_mq1教案》由会员上传分享，免费在线阅读，更多相关内容在行业资料-天天文库。

1、应用程序开发指南作者：经乾邮件：jq75@sina.com第7页共7页应用程序开发指南第一章BEATuxedo/Q简介§1.1总体描述BEATuxedo/Q部件允许消息经过排队后存储在持续介质如磁盘或非持续介质如内存中，以便供以后使用。ATMI提供了与排队相关的函数。响应消息和错误消息一样可以存放在队列中。BEATuxedo系统提供了一个命令解释器qmadmin用于创建、列表显示、修改队列。服务器收到请求后，从请求队列中取出消息，对其进行处理，然后将结果存入响应队列中。整个过程都可以进行事务处理。§1.2队

2、列系统的部件和任务下图列出了BEATuxedo队列系统的部件：队列空间是一个资源，对这些资源的访问是通过X/OPENXA-compliant的资源管理器接口来完成的。这个接口是必须的，这样，入队出队操作可以作为XA兼容资源管理器2阶段事务提交的一部分来完成。作者：经乾邮件：jq75@sina.com第7页共7页应用程序开发指南§1.3管理任务BEATuxedo管理员负责定义服务器、创建队列空间、创建队列。管理员必须至少用TMS_QM定义一个队列服务器组，用于事务管理。此外，在配置文件中还必须定义两个系统提供

3、的服务器，它们执行如下功能：⑴．消息队列服务器TMQEUE。用于对消息进行出队入队管理，它为客户机和服务器提供了一个替代的作消息排队的服务器，不论客户机和服务器相对队列来说是不是本地的。⑵．消息转发服务器TMQFORWARD。用于将消息从队列中取出，提交给服务器进行处理，应用服务器不会自动取出自己需要的消息，也不会自动将结果放入队列中。TMQFORWARD服务器从队列空间中的一个或多个消息队列中取出一条消息，将其转发给和队列同名的服务，等待响应。消息处理完毕后，若成功，则将结果放入响应队列；若失败，则将失败

4、消息放入错误队列。队列空间包含了一个队列的集合。这个概念的提出是考虑到额外的管理开销，队列空间中的所有队列都共享持续和非持续的存储空间；TMQUEUE可以处理队列空间内所有队列的出队与出队操作。TMQFORWARD可以处理队列空间中所有队列的消息转发工作。当管理员在一个队列空间中移动消息时，额外开销要比在队列空间之间小，因为只需要进行1阶段提交。定义队列的工作之一是指定队列的排队顺序，排队顺序可以和消息产生时间、消息失效时间、优先级、FIFO、LIFO或者这些方式的组合。你也可以使用消息排队机制来实现客户机

5、之间的点对点通信，这样，两个客户机之间就有再需要其它转发机制，下面是点对点通信的模型：§1.4程序员任务事务管理作者：经乾邮件：jq75@sina.com第7页共7页应用程序开发指南在事务管理方面，一个目标就是在全局事务之间通过队列机制确保可靠性。然而，为了提高应用程序的执行效率，减少执行开销，就需要尽量减少事务的数量。在事务管理方面，一种方法是将消息队列处理放在调用者事务以外，在这种情况下，若消息操作超时，一条消息是否进队将不得而知。较好的办法是将消息队列处理放入调用者事务中，如下图所示：图中，客户机启动

6、了一个事务，将消息放入队列中，成功后提交事务。TMQFORWARD启动第二个事务，消息出队，通过tpcall()调用服务，服务返回结果放入队列。客户机启动第三个事务，从队列中取出响应结果。在一个连续运行的进程中，第三个事务和第一个事务可以合并成一个。小结BEATuxedo/Q提供了如下特征：⑴．一套为客户机请求提供排队机制的API，系统确保只正确执行请求一次；一套按顺序或消息标识符出队的API。⑵．应用程序或管理员可以通过某种标准控制排队机制。⑶．使用事务来确保消息只被处理一次。⑷．管理员可以控制存储在队列

7、中的消息，这包括重试的次数，两个重试的间隔，重新排序，管理队列容量等。作者：经乾邮件：jq75@sina.com第7页共7页应用程序开发指南第二章BEATuxedo/Q的管理BEATuxedo消息系统的管理包含三个内容：配置资源、创建队列空间和队列、监控和维护。BEATuxedo/Q提供了三个服务器，一个是TMS服务器，TMS_QM是BEATuxedo/Q资源管理器的事务管理服务器。也就是说，它管理着消息队列机制的全局事务，它必须在配置文件的GROUPS节中定义。另外两个服务器是：TMQUEUE和TMQFO

8、RWARD，它们必须在配置文件的SERVER节中定义。在TMQFORWARD不能完全满足应用程序的需求时，应用程序就可以创建它自己的队列服务器。如管理员需要将某些消息放入错误队列中，这个工作就是TMQFORWARD不能实现的。应用程序也可以选择点对点的通信方式，在这和情况下，通信直接进行，不需要任何转发服务器。§2.1配置指定QM服务器组必须为每个队列空间定义一个服务器组，需要指定一个组的名称标识，以及组ID号G