Планирование Quartz.NET
Я новичок в этом Quartz.NET, и у меня есть несколько вопросов по этому поводу, потому что он, кажется, не работает, как я хочу.
Вопрос 1: я определяю простой IJobDetail
а также ITrigger
, [Решено]
NameValueCollection config = ConfigurationManager.GetSection("quartz") as NameValueCollection;
ISchedulerFactory schedFact = new StdSchedulerFactory(config);
IScheduler scheduler = schedFact.GetScheduler();
try
{
scheduler.Start();
IJobDetail job = JobBuilder.Create<HelloJobTestScheduling>()
.WithIdentity("job1", "group1")
.Build();
DateTimeOffset endDate = DateTime.Now.AddMinutes(5);
ITrigger trigger = TriggerBuilder.Create()
.WithIdentity("trigger1", "group1")
.StartNow()
.WithSimpleSchedule(x => x
.WithIntervalInSeconds(10)
.WithRepeatCount(2))
.EndAt(endDate)
.Build();
scheduler.ScheduleJob(job, trigger);
}
catch(SchedulerException se)
{
Console.WriteLine(se);
}
finally
{
scheduler.Shutdown();
}
HelloJobTestScheduling
public void Execute(IJobExecutionContext context)
{
JobKey key = context.JobDetail.Key;
JobDataMap dataMap = context.JobDetail.JobDataMap;
string connectionString = @"Data Source=localhost\dejan;Initial Catalog=QuartzTest;Integrated Security=True";
string query = "INSERT INTO test (id, datetime) " +
"VALUES (@id, @datetime) ";
// create connection and command
using (SqlConnection cn = new SqlConnection(connectionString))
using (SqlCommand cmd = new SqlCommand(query, cn))
{
// define parameters and their values
cmd.Parameters.Add("@id", SqlDbType.Int).Value = "1";
cmd.Parameters.Add("@datetime", SqlDbType.DateTime).Value = DateTime.Now;
// open connection, execute INSERT, close connection
cn.Open();
cmd.ExecuteNonQuery();
cn.Close();
}
}
App.config
<section name="quartz" type="System.Configuration.NameValueSectionHandler, System, Version=1.0.5000.0,Culture=neutral, PublicKeyToken=b77a5c561934e089" />
<quartz>
<add key="quartz.scheduler.instanceName" value="MyScheduler" />
<add key="quartz.scheduler.instanceId" value="AUTO" />
<add key="quartz.threadPool.type" value="Quartz.Simpl.SimpleThreadPool, Quartz" />
<add key="quartz.threadPool.type" value="Quartz.Simpl.SimpleThreadPool, Quartz"/>
<add key="quartz.threadPool.threadCount" value="30"/>
<add key="quartz.jobStore.type" value="Quartz.Impl.AdoJobStore.JobStoreTX, Quartz" />
<add key="quartz.jobStore.dataSource" value="default" />
<add key="quartz.dataSource.default.connectionString" value="Data Source=localhost\dejan;Initial Catalog=QuartzTest;Integrated Security=True" />
<add key="quartz.jobStore.tablePrefix" value="QRTZ_" />
<add key="quartz.jobStore.clustered" value="false" />
<!--<add key="quartz.jobStore.lockHandler.type" value="Quartz.Impl.AdoJobStore.UpdateLockRowSemaphore, Quartz" />-->
<add key="quartz.jobStore.driverDelegateType" value="Quartz.Impl.AdoJobStore.SqlServerDelegate, Quartz" />
<add key="quartz.dataSource.default.provider" value="SqlServer-20" />
<add key="quartz.jobStore.useProperties" value="false" />
</quartz>
На самом деле эта работа в действительности заключается в следующем: вставка только одной строки в базу данных, и после этого она ничего не сделает. Ждет .endAt
и показывает в консоли, что планировщик закрыт. Что не так с моим кодом?
Примечание. У меня есть все необходимые таблицы базы данных, чтобы планировщик работал в фоновом режиме.
Вопрос 2: Почему этот КРОН не распознается? .WithCronSchedule("0 1 0 ? * ?")
Ошибка Visual Studio говорит: '?' can only be specified for Day-of-Month -OR- Day-of-Week.
2 ответа
Выражения Cron в Quartz.Net состоят из 7 подвыражений:
- секунд
- минут
- часов
- День-месяц
- Месяц
- День недели
- Год (необязательное поле)
Последний не является обязательным. Ваше выражение cron недействительно. Если вы хотите запускать, чтобы выполнять что-то каждую минуту, правильный вариант: 0 0/1 * 1/1 * ? *
Я бы посоветовал вам использовать этот инструмент для генерации ваших выражений cron.
Это легче.
Вопрос 1 решен. Просто короткое замечание, моя ошибка состояла в том, что я закрыл планировщик слишком рано finally
, Если я прокомментирую эту полосу, все работает хорошо.
Но мне все еще нужна помощь по Вопросу 2.