Quartz Provider 使用

quatrz-connection-provider/EosQuartzConnectionProvider.java

@@ -0,0 +1,55 @@
+package com.primeton.dgs.workspace.quartz;
+
+import com.eos.common.connection.DataSourceHelper;
+import lombok.NonNull;
+import org.quartz.utils.ConnectionProvider;
+import org.quartz.utils.DBConnectionManager;
+
+import javax.sql.DataSource;
+import java.sql.Connection;
+import java.sql.SQLException;
+
+/**
+ *
+ * 使 Quartz 的数据源，共享使用 EOS 中的
+ *
+ * <pre>
+ *
+ * Created by zhaopx.
+ * User: zhaopx
+ * Date: 2020/4/7
+ * Time: 13:54
+ *
+ * </pre>
+ *
+ * @author zhaopx
+ */
+public class EosQuartzConnectionProvider implements ConnectionProvider {
+
+
+    /**
+     * 数据源
+     */
+    private final DataSource ds;
+
+
+    /**
+     * 必须提供默认的构造方法
+     */
+    public EosQuartzConnectionProvider() {
+        this.ds = DataSourceHelper.getDataSource();
+        // 给 Quartz 中添加数据源提供者
+        DBConnectionManager.getInstance().addConnectionProvider("default",
+                this);
+    }
+
+    @Override
+    public Connection getConnection() throws SQLException {
+        return this.ds.getConnection();
+    }
+
+    @Override
+    public void shutdown() throws SQLException {
+        // datasource 不能关闭
+    }
+}

quatrz-connection-provider/quartz.properties

