CN103188140B - 一种业务请求处理系统 - Google Patents

Abstract

本发明公开了一种业务请求处理系统，通过设置消息中间件装置，对业务中产生的各种消息进行统一调度和管理，使得系统可以对接入的不同业务请求进行统一处理，并通过异步的方式实现业务请求处理和反馈，提高了对业务请求的并发处理能力。按消息发送对象对消息分类为：上行消息队列、下行消息队列和业务处理消息队列，其中下行消息队列又进一步分为下行数据消息队列和下行文本消息队列，实现了有效的消息分类处理。

Description

一种业务请求处理系统

技术领域

本发明涉及业务平台处理技术领域，具体设计一种统一业务请求处理技术领域。

背景技术

在现有的业务平台系统实现中，大多数web请求都是同步处理的。例如，当用户要登入一个网站，首先输入用户名和密码，然后服务器验证登录合法性。如果验证成功，将允许该用户进入网站。这种实现方式，登录请求在从客户端接收以后被及时处理了。

在一种典型的应用：移动支付的票券平台中，系统一方面需要实时的与用户手机STK客户端交互，另一方面又要与业务层的企业应用组件交互，完成整个业务流程，如购票、下载票券等。前者强调交互的实时性，需要快速返回处理结果；后者强调交互的正确性，业务的处理时间随业务类型不同而异，特别是涉及到第三方支付的处理，系统需要发送支付消息并继续处理，同时不能总是要求消息的两端均已启动且就绪。

因此，异步消息传递是类似票券平台这种松散耦合的面向服务的体系结构的策略之选，因为它克服了远程通信固有的一些限制，如延迟和不可靠等。业务处理可以依赖消息传递基础设施来确保成功交付。

现有技术中出现了一种异步消息传递方式，为基于网络业务请求的处理系统及方法，该系统包括顺次连接的客户端、服务器，服务器又包括：通讯处理模块、协议处理模块及业务处理模块；通讯处理模块与协议处理模块之间、协议处理模块与业务处理模块之间均通过异步消息进行通信。这种技术方案，给出了业务请求处理系统的整体架构，模块功能划分明确，且可以根据业务请求处理瓶颈灵活的分配各模块所需资源；但系统也存在冗余度较高、复杂、实施困难等缺点。

发明内容

本发明解决的技术问题是提出一种业务请求处理系统，实现在业务处理时间较长的情况下，确保系统具有较高的并发处理接入请求的能力。

本发明提出的业务请求处理系统，包括：业务请求接入端、统一消息服务装置、消息中间件装置和业务处理装置；所述业务请求接入端将业务请求输入所述统一消息服务装置，所述统一消息服务装置用于实现所述业务请求接入端与所述消息中间件装置之间的消息交互处理；所述消息中间件装置用于实现管理上下行消息和业务处理消息，所述业务处理消息为业务处理中产生的中间消息；；所述业务处理装置用于以异步方式从所述消息中间件装置中提取消息，完成业务处理后向所述消息中间件装置返回处理结果。

进一步的，所述消息中间件装置包括：上行消息队列、下行消息队列和业务处理消息队列；所述上行消息队列用于保存上行业务请求消息；所述下行消息队列用于保存下行业务返回消息；所述业务处理消息队列用于保存业务处理消息。

进一步的，所述下行消息队列包括下行数据消息队列和下行文本消息队列，分别用于存储下行数据消息和下行文本消息。

进一步的，所述消息中间件装置还包括监听模块，所述监听模块用于监听各消息队列中的消息变化情况。

进一步的，所述统一消息服务装置包括统一消息服务服务端和统一消息服务客户端，用于接收不同方式的接入请求。

进一步的，所述统一消息服务服务端和统一消息服务客户端采用本地客户端机制或HTTP协议请求机制实现通讯。

进一步的，所述统一消息服务装置还包括与所述统一消息服务服务端相连的短消息网关，所述短消息网关用于以短消息的方式接入业务请求。

