<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    Sky's blog

    我和我追逐的夢(mèng)

    常用鏈接

    統(tǒng)計(jì)

    其他鏈接

    友情鏈接

    最新評(píng)論

    application server 下的任務(wù)異步/并行執(zhí)行方案


        在application server下,比如常見的weblogic,glassfish,jboss等,由于javaee規(guī)范的要求,一般不容許直接啟動(dòng)線程。因此在常見的異步/并行任務(wù)執(zhí)行上,會(huì)遭遇到比普通javase程序更多的麻煩。

        典型例子,在javase中,jdk1.5后就引入了java.util.concurrent包,提供Executor這個(gè)非常好用的框架,完美的滿足一下典型需求:

        1. 同步變異步
            請(qǐng)求進(jìn)來后,將請(qǐng)求封裝為task,交給Executor執(zhí)行,原線程可以立即返回
        2. 并行執(zhí)行
            請(qǐng)求進(jìn)來后,將請(qǐng)求拆分為若干個(gè)task,例如下發(fā)短信,有100個(gè)收件人就可以按照每個(gè)收件人一個(gè)task來執(zhí)行,這樣可以通過Executor來并行執(zhí)行這些請(qǐng)求,遠(yuǎn)比循環(huán)執(zhí)行要快的多。

        3. 等待任務(wù)結(jié)束
            有時(shí)有要求調(diào)用線程必須等待所有任務(wù)完成后再繼續(xù)運(yùn)行的需要,此外還有超時(shí)等細(xì)節(jié)設(shè)置要求。

        而在application server,為了避開自己?jiǎn)?dòng)線程的弊端,只好通過其他的方式來完成類似的功能。

        目前我們的項(xiàng)目開發(fā)中主要有三種實(shí)現(xiàn)方式:

        1. jms queue

            通過jms來實(shí)現(xiàn)異步和并發(fā),然后自己通過編碼方式完成調(diào)用線程等待所有任務(wù)執(zhí)行成功。

            這個(gè)方案比較通用,因?yàn)閖ms是javaee的標(biāo)準(zhǔn),所有的application server上都支持。因此天然具有跨application server的能力。

            缺點(diǎn)就比較多了,首先jms是需要實(shí)現(xiàn)串行化的,因此對(duì)task是有要求,不能串行化的類是不能傳遞的。另外串行化的性能損失比較大,造成性能和穩(wěn)定性問題,這個(gè)在大壓力下比較突出,基本我們目前在考慮放棄這個(gè)方案,而且逐步將原有的實(shí)現(xiàn)替換掉。
            這個(gè)方案還有另外一個(gè)缺點(diǎn),配置麻煩,維護(hù)困難:需要?jiǎng)?chuàng)建jsm queque, connection factory, MDB等,如果系統(tǒng)中使用的多了,配置起來很羅嗦,修改時(shí)容許出錯(cuò)。

        2. commonj work manager

            這個(gè)是weblogic和WebSphere上支持的一個(gè)很實(shí)用的解決方案,個(gè)人感覺使用上非常舒服,配置簡(jiǎn)單,只要在weblogic-ejb-jar.xml中間中簡(jiǎn)單配置:

        <work-manager>
            
    <name>wm/taskDistributionWorkManager</name>
            
    <min-threads-constraint>
                
    <name>minthreads</name>
                
    <count>1</count>
            
    </min-threads-constraint>
            
    <max-threads-constraint>
                
    <name>maxthreads</name>
                
    <count>100</count>
            
    </max-threads-constraint>
        
    </work-manager>

            使用時(shí)用jdni lookup到就可以使用了。功能和使用方式和executor框架很類似,同樣提供future,而且提供一個(gè)非常實(shí)用的waitAll()方法論支持等待任務(wù)完成。

            這個(gè)方案的性能非常好,和jms相比提升極大,運(yùn)行也穩(wěn)定。缺點(diǎn)就是不是標(biāo)準(zhǔn),只有weblogic和WebSphere執(zhí)行,在glassfish,jboss上無法使用。

        3. JCA work manager

            這個(gè)是JCA標(biāo)準(zhǔn)了,glassfish,jboss都支持的,和commonj work manager很像,但是,很遺憾的是沒有future的支持,而且也沒有類似的waitAll()方法,只能自己編碼實(shí)現(xiàn)。
            spring為glassfish提供了一個(gè)工具類"org.springframework.jca.work.WorkManagerTaskExecutor",簡(jiǎn)化了JCA work manager的使用。

            JCA work manager的性能和穩(wěn)定性都還不錯(cuò),對(duì)比jms要好的多。

        從目前我們項(xiàng)目的使用經(jīng)驗(yàn)上看,jms是準(zhǔn)備要被淘汰的了(其實(shí)我是一直對(duì)jms不感冒的,尤其是在有性能要求的地方,想不出用jms的理由)。目前項(xiàng)目要求同時(shí)支持weblogic和glassfish,因此commonj work manager和JCA work manager剛好對(duì)應(yīng)于weblogic和glassfish平臺(tái)。實(shí)際使用中,是在這兩個(gè)work manager上封裝了一個(gè)通用的接口,然后再有commonj work manager和JCA work manager兩個(gè)實(shí)現(xiàn),在運(yùn)行時(shí)通過判斷平臺(tái)來自動(dòng)選擇注入其中的一個(gè)。


    posted on 2010-03-24 16:11 sky ao 閱讀(1883) 評(píng)論(0)  編輯  收藏 所屬分類: ejb

    主站蜘蛛池模板: a级毛片在线免费| 亚洲AV日韩AV鸥美在线观看| free哆啪啪免费永久| 国产精品免费一区二区三区| 亚洲码欧美码一区二区三区| 亚洲综合图片小说区热久久| 久久久久国产亚洲AV麻豆 | 亚洲国产成人久久一区久久| 国产v精品成人免费视频400条| 日本免费电影一区二区| 猫咪免费人成在线网站 | 欧美最猛性xxxxx免费| 午夜精品射精入后重之免费观看| 一级毛片a女人刺激视频免费| 亚洲AV成人精品日韩一区| 亚洲视频一区二区三区四区| 中文字幕亚洲色图| 久久精品国产亚洲av日韩| 亚洲成a人片77777kkkk| 亚洲精品无码久久久久去q | 亚洲最大的视频网站| 亚洲AV无码久久精品蜜桃| 国精无码欧精品亚洲一区| 亚洲精品国产精品乱码不卡| 国产真人无遮挡作爱免费视频| 成人毛片免费在线观看| 拨牐拨牐x8免费| 67194成是人免费无码| 久久综合AV免费观看| 一区二区无码免费视频网站| 97在线线免费观看视频在线观看| 国产精品视频免费观看| 免费毛片a在线观看67194| 2021久久精品免费观看| 毛片免费观看网址| 黄网址在线永久免费观看| 日本免费一区二区三区最新| 又黄又爽一线毛片免费观看| 亚洲精品99久久久久中文字幕| 久久久久亚洲av成人无码电影| 亚洲综合AV在线在线播放|