使用sqlserver搭建高可用双机热备的Quartz集群部署
一般拿 Timer 和 Quartz 相比较的,简直就是对 Quartz 的侮辱,两者的功能根本就不在一个层级上,如本篇介绍的Quartz强大的集群机制,可以采用基于sqlserver,mysql的集群方案,当然还可以在第三方插件的基础上实现quartz序列化到nosql的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);Type cpType = loadHelper.LoadType(pp.GetStringProperty(PropertyDbProviderType, null));// custom connectionProvider...if (cpType != null){// remove the type name, so it isn't attempted to be setpp.UnderlyingProperties.Remove(PropertyDbProviderType);ObjectUtils.SetObjectProperties(cp, pp.UnderlyingProperties);cp.Initialize();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];dsConnectionString = connectionStringSettings.ConnectionString;}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(){NameValueCollection props = (NameValueCollection) ConfigurationManager.GetSection(ConfigurationSectionName);string requestedFile = QuartzEnvironment.GetEnvironmentVariable(PropertiesFile);string propFileName = requestedFile != null && requestedFile.Trim().Length > 0 ? requestedFile : "~/quartz.config";// check for specialstry{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";}Initialize(OverrideWithSysProps(props));}
仔细阅读上面的一串代码,你会发现,默认quartz参数配置来源于三个地方。
app.config中的p节点。
bin目录下的~/quartz.config文件。
默认配置的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的时间,好了,本篇就先说到这里吧。
使用sqlserver搭建高可用双机热备的Quartz集群部署相关推荐
- 使用sqlserver搭建高可用双机热备的Quartz集群部署【附源码】
一般拿Timer和Quartz相比较的,简直就是对Quartz的侮辱,两者的功能根本就不在一个层级上,如本篇介绍的Quartz强大的集群机制,可以采用基于 sqlserver,mysql的集群方案,当 ...
- 浅入浅出keepalived+nginx实现高可用双机热备
对应用keepalived+nginx技术实现nginx高可用进行简单的分析,下面是通过对keepalived添加校验nginx存活脚本,监控nginx的状态,应用keepalived的主备模式实现n ...
- ACS 5.4高可用——双机热备
ACS 5.4高可用--双机热备 一.安装 安装ACS_v5.4.0.46.0a.iso 1.过程等同于安装Centos,安装完成后输入setup按提示进行acs相关基础配置. 2.配置完成服务会重启 ...
- 双机热备_什么是高可用双机热备?双机热备概念原理详解
双机热备是什么意思?为什么要用双机热备?双机热备有哪些种类?包含了哪些双机热备软件?下面就来简单地说说. 什么是双机热备? 从广义上讲,就是对于重要的服务,使用两台服务器,互相备份,共同执行同一服务. ...
- rhcs套件conga实现高可用nginx+httpd集群,fence双机热备, clvm集群
红帽套件集群 HA( 高可用,双机热备,对外只有一个主机,但是两个主机都活着 ) luci: 提供了管理 rhcs 集群的 web 界面, luci 管理集群主要是通过跟 ricci 通信来完成的. ...
- 5双机配置_CentOS 7 高可用双机热备实现
一.服务器准备 两个linux版本为 CentOS7 x64, mysql 版本为 5.5.31 , 详细安装步骤参考: CentOS7 环境 编译安装mysql源码 二. Mysql 建立主-从服务 ...
- Nginx+keepalived 高可用双机热备(主从模式/双主模式)
基础介绍 负载均衡技术对于一个网站尤其是大型网站的web服务器集群来说是至关重要的!做好负载均衡架构,可以实现故障转移和高可用环境,避免单点故障,保证网站健康持续运行. 关于负载均衡介绍,可以参考:l ...
- 搭建高可用的分布式hadoop2.5.2集群 HDFS HA
HA: High Available(高可用集群) 本次安装的hadoop2.5.2是64bit的,如果需要请在我之前的博文中 规划节点数:(仅考虑HDFS 的HA) HDFS的节点分配: 两个NN ...
- 【Nginx】如何基于主从模式搭建Nginx+Keepalived双机热备环境?这是最全的一篇了!!
写在前面 最近出版了<海量数据处理与大数据技术实战>,详情可以关注 冰河技术 微信公众号,查看<我的<海量数据处理与大数据技术实战>出版啦!>一文. 也有不少小伙伴 ...
最新文章
- usaco Prime Palindromes
- 现代软件工程 第十章 【典型用户和场景】 练习与讨论
- 前后端分离的探索(五)
- solrcloud集群搭建
- colinux的安装
- 为此计算机上的所有用户安装此加载项,activex 安装给所有计算机用户
- mysql 设置数据库只读_如何设置mysql数据库为只读
- AndroidStudio_android中实现对properties文件的读写操作_不把properties文件放在assets文件夹中_支持读写---Android原生开发工作笔记238
- python可以做哪些小工具_用Python写过哪些「脑洞大开」的小工具?
- cass生成曲线要素_CASS菜鸟入门指南-道路断面
- 边缘计算以及kubeedge概念的通俗解释
- 2021年高压电工考试题及高压电工理论考试
- slitaz linux 包管理器,SliTaz
- 415 http请求 hutool_HTTP请求返回415错误码定位解决方法
- 小米手机设备锁定怎么强制解除
- IQ使命 Marrakech 马拉喀什(六边形图案)攻略
- 腾讯云双十一云服务器配置表汇总
- 十六款优秀任务管理软件,哪款适合您呢?
- 浅谈在探索数分之路上的“数据思维”论述
- 如何把手机证件照压缩到10K?手机怎么压缩照片到10K?