进一步的，所述的业务请求接入端为移动接入端，所述移动接入端用于以短消息的方式向所述短消息网关发送带业务请求的短消息。

进一步的，所述的业务请求接入端为网页接入端，所述网页接入端用于将网络业务请求发送到所述统一消息服务客户端。

进一步的，所述业务处理装置包括前置模块和业务处理模块；所述前置模块用于以异步方式从所述消息中间件装置中提取业务请求消息并发送到所述业务处理模块；所述业务处理模块用于进行业务处理，并通过所述前置模块向所述消息中间件装置返回处理结果。

本发明通过设置消息中间件装置，对业务中产生的各种消息进行统一调度和管理，使得系统可以对接入的不同业务请求进行统一处理，并通过异步的方式实现业务请求处理和反馈，提高了对业务请求的并发处理能力。按消息发送对象对消息分类为：上行消息队列、下行消息队列和业务处理消息队列，其中下行消息队列又进一步分为下行数据消息队列和下行文本消息队列，实现了有效的消息分类处理。

附图说明

图1是本发明业务请求处理系统原理图；

图2是本发明一实施方式提出的业务请求处理系统结构图；

图3是本发明另一实施方式提出的业务请求处理系统结构图。

具体实施方式

下面结合附图，并通过实施例对本发明的具体实现进行详细说明。

如图1所示，本发明提出的业务请求处理系统，包括：业务请求接入端11、统一消息服务装置12、消息中间件装置13和业务处理装置14。业务请求接入端11产生或转发业务请求，并通过不同的方式将业务请求输入统一消息服务装置12，统一消息服务装置12用来实现业务请求接入端11与消息中间件装置13之间的消息交互处理。消息中间件装置13用于管理上下行消息和业务处理消息；业务处理装置14用于以异步方式从消息中间件装置13中提取业务请求消息，完成业务处理后向所述消息中间件装置13返回处理结果。本发明对业务处理产生的所有消息在消息中间件装置13中进行统一管理，包括业务请求消息、业务处理消息等。

如图2所示，本发明一实施方式提出的业务请求处理系统结构，其基本的构成单元与图1相同。本实施方式中消息中间件装置13包括：上行消息队列131、下行消息队列132和业务处理消息队列133；上行消息队列131保存上行业务请求消息；下行消息队列132保存下行业务返回消息；业务处理消息队列133保存业务处理消息。进一步，还可以将下行消息队列132分为下行数据消息队列和下行文本消息队列，分别用于存储下行数据消息和下行文本消息。

此外，还可以在消息中间件装置13中设置监听模块，用来监听各消息队列中的消息变化情况，并触发系统中的相关装置提取消息队列中的消息进行处理。

其中的统一消息服务(UMS)装置12包括统一消息服务服务端121和统一消息服务客户端122，用于接收不同方式的接入请求。当业务请求接入端11为移动接入端111时，以手机终端为例，手机终端通过短消息向统一消息服务装置12发送业务请求，这种情况下统一消息服务装置12内还需要设置一个对应的短消息网关123，通过短消息网关123将手机终端发送的带有业务请求的短消息接入，并转发到消息中间件装置13内的上行消息队列131中进行存储。当业务请求接入端11为网页接入端112时，例如业务后台、网络门户等，通过统一消息服务客户端122接入业务请求消息，并转发到消息中间件装置13内的业务处理消息队列133中进行存储。此外，统一消息服务装置12中的统一消息服务端121和统一消息服务客户端122之间的通讯机制可以有以下两种：

1.本地客户端机制，即统一消息服务客户端122以客户端的形式访问统一消息服务端121，请求进行消息交互处理。

2.HTTP协议请求机制，即由统一消息服务客户端122直接模拟WEB工程传递参数，统一消息服务端121采用代理形式拦截消息，因此该机制需要统一消息服务客户端122采用代理形式，通过浏览器访问统一消息服务端121，实现消息的交互处理。

