使用sqlserver搭建高可用双机热备的Quartz集群部署【附源码】
|
一般拿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】
二：配置quartz的集群参数 ? ? 当我们写var scheduler = StdSchedulerFactory.GetDefaultScheduler()这段代码的时候，如果大家看过源码的话，会知道这个GetScheduler的 过程中有一个初始化方法【Instantiate】方法，此方法中你会发现在做DBProvider的时候会需要几个参数来初始化DB的，比如下面看到的几个标红属性。 IList<string> dsNames = cfg.GetPropertyGroups(PropertyDataSourcePrefix); ? ? ? ? ? ? foreach (string dataSourceName in dsNames) ? ? ? ? ? ? { ? ? ? ? ? ? ? ? string datasourceKey = "{0}.{1}".FormatInvariant(PropertyDataSourcePrefix,dataSourceName); ? ? ? ? ? ? ? ? NameValueCollection propertyGroup = cfg.GetPropertyGroup(datasourceKey,true); ? ? ? ? ? ? ? ? PropertiesParser pp = new PropertiesParser(propertyGroup); ? ? ? ? ? ? ? ? Type cpType = loadHelper.LoadType(pp.GetStringProperty(PropertyDbProviderType,null)); ? ? ? ? ? ? ? ? // custom connectionProvider... ? ? ? ? ? ? ? ? if (cpType != null) ? ? ? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? IDbProvider cp; ? ? ? ? ? ? ? ? ? ? try ? ? ? ? ? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? ? ? cp = ObjectUtils.InstantiateType<IDbProvider>(cpType); ? ? ? ? ? ? ? ? ? ? } ? ? ? ? ? ? ? ? ? ? catch (Exception e) ? ? ? ? ? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? ? ? initException = new SchedulerException("ConnectionProvider of type '{0}' could not be instantiated.".FormatInvariant(cpType),e); ? ? ? ? ? ? ? ? ? ? ? ? throw initException; ? ? ? ? ? ? ? ? ? ? } ? ? ? ? ? ? ? ? ? ? try ? ? ? ? ? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? ? ? // remove the type name,so it isn't attempted to be set ? ? ? ? ? ? ? ? ? ? ? ? pp.UnderlyingProperties.Remove(PropertyDbProviderType); ? ? ? ? ? ? ? ? ? ? ? ? ObjectUtils.SetObjectProperties(cp,pp.UnderlyingProperties); ? ? ? ? ? ? ? ? ? ? ? ? cp.Initialize(); ? ? ? ? ? ? ? ? ? ? } ? ? ? ? ? ? ? ? ? ? catch (Exception e) ? ? ? ? ? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? ? ? initException = new SchedulerException("ConnectionProvider type '{0}' props could not be configured.".FormatInvariant(cpType),e); ? ? ? ? ? ? ? ? ? ? ? ? throw initException; ? ? ? ? ? ? ? ? ? ? } ? ? ? ? ? ? ? ? ? ? dbMgr = DBConnectionManager.Instance; ? ? ? ? ? ? ? ? ? ? dbMgr.AddConnectionProvider(dataSourceName,cp); ? ? ? ? ? ? ? ? } ? ? ? ? ? ? ? ? else ? ? ? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? string dsProvider = pp.GetStringProperty(PropertyDataSourceProvider,null); ? ? ? ? ? ? ? ? ? ? string dsConnectionString = pp.GetStringProperty(PropertyDataSourceConnectionString,null); ? ? ? ? ? ? ? ? ? ? string dsConnectionStringName = pp.GetStringProperty(PropertyDataSourceConnectionStringName,null); ? ? ? ? ? ? ? ? ? ? if (dsConnectionString == null && !String.IsNullOrEmpty(dsConnectionStringName)) ? ? ? ? ? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? ? ? ConnectionStringSettings connectionStringSettings = ConfigurationManager.ConnectionStrings[dsConnectionStringName]; ? ? ? ? ? ? ? ? ? ? ? ? if (connectionStringSettings == null) ? ? ? ? ? ? ? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? ? ? ? ? initException = new SchedulerException("Named connection string '{0}' not found for DataSource: {1}".FormatInvariant(dsConnectionStringName,dataSourceName)); ? ? ? ? ? ? ? ? ? ? ? ? ? ? throw initException; ? ? ? ? ? ? ? ? ? ? ? ? } ? ? ? ? ? ? ? ? ? ? ? ? dsConnectionString = connectionStringSettings.ConnectionString; ? ? ? ? ? ? ? ? ? ? } ? ? ? ? ? ? ? ? ? ? if (dsProvider == null) ? ? ? ? ? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? ? ? initException = new SchedulerException("Provider not specified for DataSource: {0}".FormatInvariant(dataSourceName)); ? ? ? ? ? ? ? ? ? ? ? ? throw initException; ? ? ? ? ? ? ? ? ? ? } ? ? ? ? ? ? ? ? ? ? if (dsConnectionString == null) ? ? ? ? ? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? ? ? initException = new SchedulerException("Connection string not specified for DataSource: {0}".FormatInvariant(dataSourceName)); ? ? ? ? ? ? ? ? ? ? ? ? throw initException; ? ? ? ? ? ? ? ? ? ? } ? ? ? ? ? ? ? ? ? ? try ? ? ? ? ? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? ? ? DbProvider dbp = new DbProvider(dsProvider,dsConnectionString); ? ? ? ? ? ? ? ? ? ? ? ? dbp.Initialize(); ? ? ? ? ? ? ? ? ? ? ? ? dbMgr = DBConnectionManager.Instance; ? ? ? ? ? ? ? ? ? ? ? ? dbMgr.AddConnectionProvider(dataSourceName,dbp); ? ? ? ? ? ? ? ? ? ? } ? ? ? ? ? ? ? ? ? ? catch (Exception exception) ? ? ? ? ? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? ? ? initException = new SchedulerException("Could not Initialize DataSource: {0}".FormatInvariant(dataSourceName),exception); ? ? ? ? ? ? ? ? ? ? ? ? throw initException; ? ? ? ? ? ? ? ? ? ? } ? ? ? ? ? ? ? ? } ? ? ? ? ? ? } ?接下来的问题就是这几个属性是如何配置进去的，仔细观察上面代码，你会发现所有的配置的源头都来自于cfg变量，ok，接下来你可以继续翻看代码，相信 你会看到有一个Initialize方法就是做cfg变量的初始化，如下代码所示： public void Initialize() ? ? ? ? { ? ? ? ? ? ? // short-circuit if already initialized ? ? ? ? ? ? if (cfg != null) ? ? ? ? ? ? { ? ? ? ? ? ? ? ? return; ? ? ? ? ? ? } ? ? ? ? ? ? if (initException != null) ? ? ? ? ? ? { ? ? ? ? ? ? ? ? throw initException; ? ? ? ? ? ? } ? ? ? ? ? ? NameValueCollection props = (NameValueCollection) ConfigurationManager.GetSection(ConfigurationSectionName); ? ? ? ? ? ? string requestedFile = QuartzEnvironment.GetEnvironmentVariable(PropertiesFile); ? ? ? ? ? ? string propFileName = requestedFile != null && requestedFile.Trim().Length > 0 ? requestedFile : "~/quartz.config"; ? ? ? ? ? ? // check for specials ? ? ? ? ? ? try ? ? ? ? ? ? { ? ? ? ? ? ? ? ? propFileName = FileUtil.ResolveFile(propFileName); ? ? ? ? ? ? } ? ? ? ? ? ? catch (SecurityException) ? ? ? ? ? ? { ? ? ? ? ? ? ? ? log.WarnFormat("Unable to resolve file path '{0}' due to security exception,probably running under medium trust"); ? ? ? ? ? ? ? ? propFileName = "quartz.config"; ? ? ? ? ? ? } ? ? ? ? ? ? if (props == null && File.Exists(propFileName)) ? ? ? ? ? ? { ? ? ? ? ? ? ? ? // file system ? ? ? ? ? ? ? ? try ? ? ? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? PropertiesParser pp = PropertiesParser.ReadFromFileResource(propFileName); ? ? ? ? ? ? ? ? ? ? props = pp.UnderlyingProperties; ? ? ? ? ? ? ? ? ? ? Log.Info(string.Format("Quartz.NET properties loaded from configuration file '{0}'",propFileName)); ? ? ? ? ? ? ? ? } ? ? ? ? ? ? ? ? catch (Exception ex) ? ? ? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? Log.Error("Could not load properties for Quartz from file {0}: {1}".FormatInvariant(propFileName,ex.Message),ex); ? ? ? ? ? ? ? ? } ? ? ? ? ? ? } ? ? ? ? ? ? if (props == null) ? ? ? ? ? ? { ? ? ? ? ? ? ? ? // read from assembly ? ? ? ? ? ? ? ? try ? ? ? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? PropertiesParser pp = PropertiesParser.ReadFromEmbeddedAssemblyResource("Quartz.quartz.config"); ? ? ? ? ? ? ? ? ? ? props = pp.UnderlyingProperties; ? ? ? ? ? ? ? ? ? ? Log.Info("Default Quartz.NET properties loaded from embedded resource file"); ? ? ? ? ? ? ? ? } ? ? ? ? ? ? ? ? catch (Exception ex) ? ? ? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? Log.Error("Could not load default properties for Quartz from Quartz assembly: {0}".FormatInvariant(ex.Message),ex); ? ? ? ? ? ? ? ? } ? ? ? ? ? ? } ? ? ? ? ? ? if (props == null) ? ? ? ? ? ? { ? ? ? ? ? ? ? ? throw new SchedulerConfigException( ? ? ? ? ? ? ? ? ? ? @"Could not find <quartz> configuration section from your application config or load default configuration from assembly. Please add configuration to your application config file to correctly initialize Quartz."); ? ? ? ? ? ? } ? ? ? ? ? ? Initialize(OverrideWithSysProps(props)); ? ? ? ? } ? ? ?仔细阅读上面的一串代码，你会发现，默认quartz参数配置来源于三个地方。 1. app.config中的section节点。 2. bin目录下的~/quartz.config文件。 3. 默认配置的NameValueCollection字典集合，也就是上一篇博客给大家做的一个演示。? ? ? ? ?我个人不怎么喜欢通过quartz.config文件进行配置，这样也容易写死，所以我还是喜欢使用最简单的NameValueCollection配置，因为它的数据源可来源于第三方存储结构中，配置代码如下： //1.首先创建一个作业调度池 ? ? ? ? ? ? ? ? var properties = new NameValueCollection(); ? ? ? ? ? ? ? ? //存储类型 ? ? ? ? ? ? ? ? properties["quartz.jobStore.type"] = "Quartz.Impl.AdoJobStore.JobStoreTX,Quartz"; ? ? ? ? ? ? ? ? //驱动类型 ? ? ? ? ? ? ? ? properties["quartz.jobStore.driverDelegateType"] = "Quartz.Impl.AdoJobStore.SqlServerDelegate,Quartz"; ? ? ? ? ? ? ? ?//数据源名称 ? ? ? ? ? ? ? ? properties["quartz.jobStore.dataSource"] = "myDS"; ? ? ? ? ? ? ? ? //连接字符串 ? ? ? ? ? ? ? ? properties["quartz.dataSource.myDS.connectionString"] = @"server=.;Initial Catalog=quartz;Integrated Security=True"; ? ? ? ? ? ? ? ? //sqlserver版本 ? ? ? ? ? ? ? ? properties["quartz.dataSource.myDS.provider"] = "SqlServer-20"; ? ? ? ? ? ? ? ? //是否集群 ? ? ? ? ? ? ? ? properties["quartz.jobStore.clustered"] = "true"; ? ? ? ? ? ? ? ? properties["quartz.scheduler.instanceId"] = "AUTO"; ?上面的代码配置我都加过详细的注释，大家应该都能看得懂，而且这些配置就是这么定死的，没什么修改的空间，大家记住即可。? 三：Job和Trigger定义 ? ? ?在集群中环境下，job和trigger的定义该怎么写的？大家也不要想的太复杂，注意一点就可以了，在Schedule一个Job时候，通过CheckExists判断一下这个Job在Scheduler中是否已经存在了，如果存在，你就不能再次通过Schedule去重复调度一个Job就可以了。。。所以判断的代码也很简单，如下所示： ? ? ? ? ? ? ? ? IScheduler scheduler = factory.GetScheduler(); ? ? ? ? ? ? ? ? scheduler.Start(); ? ? ? ? ? ? ? ? var jobKey = JobKey.Create("myjob","group"); ? ? ? ? ? ? ? ? if (scheduler.CheckExists(jobKey)) ? ? ? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? Console.WriteLine("当前job已经存在，无需调度:{0}",jobKey.ToString()); ? ? ? ? ? ? ? ? } ? ? ? ? ? ? ? ? else ? ? ? ? ? ? ? ? { ? ? ? ? ? ? ? ? ? ? IJobDetail job = JobBuilder.Create<HelloJob>() ? ? ? ? ? ? ? ? ? ? ? ? ? ?.WithDescription("使用quartz进行持久化存储") ? ? ? ? ? ? ? ? ? ? ? ? ? ?.StoreDurably() ? ? ? ? ? ? ? ? ? ? ? ? ? ?.RequestRecovery() ? ? ? ? ? ? ? ? ? ? ? ? ? ?.WithIdentity(jobKey) ? ? ? ? ? ? ? ? ? ? ? ? ? ?.UsingJobData("count",1) ? ? ? ? ? ? ? ? ? ? ? ? ? ?.Build(); ? ? ? ? ? ? ? ? ? ? ITrigger trigger = TriggerBuilder.Create().WithSimpleSchedule(x => x.WithIntervalInSeconds(2).RepeatForever()) ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? .Build(); ? ? ? ? ? ? ? ? ? ? scheduler.ScheduleJob(job,trigger); ? ? ? ? ? ? ? ? ? ? Console.WriteLine("调度进行中！！！"); ? ? ? ? ? ? ? ? } 上面这段代码，大家就可以部署在多台机器中了，是不是很简单？ 四：强大的cluster完整演示 ? ? ?所有的初始化工作都做完了，接下来我们copy一份bin文件，同时打开两个console程序，如下所示，可以看到job任务只会被一个console调度，另外 一个在空等待。
? ? ? ?然后你肯定很好奇的跑到sqlserver中去看看，是否已经有job和trigger的db存储，很开心吧，数据都有的。。。
? ? ? ?好了，一切都是那么完美，接下来可以展示一下quartz集群下的高可用啦，如果某一个console挂了，那么另一台console会把这个任务给接过来，实 现强大的高可用。。。所以我要做的事情就是把console1关掉，再看看console2是不是可以开始调度job了？？？? 完美，这个就是本篇给大家介绍的Quartz的Cluster集群，一台挂，另一台顶住，双机热备，当然这些console你可以部署在多台机器中，要做的就是保持各个server的时间同步，因为quarz是依赖于本机server的时间，好了，本篇就先说到这里吧。 原文地址：http://www.cnblogs.com/huangxincheng/p/6916246.html .NET社区新闻，深度好文，微信中搜索dotNET跨平台或扫描二维码关注
（编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |
、