Quartz.Net系列（十五）：Quartz.Net四种修改配置的方式

精选30+云产品，助力企业轻松上云！>>>

案例：修改默认线程个数

1.NameValueCollection

System.Collections.Specialized.NameValueCollection collection = new System.Collections.Specialized.NameValueCollection();   collection.Add("quartz.threadPool.ThreadCount","20");      var factory= new StdSchedulerFactory(collection);   var scheduler= await factory.GetScheduler();   await scheduler.Start();   var metData=await scheduler.GetMetaData();   Console.WriteLine(metData.ThreadPoolSize);

原理

通过反射实例化对象DefaultThreadPool

Type tpType = loadHelper.LoadType(threadPoolTypeString) ?? typeof(DefaultThreadPool);   try   {    tp = ObjectUtils.InstantiateType<IThreadPool>(tpType);   }   catch (Exception e)   {    initException = new SchedulerException("ThreadPool type '{0}' could not be instantiated.".FormatInvariant(tpType), e);    throw initException;   }   tProps = cfg.GetPropertyGroup(PropertyThreadPoolPrefix, true);   try   {    ObjectUtils.SetObjectProperties(tp, tProps);   }   catch (Exception e)   {    initException = new SchedulerException("ThreadPool type '{0}' props could not be configured.".FormatInvariant(tpType), e);    throw initException;   }

设置对象的属性

public static void SetObjectProperties(object obj, NameValueCollection props)  {   // remove the type   props.Remove("type");   foreach (string name in props.Keys)   {    string propertyName = CultureInfo.InvariantCulture.TextInfo.ToUpper(name.Substring(0, 1)) +          name.Substring(1);    try    {     object value = props[name];     SetPropertyValue(obj, propertyName, value);    }    catch (Exception nfe)    {     throw new SchedulerConfigException(      $"Could not parse property '{name}' into correct data type: {nfe.Message}", nfe);    }   }  }

通过反射设置属性的值

public static void SetPropertyValue(object target, string propertyName, object value)  {   Type t = target.GetType();   PropertyInfo pi = t.GetProperty(propertyName);   if (pi == null || !pi.CanWrite)   {    // try to find from interfaces    foreach (var interfaceType in target.GetType().GetInterfaces())    {     pi = interfaceType.GetProperty(propertyName);     if (pi != null && pi.CanWrite)     {      // found suitable      break;     }    }   }   if (pi == null)   {    // not match from anywhere    throw new MemberAccessException($"No writable property '{propertyName}' found");   }   MethodInfo mi = pi.GetSetMethod();   if (mi == null)   {    throw new MemberAccessException($"Property '{propertyName}' has no setter");   }   if (mi.GetParameters()[0].ParameterType == typeof(TimeSpan))   {    // special handling    value = GetTimeSpanValueForProperty(pi, value);   }   else   {    value = ConvertValueIfNecessary(mi.GetParameters()[0].ParameterType, value);   }   mi.Invoke(target, new[] {value});  }

结果图

 2.App.config(只在.NETFramework生效)

<??><configuration> <configSections>  <section name="quartz" type="System.Configuration.NameValueSectionHandler, System, Version=1.0.5000.0,Culture=neutral, PublicKeyToken=b77a5c561934e089"/> </configSections> <quartz>  <add key="quartz.threadPool.ThreadCount" value="11"/> </quartz> <startup>  <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5.2" /> </startup></configuration>

static void Main(string[] args)  {   var scheduler =new StdSchedulerFactory().GetScheduler().Result;   scheduler.Start();   var metaData=scheduler.GetMetaData().Result;   Console.WriteLine(metaData.ThreadPoolSize);   Console.Read();  }

结果图

 原理

通过ConfigurationManager.GetSection()来获取App.config里面的值，如果有就转换成NameValueCollection

public virtual void Initialize()  {   // short-circuit if already initialized   if (cfg != null)   {    return;   }   if (initException != null)   {    throw initException;   }   var props = Util.Configuration.GetSection(ConfigurationSectionName);   }

internal static NameValueCollection GetSection(string sectionName)  {   try   {    return (NameValueCollection) ConfigurationManager.GetSection(sectionName);   }   catch (Exception e)   {    log.Warn("could not read configuration using ConfigurationManager.GetSection: " + e.Message);    return null;   }  }

3.quartz.config

quartz.threadPool.ThreadCount=20

System.Collections.Specialized.NameValueCollection collection = new System.Collections.Specialized.NameValueCollecti
1000
on();   //collection.Add("quartz.threadPool.ThreadCount","20");      //var factory= new StdSchedulerFactory(collection);   var factory = new StdSchedulerFactory();   var scheduler= await factory.GetScheduler();   await scheduler.Start();   var metData=await scheduler.GetMetaData();   Console.WriteLine(metData.ThreadPoolSize);

结果图

原理

判断当前程序中是否有quartz.config这个文件

如果有则读取

if (props == null && File.Exists(propFileName))   {    // file system    try    {     PropertiesParser pp = PropertiesParser.ReadFromFileResource(propFileName);     props = pp.UnderlyingProperties;     Log.Info($"Quartz.NET properties loaded from configuration file '{propFileName}'");    }    catch (Exception ex)    {     Log.ErrorException("Could not load properties for Quartz from file {0}: {1}".FormatInvariant(propFileName, ex.Message), ex);    }   }

#表示注释

!END代表结束，如果没有就读取全部

public static PropertiesParser ReadFromFileResource(string fileName)  {   return ReadFromStream(File.OpenRead(fileName));  }  private static PropertiesParser ReadFromStream(Stream stream)  {   NameValueCollection props = new NameValueCollection();   using (StreamReader sr = new StreamReader(stream))   {    string line;    while ((line = sr.ReadLine()) != null)    {     line = line.TrimStart();     if (line.StartsWith("#"))     {      // comment line      continue;     }     if (line.StartsWith("!END"))     {      // special end condition      break;     }     string[] lineItems = line.Split(new[] { '=' }, 2);     if (lineItems.Length == 2)     {      props[lineItems[0].Trim()] = lineItems[1].Trim();     }    }   }   return new PropertiesParser(props);  }

4.Environment（环境变量）

Environment.SetEnvironmentVariable("quartz.threadPool.ThreadCount","50");      System.Collections.Specialized.NameValueCollection collection = new System.Collections.Specialized.NameValueCollection();   //collection.Add("quartz.threadPool.ThreadCount","20");      //var factory= new StdSchedulerFactory(collection);   var factory = new StdSchedulerFactory();   var scheduler= await factory.GetScheduler();   await scheduler.Start();   var metData=await scheduler.GetMetaData();   Console.WriteLine(metData.ThreadPoolSize);

结果图

 原理

public virtual void Initialize(){ 。。。。。。 Initialize(OverrideWithSysProps(props));}

获取所有的环境变量，然后赋值给NameValueCollection

private static NameValueCollection OverrideWithSysProps(NameValueCollection props)  {   NameValueCollection retValue = new NameValueCollection(props);   IDictionary<string, string> vars = QuartzEnvironment.GetEnvironmentVariables();   foreach (string key in vars.Keys)   {    retValue.Set(key, vars[key]);   }   return retValue;  }

 quartz.config<app.config<环境变量<NameValueCollection