一种基于tuxedo中间件的智能分流方法转让专利
申请号 : CN202110716247.3
文献号 : CN113379548B
文献日 : 2022-04-15
发明人 : 崔楚明 , 李耀 , 彭磊
申请人 : 武汉众邦银行股份有限公司
摘要 :
权利要求 :
1.一种基于tuxedo中间件的智能分流的方法,其特征在于,包括如下步骤:步骤1:基于tuxedo中间件,银行卡业务平台收到交易请求后,通过交易场景码相关信息,从银行卡业务平台的交易码表plttrscode中加载相关交易配置信息,其中,银行卡业务平台包含借记卡系统、贷记卡系统、监控统计信息区tolmsgmap、监控统计守护进程StatMonPro、交易分发平台和缓存map,借记卡系统和贷记卡系统包括收到的交易,交易场景码相关信息包括交易的报文头中的交易事务标识channel_id、交易码tran_code字段和交易标识tran_flag;
步骤2:基于交易码tran_code字段连接监控统计信息区tolmsgmap,根据监控统计信息区tolmsgmap中的统计信息中的交易平均响应时间valtime、交易事务标识channel_id和交易标识tran_flag确定交易分发平台是走高频、快速或慢速交易平台区,其中,高频为当日同一交易交易成功的平均耗时时间排名前十名的,快速为交易成功响应平均时间valtime在1s内的,慢速为交易响应平均时间valtime大于1s的,交易分发平台基于tuxedo中间件实现交易的过滤和分发,统计信息包括交易成功完成后,银行卡业务平台加载到缓存map中的信息,缓存map中key值为交易码tran_code,key对应的value值包括每笔交易的总交易数量toltimes和交易响应时间valtime,当同一交易码tran_code的总交易数量to ltimes达到
50时,则统计算出交易码tran_code对应的平均响应时间valtime,其中,高频交易平台区包括有事务高频交易平台区和无事务高频交易平台区,快速交易平台区包括有事务快速交易平台区和无事务快速交易平台区,慢速交易平台区包括有事务慢速交易平台区和无事务慢速交易平台区,有事务高频交易平台区、无事务高频交易平台区、有事务快速交易平台区、无事务快速交易平台区、有事务慢速交易平台区和无事务慢速交易平台区自定义有应用平台组group,应用平台组group包括优先级顺序由大到小的应用平台pltapp,应用平台pltapp1和应用平台pltapp2;
步骤3:基于监控统计守护进程StatMonPro,获取高频、快速和慢速每个交易平台区中应用平台pltapp的应用状态,应用状态为正常状态,根据流控规则,对交易做出对应处理,否则转到步骤4;
步骤4:根据组内平台优先级规则,判断最终交易的接入应用平台。
2.根据权利要求1所述的一种基于tuxedo中间件的智能分流的方法,其特征在于:所述步骤1的具体步骤为:
步骤1.1:tuxedo中间件通讯接收到的数据存入数据缓冲区,存入后,将tuxedo中间件的智能分流进程IntelShutPro连接数据连接区data_view,银行卡业务平台收到交易请求后,从银行卡业务平台获取交易的报文交易信息msginfo,即报文,报文包括报文头,数据连接区data_view即指数据缓冲区;
步骤1.2:根据交易的报文头中约定的报文头格式,解析出交易的报文头中的渠道交易事务标识channel_id、交易码tran_code字段和交易标识tran_flag,交易事务标识channel_id为1表示有事务,为0表示无事务,交易标识tran_flag为1表示已定义走高频,为
2表示已定义走快速,为空值表示未定义,走慢速;
步骤1.3:根据解析出来的渠道交易事务标识channel_id和交易码tran_code字段,查找银行卡业务平台的缓存map的交易码表plttrscode获取的交易配置信息。
3.根据权利要求2所述的一种基于tuxedo中间件的智能分流的方法,其特征在于:所述步骤2的具体步骤为:步骤2.1:基于交易码tran_code字段连接监控统计信息区tolmsgmap,连接后,根据交易的报文头中的交易码tran_code字段,查找缓存map,若查到,以交易码tran_code为key值,查找缓存map中对应的value值,该value值中保存有该交易码的平均响应时间valtime和统计的总交易数量toltimes,当总交易数量toltimes toltimes>=50,转到步骤2.3,当总交易数量toltimes toltimes<50,转到步骤2.4,若未查到,转到步骤
2.2;
步骤2.2:交易分发平台走慢速交易模式,再根据交易配置信息中的交易事务标识channel_id,判断是否有交易事务,若无,则交易分发平台走无事务慢速交易平台区,否则走有事务慢速交易平台区;
步骤2.3:根据平均响应时间valtime和交易配置信息中的交易事务标识channel_id确定交易分发平台走的交易平台区;
步骤2.4:根据交易配置信息中交易标识tran_flag和交易事务标识channel_id确定交易分发平台走的交易平台区。
4.根据权利要求3所述的一种基于tuxedo中间件的智能分流的方法,其特征在于:所述步骤2.3的具体步骤为:
步骤2.3.1:首先根据sort方式将监控统计信息区tolmsgmap中根据交易码tran_code对应的平均响应时间进行排名,若该交易码tran_code的排名在前十,则默认走高频交易平台区,然后根据交易配置信息中的交易事务标识channel_id,判断是否有交易事务,若无,则交易分发平台走无事务高频交易平台区,否则走有事务高频交易平台区;
步骤2.3.2:若该交易码tran_code的排名不在前十,则不满足高频交易的分流条件,降级为快速分流的条件判断处理,即该交易的平均响应时间valtime在1s内,则该交易满足快速分流的条件,然后根据交易配置信息中的交易事务标识channel_id,判断是否有交易事务,若无,则交易分发平台走无事务快速交易平台区,否则走有事务快速交易平台区;
步骤2.3.3:若该交易不满足高频分流和快速分流的模式,则走慢速分流的模式,然后根据交易配置信息中的交易事务标识channel_id,判断是否有交易事务,若无,则交易分发平台走无事务慢速交易平台区,否则走有事务慢速交易平台区。
5.根据权利要求4所述的一种基于tuxedo中间件的智能分流的方法,其特征在于:所述步骤3的具体步骤为:
步骤3.1:基于监控统计守护进程StatMonPro,获取高频、快速和慢速交易平台区下应用平台pltapp对应的消息队列的深度;
步骤3.2若消息队列的深度大于等于给定的阈值,监控统计信息区tolmsgmap中的智能分流进程IntelShutPro会更新该应用平台pltapp的应用状态,更新为P‑暂停受理状态,否则更新为S‑正常受理状态,故获取应用平台pltapp的应用状态,通过交易平台区标识码plt_id为key值,到对应的缓存map中找到对应的交易平台区的应用状态plt_status;
步骤3.2:基于各交易平台区中应用平台pltapp的应用状态为S‑正常受理状态,应用平台pltapp接收交易,同时转到步骤3.2进行应用状态更新,否则拒绝受理交易,并转到步骤
4。
6.根据权利要求5所述的一种基于tuxedo中间件的智能分流的方法,其特征在于:所述步骤4的具体步骤为:
步骤4.1:将交易路由到应用平台组group内中最低优先级的应用平台pltapp2;
步骤4.2:若应用平台pltapp2的消息队列的深度也超过阈值,则直接拒绝受理;
步骤4.3:若应用平台pltapp2的消息队列的深度小于阈值,则临时变更应用平台pltapp2为应用平台组group内最小优先级平台,并接受交易。
7.根据权利要求6所述的一种基于tuxedo中间件的智能分流的方法,其特征在于:所述步骤4是通过分发机制转发到对应的应用平台上,即实现交易分发前的最终的智能分流。
说明书 :
一种基于tuxedo中间件的智能分流方法
技术领域
背景技术
权重的方法进行分流,没有根据基于交易平均响应时间的智能分流方案。
发明内容
预;和影响正常接口调用的问题。
业务平台包含借记卡系统、贷记卡系统、监控统计信息区tolmsgmap、监控统计守护进程
StatMonPro、交易分发平台和缓存map,借记卡系统和贷记卡系统包括收到的交易,交易场
景码相关信息包括交易的报文头中的交易事务标识channel_id、交易码tran_code字段和
交易标识tran_flag;
和交易标识tran_flag确定交易分发平台是走高频、快速或慢速交易平台区,其中,高频为
当日同一交易交易成功的平均耗时时间排名前十名的,快速为交易成功响应平均时间
valtime在1s内的,慢速为交易响应平均时间valtime大于1s的,交易分发平台基于tuxedo
中间件实现交易的过滤和分发,统计信息包括交易成功完成后,银行卡业务平台加载到缓
存map中的信息,缓存map中key值为交易码tran_code,key对应的value值包括每笔交易的
总交易数量toltimes和交易响应时间valtime,当同一交易码tran_code的总交易数量
toltimes达到50时,则统计算出交易码tran_code对应的平均响应时间valtime,其中,高频
交易平台区包括有事务高频交易平台区和无事务高频交易平台区,快速交易平台区包括有
事务快速交易平台区和无事务快速交易平台区,慢速交易平台区包括有事务慢速交易平台
区和无事务慢速交易平台区,有事务高频交易平台区、无事务高频交易平台区、有事务快速
交易平台区、无事务快速交易平台区、有事务慢速交易平台区和无事务慢速交易平台区自
定义有应用平台组group,应用平台组group包括优先级顺序由大到小的应用平台pltapp,
应用平台pltapp1和应用平台pltapp2;
理,否则转到步骤4;
请求后,从银行卡业务平台获取交易的报文交易信息msginfo,即报文,报文包括报文头,数
据连接区data_view即指数据缓冲区;
channel_id为1表示有事务,为0表示无事务,交易标识tran_flag为1表示已定义走高频,为
2表示已定义走快速,为空值表示未定义,走慢速;
map,若查到,以交易码tran_code为key值,查找缓存map中对应的value值,该value值中保
存有该交易码的平均响应时间valtime和统计的总交易数量toltimes,当总交易数量
toltimes toltimes>=50,转到步骤2.3,当总交易数量toltimes toltimes<50,转到步
骤2.4,若未查到,转到步骤2.2;
走有事务慢速交易平台区;
易平台区,然后根据交易配置信息中的交易事务标识channel_id,判断是否有交易事务,若
无,则交易分发平台走无事务高频交易平台区,否则走有事务高频交易平台区;
满足快速分流的条件,然后根据交易配置信息中的交易事务标识channel_id,判断是否有
交易事务,若无,则交易分发平台走无事务快速交易平台区,否则走有事务快速交易平台
区。
分发平台走无事务慢速交易平台区,否则走有事务慢速交易平台区。
态,否则更新为S‑正常受理状态,故获取应用平台pltapp的应用状态,通过交易平台区标识
码plt_id为key值,到对应的缓存map中找到对应的交易平台区的应用状态plt_status;
步骤4。
根据响应时间定义快速和慢速)还可保证了整个交易系统的稳定性;
情况,及时的分发到慢速平台,导致正常慢速交易被流控,快速交易正常处理,银行卡业务
平台的交易量处理能力基本能达到正常的TPS的2倍。
附图说明
具体实施方式
文以STRING或者CARRY方式存在内存中),,tuxedo中间件的智能分流进程lntelShutPro接
入数据连接区data_view(tuxedo中间件会将交易收到的请求报文放到数据连接区,以FML
或STRING的形式存在),接入数据后,银行卡业务平台收到交易请求后通过交易场景码相关
信息,从银行卡业务平台的平台交易码配置表中加载相关交易配置信息,其中,银行卡业务
平台包含借记卡系统、贷记卡系统、监控统计信息区tolmsgmap、监控统计守护进程
StatMonPro、交易分发平台和缓存map,借记卡系统和贷记卡系统包括收到的交易,;
请求后,从银行卡业务平台获取交易的报文交易信息msginfo,即报文,报文包括报文头。
channel_id为1表示有事务,为0表示无事务,交易标识tran_flag为1表示已定义走高频,为
2表示已定义走快速,为空值表示未定义,走慢速;
和交易标识tran_flag确定交易分发平台是走高频、快速或慢速交易平台区,其中,高频为
当日同一交易交易成功的平均耗时时间排名前十名的,快速为交易成功响应平均时间
valtime在1s内的,慢速为交易响应平均时间valtime大于1s的,交易分发平台基于tuxedo
中间件实现交易的过滤和分发,统计信息包括交易成功完成后,银行卡业务平台加载到缓
存map中的信息,缓存map中key值为交易码tran_code,key对应的value值包括每笔交易的
总交易数量toltimes和交易响应时间valtime,当同一交易码tran_code的总交易数量
toltimes达到50时,则统计算出交易码tran_code对应的平均响应时间valtime,其中,高频
交易平台区包括有事务高频交易平台区和无事务高频交易平台区,快速交易平台区包括有
事务快速交易平台区和无事务快速交易平台区,慢速交易平台区包括有事务慢速交易平台
区和无事务慢速交易平台区,有事务高频交易平台区、无事务高频交易平台区、有事务快速
交易平台区、无事务快速交易平台区、有事务慢速交易平台区和无事务慢速交易平台区自
定义有应用平台组group,应用平台组group包括优先级顺序由大到小的应用平台pltapp,
应用平台pltapp1和应用平台pltapp2,应用平台组group中的各应用平台为现有的;
key值,查找缓存map中对应的value值为list1,该list1中保存保存有该交易码的平均响应
时间valtime和统计的总交易数量toltimes,当总交易数量toltimes toltimes>=50,转
到步骤2.3,当总交易数量toltimes toltimes<50,转到步骤2.4,若未查到,转到步骤2.2;
走有事务慢速交易平台区。
易平台区,然后根据交易配置信息中的交易事务标识channel_id,判断是否有交易事务,若
无,则交易分发平台走无事务高频交易平台区,否则走有事务高频交易平台区;
满足快速分流的条件,然后根据交易配置信息中的交易事务标识channel_id,判断是否有
交易事务,若无,则交易分发平台走无事务快速交易平台区,否则走有事务快速交易平台
区。
分发平台走无事务慢速交易平台区,否则走有事务慢速交易平台区。
速和慢速每个交易平台区中应用平台pltapp的应用状态,应用状态为正常状态,根据流控
规则,对交易做出对应处理,否则转到步骤4。
态,否则更新为S‑正常受理状态,故获取应用平台pltapp的应用状态,通过交易平台区标识
码plt_id为key值,到对应的缓存map中找到对应的交易平台区的应用状态plt_status,即
当其关联的消息队列的深度大于等于阀值M,则该监控统计守护进程StatMonPro会将该应
用平台pltapp的应用状态修改成P‑暂停受理时(其对应为应用平台的状态表plt_status中
的status字段),若当其关联的消息队列的深度小于阀值M,则将该应用平台pltapp的应用
状态改成S‑正常状态;
步骤4。
内。