本实施方式中业务处理装置14进一步包括前置模块141和业务处理模块142；前置模块141用于以异步方式从消息中间件装置13中提取业务请求消息并发送到业务处理模块142，业务请求消息可能位于上行消息队列131中，也可能位于业务处理消息队列133中。业务处理模块142用于进行业务处理，并通过前置模块141向消息中间件装置13返回处理结果，然后再通过统一消息服务装置12将处理结果反馈到用户。

如图3所示，本发明另一实施方式提出的业务请求处理系统结构。其中UMS客户端中设置了手机端消息收发模块和业务消息发送模块。其中的业务请求接入端为票券门户、后台和手机端。本实施方式中手机端的业务请求消息通过短消息网关转发到UMS服务端，再通过UMS客户端中的手机端消息收发模块存入消息中间件装置的上行消息队列。票券门户、后台发送的业务消息直接通过UMS客户端中的业务消息发送模块存入业务处理消息队列。业务处理模块完成业务处理后，产生的下行消息根据消息的内容分别存入下行数据消息队列和下行文本消息队列，并通过手机端消息收发模块、UMS服务端、短消息网关转发到手机端。

以上所述实施例，仅为本发明的较佳实例而已，并非用于限定本发明的保护范围，凡在本发明的精神和原则之内所作的任何修改、等同替换或改进等，均应包含在本发明的保护范围之内。

Claims (10)

1.一种业务请求处理系统，包括：业务请求接入端、统一消息服务装置、消息中间件装置和业务处理装置；所述业务请求接入端将业务请求输入所述统一消息服务装置，所述统一消息服务装置用于接收各所述业务请求接入端的不同方式的接入请求并实现所述业务请求接入端与所述消息中间件装置之间的消息交互处理；所述消息中间件装置用于管理上下行消息和业务处理消息，所述业务处理消息为业务处理中产生的中间消息；所述业务处理装置用于以异步方式从所述消息中间件装置中提取上行消息和/或业务处理消息，完成业务处理后向所述消息中间件装置发送下行消息，返回处理结果。

2.根据权利要求1所述的业务请求处理系统，其特征在于，所述消息中间件装置包括：上行消息队列、下行消息队列和业务处理消息队列；所述上行消息队列用于保存上行业务请求消息；所述下行消息队列用于保存下行业务返回消息；所述业务处理消息队列用于保存业务处理消息。

3.根据权利要求2所述的业务请求处理系统，其特征在于，所述下行消息队列包括下行数据消息队列和下行文本消息队列，分别用于存储下行数据消息和下行文本消息。

4.根据权利要求3所述的业务请求处理系统，其特征在于，所述消息中间件装置还包括监听模块，所述监听模块用于监听各消息队列中的消息变化情况。

5.根据权利要求1-4任一项所述的业务请求处理系统，其特征在于，所述统一消息服务装置包括统一消息服务服务端和统一消息服务客户端。

6.根据权利要求5所述的业务请求处理系统，其特征在于，所述统一消息服务服务端和统一消息服务客户端采用本地客户端机制或HTTP协议请求机制实现通讯。

7.根据权利要求6所述的业务请求处理系统，其特征在于，所述统一消息服务装置还包括与所述统一消息服务服务端相连的短消息网关，所述短消息网关用于以短消息的方式接入业务请求。

8.根据权利要求7所述的业务请求处理系统，其特征在于，所述的业务请求接入端为移动接入端，所述移动接入端用于以短消息的方式向所述短消息网关发送带业务请求的短消息。

9.根据权利要求5所述的业务请求处理系统，其特征在于，所述的业务请求接入端为网页接入端，所述网页接入端用于将网络业务请求发送到所述统一消息服务客户端。

10.根据权利要求1-4任一项所述的业务请求处理系统，其特征在于，所述业务处理装置包括前置模块和业务处理模块；所述前置模块用于以异步方式从所述消息中间件装置中提取业务请求消息并发送到所述业务处理模块；所述业务处理模块用于进行业务处理，并通过所述前置模块向所述消息中间件装置返回处理结果。