太阳城集团

  • / 15
  • 下载费用:30 金币  

消息处理方法、装置、控制器及系统.pdf

摘要
申请专利号:

CN201611229762.4

申请日:

2016.12.27

公开号:

CN106776077A

公开日:

2017.05.31

当前法律状态:

实审

有效性:

审中

法律详情: 实质审查的生效IPC(主分类):G06F 9/54申请日:20161227|||公开
IPC分类号: G06F9/54 主分类号: G06F9/54
申请人: 中国民生银行股份有限公司
发明人: 陆黎川; 王永军; 李林臻; 乔鹤松; 裴晶瑞; 郭峰; 吕峥; 张玉; 李阿飞; 苏晖; 许焱
地址: 100031 北京市西城区复兴门内大街2号
优先权:
专利代理机构: 北京同立钧成知识产权代理有限公司 11205 代理人: 杨文娟;刘芳
PDF完整版下载: PDF下载
法律状态
申请(专利)号:

太阳城集团CN201611229762.4

授权太阳城集团号:

|||

法律状态太阳城集团日:

太阳城集团2017.06.23|||2017.05.31

法律状态类型:

实质审查的生效|||公开

摘要

太阳城集团本发明提供一种消息处理方法、装置、控制器及系统,其中,该消息处理方法包括:接收消息源系统发送的源消息;从预设的消息队列集群中确定所述源消息对应的第一类规则队列;根据所述源消息对应的第一类规则队列中的至少一个第一类规则依次对所述源消息进行处理;从所述消息队列集群中确定所述处理后的消息对应的第二类规则队列;所述第一类规则队列和所述第二规则队列为不同类型的规则队列;根据所述处理后的消息对应的第二类规则队列中的至少一个第二类规则依次对所述处理后的消息进行处理,得到目标消息;将所述目标消息发送至消息目标系统。本发明降低了消息处理的复杂度。

权利要求书

1.一种消息处理方法,其特征在于,包括:
接收消息源系统发送的源消息;
从预设的消息队列集群中确定所述源消息对应的第一类规则队列;
根据所述源消息对应的第一类规则队列中的至少一个第一类规则依次对所述源消息
进行处理;
从所述消息队列集群中确定所述处理后的消息对应的第二类规则队列;所述第一类规
则队列和所述第二规则队列为不同类型的规则队列;
根据所述处理后的消息对应的第二类规则队列中的至少一个第二类规则依次对所述
处理后的消息进行处理,得到目标消息;
将所述目标消息发送至消息目标系统。
2.根据权利要求1所述的方法,其特征在于,所述源消息包括:第一类型标识ID;所述预
设的消息队列集群包括:至少一个第一类规则队列;所述从预设的消息队列集群中确定所
述源消息对应的第一类规则队列,包括:
根据所述第一类型ID,从所述至少一个第一类规则队列中确定所述源消息对应的第一
类规则队列。
3.根据权利要求1所述的方法,其特征在于,所述处理后的消息包括:第二类型ID;所述
预设的消息队列集群包括:至少一个第二类规则队列;所述从所述消息队列集群中确定所
述处理后的消息对应的第二类规则队列,包括:
根据所述第二类型ID,从所述至少一个第二类规则队列中确定所述源消息对应的第二
类规则队列。
4.根据权利要求1-3中任一项所述的方法,其特征在于,所述第一类规规则队列为场景
规则队列,所述第一类规则为场景规则;
所述第二类规规则队列为消费规则队列,所述第二类规则为消费规则。
5.一种消息处理装置,其特征在于,包括:
接收模块,用于接收消息源系统发送的源消息;
第一确定模块,用于从预设的消息队列集群中确定所述源消息对应的第一类规则队
列;
第一处理模块,用于根据所述源消息对应的第一类规则队列中的至少一个第一类规则
依次对所述源消息进行处理;
第二确定模块,用于从所述消息队列集群中确定所述处理后的消息对应的第二类规则
队列;
第二处理模块,用于根据所述处理后的消息对应的第二类规则队列中的至少一个第二
类规则依次对所述处理后的消息进行处理,得到目标消息;
发送模块,用于将所述目标消息发送至消息目标系统。
6.根据权利要求5所述的装置,其特征在于,所述源消息包括:第一类型标识ID;所述预
设的消息队列集群包括:至少一个第一类规则队列;
所述第一确定模块,具体用于根据所述第一类型ID,从所述至少一个第一类规则队列
中确定所述源消息对应的第一类规则队列。
7.根据权利要求5所述的装置,其特征在于,所述处理后的消息包括:第二类型ID;所述
预设的消息队列集群包括:至少一个第二类规则队列;
所述第二确定模块,具体用于根据所述第二类型ID,从所述至少一个第二类规则队列
中确定所述源消息对应的第二类规则队列。
8.根据权利要求5-7中任一项所述的装置,其特征在于,所述第一类规规则队列为场景
规则队列,所述第一类规则为场景规则;
所述第二类规规则队列为消费规则队列,所述第二类规则为消费规则。
9.一种控制器,其特征在于,包括:存储器和处理器;所述存储器与所述处理器连接;
所述存储器用于存储程序指令;
所述处理器,用于调度所述存储器中的所述程序指令,用以执行上述权利要求1-4中任
一项所述的消息处理方法。
10.一种消息处理系统,其特征在于,包括:消息源系统、控制器和消息目标系统;其中,
所述消息源系统与所述控制器连接,所述控制器还与所述消息目标系统连接;
所述消息源系统用于向所述控制器发送源消息;
所述控制器,用于从预设的消息队列集群中确定所述源消息对应的第一类规则队列;
根据所述源消息对应的场景规则队列中的至少一个第一类规则依次对所述源消息进行处
理;从所述消息队列集群中确定所述处理后的消息对应的第二类规则队列;根据所述处理
后的消息对应的第二类规则队列中的至少一个第二类规则依次对所述处理后的消息进行
处理,得到目标消息;并将所述目标消息发送至消息目标系统。

