将oracle db配置为Quartz时出错。网络调度器

Question

我是新来的论坛，也学习建立石英。Net的一个业务需求。要求Quartz作为windows服务运行，并通过与Asp交互的WCF服务进行调度。Net网站。所有与工作相关的内部管理活动将通过此WCF服务处理，并致电quartz windows服务。我所取得的成果是，当我使用RAMJobStore时，这个模型工作得非常好，但是当我使用OracleDB的AdoJobStore时，我看不到相关的表使用作业详细信息和触发器进行更新。我已经下载了石英。net服务器，并将其作为windows服务安装，而无需对其代码进行任何更改。

我已经按照建议更改了实现，但现在我得到的错误如下：

无法从数据源“QuartzDB”获取数据库连接：系统。ArgumentException:““数据源”是无效的连接字符串属性

【编辑】：石英服务器的编辑配置如下：

quartz.scheduler.instanceName = ServerScheduler
    quartz.scheduler.instanceId = "AUTO

    # configure thread pool info
    quartz.threadPool.type = Quartz.Simpl.SimpleThreadPool, Quartz
    quartz.threadPool.threadCount = 10
    quartz.threadPool.threadPriority = Normal

    quartz.jobStore.misfireThreshold = 60000
    quartz.jobStore.type = Quartz.Impl.AdoJobStore.JobStoreTX, Quartz
    quartz.jobStore.tablePrefix = QRTZ_
    quartz.jobStore.clustered = true
    quartz.jobStore.driverDelegateType = Quartz.Impl.AdoJobStore.OracleDelegate, Quartz
    quartz.jobStore.dataSource = QuartzDB
    quartz.jobStore.useProperties = true
    quartz.dataSource.QuartzDB.connectionString = "Data Source=quartzdb;User Id=XXXX;Password=YYYY";
    quartz.dataSource.QuartzDB.provider = OracleODP-20

    # export this server to remoting context
    quartz.scheduler.exporter.type = Quartz.Simpl.RemotingSchedulerExporter, Quartz
    quartz.scheduler.exporter.port = 555
    quartz.scheduler.exporter.bindName = QuartzScheduler
    quartz.scheduler.exporter.channelType = tcp
    quartz.scheduler.exporter.channelName = httpQuartz

下面是WCF服务级别的[编辑]GetScheduler实现：

私有静态ISScheduler GetScheduler（）{try{var properties=new NameValueCollection（）；

         properties["quartz.scheduler.instanceName"] = "RemoteClient"; 
         properties["quartz.threadPool.threadCount"] = "0"; 
         properties["quartz.scheduler.proxy"] = "true";
         properties["quartz.scheduler.proxy.address"] = string.Format("tcp://{0}:{1}/{2}", "localhost", "555",
                                                                             "QuartzScheduler");
                // Get a reference to the scheduler
                var sf = new StdSchedulerFactory(properties);

                return sf.GetScheduler();

}

在WCF服务中定义的CreateJobs和Trigger如下：

public string ScheduleJob<T>(string jobName, string jobGroup, string triggerName, string triggerGroup) where T : IJob
        {
            try
            {
                var scheduler = GetScheduler();
                if (scheduler != null)
                {
                    var jobKey = new JobKey(jobName, jobGroup);
                    var job = JobBuilder.Create<T>()
                        .WithIdentity(jobKey)
                        //.StoreDurably()
                        //.RequestRecovery(true)
                        .Build();

                    ICronTrigger triggerObject = CreateCronTrigger(triggerName, triggerGroup);
                    if (triggerObject != null)
                    {
                        // Validate that the job doesn't already exists
                        //if (scheduler.CheckExists(new JobKey(jobKey)))
                        //{
                        //    scheduler.ScheduleJob(job, triggerObject);
                        //}
                        scheduler.ScheduleJob(job, triggerObject);
                        //scheduler.Start();

                        return "SUCCESS";
                    }
                    _log.FatalFormat("{0}Trigger could not be instantiated", Environment.NewLine);
                    return "FAILURE";
                }
                _log.FatalFormat("{0}Scheduler could not be instantiated", Environment.NewLine);
                return "FAILURE";
            }

            catch (Exception ex)
            {
                _log.FatalFormat("{0}Job could not be scheduled", Environment.NewLine);
                return "FAILURE";
            }
        }

        public ICronTrigger CreateCronTrigger(string triggerName, string triggerGroup)
        {
            try
            {
                var trigger = (ICronTrigger)TriggerBuilder.Create()
                    .WithIdentity(triggerName, triggerGroup)
                    .WithCronSchedule("0 0/1 * 1/1 * ? *") // Queues the job every minute
                    .StartAt(DateTime.UtcNow)
                    .WithPriority(1)
                    .Build();

                return trigger;
            }

            catch (Exception ex)
            {
                _log.FatalFormat("{0}Cron trigger could not be created", Environment.NewLine);
                return null;
            }
        }

任何想法，为什么我不能连接到甲骨文。当我通过sqlplus连接时，相同的凭据工作正常。

请帮忙！

Answer 1

您真正需要在WCF服务上设置的是以下属性：

properties["quartz.scheduler.instanceName"] = "RemoteClient"; 
properties["quartz.scheduler.proxy"] = "true"; 
properties["quartz.threadPool.threadCount"] = "0"; 
properties["quartz.scheduler.proxy.address"] = address;

从“客户端”中删除所有其他的。