一种机场企业服务总线系统

摘要

本申请涉及一种机场企业服务总线系统，涉及系统集成技术领域，解决了原生消息中间件不支持消息日志，所有的消息都会实时显示在控制界面中，当消息被接收或消费后，将无法溯源的问题，其包括：消息中间件；消息传输服务模块，从消息中间件内获取数据并解析，根据预设的配置判断消息的合法性和正确性，然后重新将合法和正确的信息发送回消息中间件，以便于消息中间件通过消息队列作消息分发。日志服务缓存模块，读取消息传输服务模块所产生的日志数据，并将其写入缓存；第一数据库，用于存储日志服务缓存模块所产生的缓存数据。本申请具有如下效果：让任何操作或消息传递过程都将产生审计数据，作为后续排查和溯源的数据支撑。

说明书

技术领域

本申请涉及系统集成技术领域，尤其是涉及一种机场企业服务总线系统。

背景技术

随着机场公司业务的日益发展，企业渠道也日益增多，每个渠道都希望能够在事件发生时，就立刻做出相应的反应，基于以上需要有必要建立机场企业服务总线系统，从数据层面对机场各层面的信息资源进行整合、充分发挥和挖掘信息资源的潜在价值，提供面向生产保证、旅客服务、安全运行、商业分析和运营管理的多维度分析和实时运行态势展示，实现对运行态势和运营状况的实施把控和深入分析，从而为不同情况下的决策分析提供准确有效的支持，并面向机场运营、安全管理和旅客服务提供事件处理模型，实现复杂事件决策支持，跨部门业务协同，实现主动决策及信息实时共享。

现有的机场企业服务总线系统，采用的原生的消息队列队列中间件，通过配置为各个业务系统创建消息队列(Queue)，绑定针对业务的路由键标识符(RoutingKey)，并通过不同的交换器(Exchange)发布不同主题的业务消息，借助消息中间件的分发规则，达到消息传递的目的。

针对上述中的相关技术，发明人发现如下缺陷：原生消息中间件不支持消息日志，所有的消息都会实时显示在控制界面中，当消息被接收或消费后，将无法溯源。

发明内容

为了让任何操作或消息传递过程都将产生审计数据，作为后续排查和溯源的数据支撑，本申请提供一种机场企业服务总线系统，采用如下的技术方案：

一种机场企业服务总线系统,包括：

消息中间件，消息队列的载体，具有消息分发的功能；

消息传输服务模块，从消息中间件内获取数据并解析，根据预设的配置判断消息的合法性和正确性，然后重新将合法和正确的信息发送回消息中间件，以便于消息中间件通过消息队列作消息分发。

日志服务缓存模块，读取消息传输服务模块所产生的日志数据，并将其写入缓存；

第一数据库，用于存储日志服务缓存模块所产生的缓存数据。

可选的，消息中间件包括：

消息绑定模块，被映射为消息中间件的交换器，以用于接收消息传输服务模块所传输的消息并转换为不同主题的业务信息；

消息订阅模块，映射为消息中间件中的消息队列，用于接收消息绑定模块所交换的不同主题的业务信息；

机场企业服务总线系统还包括：

系统业务模块，被映射为消息中间件中的用户，用于接收消息订阅模块所传送的信息。

可选的，一种机场企业服务总线系统还包括：

第二数据库，存储有用户所关注的主题信息的要点信息；

解析模块，用于解析主题信息中的要点信息；

处理模块，用于数据调取、分析处理；

处理模块以主题信息所发送的用户作为查询对象，从第二数据库中查询获取用户所关注的主题信息的要点信息，并通过解析模块对所发送的主题信息解析获取要点信息，在发送至用户所持终端的时候，优先展示要点信息。

可选的，一种机场企业服务总线系统还包括：

第三数据库，存储有不同主题信息所对应的紧急度，主题信息的紧急度分为一般、紧急、非常紧急；

定时浏览模块，根据不同紧急度所预设的时间限定用户先浏览要点信息；

处理模块以主题作为查询对象，从第三数据库中查询获取相应主题信息所对应的紧急度；

若紧急度为非常紧急，则以第一预设时间限定用户先浏览要点信息；

若紧急度为紧急，则以第二预设时间限定用户浏览要点信息，其中第一预设时间大于等于第二预设时间；

若紧急度为一般，则不限定用户浏览要点信息的时间。

可选的，一种机场企业服务总线系统还包括：

第四数据库，存储有用户在不同时段浏览要点信息的单位字节耗时；