说明书

消息处理方法、装置、控制器及系统

技术领域

本发明涉及消息处理技术领域,尤其涉及一种消息处理方法、装置、控制器及系
统。

背景技术

不同消息系统间的消息处理和转发可通过消息中间件实现。通过消息中间件进行
消息处理,实际是对消息进行直存直取,也就是每从消息源系统接收到一个消息便将其转
发至对应的目标消息系统中。

然而不同目标消息系统需实现不同的业务功能,仅采用消息中间件,便难以实现
对多种目标消息系统对应的业务需求。为实现满足不同的业务需求,可通过集中式消息服
务实现消息的统一处理和转发,通过定义多种不同业务对应的规则执行。在该集中式消息
服务处理过程中,每条消息需经过所有业务对应的规则。

随着应用数量的线性增长,针对各应用的消息量也大量增加,通过集中式消息服
务进行消息处理的性能难以得到有效提高,从而使得消息处理的复杂度较高。

发明内容

本发明提供一种消息处理方法、装置、控制器及系统,以降低消息处理的复杂度。

本发明提供一种消息处理方法,包括:

接收消息源系统发送的源消息;

从预设的消息队列集群中确定所述源消息对应的第一类规则队列;

根据所述源消息对应的第一类规则队列中的至少一个第一类规则依次对所述源
消息进行处理;

从所述消息队列集群中确定所述处理后的消息对应的第二类规则队列;所述第一
类规则队列和所述第二规则队列为不同类型的规则队列;

根据所述处理后的消息对应的第二类规则队列中的至少一个第二类规则依次对
所述处理后的消息进行处理,得到目标消息;

将所述目标消息发送至消息目标系统。

本发明还提供一种消息处理装置,包括:

接收模块,用于接收消息源系统发送的源消息;

第一确定模块,用于从预设的消息队列集群中确定所述源消息对应的第一类规则
队列;

第一处理模块,用于根据所述源消息对应的第一类规则队列中的至少一个第一类
规则依次对所述源消息进行处理;

第二确定模块,用于从所述消息队列集群中确定所述处理后的消息对应的第二类
规则队列;

第二处理模块,用于根据所述处理后的消息对应的第二类规则队列中的至少一个
第二类规则依次对所述处理后的消息进行处理,得到目标消息;

发送模块,用于将所述目标消息发送至消息目标系统。

本发明还提供一种控制器,包括:存储器和处理器;所述存储器与所述处理器连
接;

所述存储器用于存储程序指令;

所述处理器,用于调度所述存储器中的所述程序指令,用以执行上述所述的消息
处理方法。

本发明还提供一种消息处理系统,包括:消息源系统、控制器和消息目标系统;其
中,所述消息源系统与所述控制器连接,所述控制器还与所述消息目标系统连接;

所述消息源系统用于向所述控制器发送源消息;

