《2022年银行业务系统日终结息批处理多进程处理设计方案 .pdf》由会员分享，可在线阅读，更多相关《2022年银行业务系统日终结息批处理多进程处理设计方案 .pdf（6页珍藏版）》请在taowenge.com淘文阁网|工程机械CAD图纸|机械工程制图|CAD装配图下载|SolidWorks_CaTia_CAD_UG_PROE_设计图分享下载上搜索。
1、版本号修改人修改日期修改说明1.0 hwx 2013-01-09 初稿1.1 hwx 2013-01-10 简化了设计。明确了数据优先级的概念。名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 1 页，共 6 页 - - - - - - - - - 名词介绍监理进程 ：用来启动、停止工作进程，给工作进程分配任务，监控工作进程的状态，监控系统资源。工作进程 ：用来完成具体的业务功能，详细的业务逻辑要在这个进程里执行。报文格式“指令”是监理进程发送给工作进程的。“状态”是工作进程发送给监理
2、进程的。指令 /状态Char(1) 指令A 开始数据处理B 暂停执行C 退出程序状态1 程序处理成功完成2 程序处理失败数据长度Char(4) 不够四位，左补零数据内容Char（n）数据结构交易并发定义表( tx_concur_def) tx_code Char(4) 交易码tx_prog Char(20) 交易函数对应的 so 是 tx_prog.so tx_data Char(1024) 数据来源是一个 sql语句，返回一个结果集。首先取到的数据被优先处理。结果集格式：第一列数据例子：select opn_br_no from td_mst group by 名师资料总结 - - -精品资
3、料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 2 页，共 6 页 - - - - - - - - - opn_br_no order by count(*) desc 对于需要多列的数据的，可以把列合并。例如select prdt_no |opn_br_no ,count(*) from dd_mst group by 1 order by count(*) desc; proc_upper_lmt Decimal(3,0) 进程数上限Load_upper_lmt Decimal(3,0) 负载上限最大值为10
4、0,最小值为0 data_code Char(4) 数据编码放结果集里的数据tx_status Char(1) 交易状态0初始状态1正在执行2执行失败clear_result Char(1) 在 成 功 做 完 后删除tx_concur_result里的数据。Y 是N 否result_id Decimal(10,0) 结果标识初始值为零， 以后这个值会自动增加。每次运行一下任务，这个域的数据会加一。此列数据一般不用修改。交易并发结果表（tx_concur_result ）tx_code Char(4) 交易代码result_id Decimal(10,0) 结果标识data_id Decima
5、l(10,0) 数据标识从 1 开始递增data_value Char(100) 数据内容data_status Char(1) 任务状态Y 成功N 没有成功Create unidex index tx_concur_resut_idx1 on tx_concur_result (tx_code,result_id,data_id)监理进程流程1. 根据 tx_code,读取 tx_concur_def 里数据2. 创建 proc_upper_limit 和当前负载情况，创建适当数量的工作进程3. 查看 tx_status 的状态。如果 tx_status 为零，表示这个交易需要初始化a)把
6、result_id 加 1 b)执行 tx_data 里 sql 语句，名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 3 页，共 6 页 - - - - - - - - - c)把结果放到 tx_concur_result 里的 data_value 列里。d)把 data_status 设置为 N 4. 对并发数据 (tx_concur_result)进行循环处理a)读 取tx_concur_result 里 的 数 据 ， 条 件 为tx_concur_result.tx_co
7、de =tx_concur_def.tx_code and tx_concur_result.result_id and =tx_concur_def.result_id and data_status= Nb)调用系统监控接口，决定是否可以处理用户数据c)查看工作进程队列，如果有可用进程，把数据发送到可用进程d)检查是否有死进程，有则记录错误状态，重新启动该工作进程e)据工作进程的结果，更新tx_concur_result 里的 data_status 5. 根据 tx_concur_result 里的 data_status，更新 tx_concur_def 里的 tx_status 工作
8、进程流程1. 初始化环境2. 循环处理“监管进程”发布的指令a)解析传入的数据，把值放到相应的数据编码里b)调用 tx_prog 程序c)把 tx_prog 的执行结果返回到“监管进程”“工作进程”内部如果有循环的数据要处理， 那么也可以调用系统资源监控API，来决定是否处暂停处理下一条。储蓄活期结息的说明方法 1:按机构结息字段值说明tx_data Select opn_br_no from dd_mst group by on_br_no order by count(*) desc 按机构结息。先处理户数多的机构，然后再处理户数少的机构。因为户数是按倒序排列，所以到了最后，户数会越来越少
9、，名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 4 页，共 6 页 - - - - - - - - - 所 以无 论哪 个进程 来 处理下一个机构，耗时都很少，所以所有的进程的结束时间会基本相同。data_code1 0910 用 0910 域来放机构码。结 息程 序可 以从这 个 域里取出机构码，来做指定机构的结息。proc_upper_limit 10 说明可以并发10 个机构同时做结息load_upper_limit 80 说 明系 统负 荷综合 指 标到了 80 的时候，就
10、会暂停结息。方法 2:按机构加产品类型来结息字段值说明tx_data select prdt_no |opn_br_no ,count(*) from dd_mst group by 1 order by count(*) desc;按每个机构的一个产品为单位来结息。data_code1 0910 proc_upper_limit 10 说明可以并发机构的10个产品来结息。load_upper_limit 80 说 明系 统负 荷综合 指 标到了 80 的时候，就会暂停结息。方法 3:按帐户来结息字段值说明tx_data Select ac_id | ac_seqn from dd_mst 按
11、账户为单位来结息data_code1 0910 proc_upper_limit 10 说明可以并发10 账户同时做结息load_upper_limit 80 说 明系 统负 荷综合 指 标到了 80 的时候，就会暂名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 5 页，共 6 页 - - - - - - - - - 停结息。名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 6 页，共 6 页 - - - - - - - - -