若紧急度为非常紧急，处理模块从第四数据库中查询获取用户在不同时段浏览要点信息的单位字节耗时，并选取其中最慢的单位字节耗时，将最慢的单位字节耗时与要点信息内容所涉及的字节数的乘积，作为以第一预设时间；

若紧急度为紧急，处理模块从第四数据库中查询获取用户在不同时段浏览要点信息的单位字节耗时，并选取当下时段所对应的单位字节耗时，将当下时段所对应的单位字节耗时与要点信息内容所涉及的字节数的乘积，作为以第一预设时间。

可选的，一种机场企业服务总线系统，包括

第五数据库，存储有用户所倾向的警示颜色；

处理模块以用户作为查询对象，从第五数据库中查询获取用户所倾向的警示颜色，对要点信息作标记。

可选的，一种机场企业服务总线系统包括：

信息确认接收模块，用于确认用户是否确认接收主题信息；

第六数据库，存储有用户在不同时段接收不同形式信息的反应时长；

处理模块以用户以及当前时段作为查询对象，从第六数据库中查询获取用户在当前时段的反应时长；

语音提示模块，用于语音提示用户；

若信息确认接收模块未在用户在当前时段的反应时长内确认接收主题信息，则启动语音提示模块提醒用户。

可选的，一种机场企业服务总线系统包括：

第七数据库，存储有用户失联所在地的概率分布信息以及相应所在地其余人员在现场的概率；

若语音提示模块启动后，信息确认接收模块未在用户在当前时段的反应时长内确认接收主题信息，则处理器从第七数据中查询获取用户失联最大概率的所在地以及相应所在地其余人员在现场的概率；

选择最大概率在现场人员作为通知对象，通过语音提示模块进行通知，以间接通知相应用户。

综上所述，本申请的有益技术效果为：

本发明提供可视化的配置操作界面，把复杂的专业消息队列配置转化为业务操作形式，即消息绑定和订阅。在本发明系统中，业务系统被映射成消息中间件中的用户，消息绑定映射为消息中间件中的交换器，消息订阅映射为消息中间件中的消息队列。业务系统的消息绑定和订阅将实时地再消息中间件中创建相应的系统资源，保证系统配置和消息中间件资源实时同步。用户不再需要了解消息中间件的概念，只要按照需求，对业务系统的关系进行配置即可。

2、本发明在消息中间件的基础上进行开发，任何操作或消息传递过程都将产生审计数据，作为后续排查和溯源的数据支撑。

附图说明

为了更清楚地说明本发明实施例或现有技术中的技术方案，下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图示出的结构获得其他的附图。

图1是本申请实施例一种机场企业服务总线系统的系统框图一。

图2是本申请实施例一种机场企业服务总线系统的系统框图二。

图3是本申请实施例一种机场企业服务总线系统的系统框图三。

图中，1、消息中间件；2、消息传输服务模块；3、日志服务缓存模块；4、第一数据库；5、消息绑定模块；6、消息订阅模块；7、系统业务模块；8、第二数据库；9、解析模块；10、处理模块；11、第三数据库；12、定时浏览模块；13、第四数据库；14、第五数据库；15、信息确认接收模块；16、第六数据库；17、语音提示模块；18、第七数据库。

具体实施方式

以下结合附图对本申请作进一步详细说明。

参照图1，为本申请公开的一种机场企业服务总线系统,包括消息中间件1、消息传输服务模块2、日志服务缓存模块3、第一数据库4。

其中，消息中间件1为消息队列的载体，具有消息分发的功能；消息传输服务模块2从消息中间件1内获取数据并解析，根据预设的配置判断消息的合法性和正确性，然后重新将合法和正确的信息发送回消息中间件1，以便于消息中间件1通过消息队列作消息分发；日志服务缓存模块3用于读取消息传输服务模块2所产生的日志数据，并将其写入缓存；第一数据库4，用于存储日志服务缓存模块3所产生的缓存数据。

进一步考虑到原有消息中间件1的处理，需要负责管理的业务人员需要具备专业的技术知识，了解消息队列和消息分发的原理和规则才能准确地进行相关配置。

基于以上考虑，消息中间件1包括消息绑定模块5、消息订阅模块6；机场企业服务总线系统还包括系统业务模块7。

其中，消息绑定模块5被映射为消息中间件1的交换器，以用于接收消息传输服务模块2所传输的消息并转换为不同主题的业务信息；消息订阅模块6，映射为消息中间件1中的消息队列，用于接收消息绑定模块5所交换的不同主题的业务信息；系统业务模块7，被映射为消息中间件1中的用户，用于接收消息订阅模块6所传送的信息，其中，系统业务为需要使用消息传输功能的其他系统。