所述控制器,用于从预设的消息队列集群中确定所述源消息对应的第一类规则队
列;根据所述源消息对应的场景规则队列中的至少一个第一类规则依次对所述源消息进行
处理;从所述消息队列集群中确定所述处理后的消息对应的第二类规则队列;根据所述处
理后的消息对应的第二类规则队列中的至少一个第二类规则依次对所述处理后的消息进
行处理,得到目标消息;并将所述目标消息发送至消息目标系统。

本发明提供的消息处理方法、装置、控制器及系统,可在接收到消息源系统发送的
源消息后,可从预设的消息队列集群中确定该源消息对应的第一类规则队列,并根据该源
消息对应的第一类规则队列中的至少一个第一类规则依次对该源消息进行处理;从该消息
队列集群中确定该处理后的消息对应的第二类规则队列,根据该处理后的消息对应的第二
类规则队列中的至少一个第二类规则依次对该处理后的消息进行处理,得到目标消息;继
而将该目标消息发送至消息目标系统。该消息处理方法中,针对每个源消息,只需根据该源
消息对应的第一类规则队列中的规则进行处理,并根据确定的该处理后的消息对应的第二
类规则队列中的规则进行处理,而无需经过所有的业务规则进行处理,从而减小了消息处
理的复杂度。

附图说明

图1为本发明的一种消息处理系统的结构示意图;

图2为本发明提供的一种消息处理方法的流程图;

图3为本发明提供的一种消息处理方法的流程图;

图4为本发明提供的一种消息处理装置的结构示意图;

图5为本发明提供的一种控制器的结构示意图;

图6为本发明提供的另一种消息处理系统的结构图。

具体实施方式

这里将详细地对示例性实施例进行说明,其示例表示在附图中。下面的描述涉及
附图时,除非另有表示,不同附图中的相同数字表示相同或相似的要素。以下示例性实施例
中所描述的实施方式并不代表与本发明相一致的所有实施方式。相反,它们仅是与如所附
权利要求书中所详述的、本发明的一些方面相一致的装置和方法的例子。

本发明提供的各消息处理方法、装置及控制器,可适用于消息处理系统中。该消息
处理方法可根据确定的源消息对应的第一类规则队列中的至少一个第一类规则对该源消
息进行处理,并根据确定该处理后的消息对应的第二类规则队列中的至少一个第二类规则
依次对该处理后的消息进行处理得到目标消息,继而发送至消息目标系统,可使得该目标
消息既可实现该源消息对应的第一类规则队列所对应的原子服务,也可实现该处理后的消
息对应的跌类规则队列所对应的原子服务。也就是说,该消息处理系统既可实现第一类规
则队列对应的原子服务,也可实现第二类规则队列对应的原子服务,因而该消息处理系统
也可称为分布式消息服务系统。其中,该第一类规则队列可以为场景规则队列,该第一类规
则队列包括包括的每个第一类规则为场景规则;该第二类规规则队列为消费规则队列,该
第二类规则队列包括包括的每个第二类规则为消费规则。

图1为本发明的一种消息处理系统的结构示意图。如图1所示,消息处理系统可包
括:消息源系统101、控制器102、消息目标系统103。消息源系统101可将源消息发送至控制
器102中,控制器102可对该源消息进行处理后得到目标消息消息,将该目标消息发送至消
息目标系统103。消息源系统101和消息目标系统103中的传输的每个消息均需经过控制器
102,由控制器进行处理,因而,控制器102还可以称为消息中心控制器。

其中,控制器102可存储有预设的消息队列集群,该消息队列集群中包括至少一个
第一类规则队列,和,至少一个第二类规则队列。该第一类规则队列和该第二规则队列分别
为不同类型的规则队列。其中,每个第一类规则队列包括依次排列的至少一个第一类规则,
每个第二类规则队列包括依次排列的至少一个第二类规则。每一类规则队列对应一个服
务,无论是第一类规则队列对应的第一类服务,还是第二类规则队列对应的第二类服务,所
有的服务均可注册在该控制器102上,只有注册在控制器102上的服务才可运行。因此,控制
器102可称为所有服务的中央,控制器102可对所有服务的基本太阳城集团和运行情况进行统一监
控,实现合理的服务布局。需要说明的是,控制器102上注册的每个服务可以为原子服务如
分布式原子服务。

