dhbChange
2016-08-05 17:41:49 0 举报dhbChange是一个用于处理数据更改的函数。它的主要功能是接收一个数据集和一个更改操作，然后根据该操作对数据集进行相应的修改。这个函数通常用于在数据分析或数据处理过程中，对数据进行筛选、排序、添加或删除等操作。dhbChange可以应用于各种编程语言和数据处理库中，如Python、R、SQL等。使用dhbChange可以提高数据处理的效率和灵活性，使得数据处理过程更加自动化和高效。无论是在学术研究、商业分析还是软件开发中，dhbChange都是一个非常重要的工具。
作者其他创作
大纲/内容
消息基础事件监听器
可以用 AOP进行日志
doBusinessAsyn
DhbXXXManagerImpl
otherBiz()handleRemoteInvoke()
异步失败
SaveDB()
APP接口
handleRemoteInvoke
开启异步
异步补偿框架，取代XTS，XTS实现基于Base协议的2PC，必须能够将业务逻辑上差分为两阶段，否则用AsynExecutor取代XTS
bkdepbussTransactionTemplate
doBusiness
固定频率
businessStoreTransaction
handleRemoteInvoke
setEventAndProd
真实服务实现 Impl
为了异步命令框架服务
实现
createEventObject
...
+ doBusinessAsyn() （异步调用）+ doBusiness() （同步调用）+ notify()
Mobile
失败则转换成异步
资金交换
autoSelfSchdule()
执行 - 载入 - 拆分 = 触发
DB
+SaveService()+ DrawService()+ QueryService()
XXXMessageReceiver
- receive()
补偿
EventMessageReceiver
缺点：不符合开闭原则，对扩展开放，对修改关闭应该先写接口，再写实现类
synWork()
Function
Schedule
+ doBusinessAsyn()+ doBusiness()+ handleRemoteInvoke
先获得任务类型对应的 Lock
toWork()
异步框架——命令和执行
TransactionSynchronizationManager.registerSynchronization
processAsyn(){ doBusinessAsyn() }
lockEventObject
doRealBusinessAsyn
+ XXXService
XXXServiceProviderAdapter
+ XXXService()
同步失败则异步补偿
tr 调用
DhbXXXAsynCmd
serialVersionUID
所有请求异步执行（先同步尝试），异步执行完毕则发送消息修改状态
AsynExecutorCmdFacade
+receiveAsynExecutorCmd
定时捞取任务
MsgBorker
存款核心
JVM 调用
定时触发
doBusiness()
AsynExecutorCmdFacadeImpl
+ receiveAsynExecutorCmd()
调度中心
AsynExecutor
+ execute() { doWork() }+ abstract doWork()+ toWork()+ synWork()
Change
DhbXXXExecutor
dhbXXXManager:DhbXXXManager
doWork() { doBusinessAsyn }
createAsynCommand
SaveCmd()
businessResultLog
AsynExecutorCmd
Other
receive() { DhbXXXManager.notify()}
- notifyFail()- notifySuccess()
DhbXXXManager
- notify()
运行成功则删除命令
异步命令存储先同步尝试
BizHandler
基础事件监听器
doBusinessValidator
Integration
事务中途 失败自调度再次 尝试
getExecutor()
XXXServiceImpl
+SaveService()+ DrawService()
+ notify()
0 条评论
下一页
为你推荐
查看更多
抱歉，暂无相关内容