Java開源生鮮電商平臺-定時器,定時任務quartz的設計與架構(源碼可下載）

来源:https://www.cnblogs.com/jurendage/archive/2018/06/08/9153835.html
-Advertisement-
Play Games

Java開源生鮮電商平臺-定時器,定時任務quartz的設計與架構(源碼可下載） 說明：任何業務有時候需要系統在某個定點的時刻執行某些任務，比如：凌晨2點統計昨天的報表，早上6點抽取用戶下單的佣金。 對於Java開源生鮮電商平臺而言，有定時推送客戶備貨，定時計算賣家今日的收益，定時提醒每日的提現金額 ...


Java開源生鮮電商平臺-定時器,定時任務quartz的設計與架構(源碼可下載）

 

說明：任何業務有時候需要系統在某個定點的時刻執行某些任務，比如：凌晨2點統計昨天的報表，早上6點抽取用戶下單的佣金。

          對於Java開源生鮮電商平臺而言，有定時推送客戶備貨，定時計算賣家今日的收益，定時提醒每日的提現金額等等

          對於Java定時器而言，我們採用spring+quartz來進行技術解決方案：

對於業務而言，需要滿足以下幾個方面：

 

1.  對定時任務需要可以手動啟動，手動停止，手動刪除等。

2. 對定時任務的結果需要記錄，什麼時候執行，執行的結果如何，是否存在異常，是否有異常的記錄。

3. 對定時器的錯誤，如果是級別很重要，是否有簡訊提醒來讓運營人員或者技術人員手工處理呢？

類似這樣：

 

為了滿足業務的需求，根據quartz的技術選型，設計一下基礎架構：

 

1. 任務記錄信息表：

CREATE TABLE `t_job` (
  `JOB_ID` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '任務id',
  `BEAN_NAME` varchar(100) NOT NULL COMMENT 'spring bean名稱',
  `METHOD_NAME` varchar(100) NOT NULL COMMENT '方法名',
  `PARAMS` varchar(200) DEFAULT NULL COMMENT '參數',
  `CRON_EXPRESSION` varchar(100) NOT NULL COMMENT 'cron表達式',
  `STATUS` char(2) NOT NULL COMMENT '任務狀態  0：正常  1：暫停',
  `REMARK` varchar(200) DEFAULT NULL COMMENT '備註',
  `CREATE_TIME` datetime DEFAULT NULL COMMENT '創建時間',
  PRIMARY KEY (`JOB_ID`)
) ENGINE=InnoDB AUTO_INCREMENT=12 DEFAULT CHARSET=utf8;

2. 任務操作日誌記錄表：

CREATE TABLE `t_job_log` (
  `LOG_ID` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '任務日誌id',
  `JOB_ID` bigint(20) NOT NULL COMMENT '任務id',
  `BEAN_NAME` varchar(100) NOT NULL COMMENT 'spring bean名稱',
  `METHOD_NAME` varchar(100) NOT NULL COMMENT '方法名',
  `PARAMS` varchar(200) DEFAULT NULL COMMENT '參數',
  `STATUS` char(2) NOT NULL COMMENT '任務狀態    0：成功    1：失敗',
  `ERROR` text COMMENT '失敗信息',
  `TIMES` decimal(11,0) DEFAULT NULL COMMENT '耗時(單位：毫秒)',
  `CREATE_TIME` datetime DEFAULT NULL COMMENT '創建時間',
  PRIMARY KEY (`LOG_ID`)
) ENGINE=InnoDB AUTO_INCREMENT=2476 DEFAULT CHARSET=utf8;

 

說明：整個業務很簡單，整個表設計與架構也很簡單。

最終運營截圖如下：

 

 

 

 

相關的系統設置與配置說明：

相關的核心代碼如下：（貼些核心的，不算很核心的，大家可以去我github下麵下載即可）

 

/**
 * 定時任務
 * 
 * @author Administrator
 *
 */
public class ScheduleJob extends QuartzJobBean {
    private Logger logger = LoggerFactory.getLogger(this.getClass());
    private ExecutorService service = Executors.newSingleThreadExecutor();

    @Override
    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
        Job scheduleJob = (Job) context.getMergedJobDataMap().get(Job.JOB_PARAM_KEY);

        // 獲取spring bean
        JobLogService scheduleJobLogService = (JobLogService) SpringContextUtils.getBean("JobLogService");

        JobLog log = new JobLog();
        log.setJobId(scheduleJob.getJobId());
        log.setBeanName(scheduleJob.getBeanName());
        log.setMethodName(scheduleJob.getMethodName());
        log.setParams(scheduleJob.getParams());
        log.setCreateTime(new Date());

        long startTime = System.currentTimeMillis();

        try {
            // 執行任務
            logger.info("任務準備執行，任務ID：" + scheduleJob.getJobId());
            ScheduleRunnable task = new ScheduleRunnable(scheduleJob.getBeanName(), scheduleJob.getMethodName(),
                    scheduleJob.getParams());
            Future<?> future = service.submit(task);
            future.get();
            long times = System.currentTimeMillis() - startTime;
            log.setTimes(times);
            // 任務狀態 0：成功 1：失敗
            log.setStatus("0");

            logger.info("任務執行完畢，任務ID：" + scheduleJob.getJobId() + "  總共耗時：" + times + "毫秒");
        } catch (Exception e) {
            logger.error("任務執行失敗，任務ID：" + scheduleJob.getJobId(), e);
            long times = System.currentTimeMillis() - startTime;
            log.setTimes(times);
            // 任務狀態 0：成功 1：失敗
            log.setStatus("1");
            log.setError(StringUtils.substring(e.toString(), 0, 2000));
        } finally {
            scheduleJobLogService.saveJobLog(log);
        }
    }
}

 

/**
 * 執行定時任務
 * 
 * @author Administrator
 *
 */
public class ScheduleRunnable implements Runnable {
    private Object target;
    private Method method;
    private String params;

    public ScheduleRunnable(String beanName, String methodName, String params)
            throws NoSuchMethodException, SecurityException {
        this.target = SpringContextUtils.getBean(beanName);
        this.params = params;

        if (StringUtils.isNotBlank(params)) {
            this.method = target.getClass().getDeclaredMethod(methodName, String.class);
        } else {
            this.method = target.getClass().getDeclaredMethod(methodName);
        }
    }

    @Override
    public void run() {
        try {
            ReflectionUtils.makeAccessible(method);
            if (StringUtils.isNotBlank(params)) {
                method.invoke(target, params);
            } else {
                method.invoke(target);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}

 

/**
 * 執行定時任務
 * 
 * @author Administrator
 *
 */
public class ScheduleRunnable implements Runnable {
    private Object target;
    private Method method;
    private String params;

    public ScheduleRunnable(String beanName, String methodName, String params)
            throws NoSuchMethodException, SecurityException {
        this.target = SpringContextUtils.getBean(beanName);
        this.params = params;

        if (StringUtils.isNotBlank(params)) {
            this.method = target.getClass().getDeclaredMethod(methodName, String.class);
        } else {
            this.method = target.getClass().getDeclaredMethod(methodName);
        }
    }

    @Override
    public void run() {
        try {
            ReflectionUtils.makeAccessible(method);
            if (StringUtils.isNotBlank(params)) {
                method.invoke(target, params);
            } else {
                method.invoke(target);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}

 

POM文件

<dependency>
    <groupId>org.quartz-scheduler</groupId>
    <artifactId>quartz</artifactId>
    <version>2.2.1</version>
</dependency>
<dependency>
    <groupId>org.quartz-scheduler</groupId>
    <artifactId>quartz-jobs</artifactId>
    <version>2.2.1</version>
</dependency>

 

org.quartz.scheduler.instanceName屬性可為任何值，用在 JDBC JobStore 中來唯一標識實例，但是所有集群節點中必須相同。

org.quartz.scheduler.instanceId　屬性為 AUTO即可，基於主機名和時間戳來產生實例 ID。

org.quartz.jobStore.class屬性為 JobStoreTX，將任務持久化到數據中。因為集群中節點依賴於資料庫來傳播 Scheduler 實例的狀態，你只能在使用 JDBC JobStore 時應用 Quartz 集群。這意味著你必須使用 JobStoreTX 或是 JobStoreCMT 作為 Job 存儲；你不能在集群中使用 RAMJobStore。

org.quartz.jobStore.isClustered 屬性為 true，你就告訴了 Scheduler 實例要它參與到一個集群當中。這一屬性會貫穿於調度框架的始終，用於修改集群環境中操作的預設行為。

org.quartz.jobStore.clusterCheckinInterval 屬性定義了Scheduler 實例檢入到資料庫中的頻率(單位：毫秒)。Scheduler 檢查是否其他的實例到了它們應當檢入的時候未檢入；這能指出一個失敗的 Scheduler 實例，且當前 Scheduler 會以此來接管任何執行失敗並可恢復的 Job。通過檢入操作，Scheduler 也會更新自身的狀態記錄。clusterChedkinInterval 越小，Scheduler 節點檢查失敗的 Scheduler 實例就越頻繁。預設值是 15000 (即15 秒)。

 

最終：系統架構設計圖：

 

 

最後：很多人說系統功能很強大很好，但是我的一種思維方式是不一定，強大固然好，但是你需要通過這麼多的系統數據中來分析出問題的關鍵，而不是所謂的代碼堆積。

           你所需要的是思考，再思考，最終思考。

 

Java開源生鮮電商平臺-定時器,定時任務quartz的設計與架構(源碼可下載）,如果需要下載的話，可以在我的github下麵進行下載。

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • bootstrap-treeview 樹形菜單帶覆選框以及級聯選擇
    ...
  • 課時3.瀏覽器請求數據的過程（理解）
    請求報文：請求行+請求頭+空行+請求體 響應報文：響應行+響應頭+響應體 如何打開谷歌的開發者工具？ ...
  • 課時2.瀏覽器和伺服器（瞭解）
    什麼是伺服器？ 伺服器也是電腦，只不過是比我們的電腦配置更高的電腦，並且24小時不斷電，不關機的電腦 伺服器是專門用於存儲數據的電腦，訪問者可以訪問伺服器獲得伺服器上存儲的數據 伺服器一旦關機，訪問者就無法訪問 3.瀏覽器訪問網頁原理（理解） 所以綜合我們的第二點和第三點，我們得出一個結論，這些系 ...
  • ubuntu搭建nodejs生產環境——快速部署手冊
    body{ font family: SimSun,PingFang SC; } ubuntu搭建nodejs生產環境——快速部署手冊 為什麼不用CentOS而用Ubuntu作為生產環境的運行平臺？這個我也比較好奇，公司訂的只能沿用傳統，從使用成本的角度來說，此舉也是值得肯定的。 測試環境 騰訊雲 ...
  • [譯文]Domain Driven Design Reference（六）—— 提煉戰略設計
    本書是Eric Evans對他自己寫的《領域驅動設計-軟體核心複雜性應對之道》的一本字典式的參考書，可用於快速查找《領域驅動設計》中的諸多概念及其簡明解釋。 其它本系列其它文章地址： [譯文]Domain Driven Design Reference（一）—— 前言 [譯文]Domain Driv ...
  • Unity 游戲框架搭建 2018 (一) 架構、框架與 QFramework 簡介
    約定 還記得上版本的第二十四篇的約定嘛？現在出來履行啦~ 為什麼要重製? 之前寫的專欄都是按照心情寫的，在最初的時候筆者什麼都不懂，而且文章的發佈是按照很隨性的一個順序。結果就是說，大家都看完了，都還對框架沒有一個感覺，感覺很亂。而現在，經過兩年多的摸索，筆者已經對框架的體系有了一個瞭解，所以希望再 ...
  • Eclipse開發工具常用快捷鍵的使用技巧
    Eclipse作為軟體開發的常用工具，被很多的人所歡迎，尤其是豐富的快捷鍵，可以極大的提高編碼的效率，下麵將常用的快捷鍵做了整理，便於大家學習和使用。 Eclipse常用快捷鍵 1代碼提示 Alt+/; 2代碼複製 ctrl+alt+方向鍵（上下） 複製快捷鍵 3單行註釋 方式一：ctr+/ 方式二 ...
  • 大型分散式電商系統架構是如何從0開始演進的？
    轉自：https://my.oschina.net/editorial-story/blog/1808757 本文是學習大型分散式網站架構的技術總結。對架構一個高性能、高可用、可伸縮及可擴展的分散式網站進行了概要性描述，並給出一個架構參考。文中一部分為讀書筆記，一部分是個人經驗總結，對大型分散式網站 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類