@@ -0,0 +1,76 @@
+# Default Properties file for use by StdSchedulerFactory
+# to create a Quartz Scheduler Instance, if a different
+# properties file is not explicitly specified.
+#
+# StdSchedulerFactory\u4f7f\u7528quartz.properties \u521b\u5efa\u4e00\u4e2aQuartz Scheduler\u5b9e\u4f8b
+# \u53c2\u6570\u8bf7\u53c2\u8003\uff1ahttp://www.quartz-scheduler.org/documentation/quartz-2.x/configuration/
+#
+# Quartz\u63d0\u4f9b\u4e24\u79cd\u57fa\u672c\u4f5c\u4e1a\u5b58\u50a8\u7c7b\u578b
+# --->\u7b2c\u4e00\u79cd\u7c7b\u578b\u53eb\u505aRAMJobStore:
+#     \u6700\u4f73\u7684\u6027\u80fd\uff0c\u56e0\u4e3a\u5185\u5b58\u4e2d\u6570\u636e\u8bbf\u95ee\u6700\u5feb
+#     \u4e0d\u8db3\u4e4b\u5904\u662f\u7f3a\u4e4f\u6570\u636e\u7684\u6301\u4e45\u6027\uff0c\u5f53\u7a0b\u5e8f\u8def\u9014\u505c\u6b62\u6216\u7cfb\u7edf\u5d29\u6e83\u65f6\uff0c\u6240\u6709\u8fd0\u884c\u7684\u4fe1\u606f\u90fd\u4f1a\u4e22\u5931
+# --->\u7b2c\u4e8c\u79cd\u7c7b\u578b\u53eb\u505aJDBC\u4f5c\u4e1a\u5b58\u50a8:
+#     \u901a\u8fc7\u8c03\u6574\u5176quartz.properties\u5c5e\u6027\u6587\u4ef6\uff0c\u6301\u4e45\u5316\u4efb\u52a1\u8c03\u5ea6\u4fe1\u606f
+#     \u4f7f\u7528\u6570\u636e\u5e93\u4fdd\u5b58\u4efb\u52a1\u8c03\u5ea6\u4fe1\u606f\u540e\uff0c\u5373\u4f7f\u7cfb\u7edf\u5d29\u6e83\u540e\u91cd\u65b0\u542f\u52a8\uff0c\u4efb\u52a1\u7684\u8c03\u5ea6\u4fe1\u606f\u5c06\u5f97\u5230\u6062\u590d
+#
+
+
+#============================================================================
+# \u57fa\u7840\u914d\u7f6e
+#============================================================================
+
+# \u8bbe\u7f6e\u8c03\u5ea6\u5668\u7684\u5b9e\u4f8b\u540d(instanceName) \u548c\u5b9e\u4f8bID (instanceId)
+# \u6ce8\u610f\uff1a\u5982\u679c\u4f7f\u7528JobStoreTX\uff0c\u5b9e\u4f8b\u540d\u4e25\u7981\u4f7f\u7528\uff1aDefaultQuartzScheduler
+# \u539f\u56e0\uff1a\u5185\u5b58\u65b9\u5f0f\u7684instanceid\u4e3a\u9ed8\u8ba4\u7684DefaultQuartzScheduler\uff0c\u5982\u679c\u4e0d\u4fee\u6539\u7cfb\u7edf\u4f1a\u540c\u65f6\u5b58\u5728\u5185\u5b58\u578b\u548cDB\u578b\uff0c\u9ed8\u8ba4\u4f1a\u8d70\u5185\u5b58
+org.quartz.scheduler.instanceName: ExtractorInnerQuartzScheduler
+#\u5982\u679c\u4f7f\u7528\u96c6\u7fa4\uff0cinstanceId\u5fc5\u987b\u552f\u4e00\uff0c\u8bbe\u7f6e\u6210AUTO
+org.quartz.scheduler.instanceId = AUTO
+
+org.quartz.scheduler.rmi.export: false
+org.quartz.scheduler.rmi.proxy: false
+org.quartz.scheduler.wrapJobExecutionInUserTransaction: false
+
+#============================================================================
+# \u8c03\u5ea6\u5668\u7ebf\u7a0b\u6c60\u914d\u7f6e
+#============================================================================
+
+org.quartz.threadPool.class: org.quartz.simpl.SimpleThreadPool
+# \u6307\u5b9a\u591a\u5c11\u4e2a\u5de5\u4f5c\u8005\u7ebf\u7a0b\u88ab\u521b\u5efa\u7528\u6765\u5904\u7406 Job
+org.quartz.threadPool.threadCount: 1
+# \u8bbe\u7f6e\u5de5\u4f5c\u8005\u7ebf\u7a0b\u7684\u4f18\u5148\u7ea7\uff08\u6700\u5927\u503c10\uff0c\u6700\u5c0f\u503c1\uff0c\u5e38\u7528\u503c5\uff09
+org.quartz.threadPool.threadPriority: 5
+# \u52a0\u8f7d\u4efb\u52a1\u4ee3\u7801\u7684ClassLoader\u662f\u5426\u4ece\u5916\u90e8\u7ee7\u627f
+org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread: true
+
+org.quartz.jobStore.misfireThreshold: 60000
+
+#============================================================================
+# Configure JobStore \u4f5c\u4e1a\u5b58\u50a8\u914d\u7f6e
+#============================================================================
+
+# \u9ed8\u8ba4\u914d\u7f6e\uff0c\u6570\u636e\u4fdd\u5b58\u5230\u5185\u5b58(\u8c03\u5ea6\u7a0b\u5e8f\u4fe1\u606f\u662f\u5b58\u50a8\u5728\u88ab\u5206\u914d\u7ed9JVM\u7684\u5185\u5b58\u91cc\u9762\uff0c\u8fd0\u884c\u901f\u5ea6\u5feb)
+#org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore
+
+# \u6301\u4e45\u5316\u914d\u7f6e\uff08\u5b58\u50a8\u65b9\u5f0f\u4f7f\u7528JobStoreTX\uff0c\u4e5f\u5c31\u662f\u6570\u636e\u5e93\uff09
+org.quartz.jobStore.class:org.quartz.impl.jdbcjobstore.JobStoreTX
+# \u9a71\u52a8\u5668\u65b9\u8a00
+#org.quartz.jobStore.driverDelegateClass:org.quartz.impl.jdbcjobstore.StdJDBCDelegate
+org.quartz.jobStore.driverDelegateClass:com.primeton.dgs.workspace.quartz.core.jdbcjobstore.SQLDelegate
+# \u4f7f\u7528\u81ea\u5df1\u7684\u914d\u7f6e\u6587\u4ef6
+org.quartz.jobStore.useProperties:true
+
+#\u6570\u636e\u5e93\u4e2dquartz\u8868\u7684\u8868\u540d\u524d\u7f00
+org.quartz.jobStore.tablePrefix:qrtz_
+org.quartz.jobStore.dataSource:default
+
+#\u662f\u5426\u4f7f\u7528\u96c6\u7fa4\uff08\u5982\u679c\u9879\u76ee\u53ea\u90e8\u7f72\u5230 \u4e00\u53f0\u670d\u52a1\u5668\uff0c\u5c31\u4e0d\u7528\u4e86\uff09
+org.quartz.jobStore.isClustered = true
+
+#============================================================================
+# Configure Datasources\u914d\u7f6e\u6570\u636e\u6e90(\u53ef\u88ab\u8986\u76d6\uff0c\u5982\u679c\u5728schedulerFactoryBean\u6307\u5b9a\u6570\u636e\u6e90)
+#============================================================================
+
+org.quartz.dataSource.default.connectionProvider.class=com.primeton.dgs.workspace.quartz.EosQuartzConnectionProvider
+org.quartz.jobStore.acquireTriggersWithinLock : true
+org.quartz.jobStore.selectWithLockSQL : SELECT * FROM {0}LOCKS UPDLOCK WHERE LOCK_NAME = ?
+