使用sqlserver搭建高可用雙機熱備的Quartz集群部署【附源碼】

来源:http://www.cnblogs.com/huangxincheng/archive/2017/05/28/6916246.html
-Advertisement-
Play Games

一般拿Timer和Quartz相比較的，簡直就是對Quartz的侮辱，兩者的功能根本就不在一個層級上，如本篇介紹的Quartz強大的集群機制，可以採用基於 sqlserver，mysql的集群方案，當然還可以在第三方插件的基礎上實現quartz序列化到熱炒的mongodb，redis，震撼力可想而知 ...


　　一般拿Timer和Quartz相比較的，簡直就是對Quartz的侮辱，兩者的功能根本就不在一個層級上，如本篇介紹的Quartz強大的集群機制，可以採用基於

sqlserver，mysql的集群方案，當然還可以在第三方插件的基礎上實現quartz序列化到熱炒的mongodb，redis，震撼力可想而知，接下來本篇就和大家聊

一聊怎麼搭建基於sqlserver的quartz集群，實現這麼一種雙機熱備的強大功能。

 

一：下載sqlserver版的建表腳本

　   首先大家可以通過github上搜索quartz的源代碼，在源碼項目的/database/tables目錄下，可以找到firebird，oracle，mysql，sqlserver等建庫腳本，

