定时任务端口多进程处理

CallCenterApi/CallCenterApi.Interface/CallCenterApi.Interface/Global.asax.cs

@@ -1,15 +1,12 @@
 using CallCenter.QuartzService;
 using CallCenter.Utility;
 using CallCenterApi.Common;
-using CallCenterApi.Interface.Models.Common;
 using System;
 using System.Collections.Generic;
-using System.Linq;
+using System.Threading.Tasks;
 using System.Web;
 using System.Web.Mvc;
 using System.Web.Routing;
-using System.Web.Script.Serialization;
-using System.Web.Security;
 
 namespace CallCenterApi.Interface
 {
@@ -22,15 +19,25 @@ namespace CallCenterApi.Interface
             RouteConfig.RegisterRoutes(RouteTable.Routes);
             //clq 增加异常日志记录 自定义 HandleErrorAttribute
             FilterConfig.RegisterGlobalFilters(GlobalFilters.Filters);
-            if (!CommonHelper.PortInUse(Int32.Parse(Configs.GetValue("quartz_port"))))
+
+            int port = Int32.Parse(Configs.GetValue("quartz_port"));
+            Task.Run(() =>
             {
-                _worker = new QuartzWorker();
-                _worker.AddWork(new SatisfactionClose());
-                _worker.AddWork(new ZhengWuDuiJie());
-                _worker.AddWork(new Peoplewebsite());
-                //_worker.AddWork(new PushWorkorder());
-                _worker.Start();
-            }
+                Task.Delay(TimeSpan.FromMinutes(1)).Wait();
+                if (!CommonHelper.PortInUse(port))
+                {
+                    _worker = new QuartzWorker(port);
+                    _worker.AddWork(new SatisfactionClose());
+                    _worker.AddWork(new ZhengWuDuiJie());
+                    _worker.AddWork(new Peoplewebsite());
+                    //_worker.AddWork(new PushWorkorder());
+                    _worker.Start();
+                }
+
+            }).ContinueWith(p =>
+            {
+                System.Diagnostics.Debug.WriteLine(DateTime.Now);
+            });
         }
         protected void Application_End()
         {

CallCenterCommon/CallCenter.QuartzService/QuartzWorker.cs

@@ -9,7 +9,7 @@ namespace CallCenter.QuartzService
     public class QuartzWorker
     {
         readonly IScheduler _scheduler;
-        public QuartzWorker()
+        public QuartzWorker(int port)
         {
             var properties = new NameValueCollection();
             //properties["quartz.scheduler.instanceName"] = "RemoteServerSchedulerClient";
@@ -20,7 +20,7 @@ namespace CallCenter.QuartzService
 
             // 远程输出配置
             properties["quartz.scheduler.exporter.type"] = "Quartz.Simpl.RemotingSchedulerExporter, Quartz";
-            properties["quartz.scheduler.exporter.port"] = Configs.GetValue("quartz_port");
+            properties["quartz.scheduler.exporter.port"] = port.ToString();
             properties["quartz.scheduler.exporter.bindName"] = "QuartzScheduler";
             properties["quartz.scheduler.exporter.channelType"] = "tcp";