使用嵌入 Windows 服务的 Quartz.Net

Question

我正在尝试使用 Quartz.Net 来安排我开发的 Windows 服务中的作业。

我在 Onstart 方法中添加了以下代码，scheduler 是一个 Class 属性 私有只读 IScheduler 调度程序；

logger = LogManager.GetLogger(typeof (TelegestionService));
调度程序 = new StdSchedulerFactory().GetScheduler();
var job = new JobDetail("job1", "group1", typeof (HelloJob));
var 触发器 = new SimpleTrigger("trigger1", "group1", runTime);
Scheduler.ScheduleJob（作业，触发器）；

这对我来说效果很好。我运行了作业。

现在我正在尝试使调度程序嵌入远程可访问，基于 Quartz 源示例中的Example12（控制台服务器/客户端工作正常）。

<代码> var 属性 = new NameValueCollection();
属性["quartz.scheduler.instanceName"] = "RemoteServer";
属性[“quartz.threadPool.type”] =“Quartz.Simpl.SimpleThreadPool，Quartz”;
属性[“quartz.threadPool.threadCount”] =“5”;
属性["quartz.threadPool.threadPriority"] = "正常";
属性[“quartz.scheduler.exporter.type”] =“Quartz.Simpl.RemotingSchedulerExporter，Quartz”;
属性[“quartz.scheduler.exporter.port”] =“555”;
属性["quartz.scheduler.exporter.bindName"] = "QuartzScheduler";
属性[“quartz.scheduler.exporter.channelType”] =“tcp”;

调度程序 = new StdSchedulerFactory(properties).GetScheduler();
服务正确启动，调度程序

也正确启动，但我无法使用控制台/Winform 客户端远程调度作业（连接被拒绝）。

我使用 SysInternals TcpView 检查了服务器上的侦听端口，但找不到上面指定的 555 端口。

我怀疑存在与 .Net Remoting 有关的问题，但不知道如何解决此问题。 有什么想法吗？

提前致谢。

Answer 1

可以使用 http://topshelf-project.com/ 来托管 Scheduler，它将提供 hostFactory 并使用它可以通过 HttpSelfHostServer 托管主机，http 更好，因为您可以通过控制器调用作业。示例代码如下

希望有所帮助。

using System;
using System.Configuration;
using System.Web.Http;
using System.Web.Http.SelfHost;
using Topshelf;
     class Program
    {
        static void Main(string[] args)
        {
            HostFactory.Run(hostConfigurator =>
            {
                if (!Uri.TryCreate("http://localhost:8080", UriKind.RelativeOrAbsolute, out var hostname))
                {
                    throw new ConfigurationErrorsException($"Could not uri");
                }

                var serviceName = "my service";

                var hostConfiguration = new HttpSelfHostConfiguration(hostname);
                hostConfiguration.Routes.MapHttpRoute("API", "{controller}/{action}/{id}", (object)new
                {
                    id = RouteParameter.Optional
                });

                var httpSelfHostServer = new HttpSelfHostServer(hostConfiguration);

                // Impl.Scheduler would be your implementation of scheduler
                hostConfigurator.Service<Impl.Scheduler>(s =>
                {
                    s.ConstructUsing(name => new Impl.Scheduler());
                    s.WhenStarted(tc =>
                    {
                        tc.Start();

                        httpSelfHostServer.OpenAsync().Wait();
                    });
                    s.WhenStopped(tc =>
                    {
                        tc.Stop();
                        //dispose scheduler implementation if using IOC container
                        httpSelfHostServer.CloseAsync().Wait();
                    });
                });
                hostConfigurator.RunAsLocalSystem();

                hostConfigurator.SetDescription(serviceName);
                hostConfigurator.SetDisplayName(serviceName);
                hostConfigurator.SetServiceName(serviceName);
            });
        }
    }