需要:从数据库中的作业队列执行作业的Windows服务; 通缉:示例代码

using System;
using System.ServiceProcess;
using System.Threading;
using System.Data.SqlClient;

namespace JobQueueService
{
    public partial class JobQueueService : ServiceBase
    {
        private bool isRunning;
        private Thread workerThread;
        private string connectionString;

        public JobQueueService()
        {
            InitializeComponent();
            this.ServiceName = "JobQueueService";
            this.CanStop = true;
            this.CanPauseAndContinue = true;
            this.AutoLog = true;
            this.isRunning = false;
            this.connectionString = "your_database_connection_string";
        }

        protected override void OnStart(string[] args)
        {
            this.isRunning = true;
            this.workerThread = new Thread(ExecuteJobs);
            this.workerThread.Start();
        }

        protected override void OnStop()
        {
            this.isRunning = false;
            this.workerThread.Join();
        }

        private void ExecuteJobs()
        {
            while (this.isRunning)
            {
                // Check if there are any pending jobs in the database
                using (SqlConnection connection = new SqlConnection(this.connectionString))
                {
                    connection.Open();
                    SqlCommand command = new SqlCommand("SELECT TOP 1 * FROM JobQueue WHERE Status = 'Pending' ORDER BY Priority DESC", connection);
                    SqlDataReader reader = command.ExecuteReader();

                    if (reader.Read())
                    {
                        // Get job details from the database
                        int jobId = (int)reader["Id"];
                        string jobName = (string)reader["Name"];
                        // ... (other job details)

                        // Execute the job
                        Console.WriteLine("Executing job: " + jobName);
                        // ... (execute the job logic)

                        // Update job status in the database
                        SqlCommand updateCommand = new SqlCommand("UPDATE JobQueue SET Status = 'Completed' WHERE Id = @JobId", connection);
                        updateCommand.Parameters.AddWithValue("@JobId", jobId);
                        updateCommand.ExecuteNonQuery();
                    }

                    reader.Close();
                }

                // Sleep for a while before checking for the next job
                Thread.Sleep(5000);
            }
        }
    }
}