本发明提供的各消息处理方法可由图1所示的控制器102执行,控制器102在接收
到消息源系统101发送的源消息后,可从预先存储的消息队列集群中确定该源消息对应的
第一类规则队列,并根据该源消息对应的第一类规则队列中的至少一个第一类规则依次对
该源消息进行处理,实现该源消息对应的第一类规则队列所对应的服务的运行;还从该消
息队列集群中确定该处理后的消息对应的第二类规则队列;根据该处理后的消息对应的第
二类规则队列中的至少一个第二类规则依次对该处理后的消息进行处理,实现运行该源消
息对应的第二类规则队列所对应的服务的运行,得到目标消息;继而将该目标消息发送至
消息目标系统。

该消息处理方法中,针对每个源消息,只需根据该源消息对应的第一类规则队列
中的规则进行处理,并根据确定的该处理后的消息对应的第二类规则队列中的规则进行处
理,而无需经过所有的业务规则进行处理,从而减小了消息处理的复杂度。

如下通过多个实例对本发明的消息处理方法进行说明。

图2为本发明提供的一种消息处理方法的流程图。如图2所示,该方法可包括:

S201、接收消息源系统发送的源消息。

S202、从预设的消息队列集群中确定该源消息对应的第一规则队列。

具体地,该预设的消息队列集群可以为控制器中所存储的消息队列集群。该消息
队列集群中包括至少一个第一类规则队列,和,至少一个第二类规则队列,因而,该消息队
列集群可以为消息的规则队列集群。该S202中可以是根据该源消息,从该预设的消息队列
集群中的至少一个第一类规则队列中确定该源消息对应的第一类规则队列。可选的,该第
一类规规则队列可以为场景规则队列,该第一类规则队列包括包括的每个第一类规则为场
景规则。举例来说,若第一类规则队列为场景规则队列,该消息队列集群中可包括场景规则
队列1、场景规则队列2……场景规则队列N,通过执行该S202中所确定该源消息对应的第一
类规则队列可以为场景规则队列2。

S203、根据该源消息对应的第一类规则队列中的至少一个第一类规则依次对该源
消息进行处理。

具体地,该S203中可以是采用该源消息对应的第一类规则队列的规则排列顺序,
根据该至少一个第一类规则依次对该源消息进行处理,从而实现该源消息对应的第一类规
则队列所对应的服务。

需要说明的是,在执行如上所述的S203中根据该源消息对应的第一类规则队列中
的至少一个第一类规则依次对该源消息进行处理之前,该方法还可包括:

判断该源消息对应的第一类规则队列所对应的服务是否已注册。

若该源消息对应的第一类规则队列所对应的服务已注册,则根据该源消息对应的
第一类规则队列中的至少一个第一类规则依次对该源消息进行处理;反之,若该源消息对
应的第一类规则队列所对应的服务未注册,则无法根据第一类规则对该源消息进行处理,
并向消息源系统返回提示太阳城集团,以指示服务未注册,从而无法根据第一类规则进行消息处
理。

在一种可选的实例中,该方法中可以是通过检测该源消息对应的第一类规则队列
是否具有注册标识,若是,则可确定该源消息对应的第一类规则队列所对应的服务已注册;
若否,则可确定该源消息对应的第一类规则队列所对应的服务未被注册。

在另一种可选的实例中,该方法中还可以是通过确定每个已注册的服务所对应的
第一类规则队列与该源消息对应的第一类规则队列是否一致。若已注册服务中存在一个服
务,其对应的第一类规则队列与该源消息对应的第一类规则队列一致,则可确定该源消息
对应的第一类规则队列所对应的服务已注册;若每个已注册的服务所对应的第一类规则队
列与该源消息对应的第一类规则队列均不一致,则可确定该源消息对应的第一类规则队列
所对应的服务未被注册。

举例来说,若该源消息对应的第一类规则队列为场景规则队列2,则该方法中可以
是采用场景规则队列2的规则排列顺序,根据该场景规则队列2中的至少一个场景规则依次
对该源消息进行处理,从而实现场景规则队列2对应的场景服务。为保证根据场景规则队列
2对该源消息处理,可实现对应的服务,使得控制器精确对所有服务的基本太阳城集团和运行情况
进行统一监控,实现合理的服务布局,该方法中需确定该场景规则队列2对应的服务是否注
册,若是,则根据该场景规则队列2中的至少一个场景规则依次对该源消息进行处理。

S204、从该消息队列集群中确定该处理后的消息对应的第二类规则队列。