参照图2，进一步考虑到用户在接收信息的时候能够先了解要点后再去看具体的内容，以便于更好把控重点，一种机场企业服务总线系统，还包括存储有用户所关注的主题信息的要点信息的第二数据库8、用于解析主题信息中的要点信息的解析模块9、用于数据调取、分析处理的处理模块10；处理模块10优选中央处理器。

处理模块10以主题信息所发送的用户作为查询对象，从第二数据库8中查询获取用户所关注的主题信息的要点信息，并通过解析模块9对所发送的主题信息解析获取要点信息，在发送至用户所持终端的时候，优先展示要点信息。

另外，考虑到由于不同主题信息的紧急度也是有所不同的，因此一种机场企业服务总线系统还包括存储有不同主题信息所对应的紧急度的第三数据库11、根据不同紧急度所预设的时间限定用户先浏览要点信息的定时浏览模块12。其中，主题信息的紧急度分为一般、紧急、非常紧急。

处理模块10以主题作为查询对象，从第三数据库11中查询获取相应主题信息所对应的紧急度；若紧急度为非常紧急，则以第一预设时间限定用户先浏览要点信息；若紧急度为紧急，则以第二预设时间限定用户浏览要点信息，其中第一预设时间大于等于第二预设时间；若紧急度为一般，则不限定用户浏览要点信息的时间。

进一步的，考虑到每个用户浏览要点信息的速度也是不一致的，因此需要对其中的预设时间作出修改，以便于更符合用户的需要，一种机场企业服务总线系统还包括存储有用户在不同时段浏览要点信息的单位字节耗时的第四数据库13。

若紧急度为非常紧急，处理模块10从第四数据库13中查询获取用户在不同时段浏览要点信息的单位字节耗时，并选取其中最慢的单位字节耗时，将最慢的单位字节耗时与要点信息内容所涉及的字节数的乘积，作为以第一预设时间；若紧急度为紧急，处理模块10从第四数据库13中查询获取用户在不同时段浏览要点信息的单位字节耗时，并选取当下时段所对应的单位字节耗时，将当下时段所对应的单位字节耗时与要点信息内容所涉及的字节数的乘积，作为以第一预设时间。

另外，考虑到不同用户对警示颜色有所不同，为更好的保障通知用户的效果，一种机场企业服务总线系统包括存储有用户所倾向的警示颜色的第五数据库14。

处理模块10以用户作为查询对象，从第五数据库14中查询获取用户所倾向的警示颜色，对要点信息作标记。

参照图3，进一步，考虑到用户是否及时确认接收信息的情况，一种机场企业服务总线系统包括用于确认用户是否确认接收主题信息的信息确认接收模块15、存储有用户在不同时段接收不同形式信息的反应时长的第六数据库16、用于语音提示用户的语音提示模块17。

处理模块10以用户以及当前时段作为查询对象，从第六数据库16中查询获取用户在当前时段的反应时长。

若信息确认接收模块15未在用户在当前时段的反应时长内确认接收主题信息，则启动语音提示模块17提醒用户。

进一步考虑到用户无法及时通知的情况，此时考虑通过他人间接通知相应用户，一种机场企业服务总线系统包括存储有用户失联所在地的概率分布信息以及相应所在地其余人员在现场的概率的第七数据库18。

若语音提示模块17启动后，信息确认接收模块15未在用户在当前时段的反应时长内确认接收主题信息，则处理器从第七数据中查询获取用户失联最大概率的所在地以及相应所在地其余人员在现场的概率；

处理器选择最大概率在现场人员作为通知对象，通过语音提示模块17进行通知，以间接通知相应用户。

本实施例的实施原理为：

业务系统被映射成消息中间件1中的用户，消息绑定映射为消息中间件1中的交换器，消息订阅映射为消息中间件1中的消息队列。业务系统的消息绑定和订阅将实时地再消息中间件1中创建相应的系统资源，保证系统配置和消息中间件1资源实时同步。用户不再需要了解消息中间件1的概念，只要按照需求，对业务系统的关系进行配置即可。

在通知用户的时候充分考虑用户的浏览要点的速度设定时间让用户在接收要点信息后进行浏览，从而对主题信息有初步了解，而且在无法通知到用户的时候，也会采用更换通知方式，甚至会在实在无法通知到用户的情况下，会通过他人来通知相应用户。

本具体实施方式的实施例均为本申请的较佳实施例，并非依此限制本申请的保护范围，故：凡依本申请的结构、形状、原理所做的等效变化，均应涵盖于本申请的保护范围之内。