本篇只需拿取sqlserver版本即可。 https://github.com/quartznet/quartznet/tree/master/database/tables  如下圖所示

 

 

   

     從上面的截圖中可以看到，我接下來要做的事情就是增加一個你需要創建的database名字，這裡取為：【quartz】，完整的腳本如下：

  1 -- this script is for SQL Server and Azure SQL
  2 
  3 CREATE DATABASE [quartz]
  4 GO
  5 
  6 USE [quartz]
  7 GO
  8 
  9 IF EXISTS (SELECT * FROM dbo.sysobjects WHERE id = OBJECT_ID(N'[dbo].[FK_QRTZ_TRIGGERS_QRTZ_JOB_DETAILS]') AND OBJECTPROPERTY(id, N'ISFOREIGNKEY') = 1)
 10 ALTER TABLE [dbo].[QRTZ_TRIGGERS] DROP CONSTRAINT FK_QRTZ_TRIGGERS_QRTZ_JOB_DETAILS
 11 GO
 12 
 13 IF EXISTS (SELECT * FROM dbo.sysobjects WHERE id = OBJECT_ID(N'[dbo].[FK_QRTZ_CRON_TRIGGERS_QRTZ_TRIGGERS]') AND OBJECTPROPERTY(id, N'ISFOREIGNKEY') = 1)
 14 ALTER TABLE [dbo].[QRTZ_CRON_TRIGGERS] DROP CONSTRAINT FK_QRTZ_CRON_TRIGGERS_QRTZ_TRIGGERS
 15 GO
 16 
 17 IF EXISTS (SELECT * FROM dbo.sysobjects WHERE id = OBJECT_ID(N'[dbo].[FK_QRTZ_SIMPLE_TRIGGERS_QRTZ_TRIGGERS]') AND OBJECTPROPERTY(id, N'ISFOREIGNKEY') = 1)
 18 ALTER TABLE [dbo].[QRTZ_SIMPLE_TRIGGERS] DROP CONSTRAINT FK_QRTZ_SIMPLE_TRIGGERS_QRTZ_TRIGGERS
 19 GO
 20 
 21 IF EXISTS (SELECT * FROM dbo.sysobjects WHERE id = OBJECT_ID(N'[dbo].[FK_QRTZ_SIMPROP_TRIGGERS_QRTZ_TRIGGERS]') AND OBJECTPROPERTY(id, N'ISFOREIGNKEY') = 1)
 22 ALTER TABLE [dbo].[QRTZ_SIMPROP_TRIGGERS] DROP CONSTRAINT FK_QRTZ_SIMPROP_TRIGGERS_QRTZ_TRIGGERS
 23 GO
 24 
 25 IF  EXISTS (SELECT * FROM sys.foreign_keys WHERE object_id = OBJECT_ID(N'[dbo].[FK_QRTZ_JOB_LISTENERS_QRTZ_JOB_DETAILS]') AND parent_object_id = OBJECT_ID(N'[dbo].[QRTZ_JOB_LISTENERS]'))
 26 ALTER TABLE [dbo].[QRTZ_JOB_LISTENERS] DROP CONSTRAINT [FK_QRTZ_JOB_LISTENERS_QRTZ_JOB_DETAILS]
 27 
 28 IF  EXISTS (SELECT * FROM sys.foreign_keys WHERE object_id = OBJECT_ID(N'[dbo].[FK_QRTZ_TRIGGER_LISTENERS_QRTZ_TRIGGERS]') AND parent_object_id = OBJECT_ID(N'[dbo].[QRTZ_TRIGGER_LISTENERS]'))
 29 ALTER TABLE [dbo].[QRTZ_TRIGGER_LISTENERS] DROP CONSTRAINT [FK_QRTZ_TRIGGER_LISTENERS_QRTZ_TRIGGERS]
 30 
 31 
 32 IF EXISTS (SELECT * FROM dbo.sysobjects WHERE id = OBJECT_ID(N'[dbo].[QRTZ_CALENDARS]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)
 33 DROP TABLE [dbo].[QRTZ_CALENDARS]
 34 GO
 35 
 36 IF EXISTS (SELECT * FROM dbo.sysobjects WHERE id = OBJECT_ID(N'[dbo].[QRTZ_CRON_TRIGGERS]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)
 37 DROP TABLE [dbo].[QRTZ_CRON_TRIGGERS]
 38 GO
 39 
 40 IF EXISTS (SELECT * FROM dbo.sysobjects WHERE id = OBJECT_ID(N'[dbo].[QRTZ_BLOB_TRIGGERS]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)
 41 DROP TABLE [dbo].[QRTZ_BLOB_TRIGGERS]
 42 GO
 43 
 44 IF EXISTS (SELECT * FROM dbo.sysobjects WHERE id = OBJECT_ID(N'[dbo].[QRTZ_FIRED_TRIGGERS]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)
 45 DROP TABLE [dbo].[QRTZ_FIRED_TRIGGERS]
 46 GO
 47 
 48 IF EXISTS (SELECT * FROM dbo.sysobjects WHERE id = OBJECT_ID(N'[dbo].[QRTZ_PAUSED_TRIGGER_GRPS]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)
 49 DROP TABLE [dbo].[QRTZ_PAUSED_TRIGGER_GRPS]
 50 GO
 51 
 52 IF  EXISTS (SELECT * FROM sys.objects WHERE object_id = OBJECT_ID(N'[dbo].[QRTZ_JOB_LISTENERS]') AND type in (N'U'))
 53 DROP TABLE [dbo].[QRTZ_JOB_LISTENERS]
 54 
 55 IF EXISTS (SELECT * FROM dbo.sysobjects WHERE id = OBJECT_ID(N'[dbo].[QRTZ_SCHEDULER_STATE]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)
 56 DROP TABLE [dbo].[QRTZ_SCHEDULER_STATE]
 57 GO
 58 
 59 IF EXISTS (SELECT * FROM dbo.sysobjects WHERE id = OBJECT_ID(N'[dbo].[QRTZ_LOCKS]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)
 60 DROP TABLE [dbo].[QRTZ_LOCKS]
 61 GO
 62 IF  EXISTS (SELECT * FROM sys.objects WHERE object_id = OBJECT_ID(N'[dbo].[QRTZ_TRIGGER_LISTENERS]') AND type in (N'U'))
 63 DROP TABLE [dbo].[QRTZ_TRIGGER_LISTENERS]
 64 
 65 
 66 IF EXISTS (SELECT * FROM dbo.sysobjects WHERE id = OBJECT_ID(N'[dbo].[QRTZ_JOB_DETAILS]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)
 67 DROP TABLE [dbo].[QRTZ_JOB_DETAILS]
 68 GO
 69 
 70 IF EXISTS (SELECT * FROM dbo.sysobjects WHERE id = OBJECT_ID(N'[dbo].[QRTZ_SIMPLE_TRIGGERS]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)
 71 DROP TABLE [dbo].[QRTZ_SIMPLE_TRIGGERS]
 72 GO
 73 
 74 IF EXISTS (SELECT * FROM dbo.sysobjects WHERE id = OBJECT_ID(N'[dbo].[QRTZ_SIMPROP_TRIGGERS]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)
 75 DROP TABLE [dbo].QRTZ_SIMPROP_TRIGGERS
 76 GO
 77 
 78 IF EXISTS (SELECT * FROM dbo.sysobjects WHERE id = OBJECT_ID(N'[dbo].[QRTZ_TRIGGERS]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)
 79 DROP TABLE [dbo].[QRTZ_TRIGGERS]
 80 GO
 81 
 82 CREATE TABLE [dbo].[QRTZ_CALENDARS] (
 83   [SCHED_NAME] [NVARCHAR] (120)  NOT NULL ,
 84   [CALENDAR_NAME] [NVARCHAR] (200)  NOT NULL ,
 85   [CALENDAR] [IMAGE] NOT NULL
 86 )
 87 GO
 88 
 89 CREATE TABLE [dbo].[QRTZ_CRON_TRIGGERS] (
 90   [SCHED_NAME] [NVARCHAR] (120)  NOT NULL ,
 91   [TRIGGER_NAME] [NVARCHAR] (150)  NOT NULL ,
 92   [TRIGGER_GROUP] [NVARCHAR] (150)  NOT NULL ,
 93   [CRON_EXPRESSION] [NVARCHAR] (120)  NOT NULL ,
 94   [TIME_ZONE_ID] [NVARCHAR] (80) 
 95 )
 96 GO
 97 
 98 CREATE TABLE [dbo].[QRTZ_FIRED_TRIGGERS] (
 99   [SCHED_NAME] [NVARCHAR] (120)  NOT NULL ,
100   [ENTRY_ID] [NVARCHAR] (140)  NOT NULL ,
101   [TRIGGER_NAME] [NVARCHAR] (150)  NOT NULL ,
102   [TRIGGER_GROUP] [NVARCHAR] (150)  NOT NULL ,
103   [INSTANCE_NAME] [NVARCHAR] (200)  NOT NULL ,
104   [FIRED_TIME] [BIGINT] NOT NULL ,
105   [SCHED_TIME] [BIGINT] NOT NULL ,
106   [PRIORITY] [INTEGER] NOT NULL ,
107   [STATE] [NVARCHAR] (16)  NOT NULL,
108   [JOB_NAME] [NVARCHAR] (150)  NULL ,
109   [JOB_GROUP] [NVARCHAR] (150)  NULL ,
110   [IS_NONCONCURRENT] BIT  NULL ,
111   [REQUESTS_RECOVERY] BIT  NULL 
112 )
113 GO
114 
115 CREATE TABLE [dbo].[QRTZ_PAUSED_TRIGGER_GRPS] (
116   [SCHED_NAME] [NVARCHAR] (120)  NOT NULL ,
117   [TRIGGER_GROUP] [NVARCHAR] (150)  NOT NULL 
118 )
119 GO
120 
121 CREATE TABLE [dbo].[QRTZ_SCHEDULER_STATE] (
122   [SCHED_NAME] [NVARCHAR] (120)  NOT NULL ,
123   [INSTANCE_NAME] [NVARCHAR] (200)  NOT NULL ,
124   [LAST_CHECKIN_TIME] [BIGINT] NOT NULL ,
125   [CHECKIN_INTERVAL] [BIGINT] NOT NULL
126 )
127 GO
128 
129 CREATE TABLE [dbo].[QRTZ_LOCKS] (
130   [SCHED_NAME] [NVARCHAR] (120)  NOT NULL ,
131   [LOCK_NAME] [NVARCHAR] (40)  NOT NULL 
132 )
133 GO
134 
135 CREATE TABLE [dbo].[QRTZ_JOB_DETAILS] (
136   [SCHED_NAME] [NVARCHAR] (120)  NOT NULL ,
137   [JOB_NAME] [NVARCHAR] (150)  NOT NULL ,
138   [JOB_GROUP] [NVARCHAR] (150)  NOT NULL ,
139   [DESCRIPTION] [NVARCHAR] (250) NULL ,
140   [JOB_CLASS_NAME] [NVARCHAR] (250)  NOT NULL ,
141   [IS_DURABLE] BIT  NOT NULL ,
142   [IS_NONCONCURRENT] BIT  NOT NULL ,
143   [IS_UPDATE_DATA] BIT  NOT NULL ,
144   [REQUESTS_RECOVERY] BIT  NOT NULL ,
145   [JOB_DATA] [IMAGE] NULL
146 )
147 GO
148 
149 CREATE TABLE [dbo].[QRTZ_SIMPLE_TRIGGERS] (
150   [SCHED_NAME] [NVARCHAR] (120)  NOT NULL ,
151   [TRIGGER_NAME] [NVARCHAR] (150)  NOT NULL ,
152   [TRIGGER_GROUP] [NVARCHAR] (150)  NOT NULL ,
153   [REPEAT_COUNT] [INTEGER] NOT NULL ,
154   [REPEAT_INTERVAL] [BIGINT] NOT NULL ,
155   [TIMES_TRIGGERED] [INTEGER] NOT NULL
156 )
157 GO
158 
159 CREATE TABLE [dbo].[QRTZ_SIMPROP_TRIGGERS] (
160   [SCHED_NAME] [NVARCHAR] (120)  NOT NULL ,
161   [TRIGGER_NAME] [NVARCHAR] (150)  NOT NULL ,
162   [TRIGGER_GROUP] [NVARCHAR] (150)  NOT NULL ,
163   [STR_PROP_1] [NVARCHAR] (512) NULL,
164   [STR_PROP_2] [NVARCHAR] (512) NULL,
165   [STR_PROP_3] [NVARCHAR] (512) NULL,
166   [INT_PROP_1] [INT] NULL,
167   [INT_PROP_2] [INT] NULL,
168   [LONG_PROP_1] [BIGINT] NULL,
169   [LONG_PROP_2] [BIGINT] NULL,
170   [DEC_PROP_1] [NUMERIC] (13,4) NULL,
171   [DEC_PROP_2] [NUMERIC] (13,4) NULL,
172   [BOOL_PROP_1] BIT NULL,
173   [BOOL_PROP_2] BIT NULL,
174 )
175 GO
176 
177 CREATE TABLE [dbo].[QRTZ_BLOB_TRIGGERS] (
178   [SCHED_NAME] [NVARCHAR] (120)  NOT NULL ,
179   [TRIGGER_NAME] [NVARCHAR] (150)  NOT NULL ,
180   [TRIGGER_GROUP] [NVARCHAR] (150)  NOT NULL ,
181   [BLOB_DATA] [IMAGE] NULL
182 )
183 GO
184 
185 CREATE TABLE [dbo].[QRTZ_TRIGGERS] (
186   [SCHED_NAME] [NVARCHAR] (120)  NOT NULL ,
187   [TRIGGER_NAME] [NVARCHAR] (150)  NOT NULL ,
188   [TRIGGER_GROUP] [NVARCHAR] (150)  NOT NULL ,
189   [JOB_NAME
您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 虛擬機CentOS的NAT模式聯網和secureCRT遠程登錄管理工具
    這幾天白天在公司上班敲代碼，晚上回家鼓搗虛擬機下的CentOS上網，還有secureCRT遠程管理工具的配置，今天終於都搞好了，記個筆記。 我使用的是NAT模式，配置的是靜態地址，還有Bridge橋接模式和Host-only僅主機模式，三個模式之間的區別網上有的是，但是我覺得NAT模式更接近現實中的 ...
  • centos命令行常用操作
    1、查看某個埠占用 lsof -i tcp:80 2、查看是否安裝了防火牆 service iptables status 查看是否啟用防火牆/etc/init.d/iptables status 3、查看全部安裝的文件包yum list installed 4、查看有多少個php-fpm執行ps ...
  • Linux：快速找到占用CPU過高的Thread
    1、通過top命令找到高耗CPU的進程，記下PID 2、使用命令ps -mp PID -o THREAD,tid,time找到高耗CPU的那些線程 3、jstack PID 4、對每個高耗CPU的線程，把線程id，轉換為16進程數（ 可以使用命令：printf "%x\n" tid ），然後從thr ...
  • 重裝win7系統的過程
    今天因為C盤的記憶體變得不夠多而再次選擇了重裝系統，重裝系統，win7的重裝系統的映像網址為：http://win.njbda.cn/win7.html 我選擇的是“雨林木風”的64位系統，那麼問題來了，每個人的電腦本機系統不同，那麼我們需要根據自己的系統進行對win7的下載，那麼，如果像我一樣不記得 ...
  • sed用法詳解（轉載）
    簡介 sed 是一種線上編輯器，它一次處理一行內容。處理時，把當前處理的行存儲在臨時緩衝區中，稱為“模式空間”（pattern space），接著用sed命令處理緩衝區中的內容，處理完成後，把緩衝區的內容送往屏幕。接著處理下一行，這樣不斷重覆，直到文件末尾。文件內容並沒有 改變，除非你使用重定向存儲 ...
  • Linux系統開啟路由功能
    方法有二： 1、臨時開啟（重啟即失效） echo 1 > /proc/sys/net/ipv4/ip_forward 或 vim /proc/sys/net/ipv4/ip_forward，將0修改為1，保存退出 2、永久開啟 sed -i 's/net.ipv4.ip_forward = 0/ne ...
  • centos7搭建SVN+Apache+IF.svnadmin支持https實現web管理SVN
    閱讀目錄 1. 介紹 2. 軟體準備 3. 建立SVN Server倉庫 4. 配置安裝PHP&IF.SVNadmin 5. 啟動服務 1.介紹 公司最近想把Windows server平臺的SVN遷移到Linux平臺;這邊經過測試成功,所以寫個隨筆記錄一下 今天寫的是CentOS7上搭建基於Apa ...
  • 解密Lazy<T>
    1.Lazy<T>的使用 無意間看到一段代碼，在創建對象的時候使用了Lazy，顧名思義Lazy肯定是延遲載入，那麼它具體是如何創建對象，什麼時候創建對象了？ 先看這段示列代碼： 使用非常簡單，把 OrderService 放到Lazy<T> 中，然後 _orderSrv.Value 的時候才真正創建 ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類