具体地,该S204中可以是根据该处理后的消息,从该消息队列集群中的至少一个
第二类规则队列中确定该处理后的消息对应的第二类规则队列。可选的,该第二类规规则
队列可以为消费规则队列,该第二类规则队列包括包括的每个第二类规则为消费规则。举
例来说,若第二类规则队列为消费规则队列,该消息队列集群中可包括消费规则队列1、消
费规则队列2……消费规则队列N,通过执行该S204中所确定该处理后的消费规则队列可以
为消费规则队列3。

S205、根据该处理后的消息对应的第二类规则队列中的至少一个第二类规则依次
对该处理后的消息进行处理,得到目标消息。

具体地,该S205中可以是采用该处理后的消息对应的第二类规则队列的规则排列
顺序,根据该至少一个第二类规则依次对该处理后的消息进行处理,从而实现该处理后的
消息对应的第二类规则队列所对应的服务。

需要说明的是,在执行如上所述的S205中根据该处理后的消息对应的第二类规则
队列中的至少一个第二类规则依次对该处理后的消息进行处理,得到目标消息之前,该方
法还可包括:

判断该处理后的消息对应的第二类规则队列所对应的服务是否已注册。

若该处理后的消息对应的第二类规则队列所对应的服务已注册,则根据该处理后
的消息对应的第二类规则队列中的至少一个第二类规则依次对该处理后的消息进行处理;
反之,若该处理后的消息对应的第二类规则队列所对应的服务未注册,则无法根据第二类
规则对该处理后的消息进行处理,并向消息源系统返回提示太阳城集团,以指示服务未注册,从而
无法根据第二类规则进行消息处理。

具体如何判断该处理后的消息对应的第二类规则队列所对应的服务是否已注册
的实现过程,与上述判断该源消息对应的第一类规则队列所对应的服务是否已注册的实现
过程类似,在此不再赘述。

举例来说,若该处理后的消息对应的第二类规则队列为消费规则队列3,则该方法
中可以是采用消费规则队列3的规则排列顺序,根据该消费规则队列3中的至少一个消费规
则依次对该处理后的消息进行处理,从而实现消费规则队列3对应的消费服务。为保证根据
消费规则队列3对该处理后的消息处理,可实现对应的服务,使得控制器精确对所有服务的
基本太阳城集团和运行情况进行统一监控,实现合理的服务布局,该方法中需确定该消费规则队
列3对应的服务是否注册,若是,则根据该消费规则队列3中的至少一个消费规则依次对该
处理后的消息进行处理。

S206、将该目标消息发送至消息目标系统。

本发明提供的消息处理方法,可在接收到消息源系统发送的源消息后,可从预设
的消息队列集群中确定该源消息对应的第一类规则队列,并根据该源消息对应的第一类规
则队列中的至少一个第一类规则依次对该源消息进行处理;从该消息队列集群中确定该处
理后的消息对应的第二类规则队列,根据该处理后的消息对应的第二类规则队列中的至少
一个第二类规则依次对该处理后的消息进行处理,得到目标消息;继而将该目标消息发送
至消息目标系统。该消息处理方法中,针对每个源消息,只需根据该源消息对应的第一类规
则队列中的规则进行处理,并根据确定的该处理后的消息对应的第二类规则队列中的规则
进行处理,而无需经过所有的业务规则进行处理,从而减小了消息处理的复杂度。

由于该方法降低了针对每个源消息的处理复杂度,因而该方法还可有效保证随着
应用数量的增长带来的消息量的增加情况下的消息处理性能。

该方法中,可通过一种类型的一个规则队列对应一个服务,如原子服务,可通过动
态配置规则队列动态扩展对应的服务,实现消息服务的动态扩展。例如可服务的性能配置
对应的规则队列,如对于处理太阳城集团短的消息服务,可配置较少的原子服务个数保证性能;相
反地,对于处理太阳城集团长的消息服务,可通过配置较多的原子服务个数保证性能。

由于该方法中,将不同类型的规则队列独立部署,实现不同的服务,即采用了原子
服务的分布式部署,即便某个规则队列失效即某个规则对应的原子服务失效,也不会响应
其它规则队列,从而不会响应整体服务的失效,保证了消息处理系统所提供的消息服务的
健壮性。

可选的,如上所述的所述源消息包括:第一类型标识(Identity,简称ID);该预设
的消息队列集群包括:至少一个第一类规则队列。如上所述的S202中从预设的消息队列集
群中确定该源消息对应的第一规则队列,可以包括:

根据该第一类型ID,从该至少一个第一类规则队列中确定该源消息对应的第一类
规则队列。

具体地,该方法中,可以是根据该第一类型ID,从至少一个第一类规则队列中,确
定该第一类型ID所对应的规则队列为该源消息对应第一类规则队列。该第一类型ID所对应
的规则队列还可称为该第一类型ID所定义的规则链。第一类型ID可以为场景ID,该第一类
规则队列可以为场景规则队列。该方法中,根据该第一类型ID,确定该第一类型ID所对应的
规则队列为该源消息对应第一类规则队列,提高了确定规则队列的灵活性,从而提高消息
处理的灵活性;该方法中仅可根据确定的该源消息对应第一类规则队列进行消息处理,而
无需根据其他第一类规则队列进行消息处理,因而,还降低针对不同规则队列,即不同原子
服务进行消息处理的负载。

可选的,该处理后的消息包括:第二类型ID;该预设的消息队列集群包括:至少一
个第二类规则队列。如上所述的S204中从该消息队列集群中确定该处理后的消息对应的第
二类规则队列,可包括:

根据该第二类型ID,从该至少一个第二类规则队列中确定该源消息对应的第二类
规则队列。

该方法中,可以是根据该第二类型ID,从至少一个第二类规则队列中,确定该第二
类型ID所对应的规则队列为该源消息对应第二类规则队列。该第二类型ID所对应的规则队
列还可称为该第二类型ID所定义的规则链。第二类型ID可以为消费ID,该第二类规则队列
可以为消费规则队列。该方法中,根据该第二类型ID,确定该第二类型ID所对应的规则队列
为该处理后的消息对应第二类规则队列,也可提高确定规则队列的灵活性,从而提高消息
处理的灵活性;该方法中仅可根据确定的该源消息对应第二类规则队列进行消息处理,而
无需根据其他第二类规则队列进行消息处理,因而,还降低针对不同规则队列,即不同原子
服务进行消息处理的负载。

可选的,本发明还提供一种消息处理方法。图3为本发明提供的一种消息处理方法
的流程图。如图3所示,该方法可包括:

S301、接收消息源系统发送的源消息,该源消息可包括:场景ID和消费ID。

S302、根据该场景ID,从预设的消息队列集群中的至少一个场景规则队列中,确定
该场景ID对应的场景规则队列为该源消息对应的场景规则队列。

S303、根据该源消息对应的场景规则队列中的至少一个场景规则依次对该源消息
进行处理,得到处理后的消息,该处理后的消息包括该消费ID。

S304、根据该消费ID,从预设的消息队列集群中的至少一个消费规则队列中,确定
该消费ID对应的消费规则队列为该处理后的消息对应的消费规则队列。

S305、根据该处理后的消息对应的消费规则队列中的至少一个消费规则依次对该
处理后的消息进行处理,得到目标消息。

S306、将该目标消息发送至消息目标系统。

本发明提供的消息处理方法,可在接收到消息源系统发送的源消息后,可从预设
的消息队列集群中确定该源消息对应的场景规则队列,并根据该源消息对应的场景规则队
列中的至少一个场景规则依次对该源消息进行处理;从该消息队列集群中确定该处理后的
消息对应的消费规则队列,根据该处理后的消息对应的消费规则队列中的至少一个消费规
则依次对该处理后的消息进行处理,得到目标消息;继而将该目标消息发送至消息目标系
统。该消息处理方法中,针对每个源消息,只需根据该源消息对应的场景规则队列中的规则
进行处理,并根据确定的该处理后的消息对应的消费规则队列中的规则进行处理,而无需
经过所有的业务规则进行处理,从而减小了消息处理的复杂度。

本发明还提供一种消息处理装置。该消息处理装置可通过软件和/或硬件的方式
实现,用以执行上述图2或图3中任一所述的消息处理方法。图4为本发明提供的一种消息处
理装置的结构示意图。如图4所示,该消息处理装置400可包括:

接收模块401,用于接收消息源系统发送的源消息。

第一确定模块402,用于从预设的消息队列集群中确定该源消息对应的第一类规
则队列。

第一处理模块403,用于根据该源消息对应的第一类规则队列中的至少一个第一
类规则依次对该源消息进行处理,

