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

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

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

    菜園子

    BlogJava 首頁(yè) 新隨筆 聯(lián)系 聚合 管理
      7 Posts :: 1 Stories :: 31 Comments :: 0 Trackbacks

    在我們開發(fā)的一個(gè)系統(tǒng)中,有定時(shí)任務(wù),自然就想到了Quartz,由于框架采用的Spring,Quartz跟Spring的集成也非常簡(jiǎn)單,所以就把Quartz配置到框架中,當(dāng)系統(tǒng)啟動(dòng)后,定時(shí)任務(wù)也就自動(dòng)啟動(dòng)。在開發(fā)的過程中一直沒有發(fā)現(xiàn)問題,但是最后上線的時(shí)候,采用的是weblogic cluster,啟動(dòng)了4個(gè)節(jié)點(diǎn),發(fā)現(xiàn)有的定時(shí)任務(wù)執(zhí)行了不止一次,才恍然大悟,4個(gè)節(jié)點(diǎn)啟動(dòng)了4個(gè)應(yīng)用,也就啟動(dòng)了4個(gè)定時(shí)任務(wù),所以在同一個(gè)時(shí)間定時(shí)任務(wù)執(zhí)行了不止一次。去網(wǎng)上搜索,發(fā)現(xiàn)Quartz也支持cluster,但是我覺得就我們的系統(tǒng)而言,沒有必要采用cluster的定時(shí)任務(wù),也許是比較懶吧,就想讓定時(shí)任務(wù)只執(zhí)行一次。在網(wǎng)上搜到了robbin的一篇文章(http://robbin.iteye.com/blog/40989 ),發(fā)現(xiàn)把quartz集中到webapp當(dāng)中還是有一定的風(fēng)險(xiǎn),同時(shí)同一個(gè)時(shí)間點(diǎn)執(zhí)行也不止一次。Robbin的解決辦法就是自己?jiǎn)为?dú)啟動(dòng)一個(gè)Job Server,來(lái)quartz跑job,不要部署在web容器中。 

    我也比較同意這個(gè)辦法。鑒于時(shí)間比較緊,就想有沒有比較方便的方法。其實(shí)把原來(lái)的webapp當(dāng)做一個(gè)quartz的容器就可以了。可以自己寫一個(gè)線程來(lái)跑應(yīng)用,再寫一個(gè)command啟動(dòng)這個(gè)線程就可以了。線程類很簡(jiǎn)單,如下:

    public class StartServer {

        public static void main(String[] args) throws Exception {

            ClassPathXmlApplicationContext ctx = new ClassPathXmlApplicationContext(
    new String[] { "/spring/context-annotation.xml","/spring/context-transaction.xml",
    "/spring/context-hibernate.xml",
    "/spring/context-quartz.xml"});

            System.out.println("start server....");

            while (true) {

                try {

                    Thread.sleep(900);

                } catch (InterruptedException ex) {

                }

            }

        };

    }

    去掉了系統(tǒng)的controller配置servlet.xml,運(yùn)行這個(gè)類就可以了。

    在web-inf目錄下寫一個(gè)command來(lái)啟動(dòng)這個(gè)java類:

    setlocal ENABLEDELAYEDEXPANSION

    if defined CLASSPATH (set CLASSPATH=%CLASSPATH%;.) else (set CLASSPATH=.)

    FOR /R .\lib %%G IN (*.jar) DO set CLASSPATH=!CLASSPATH!;%%G

    Echo The Classpath definition is==== %CLASSPATH%

    set CLASSPATH=./classes;%CLASSPATH%

    java com.company.job.StartServer

    這個(gè)command需要把需要的jar(web-inf/lib中)包都放到classpath中。

    每次啟動(dòng)的時(shí)候執(zhí)行這個(gè)command就可以了。跟原來(lái)的應(yīng)用分開了,調(diào)試起定時(shí)任務(wù)也不用影響到原來(lái)的應(yīng)用,還是比較方便的。部署的時(shí)候原樣拷貝一份,然后執(zhí)行這個(gè)command就好了,部署起來(lái)也比較方便。

     



    QQ:24889356
    posted on 2011-09-13 12:53 GhostZhang 閱讀(2667) 評(píng)論(3)  編輯  收藏

    Feedback

    # re: 一次定時(shí)任務(wù) 2011-09-14 08:55 tb
    恩 不錯(cuò)   回復(fù)  更多評(píng)論
      

    # re: 一次定時(shí)任務(wù) 2011-09-15 18:19 Mister4
    可以根據(jù)服務(wù)器的iP做個(gè)判斷  回復(fù)  更多評(píng)論
      

    # re: 一次定時(shí)任務(wù)[未登錄] 2011-09-30 15:57 BucketLi
    這個(gè)簡(jiǎn)單處理方式有很多. 數(shù)據(jù)庫(kù)搞張任務(wù)表,放一條記錄,每個(gè)節(jié)點(diǎn)先取這條記錄(任務(wù)狀態(tài)是可執(zhí)行),然后再通過update將value+1并且更新狀態(tài),帶上先前查詢出來(lái)的value作為查詢條件,這樣相當(dāng)于加了一把樂觀鎖,因?yàn)閿?shù)據(jù)庫(kù)底層是原子的,所以只有一臺(tái)機(jī)器會(huì)更新成功. 這樣就達(dá)到目的了. 還有稍微復(fù)雜點(diǎn)的是通過zk來(lái)維持一把任務(wù)鎖,這樣執(zhí)行任務(wù)的只有一臺(tái)機(jī)器,掛掉后另外一臺(tái)機(jī)器搶到鎖開始做事情. 當(dāng)然還有其他方法  回復(fù)  更多評(píng)論
      


    只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。


    網(wǎng)站導(dǎo)航:
     
    主站蜘蛛池模板: 久久免费国产视频| 日本在线免费播放| 成年性生交大片免费看| 91精品国产免费入口| 国产A在亚洲线播放| 成人无码a级毛片免费| 日本高清免费中文字幕不卡| 国产免费黄色大片| 亚洲黄色免费网址| 久久精品熟女亚洲av麻豆| 中文字幕免费在线播放| 一个人免费高清在线观看| 亚洲电影唐人社一区二区| 国产成人免费网站| 亚洲精华液一二三产区| 国精产品一区一区三区免费视频 | 色天使亚洲综合在线观看| 无人在线直播免费观看| 亚洲色偷偷色噜噜狠狠99| 性做久久久久免费观看| 亚洲阿v天堂在线2017免费| 97在线观免费视频观看| 亚洲日本VA午夜在线影院| 午夜视频在线免费观看| 亚洲美女大bbbbbbbbb| 久久精品国产亚洲AV高清热| 久久狠狠爱亚洲综合影院| igao激情在线视频免费| 亚洲色欲色欲www在线丝| 两个人看的www视频免费完整版| 国产亚洲AV夜间福利香蕉149| 99在线观看精品免费99| 亚洲乱亚洲乱妇24p| 日韩中文字幕免费| 在线看片免费人成视频久网下载 | 91在线亚洲精品专区| 啦啦啦中文在线观看电视剧免费版 | 日韩一级视频免费观看| 久久一区二区免费播放| 亚洲高清最新av网站| 免费人成黄页在线观看日本|