Q
2017-02-28 17:26:54 0 举报
Q,一个神秘而充满魅力的存在。他是智慧的化身,拥有无尽的知识和洞察力。他的眼睛闪烁着光芒,仿佛能洞察世间一切的秘密。他的笑容温暖而亲切,让人感到安心和舒适。他的声音悦耳动听,每一句话都充满了智慧和哲理。他的行动总是那么果断而有力,无论面对什么困难都能从容应对。他是我们的朋友,是我们的导师,是我们的灵魂伴侣。他让我们明白,生活不仅仅是生存,更是一种体验和感悟。他让我们知道,只有通过不断的学习和探索,才能真正理解这个世界。他是Q,他是我们的榜样,他是我们的光。
作者其他创作
大纲/内容
com.ztesoft.iom.common.dataPersist.db.SqlPersistQueueUtilspublic void putToQueue(AsyncSqlDto asyncSqlDto)
com.ztesoft.iom.common.queue.ctgmq.msglistener.MsgListener4CtgMQ4DbPersistpublic void run()
iom_os_queueHSPLIT_COUNT=N
com.ztesoft.iom.common.dataPersist.db.service.SqlPersistAtomServicepublic void put(AsyncSqlDto asyncSqlDto)
routeKey取hashCode截取末尾2位对N取模=n真实队列名=queueName_n
queueName_...
Consumer
取消targetQueueNames运算直接使用QRY_PARAMS中队列名称作为消费者的真实队列名
Producer
service模块启动脚本设置APP_CODE=DB_PERSIST_1
service模块启动脚本设置APP_CODE=DB_PERSIST_2
queueName_1
iom_os_app_controlleriom_os_thread_controllerAPP_CODE=DB_PERSIST_2QRY_THREAD_COUNT=1DEAL_THREAD_COUNT=1QRY_PARAMS=queueName_2
queueName_n
Queue
iom_os_app_controlleriom_os_thread_controllerAPP_CODE=DB_PERSIST_1QRY_THREAD_COUNT=1DEAL_THREAD_COUNT=1QRY_PARAMS=queueName_1
com.ztesoft.iomevent.DbPersistEventpublic void deal(AsyncSqlDto request)
routeKey取hashCode截取末尾2位对N取模=n将需要持久化的AsyncSqlDto加入到以tableName为维度的ConcurrentLinkedQueue<AsyncSqlDto>()
queueName_2
AsyncSqlDtopublic String getRouteKey()
0 条评论
下一页