第二确定模块404,用于从该消息队列集群中确定该处理后的消息对应的第二类
规则队列。

第二处理模块405,用于根据该处理后的消息对应的第二类规则队列中的至少一
个第二类规则依次对该处理后的消息进行处理,得到目标消息。

发送模块406,用于将该目标消息发送至消息目标系统。

可选的,该源消息可包括:第一类型ID;该预设的消息队列集群包括:至少一个第
一类规则队列。

第一确定模块402,具体用于根据该第一类型ID,从该至少一个第一类规则队列中
确定该源消息对应的第一类规则队列。

可选的,该处理后的消息包括:第二类型ID;该预设的消息队列集群包括:至少一
个第二类规则队列。

第二确定模块404,具体用于根据该第二类型ID,从该至少一个第二类规则队列中
确定该源消息对应的第二类规则队列。

可选的,该第一类规规则队列为场景规则队列,该第一类规则为场景规则;

该第二类规规则队列为消费规则队列,该第二类规则为消费规则。

本发明所提供的消息处理装置,可执行上述图2或图3中任一所述的消息处理方
法,其具体的实现过程及有益效果可参见上述,在此不再赘述。

本发明还提供一种控制器。该控制器中可集成有如上图4所示的消息处理模块,用
以执行上述图2或图3中任一所述的消息处理方法。图5为本发明提供的一种控制器的结构
示意图。如图5所示,控制器500包括:存储器501和处理器502;存储器501与处理器502连接。

存储器501用于存储程序指令。

处理器502,用于调用存储器501中的程序指令,用以执行上述图2或3项所述的消
息处理方法。

本发明所提供的控制器,可执行上述图2或图3中任一所述的消息处理方法,其具
体的实现过程及有益效果可参见上述,在此不再赘述。

本发明还提供一种消息处理系统。图6为本发明提供的另一种消息处理系统的结
构图。如图6所示,消息处理系统600,可包括:消息源系统601、控制器602和消息目标系统
603;其中,消息源系统601与控制器602连接,控制器602还与消息目标系统603连接。

其中,消息源系统601用于向控制器602发送源消息。

控制器602,用于从预设的消息队列集群中确定该源消息对应的第一类规则队列;
根据该源消息对应的场景规则队列中的至少一个第一类规则依次对该源消息进行处理;从
该消息队列集群中确定该处理后的消息对应的第二类规则队列;根据该处理后的消息对应
的第二类规则队列中的至少一个第二类规则依次对该处理后的消息进行处理,得到目标消
息;并将该目标消息发送至消息目标系统603。

可选的,该源消息包括:第一类型ID;该预设的消息队列集群包括:至少一个第一
类规则队列。

控制器602,具体用于根据该第一类型ID,从该至少一个第一类规则队列中确定该
源消息对应的第一类规则队列。

可选的,该处理后的消息包括:第二类型ID;该预设的消息队列集群包括:至少一
个第二类规则队列。

控制器602,具体用于根据该第二类型ID,从该至少一个第二类规则队列中确定该
源消息对应的第二类规则队列。

可选的,该第一类规规则队列为场景规则队列,该第一类规则为场景规则;该第二
类规规则队列为消费规则队列,该第二类规则为消费规则。

本发明所提供的消息处理系统,可执行上述图2或图3中任一所述的消息处理方
法,其具体的实现过程及有益效果可参见上述,在此不再赘述。

最后应说明的是:以上各实施例仅用以说明本发明的技术方案,而非对其限制;尽
管参照前述各实施例对本发明进行了详细的说明,本领域的普通技术人员应当理解:其依
然可以对前述各实施例所记载的技术方案进行修改,或者对其中部分或者全部技术特征进
行等同替换;而这些修改或者替换,并不使相应技术方案的本质脱离本发明各实施例技术
方案的范围。

关 键 词:
消息 处理 方法 装置 控制器 系统
  专利查询网所有资源均是用户自行上传分享,仅供网友学习交流,未经上传用户书面授权,请勿作他用。
太阳城集团本文
本文标题:消息处理方法、装置、控制器及系统.pdf
链接地址:http://zh228.com/p-6019834.html
太阳城集团我们 - 网站声明 - 网站地图 - 资源地图 - 友情链接 - 网站客服客服 - 联系我们

copyright@ 2017-2018 zhuanlichaxun.net网站版权所有
经营许可证编号:粤ICP备17046363号-1 
 


收起
展开
葡京赌场|welcome document.write ('');